Struct CheckpointManager 

pub struct CheckpointManager { /* private fields */ }

Manages file-based checkpoints for one or more workflows.

Each checkpoint is persisted as a JSON file named <storage_dir>/<workflow_id>.checkpoint.json.

Implementations

impl CheckpointManager

pub fn new(storage_dir: PathBuf) -> Self

Creates a new manager that stores checkpoints under storage_dir.

The directory is created on first use (lazily), so it does not need to exist at construction time.

pub fn storage_dir(&self) -> &PathBuf

Returns the storage directory path.

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

Serialises checkpoint to JSON and writes it to disk.

Overwrites any previously saved checkpoint for the same workflow_id.

Errors

Returns WorkflowError::Io if the file cannot be written, or WorkflowError::Serialization if JSON serialisation fails.

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

Reads and deserialises the checkpoint for workflow_id from disk.

Errors

Returns WorkflowError::FileNotFound if no checkpoint exists, or WorkflowError::Io / WorkflowError::Serialization on read/parse failure.

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

Deletes the checkpoint file for workflow_id.

Returns Ok(()) even if no checkpoint file existed.

Errors

Returns WorkflowError::Io if the file exists but cannot be removed.

pub fn exists(&self, workflow_id: &str) -> bool

Returns true if a checkpoint file exists for workflow_id.

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

Returns the workflow IDs of all checkpoints currently on disk.

Scans storage_dir for files matching *.checkpoint.json and strips the suffix to produce the workflow ID. Files that do not parse as valid checkpoints are silently skipped.

Errors

Returns WorkflowError::Io if the storage directory cannot be read.

Trait Implementations

impl Clone for CheckpointManager

fn clone(&self) -> CheckpointManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CheckpointManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.