Struct ThreadSafeMemoryCheckpointer 

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

Thread-safe memory checkpointer

Implementations

impl<S: StateSchema> ThreadSafeMemoryCheckpointer<S>

pub fn new() -> Self

Trait Implementations

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

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

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

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,

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,

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,

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

fn default() -> Self

Returns the “default value” for a type.