Struct MemorySagaOutbox 

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

In-memory saga state and action outbox sharing one atomic commit boundary.

Implementations

impl<S, C> MemorySagaOutbox<S, C>

where C: Command<Output = ()>,

pub fn new() -> Self

Creates an empty combined saga store and action outbox.

pub const fn saga_store(&self) -> &MemorySagaStore<S>

Returns the saga-state view.

pub const fn action_store(&self) -> &MemorySagaActionStore<C>

Returns the action and timer view.

Trait Implementations

impl<S: Debug, C> Debug for MemorySagaOutbox<S, C>

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

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

Formats the value using the given formatter.

impl<S, C> Default for MemorySagaOutbox<S, C>

where C: Command<Output = ()>,

fn default() -> Self

Returns the “default value” for a type.

impl<S, C> TransactionalSagaOutbox<S, C> for MemorySagaOutbox<S, C>

where S: Send, C: Command<Output = ()>,

fn commit_transition<'a>( &'a self, saga_id: &'a SagaId, expected: ExpectedSagaVersion, saga: S, transition: MessageMetadata, actions: Vec<SagaAction<C>>, ) -> BoxFuture<'a, SoapResult<SagaCommitResult>>

Saves one state transition and its actions atomically.