Struct MarkerReader 

pub struct MarkerReader { /* private fields */ }

Read-side scanner for a single data marker sidecar.

The reader owns an already-open marker backend. It folds cursor snapshots up to a target event_seq_before and resolves stream slots through the durable stream dictionary.

Implementations

impl MarkerReader

pub fn new(backend: Box<dyn MarkerBackend>) -> Self

Creates a reader over an already-open marker backend.

pub fn fold_to( &self, event_seq_before: u64, ) -> Result<AHashMap<StreamSlot, StreamCursor>, EventStoreError>

Folds cursor snapshots whose event_seq_before is at or below event_seq_before.

The returned map carries the latest known cursor per stream slot at the target event-store boundary. Slots that did not advance in later snapshots keep their previous cursor.

Errors

Returns EventStoreError when the backend cannot scan cursor snapshots.

pub fn stream_dictionary( &self, ) -> Result<AHashMap<StreamSlot, StreamDictEntry>, EventStoreError>

Scans the durable stream dictionary into a map keyed by stream slot.

Errors

Returns EventStoreError when the backend cannot scan the dictionary.

pub fn resolve_slot(&self, slot: StreamSlot) -> Option<StreamDictEntry>

Resolves slot to its stream dictionary entry.

Returns None when the slot is unknown or the backend cannot scan the dictionary.

Trait Implementations

impl Debug for MarkerReader

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

Formats the value using the given formatter.