Skip to main content

CheckpointStorage

Trait CheckpointStorage 

Source
pub trait CheckpointStorage: Send + Sync {
    // Required methods
    fn store(&self, checkpoint: &Checkpoint) -> Result<()>;
    fn load(&self, checkpoint_id: u64) -> Result<Option<Checkpoint>>;
    fn delete(&self, checkpoint_id: u64) -> Result<()>;
    fn list(&self) -> Result<Vec<u64>>;
    fn latest(&self) -> Result<Option<u64>>;
}
Expand description

Checkpoint storage.

Required Methods§

Source

fn store(&self, checkpoint: &Checkpoint) -> Result<()>

Store a checkpoint.

Source

fn load(&self, checkpoint_id: u64) -> Result<Option<Checkpoint>>

Load a checkpoint.

Source

fn delete(&self, checkpoint_id: u64) -> Result<()>

Delete a checkpoint.

Source

fn list(&self) -> Result<Vec<u64>>

List all checkpoints.

Source

fn latest(&self) -> Result<Option<u64>>

Get the latest checkpoint ID.

Implementors§