Struct InMemorySagaJournal 

pub struct InMemorySagaJournal { /* private fields */ }

In-memory journal for unit tests.

Implementations

impl InMemorySagaJournal

pub fn records(&self) -> Vec<SagaJournalRecord>

Snapshot persisted records.

Panics

Panics if the journal lock is poisoned.

Trait Implementations

impl Default for InMemorySagaJournal

fn default() -> InMemorySagaJournal

Returns the “default value” for a type.

impl SagaJournal for InMemorySagaJournal

fn on_started<'a>( &'a self, saga_id: &'a [u8], _steps: usize, catalog_version: Option<u32>, ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist saga start.

fn on_step_committed<'a>( &'a self, saga_id: &'a [u8], step: usize, ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist a committed forward step.

fn on_completed<'a>( &'a self, saga_id: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist saga completion.

fn on_compensation_started<'a>( &'a self, saga_id: &'a [u8], failed_step: usize, ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist compensation start after forward failure.

fn on_compensated<'a>( &'a self, saga_id: &'a [u8], _compensated_steps: usize, ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist successful compensation.

fn on_stuck<'a>( &'a self, saga_id: &'a [u8], failed_step: usize, compensate_failed_at: usize, ) -> Pin<Box<dyn Future<Output = Result<(), SagaJournalError>> + Send + 'a>>

Persist stuck saga (compensation failure).

fn load<'a>( &'a self, saga_id: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<Option<SagaJournalRecord>, SagaJournalError>> + Send + 'a>>

Load the latest journal record for saga_id, if any.