Struct SnapshotStore 

pub struct SnapshotStore { /* private fields */ }

Manages a series of snapshots for a workflow.

Implementations

impl SnapshotStore

pub fn new(workflow_id: impl Into<String>) -> Self

Create a new snapshot store for the given workflow.

pub fn with_max_snapshots(self, max: usize) -> Self

Set a maximum retention limit for snapshots.

pub fn take_snapshot( &mut self, timestamp_secs: u64, label: impl Into<String>, tasks: Vec<TaskSnapshot>, ) -> SnapshotSeq

Take a new snapshot and add it to the store.

pub fn len(&self) -> usize

Return the number of stored snapshots.

pub fn is_empty(&self) -> bool

Check if the store has no snapshots.

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

Get the latest snapshot.

pub fn get(&self, seq: SnapshotSeq) -> Option<&WorkflowSnapshot>

Get a snapshot by sequence number.

pub fn list(&self) -> Vec<(SnapshotSeq, &str)>

List all snapshot sequence numbers and labels.

pub fn diff(&self, a: SnapshotSeq, b: SnapshotSeq) -> Option<Vec<String>>

Compare two snapshots and return task ids whose state changed.

pub fn clear(&mut self)

Clear all snapshots.

Trait Implementations

impl Debug for SnapshotStore

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

Formats the value using the given formatter.