Struct InMemoryCheckpointStore 

pub struct InMemoryCheckpointStore<C: Context, WI: WorkItem> { /* private fields */ }

A simple in-memory checkpoint store using JSON serialization

Implementations

impl<C: Context, WI: WorkItem> InMemoryCheckpointStore<C, WI>

pub fn new() -> Self

Trait Implementations

impl<C: Context, WI: WorkItem> CheckpointStore<C, WI> for InMemoryCheckpointStore<C, WI>

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, workflow_id: &'life1 str, checkpoint: &'life2 Checkpoint<C, WI>, ) -> Pin<Box<dyn Future<Output = Result<(), CheckpointError>> + Send + 'async_trait>>

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

Persist the given checkpoint under workflow_id.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint<C, WI>>, CheckpointError>> + Send + 'async_trait>>

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

Load the last-saved checkpoint for workflow_id, if any.

impl<C: Clone + Context, WI: Clone + WorkItem> Clone for InMemoryCheckpointStore<C, WI>

fn clone(&self) -> InMemoryCheckpointStore<C, WI>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Context, WI: WorkItem> Default for InMemoryCheckpointStore<C, WI>

fn default() -> Self

Returns the “default value” for a type.