Struct JournalWriterHandle 

pub struct JournalWriterHandle { /* private fields */ }

A cheap, cloneable handle to a JournalWriter.

Cloning shares the same underlying channel; the writer stops once the last handle is dropped.

Implementations

impl JournalWriterHandle

pub fn append_buffered(&self, entry: JournalEntry)

Enqueue a buffered, fire-and-forget append.

Returns immediately. On a full channel the entry is dropped with a WARN (acceptable for Idempotent/AtLeastOnce effects, which re-run safely on resume); on a stopped writer it is likewise dropped. Use append_acked when durability-on-return matters.

pub async fn append_acked( &self, entry: JournalEntry, ) -> Result<JournalSeq, DurableError>

Append an exactly-once entry and await its committed JournalSeq.

The writer flushes all causally-preceding buffered entries before committing this one (INV-4). The whole round-trip is bounded by journal_ack_timeout_ms.

Errors

Returns DurableError::JournalUnavailable if the writer does not acknowledge within the timeout or is unreachable, and propagates a backend DurableError if the commit itself fails. The caller never blocks indefinitely (INV-12).

pub async fn flush(&self) -> Result<(), DurableError>

Drain all buffered entries to the database and await confirmation — a turn-boundary barrier.

Errors

Returns DurableError::JournalUnavailable if the writer does not confirm within the timeout or is unreachable.

Trait Implementations

impl Clone for JournalWriterHandle

fn clone(&self) -> JournalWriterHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JournalWriterHandle

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

Formats the value using the given formatter.