Struct InMemorySagaStateStore 

pub struct InMemorySagaStateStore { /* private fields */ }

Reference in-memory implementation. Survives runner restarts within the same process; loses everything on process restart.

Implementations

impl InMemorySagaStateStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemorySagaStateStore

fn default() -> Self

Returns the “default value” for a type.

impl SagaStateStore for InMemorySagaStateStore

fn load<'life0, 'life1, 'async_trait>( &'life0 self, correlation_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load the persisted state for correlation_id. None means no state exists yet (treat as fresh / Default).

fn save<'life0, 'life1, 'async_trait>( &'life0 self, correlation_id: &'life1 str, payload: Vec<u8>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Persist payload as the latest state for correlation_id.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, correlation_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drop the state for correlation_id (called on SagaAction::Complete).

fn keys<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Every correlation id with persisted state — used at startup to rehydrate in-flight sagas.