Struct FilesystemCheckpointStore 

pub struct FilesystemCheckpointStore { /* private fields */ }

Filesystem-backed checkpoint storage.

Implementations

impl FilesystemCheckpointStore

pub fn new(root: impl Into<PathBuf>) -> Self

Creates a backend rooted at root.

Trait Implementations

impl CheckpointStore for FilesystemCheckpointStore

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

Persists checkpoint content for the run id.

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

Loads checkpoint for the provided run id.

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

Deletes checkpoint for the provided run id.

impl Clone for FilesystemCheckpointStore

fn clone(&self) -> FilesystemCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FilesystemCheckpointStore

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

Formats the value using the given formatter.