Trait OutboxStore 

pub trait OutboxStore:
    Send
    + Sync
    + 'static {
    // Required methods
    fn fetch_pending(
        &self,
        limit: usize,
    ) -> BoxFuture<'_, Result<Vec<OutboxEntry>, DataError>>;
    fn mark_published(&self, id: u64) -> BoxFuture<'_, Result<(), DataError>>;
}

Committed-but-unpublished entries, fetched/acked by the relay.

Required Methods

fn fetch_pending( &self, limit: usize, ) -> BoxFuture<'_, Result<Vec<OutboxEntry>, DataError>>

Oldest committed-but-unpublished entries, up to limit, in order.

fn mark_published(&self, id: u64) -> BoxFuture<'_, Result<(), DataError>>

Mark one entry delivered (idempotent — the relay may retry).

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors