Struct CheckpointManager 

pub struct CheckpointManager { /* private fields */ }

Manages a series of checkpoints for one workflow.

Implementations

impl CheckpointManager

pub fn new(policy: CheckpointPolicy) -> Self

Creates a new manager with the given policy.

pub fn with_interval(interval_secs: u64) -> Self

Creates a manager with a fixed interval policy.

pub fn set_max_retained(&mut self, max: usize)

Sets the maximum number of checkpoints to retain.

pub fn policy(&self) -> CheckpointPolicy

Returns the current policy.

pub fn count(&self) -> usize

Returns the number of stored checkpoints.

pub fn create_checkpoint(&mut self, workflow_id: &str) -> &Checkpoint

Creates and stores a new checkpoint for the given workflow.

pub fn latest(&self) -> Option<&Checkpoint>

Returns the latest checkpoint, if any.

pub fn checkpoints_for(&self, workflow_id: &str) -> Vec<&Checkpoint>

Returns all checkpoints for a given workflow ID.

pub fn clear(&mut self)

Removes all checkpoints.

pub fn interval_secs(&self) -> u64

Returns the configured interval in seconds.

Trait Implementations

impl Clone for CheckpointManager

fn clone(&self) -> CheckpointManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointManager

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

Formats the value using the given formatter.

impl Default for CheckpointManager

fn default() -> Self

Returns the “default value” for a type.