Skip to main content

CheckpointStore

simple_agents_workflow::checkpoint

Trait CheckpointStore 

Source 
pub trait CheckpointStore: Send + Sync {
    // Required methods
    fn save(
        &self,
        checkpoint: &WorkflowCheckpoint,
    ) -> Result<(), CheckpointError>;
    fn load(
        &self,
        run_id: &str,
    ) -> Result<Option<WorkflowCheckpoint>, CheckpointError>;
    fn delete(&self, run_id: &str) -> Result<(), CheckpointError>;
}
Expand description

Storage abstraction for workflow checkpoints.

Required Methods§

Source

fn save(&self, checkpoint: &WorkflowCheckpoint) -> Result<(), CheckpointError>

Persists checkpoint content for the run id.

Source

fn load( &self, run_id: &str, ) -> Result<Option<WorkflowCheckpoint>, CheckpointError>

Loads checkpoint for the provided run id.

Source

fn delete(&self, run_id: &str) -> Result<(), CheckpointError>

Deletes checkpoint for the provided run id.

Implementors§