flo-bit.dev / contrail
[READ-ONLY] Mirror of https://github.com/flo-bit/contrail. atproto backend in a bottle flo-bit.dev/contrail
Star
Fork 0
Watch

feat: add persistent ingestion mode with batch flushing master

Add runPersistent() for long-lived Jetstream ingestion that batches events and flushes periodically. Handles reconnection, graceful shutdown via AbortSignal, and cursor persistence across restarts. Includes unit tests.

Author Tom Scanlan Date Commit c0d01385 Parent dbf10a67
+421
2 changed files