Struct EventStoreWriter 

pub struct EventStoreWriter { /* private fields */ }

The dedicated event store writer.

Implementations

impl EventStoreWriter

pub fn spawn( backend: Box<dyn EventStore + Send>, clock: &'static AtomicTime, halt: HaltCallback, config: WriterConfig, ) -> Result<Self, EventStoreError>

Spawns the writer thread and takes ownership of backend.

The backend must already have an open run; the writer reads its current high-watermark to seed the next assigned seq.

Errors

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

pub fn submit(&self, draft: EntryDraft) -> Result<(), SubmitError>

Submits a captured entry. Stamps ts_publish from the clock at receive time and hands the draft to the writer thread.

Blocks (with retry) when the channel is full. If the cumulative wait exceeds the halt threshold, fires the halt callback once and returns SubmitError::HaltSignaled; subsequent submits return SubmitError::Closed without blocking.

Under concurrent submitters, two threads stalled at the threshold can each reach the halt-fire path before either sets the halted flag, so the halt callback may run more than once and a submit already past the entry check may briefly race with another thread’s halt-fire; the kernel’s fail-stop callback must therefore be idempotent.

Errors

Returns SubmitError::Closed when the writer is shut down, the writer thread has exited, or a prior submit already fired a fail-stop halt; returns SubmitError::HaltSignaled when this submit’s stall first crosses the configured halt threshold.

pub fn high_watermark(&self) -> u64

Returns the largest seq durably acknowledged by the backend.

Updated only after a successful append_batch ack; reflects what is safe to anchor a snapshot against.

pub fn record_snapshot_anchor( &self, blob_ref: impl Into<String>, content_hash: impl Into<String>, ) -> Result<SnapshotAnchor, EventStoreError>

Flushes pending entries and records a snapshot anchor at the durable high-watermark.

The cache owns blob_ref and content_hash; the writer derives the high-watermark only after earlier submitted entries have committed, so the anchor never points past durable event-store state.

Errors

Returns EventStoreError::Closed when the writer is closed or halted, and forwards backend errors when flushing pending entries or recording the anchor fails.

pub fn close(self, run_ended: EntryDraft) -> Result<u64, EventStoreError>

Drains the channel, commits run_ended as the final entry, and seals the manifest with crate::manifest::RunStatus::Ended.

Consumes the writer; further submits are unrepresentable.

Errors

Returns EventStoreError when the writer thread fails to commit the final batch, when seal fails, or when the writer thread panicked.

Trait Implementations

impl Debug for EventStoreWriter

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

Formats the value using the given formatter.

impl Drop for EventStoreWriter

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.