Struct SqliteSaver 

pub struct SqliteSaver { /* private fields */ }

SQLite-backed checkpoint saver.

Persists checkpoints to a SQLite database file with configurable maximum checkpoint size. The database file is created with mode 0600 permissions on Unix systems.

Implementations

impl SqliteSaver

pub fn new(path: &Path) -> Result<Self, CheckpointError>

Create a new SqliteSaver at the given path.

Creates the database file (with 0600 permissions on Unix) and initialises the schema if it does not already exist.

Errors

Returns CheckpointError::Storage if the database cannot be opened or the schema cannot be created.

pub fn with_max_size( path: &Path, max_checkpoint_size: usize, ) -> Result<Self, CheckpointError>

Create a new SqliteSaver with a custom maximum checkpoint size.

Errors

Returns CheckpointError::Storage if the database cannot be opened or the schema cannot be created.

Trait Implementations

impl BaseCheckpointSaver for SqliteSaver

fn get_tuple<'a>( &'a self, config: &'a CheckpointConfig, ) -> BoxFuture<'a, Result<Option<CheckpointTuple>, CheckpointError>>

Retrieve a single checkpoint tuple matching the given configuration.

fn list<'a>( &'a self, config: &'a CheckpointConfig, limit: Option<usize>, ) -> BoxFuture<'a, Result<Vec<CheckpointTuple>, CheckpointError>>

List checkpoint tuples for the given configuration.

fn put<'a>( &'a self, config: &'a CheckpointConfig, checkpoint: Checkpoint, metadata: CheckpointMetadata, ) -> BoxFuture<'a, Result<CheckpointConfig, CheckpointError>>

Persist a checkpoint with its metadata.

impl Clone for SqliteSaver

fn clone(&self) -> SqliteSaver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteSaver

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

Formats the value using the given formatter.