Struct WorkflowSnapshot 

pub struct WorkflowSnapshot {
    pub seq: SnapshotSeq,
    pub workflow_id: String,
    pub timestamp_secs: u64,
    pub label: String,
    pub tasks: Vec<TaskSnapshot>,
    pub metadata: HashMap<String, String>,
}

An immutable snapshot of the entire workflow at a point in time.

Fields

seq: SnapshotSeq

Sequence number of this snapshot.

workflow_id: String

Workflow identifier.

timestamp_secs: u64

Wall-clock time the snapshot was taken (seconds since epoch).

label: String

Label describing why this snapshot was taken.

tasks: Vec<TaskSnapshot>

Per-task state snapshots.

metadata: HashMap<String, String>

Arbitrary metadata attached to the snapshot.

Implementations

impl WorkflowSnapshot

pub fn new( seq: SnapshotSeq, workflow_id: impl Into<String>, timestamp_secs: u64, label: impl Into<String>, ) -> Self

Create a new workflow snapshot.

pub fn add_task(&mut self, task: TaskSnapshot)

Add a task snapshot.

pub fn set_metadata(&mut self, key: impl Into<String>, value: impl Into<String>)

Attach metadata.

pub fn task_count(&self) -> usize

Return the number of tasks in this snapshot.

pub fn count_in_state(&self, state: &CapturedTaskState) -> usize

Count tasks in a given state.

pub fn completion_ratio(&self) -> f64

Return the completion ratio (0.0..=1.0).

pub fn find_task(&self, task_id: &str) -> Option<&TaskSnapshot>

Find a task snapshot by id.

Trait Implementations

impl Clone for WorkflowSnapshot

fn clone(&self) -> WorkflowSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowSnapshot

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

Formats the value using the given formatter.