Struct InMemoryWorkflowStore 

pub struct InMemoryWorkflowStore { /* private fields */ }

In-memory WorkflowStore for tests and the standalone OSS runner. Two HashMaps wrapped in one struct — the trait surface stays singular regardless of the internal layout.

Implementations

impl InMemoryWorkflowStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryWorkflowStore

fn default() -> InMemoryWorkflowStore

Returns the “default value” for a type.

impl WorkflowStore for InMemoryWorkflowStore

fn create_run<'life0, 'async_trait>( &'life0 self, state: WorkflowExecutionState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Insert a new run record. Existing record under the same run_task_id is overwritten (treat the call as create-or-resume).

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowExecutionState>>> + Send + 'async_trait>>

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

Load the run-level state for a workflow.

fn update_context<'life0, 'life1, 'async_trait>( &'life0 self, run_task_id: &'life1 str, context: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Update the shared context bag (called after step results merge in). Other run-level fields are immutable for the life of the run.

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

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

Drop a run and all its step rows.

fn upsert_step<'life0, 'life1, 'async_trait>( &'life0 self, run_task_id: &'life1 str, step: WorkflowStepState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Insert or update one step’s state under a run.

fn get_step<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_task_id: &'life1 str, step_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<WorkflowStepState>>> + Send + 'async_trait>>

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

Load one step’s state.

fn list_steps<'life0, 'life1, 'async_trait>( &'life0 self, run_task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowStepState>>> + Send + 'async_trait>>

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

List all step states for a run, in insertion order.