v0.19.4lumaweave2026-07-02
Gap replay on subscription degradation
cerebra_watcher now replays missed GSA events when a PostCommit subscription degrades and re-subscribes, closing a silent data loss window.
v0.19.42026-07-02
- ·emit_gsa_event extracted as standalone fn — shared by live handler and catch-up path
- ·GsaHandler tracks last_seen (stream → version) on every delivered event
- ·catch_up_missed reads from last_seen[stream]+1 with GSA type filter on degradation
- ·Catch-up runs while WatcherInner still alive; store is dropped only after replay
- ·Known limit: new lineage_id streams appearing during degradation replay on next sub