Struct ThreadSafeMemoryCheckpointer 

pub struct ThreadSafeMemoryCheckpointer<S: StateSchema> { /* private fields */ }

Thread-safe memory checkpointer

Implementations

impl<S: StateSchema> ThreadSafeMemoryCheckpointer<S>

pub fn new() -> Self

Create a new empty thread-safe memory checkpointer.

Trait Implementations

impl<S: StateSchema> Checkpointer<S> for ThreadSafeMemoryCheckpointer<S>

fn save<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 S, recursion_count: usize, ) -> Pin<Box<dyn Future<Output = GraphResult<String>> + Send + 'async_trait>>

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

Insert a new checkpoint, recording how much of the recursion budget had been consumed by the run at that point (M6).

fn load<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = GraphResult<S>> + Send + 'async_trait>>

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

Load the state saved under the given checkpoint id.

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

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

List checkpoint ids, ordered from oldest to most recent (H5).

fn last<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = GraphResult<Option<(S, usize)>>> + Send + 'async_trait>>

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

State and recursion budget of the most recently saved checkpoint.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = GraphResult<()>> + Send + 'async_trait>>

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

Delete the checkpoint with the given id.

impl<S: StateSchema> Default for ThreadSafeMemoryCheckpointer<S>

fn default() -> Self

Returns the “default value” for a type.