Struct InMemorySyncOutbox 

pub struct InMemorySyncOutbox { /* private fields */ }

Process-local synchronization outbox.

Implementations

impl InMemorySyncOutbox

pub fn new() -> Self

Creates an empty in-memory outbox.

Trait Implementations

impl Debug for InMemorySyncOutbox

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

Formats the value using the given formatter.

impl Default for InMemorySyncOutbox

fn default() -> InMemorySyncOutbox

Returns the “default value” for a type.

impl SyncOutbox for InMemorySyncOutbox

fn try_enqueue(&self, message: SyncMessage, max_len: usize) -> SyncResult<bool>

Enqueues a batch if the current length is below max_len.

fn front(&self) -> SyncResult<Option<SyncMessage>>

Returns the oldest pending batch.

fn acknowledge_front(&self, batch_id: &str) -> SyncResult<()>

Removes the oldest batch only when its identifier matches batch_id.

fn messages(&self) -> SyncResult<Vec<SyncMessage>>

Returns all pending batches in delivery order.

fn len(&self) -> SyncResult<usize>

Returns the number of pending batches.

fn is_empty(&self) -> SyncResult<bool>

Reports whether no batches are pending.