nats-jetstream
Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation
(jetstream | file) --> polars dataframe <--> bitemporal db
implements the RustStream broker contract over async-nats