Struct MemoryMarkerBackend 

pub struct MemoryMarkerBackend { /* private fields */ }

In-memory implementation of MarkerBackend.

Stores snapshots, high-fidelity markers, and gaps as Vec tables, and the slot dictionary as an [IndexMap] keyed by slot for write-once semantics. Each record’s integrity hash is retained alongside it so the verifier can recompute and compare. The scan_* methods return records in their documented sort order regardless of append order, matching the keyed persistent backend. One instance owns at most one open run at a time; opening a new run replaces the previous one (markers never block boot). Used by writer and reader unit tests and by the cfg(madsim) simulation lane.

Implementations

impl MemoryMarkerBackend

pub fn new() -> Self

Creates a new empty MemoryMarkerBackend with no run open.

Trait Implementations

impl Debug for MemoryMarkerBackend

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

Formats the value using the given formatter.

impl Default for MemoryMarkerBackend

fn default() -> MemoryMarkerBackend

Returns the “default value” for a type.

impl MarkerBackend for MemoryMarkerBackend

fn open_run(&mut self, manifest: MarkerManifest) -> Result<(), EventStoreError>

Opens a run for marker capture with the supplied manifest.

fn append_snapshot( &mut self, snapshot: &DataCursorSnapshot, hash: [u8; 32], ) -> Result<(), EventStoreError>

Appends a cursor snapshot with its precomputed integrity hash.

fn append_hifi( &mut self, marker: &HiFiMarker, hash: [u8; 32], ) -> Result<(), EventStoreError>

Appends a high-fidelity marker with its precomputed integrity hash.

fn append_gap( &mut self, gap: &MarkerGap, hash: [u8; 32], ) -> Result<(), EventStoreError>

Appends a gap covering a dropped range of marker sequences, with its precomputed integrity hash.

fn put_dict( &mut self, entry: &StreamDictEntry, hash: [u8; 32], ) -> Result<(), EventStoreError>

Records a slot dictionary entry with its precomputed integrity hash, write-once by slot.

fn scan_snapshots(&self) -> Result<Vec<DataCursorSnapshot>, EventStoreError>

Scans all cursor snapshots in ascending marker_seq order.

fn scan_snapshot_records( &self, ) -> Result<Option<Vec<StoredMarkerRecord<DataCursorSnapshot>>>, EventStoreError>

Scans cursor snapshots with stored integrity hashes when the backend exposes them.

fn scan_hifi(&self) -> Result<Vec<HiFiMarker>, EventStoreError>

Scans all high-fidelity markers in ascending marker_seq order.

fn scan_hifi_records( &self, ) -> Result<Option<Vec<StoredMarkerRecord<HiFiMarker>>>, EventStoreError>

Scans high-fidelity markers with stored integrity hashes when the backend exposes them.

fn scan_gaps(&self) -> Result<Vec<MarkerGap>, EventStoreError>

Scans all recorded gaps in ascending from_marker_seq order.

fn scan_gap_records( &self, ) -> Result<Option<Vec<StoredMarkerRecord<MarkerGap>>>, EventStoreError>

Scans marker gaps with stored integrity hashes when the backend exposes them.

fn scan_dict(&self) -> Result<Vec<StreamDictEntry>, EventStoreError>

Scans all slot dictionary entries in ascending slot order.

fn scan_dict_records( &self, ) -> Result<Option<Vec<StoredMarkerRecord<StreamDictEntry>>>, EventStoreError>

Scans dictionary entries with stored integrity hashes when the backend exposes them.

fn seal(&mut self, status: RunStatus) -> Result<(), EventStoreError>

Seals the open run with the given terminal status.

fn manifest(&self) -> Result<MarkerManifest, EventStoreError>

Returns the current marker manifest.