Trait OutboxStore 

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

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

Required Methods

fn fetch_pending( &self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxEntry>, DataError>> + Send + '_>>

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

fn mark_published( &self, id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), DataError>> + Send + '_>>

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