Struct DataMarkerCapture 

pub struct DataMarkerCapture { /* private fields */ }

Engine-thread component that captures data marker cursors at the bus boundary.

DataMarkerCapture owns the in-memory cursor state and the run-local marker sequence. It reads the shared entry submit counter with acquire ordering so marker records preserve engine-thread causal order while the writer lane remains non-blocking.

Implementations

impl DataMarkerCapture

pub fn new( registry: DataMarkerExtractorRegistry, writer: MarkerWriter, submit_counter: Arc<AtomicU64>, config: &DataMarkerConfig, ) -> Self

Creates a capture component over registry, writer, and the shared submit counter.

pub fn observe_publish( &mut self, topic: Topic, message: &dyn Any, _now: UnixNanos, )

Observes a bus publish and advances the data cursor when an extractor is registered.

pub fn on_entry_submitted(&mut self, now: UnixNanos)

Emits a cursor snapshot for an event-store entry boundary when data advanced.

pub fn maybe_safety_flush(&mut self, now: UnixNanos)

Emits a cursor snapshot when the safety interval has elapsed and data advanced.

pub fn close(self)

Closes the writer lane and seals the marker run.

Trait Implementations

impl Debug for DataMarkerCapture

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.