Struct FilesystemStore 

pub struct FilesystemStore { /* private fields */ }

Filesystem implementation of CheckpointStore trait.

Stores checkpoints as JSON files in a directory.

Implementations

impl FilesystemStore

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

Create a new FilesystemStore with the given directory.

pub fn dir(&self) -> &PathBuf

Get the directory path.

Trait Implementations

impl CheckpointStore for FilesystemStore

fn store_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 CheckpointID, checkpoint_data: String, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store a checkpoint in the storage backend.

fn read_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 CheckpointID, ) -> Pin<Box<dyn Future<Output = Result<Option<StoredCheckpoint>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read a checkpoint from the storage backend.