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