mvp of streaming pipelines by emulating a trimmed version of the palantir txn and dataset APIs. Includes an AI search / enrichment flow using gemini + google search. written in go and with no pre-caching optimizations seeing 10x faster start up for full local testing.