Skip to main content

Module changelog_drainer

Module changelog_drainer 

Source
Expand description

Ring 1 changelog drainer Ring 1 changelog drainer.

Consumes entries from the Ring 0 StateChangelogBuffer to relieve SPSC backpressure. Runs in the background (Ring 1) on a periodic or checkpoint-triggered schedule.

§Design

  • Drains the SPSC buffer without allocation (reads pre-allocated entries)
  • Tracks drain metrics for observability
  • Supports explicit flush for checkpoint coordination
  • Bounded pending buffer prevents unbounded memory growth

Structs§

ChangelogDrainer
Drains a Ring 0 StateChangelogBuffer from Ring 1.