Struct RedbMarkerBackend 

pub struct RedbMarkerBackend { /* private fields */ }

On-disk MarkerBackend backed by a per-run [redb] marker sidecar file.

The caller supplies the full file path, normally <base>/<instance_id>/<run_id>.markers.redb. The backend creates the parent directory on first open, stores every durable record with its precomputed 32-byte integrity hash, and commits each mutation with [Durability::Immediate]. Reopening an unsealed marker file seals it as RunStatus::CrashedRecovered and returns Ok(()), because marker files never block trader boot.

Implementations

impl RedbMarkerBackend

pub fn new(file_path: impl Into<PathBuf>) -> Self

Creates a backend for the supplied marker sidecar file path.

pub fn current_path(&self) -> Result<&Path, EventStoreError>

Returns the path of the currently open marker file.

Errors

Returns EventStoreError::Backend when no run is open.

pub fn open_read_only_file( path: impl Into<PathBuf>, ) -> Result<Self, EventStoreError>

Opens an existing marker sidecar file read-only for verification.

Marker verification must not seal, recover, or otherwise mutate the sidecar it scans. This constructor accepts any manifest status and leaves lifecycle policy to the caller’s report.

Errors

Returns EventStoreError::Backend when the marker file is missing, and EventStoreError::Corrupted when the file lacks a marker manifest or fails to decode.

Trait Implementations

impl Debug for RedbMarkerBackend

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

Formats the value using the given formatter.

impl MarkerBackend for RedbMarkerBackend

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.