Struct MarkerWriter 

pub struct MarkerWriter { /* private fields */ }

Dedicated marker writer thread.

Implementations

impl MarkerWriter

pub fn spawn( backend: Box<dyn MarkerBackend + Send>, _clock: &'static AtomicTime, config: MarkerWriterConfig, ) -> Result<Self, EventStoreError>

Spawns the marker writer thread and takes ownership of backend.

Errors

Returns EventStoreError::Backend when the backend has no open run or when the writer thread cannot be spawned.

pub fn submit( &self, msg: MarkerMsg, marker_seq: u64, ) -> Result<bool, EventStoreError>

Submits a marker without blocking the caller.

Returns Ok(false) when the bounded channel is full; the dropped marker sequence is recorded into the next overflow gap.

Errors

Returns EventStoreError::Closed when the writer is closed, and EventStoreError::Backend when msg is not a Snapshot or HiFi marker.

Panics

Panics if the pending overflow range mutex is poisoned.

pub fn put_dict(&self, entry: StreamDictEntry) -> Result<bool, EventStoreError>

Submits a stream dictionary entry to the writer.

Dictionary entries are one-time stream metadata, so this path waits for channel capacity instead of dropping and gap-accounting them.

Errors

Returns EventStoreError::Closed when the writer is closed.

pub fn close(self)

Drains pending markers and seals the marker run.

Trait Implementations

impl Debug for MarkerWriter

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

Formats the value using the given formatter.

impl Drop for MarkerWriter

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.