Struct Writer 

pub struct Writer<E: Clock + Storage + Metrics, V: CodecShared> { /* private fields */ }

Writer handle for enqueueing items.

This handle can be cloned to allow multiple tasks to enqueue items concurrently. All clones share the same underlying queue and notification channel.

Implementations

impl<E: Clock + Storage + Metrics, V: CodecShared> Writer<E, V>

pub async fn enqueue(&self, item: V) -> Result<u64, Error>

Enqueue an item, returning its position. The lock is held for the full append + commit, so no reader can see the item until it is durable.

Errors

Returns an error if the underlying storage operation fails.

pub async fn enqueue_bulk( &self, items: impl IntoIterator<Item = V>, ) -> Result<Range<u64>, Error>

Enqueue a batch of items with a single commit, returning positions [start, end). The lock is held for the full batch, so no reader can see any item until the entire batch is durable.

Errors

Returns an error if any append or the final commit fails.

pub async fn append(&self, item: V) -> Result<u64, Error>

Append an item without committing, returning its position. The item is immediately visible to the reader but is not durable until Self::commit is called or the underlying journal auto-syncs at a section boundary (see variable::Journal invariant 1).

Errors

Returns an error if the underlying storage operation fails.

pub async fn commit(&self) -> Result<(), Error>

See Queue::commit.

pub async fn sync(&self) -> Result<(), Error>

See Queue::sync.

pub async fn size(&self) -> u64

Returns the total number of items that have been enqueued.

Trait Implementations

impl<E: Clock + Storage + Metrics, V: CodecShared> Clone for Writer<E, V>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.