Struct ScopedOutboxStore 

pub struct ScopedOutboxStore { /* private fields */ }

Implementations

impl ScopedOutboxStore

pub fn new(inner: Arc<dyn OutboxStore>, scope_id: ScopeId) -> ScopedOutboxStore

pub fn scope_id(&self) -> &ScopeId

pub fn inner(&self) -> &dyn OutboxStore

Trait Implementations

impl Clone for ScopedOutboxStore

fn clone(&self) -> ScopedOutboxStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutboxStore for ScopedOutboxStore

fn enqueue_outbox<'life0, 'async_trait>( &'life0 self, draft: OutboxMessageDraft, ) -> Pin<Box<dyn Future<Output = Result<OutboxEnqueueResult, OutboxError>> + Send + 'async_trait>>

where 'life0: 'async_trait, ScopedOutboxStore: 'async_trait,

Enqueue an outbox row in the backend’s own transaction. Use the concrete-type transactional method (see trait docs) when the caller needs to share a transaction with other writes.

fn claim_outbox<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, lane: &'life1 str, target: &'life2 str, limit: usize, lease_ms: u64, consumer_id: &'life3 str, now: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxMessage>, OutboxError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, ScopedOutboxStore: 'async_trait,

fn ack_outbox<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, outbox_id: &'life1 str, claim_token: &'life2 str, now: u64, ) -> Pin<Box<dyn Future<Output = Result<bool, OutboxError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedOutboxStore: 'async_trait,

fn nack_outbox<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, outbox_id: &'life1 str, claim_token: &'life2 str, error: &'life3 str, retry_at: u64, now: u64, ) -> Pin<Box<dyn Future<Output = Result<OutboxNackOutcome, OutboxError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, ScopedOutboxStore: 'async_trait,

fn list_outbox<'life0, 'async_trait>( &'life0 self, status: Option<OutboxStatus>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxMessage>, OutboxError>> + Send + 'async_trait>>

where 'life0: 'async_trait, ScopedOutboxStore: 'async_trait,