Struct JournalSagaStateStore 

pub struct JournalSagaStateStore<J: Journal> { /* private fields */ }

Journal-backed saga state store.

Each (saga_name, correlation_id) pair is treated as a single persistence id (saga::<saga_name>::<correlation_id>). Saves append a new event; loads replay the stream and return the most recent state payload. keys() is best-effort — it consults Journal::all_persistence_ids.

Implementations

impl<J: Journal> JournalSagaStateStore<J>

pub fn new(journal: Arc<J>, saga_name: impl Into<String>) -> Self

Trait Implementations

impl<J: Journal> SagaStateStore for JournalSagaStateStore<J>

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.