Struct StateStore 

pub struct StateStore { /* private fields */ }

State store for workflow persistence

Implementations

impl StateStore

pub fn new() -> Result<Self>

Create a new state store

pub fn with_path(path: impl Into<PathBuf>) -> Result<Self>

Create state store with custom path

pub fn save_step( &self, workflow_id: &str, step_id: &str, output: &StepOutput, ) -> Result<()>

Save step output

pub fn load_step( &self, workflow_id: &str, step_id: &str, ) -> Result<Option<StepOutput>>

Load step output

pub fn save_context(&self, ctx: &StepContext) -> Result<()>

Save workflow context

pub fn load_context(&self, workflow_id: &str) -> Result<Option<StepContext>>

Load workflow context

pub fn clear_workflow(&self, workflow_id: &str) -> Result<()>

Clear workflow state

pub fn save_execution(&self, state: &ExecutionState) -> Result<()>

Save execution state

pub fn load_execution( &self, workflow_id: &str, ) -> Result<Option<ExecutionState>>

Load execution state

pub fn delete_execution(&self, workflow_id: &str) -> Result<()>

Delete execution state

pub fn list_active(&self) -> Result<Vec<ExecutionState>>

List all active workflows (Running or Paused)

pub fn list_by_status( &self, status: WorkflowStatus, ) -> Result<Vec<ExecutionState>>

List all workflows by status

Trait Implementations

impl Default for StateStore

fn default() -> Self

Returns the “default value” for a type.