Struct MemorySagaActionStore 

pub struct MemorySagaActionStore<C>
where
    C: Command<Output = ()>,
{ /* private fields */ }

In-memory durable saga action and timer store.

Implementations

impl<C> MemorySagaActionStore<C>

where C: Command<Output = ()>,

pub fn new() -> Self

Creates an empty saga action store.

Trait Implementations

impl<C> Debug for MemorySagaActionStore<C>

where C: Command<Output = ()> + Debug,

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

Formats the value using the given formatter.

impl<C> Default for MemorySagaActionStore<C>

where C: Command<Output = ()>,

fn default() -> Self

Returns the “default value” for a type.

impl<C> SagaActionStore<C> for MemorySagaActionStore<C>

where C: Command<Output = ()> + Clone,

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

Claims actions whose schedule is due, using one exclusive worker lease.

fn mark_completed<'a>( &'a self, id: &'a SagaActionId, claim_id: &'a DeliveryClaimId, completed_at: SystemTime, ) -> BoxFuture<'a, SoapResult<()>>

Marks a claimed action as successfully handled.

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

Records a failed attempt and schedules another eligible time.

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

Moves a claimed action to terminal dead-letter state.