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 an error if 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 an error if the writer is closed, or if msg is not a Snapshot or HiFi marker.

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 an error if 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.