Struct StatePersistence 

pub struct StatePersistence { /* private fields */ }

State persistence manager.

Implementations

impl StatePersistence

pub fn new(state_dir: String) -> Self

Create a new state persistence manager.

pub async fn save(&self, state: &WorkflowState) -> Result<()>

Save workflow state to disk.

pub async fn load(&self, execution_id: &str) -> Result<WorkflowState>

Load workflow state from disk.

pub async fn delete(&self, execution_id: &str) -> Result<()>

Delete workflow state from disk.

pub async fn list(&self) -> Result<Vec<String>>

List all workflow states.

pub async fn save_checkpoint( &self, checkpoint: &WorkflowCheckpoint, ) -> Result<()>

Save a workflow checkpoint (state + DAG) to disk.

pub async fn load_checkpoint( &self, execution_id: &str, ) -> Result<WorkflowCheckpoint>

Load the latest checkpoint for an execution.

pub async fn load_checkpoint_by_sequence( &self, execution_id: &str, sequence: u64, ) -> Result<WorkflowCheckpoint>

Load a specific checkpoint by sequence number.

pub async fn delete_checkpoint( &self, execution_id: &str, sequence: u64, ) -> Result<()>

Delete a checkpoint.

pub async fn delete_all_checkpoints(&self, execution_id: &str) -> Result<()>

Delete all checkpoints for an execution.

pub async fn list_checkpoints(&self, execution_id: &str) -> Result<Vec<u64>>

List all checkpoints for an execution (sorted by sequence).

pub async fn checkpoint_exists(&self, execution_id: &str) -> bool

Check if a checkpoint exists for an execution.