Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory store for testing.

Implementations

impl InMemoryStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl WorkflowStateStore for InMemoryStore

fn load<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowRun>, String>> + Send + 'async_trait>>

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

Load a run by workflow ID.

fn save<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 WorkflowRun, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Save the full run state.

fn commit_step<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, step_index: usize, result: StepResult, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Update a specific step’s result and advance the run.

fn save_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _workflow_id: &'life1 str, _step_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<CheckpointMeta, String>> + Send + 'async_trait>>

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

Save a named checkpoint snapshot. Default: not supported.

fn load_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _workflow_id: &'life1 str, _checkpoint_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowRun>, String>> + Send + 'async_trait>>

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

Load a checkpoint by ID. Default: not supported.

fn list_checkpoints<'life0, 'life1, 'async_trait>( &'life0 self, _workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointMeta>, String>> + Send + 'async_trait>>

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

List available checkpoints. Default: empty.