Struct PauseCheckpointStore 

pub struct PauseCheckpointStore { /* private fields */ }

In-memory store for PauseCheckpoint instances.

Checkpoints are keyed by workflow_id. Saving a checkpoint with an existing key overwrites the previous one.

Implementations

impl PauseCheckpointStore

pub fn new() -> Self

Create an empty store.

pub fn save(&mut self, checkpoint: PauseCheckpoint)

Save (insert or overwrite) a checkpoint.

pub fn load(&self, workflow_id: &str) -> Option<&PauseCheckpoint>

Load a checkpoint by workflow ID.

pub fn delete(&mut self, workflow_id: &str) -> bool

Delete a checkpoint. Returns true if the checkpoint existed.

pub fn list_paused(&self) -> Vec<&PauseCheckpoint>

Return references to all stored checkpoints.

pub fn count(&self) -> usize

Number of stored checkpoints.

Trait Implementations

impl Debug for PauseCheckpointStore

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

Formats the value using the given formatter.

impl Default for PauseCheckpointStore

fn default() -> PauseCheckpointStore

Returns the “default value” for a type.