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 peek(&self, limit: usize, max_bytes: usize) -> SyncResult<Vec<SyncMessage>>

Returns a delivery-order page bounded before cloning message payloads.

fn stats(&self) -> SyncResult<SyncOutboxStats>

Returns payload-free queue statistics.

fn mark_attempt(&self, batch_id: &str, next_ready_at_ms: u64) -> SyncResult<u32>

Records one failed delivery attempt and its next eligible timestamp.

fn next_ready( &self, now_ms: u64, limit: usize, max_bytes: usize, ) -> SyncResult<Vec<SyncMessage>>

Returns the ready delivery-order prefix within both page bounds.

fn acknowledge_receipt(&self, receipt: &SyncOutboxReceipt) -> SyncResult<usize>

Acknowledges the exact ordered prefix named by a partial receipt.

fn is_empty(&self) -> Result<bool, SyncError>

Reports whether no batches are pending.