Struct MemorySaver 

pub struct MemorySaver { /* private fields */ }

In-memory checkpoint storage

Thread-safe checkpoint storage using in-memory data structures. Data is lost when the process exits. Suitable for development and testing.

Implementations

impl MemorySaver

pub fn new() -> Self

Create a new in-memory saver

pub fn with_ttl_config(self, ttl_config: TtlConfig) -> Self

Create a new in-memory saver with TTL configuration (M04-001)

Arguments

• ttl_config - TTL configuration for automatic checkpoint expiration

pub fn ttl_config(&self) -> TtlConfig

Get the current TTL configuration

Returns a clone of the current TTL configuration.

Panics

Panics if the internal RwLock is poisoned (indicating a writer thread panicked while holding the write lock).

pub fn set_ttl_config(&self, ttl_config: TtlConfig)

Update the TTL configuration (M04-001)

Arguments

• ttl_config - New TTL configuration

Panics

Panics if the internal RwLock is poisoned (indicating a writer thread panicked while holding the write lock).

Trait Implementations

impl CheckpointSaver for MemorySaver

fn get_tuple<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Option<CheckpointTuple>, CoreCheckpointError>> + Send + 'async_trait>>

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

Get checkpoint tuple by configuration

fn list<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 RunnableConfig, filter: Option<CheckpointFilter>, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointTuple>, CoreCheckpointError>> + Send + 'async_trait>>

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

List checkpoints with optional filtering

fn put<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 RunnableConfig, checkpoint: Checkpoint, metadata: CheckpointMetadata, ) -> Pin<Box<dyn Future<Output = Result<RunnableConfig, CoreCheckpointError>> + Send + 'async_trait>>

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

Save a checkpoint

fn put_writes<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, config: &'life1 RunnableConfig, writes: Vec<PendingWrite>, task_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CoreCheckpointError>> + Send + 'async_trait>>

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

Save incremental writes from a completed task

impl Clone for MemorySaver

fn clone(&self) -> MemorySaver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemorySaver

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

Formats the value using the given formatter.

impl Default for MemorySaver

fn default() -> Self

Returns the “default value” for a type.