Struct SqliteSyncOutbox 

pub struct SqliteSyncOutbox { /* private fields */ }

SQLite-backed bounded synchronization outbox.

Trait Implementations

impl Clone for SqliteSyncOutbox

fn clone(&self) -> SqliteSyncOutbox

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteSyncOutbox

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

Formats the value using the given formatter.

impl SyncOutbox for SqliteSyncOutbox

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) -> Result<bool, SyncError>

Reports whether no batches are pending.