Struct WorkflowMetrics 

pub struct WorkflowMetrics {
    pub workflow_id: WorkflowId,
    pub workflow_name: String,
    pub state: WorkflowState,
    pub start_time: Option<DateTime<Utc>>,
    pub end_time: Option<DateTime<Utc>>,
    pub duration: Option<Duration>,
    pub tasks: HashMap<TaskId, TaskMetrics>,
    pub total_tasks: usize,
    pub completed_tasks: Arc<AtomicU64>,
    pub failed_tasks: Arc<AtomicU64>,
    pub running_tasks: Arc<AtomicU64>,
}

Workflow execution metrics.

The completed_tasks, failed_tasks, and running_tasks counters are backed by Arc<AtomicU64> so they can be incremented/decremented from any thread without a mutable borrow. The Arc also allows sharing a counter across cheap clones (each clone shares the same atomic).

Fields

workflow_id: WorkflowId

Workflow identifier.

workflow_name: String

Workflow name.

state: WorkflowState

Current state.

start_time: Option<DateTime<Utc>>

Start time.

end_time: Option<DateTime<Utc>>

End time.

duration: Option<Duration>

Total duration.

tasks: HashMap<TaskId, TaskMetrics>

Task metrics.

total_tasks: usize

Total task count.

completed_tasks: Arc<AtomicU64>

Completed tasks count (atomic for lock-free concurrent updates).

failed_tasks: Arc<AtomicU64>

Failed tasks count (atomic for lock-free concurrent updates).

running_tasks: Arc<AtomicU64>

Running tasks count (atomic for lock-free concurrent updates).

Implementations

impl WorkflowMetrics

pub fn new( workflow_id: WorkflowId, workflow_name: String, total_tasks: usize, ) -> Self

Create new workflow metrics.

pub fn completed_tasks_count(&self) -> u64

Read the completed tasks count.

pub fn failed_tasks_count(&self) -> u64

Read the failed tasks count.

pub fn running_tasks_count(&self) -> u64

Read the running tasks count.

pub fn mark_started(&mut self)

Mark workflow as started.

pub fn mark_completed(&mut self)

Mark workflow as completed.

pub fn mark_failed(&mut self)

Mark workflow as failed.

pub fn update_task(&mut self, task_metrics: TaskMetrics)

Update task metrics.

pub fn progress_percentage(&self) -> f64

Get progress percentage.

pub fn average_task_duration(&self) -> Option<Duration>

Get average task duration.

pub fn throughput(&self) -> f64

Get throughput (tasks per second).

Trait Implementations

impl Clone for WorkflowMetrics

fn clone(&self) -> WorkflowMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowMetrics

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowMetrics

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkflowMetrics

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.