Struct InMemoryCheckpointSaver 

pub struct InMemoryCheckpointSaver { /* private fields */ }

An in-memory checkpoint saver backed by a RwLock<HashMap>.

Stores checkpoints in memory keyed by thread ID. Suitable for testing and short-lived processes. Data is lost when the process exits.

Implementations

impl InMemoryCheckpointSaver

pub fn new() -> Self

Create a new, empty in-memory checkpoint saver.

Trait Implementations

impl BaseCheckpointSaver for InMemoryCheckpointSaver

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 InMemoryCheckpointSaver

fn clone(&self) -> InMemoryCheckpointSaver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryCheckpointSaver

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

Formats the value using the given formatter.

impl Default for InMemoryCheckpointSaver

fn default() -> InMemoryCheckpointSaver

Returns the “default value” for a type.