Struct MemoryOutboxStore 

pub struct MemoryOutboxStore<M> { /* private fields */ }

In-memory outbox with exclusive, expiring worker claims.

Implementations

impl<M> MemoryOutboxStore<M>

pub fn new() -> Self

Creates an empty outbox store.

Trait Implementations

impl<M: Debug> Debug for MemoryOutboxStore<M>

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

Formats the value using the given formatter.

impl<M> Default for MemoryOutboxStore<M>

fn default() -> Self

Returns the “default value” for a type.

impl<M> OutboxStore<M> for MemoryOutboxStore<M>

where M: IntegrationEvent + Clone,

fn enqueue( &self, messages: Vec<OutboxRecord<M>>, ) -> BoxFuture<'_, SoapResult<()>>

Enqueues messages durably.

fn claim_pending( &self, claim_id: DeliveryClaimId, now: SystemTime, lease_until: SystemTime, limit: usize, ) -> BoxFuture<'_, SoapResult<Vec<ClaimedOutboxRecord<M>>>>

Claims pending messages available at now using an exclusive lease.

fn mark_delivered<'a>( &'a self, id: &'a MessageId, claim_id: &'a DeliveryClaimId, delivered_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Marks one claimed message as delivered if the lease identity still owns it.

fn mark_failed<'a>( &'a self, id: &'a MessageId, claim_id: &'a DeliveryClaimId, safe_error: &'a str, failed_at: SystemTime, available_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Records a failed delivery and its next eligible attempt.

fn mark_dead_lettered<'a>( &'a self, id: &'a MessageId, claim_id: &'a DeliveryClaimId, safe_error: &'a str, failed_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Moves a claimed message to terminal dead-letter state.