Struct MemoryCheckpointer 

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

In-memory checkpointer for development

Implementations

impl<S: StateSchema> MemoryCheckpointer<S>

pub fn new() -> Self

Trait Implementations

impl<S: StateSchema> Checkpointer<S> for MemoryCheckpointer<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,

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,

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

fn default() -> Self

Returns the “default value” for a type.