Struct FileCheckpointStore 

pub struct FileCheckpointStore { /* private fields */ }

File-based checkpoint store for persistent storage

This implementation uses tokio::fs for non-blocking async I/O operations, making it safe to use in async contexts without blocking the runtime.

Implementations

impl FileCheckpointStore

pub fn new(base_path: impl AsRef<Path>) -> Self

Create a new file-based checkpoint store

Arguments

• base_path - Directory where checkpoint files will be stored

Trait Implementations

impl CheckpointStore for FileCheckpointStore

fn save<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 Checkpoint, ) -> Pin<Box<dyn Future<Output = Result<(), CheckpointError>> + Send + 'async_trait>>

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

Save a checkpoint

fn load<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 CheckpointId, ) -> Pin<Box<dyn Future<Output = Result<Checkpoint, CheckpointError>> + Send + 'async_trait>>

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

Load a checkpoint by ID

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 CheckpointId, ) -> Pin<Box<dyn Future<Output = Result<(), CheckpointError>> + Send + 'async_trait>>

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

Delete a checkpoint

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointId>, CheckpointError>> + Send + 'async_trait>>

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

List all checkpoint IDs

fn latest<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint>, CheckpointError>> + Send + 'async_trait>>

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

Get the latest checkpoint

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), CheckpointError>> + Send + 'async_trait>>

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

Clear all checkpoints