Struct DashboardDataProvider 

pub struct DashboardDataProvider { /* private fields */ }

Aggregates metrics from workflow engine state into DashboardSnapshots.

The provider holds an internal event log and counters that are updated as workflows and tasks progress. Call DashboardDataProvider::snapshot to obtain a consistent read of all metrics at a given timestamp.

Implementations

impl DashboardDataProvider

pub fn new() -> Self

Create a new dashboard data provider with defaults.

pub fn on_workflow_started( &mut self, workflow_id: impl Into<String>, name: impl Into<String>, total_tasks: usize, started_at_secs: u64, )

Register a workflow starting.

pub fn on_workflow_completed( &mut self, workflow_id: &str, success: bool, now_secs: u64, )

Record a workflow completing (successfully or otherwise).

pub fn on_task_completed( &mut self, workflow_id: &str, task_name: &str, success: bool, duration_secs: f64, now_secs: u64, )

Record a task completing.

pub fn on_task_failed( &mut self, task_name: &str, error: impl Into<String>, retry_count: u32, )

Record a task failure with an error message.

pub fn update_queue_depth(&mut self, snapshot: QueueDepthSnapshot)

Update the queue depth snapshot.

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

Set a custom metric value.

pub fn snapshot(&self, now_secs: u64) -> DashboardSnapshot

Build a DashboardSnapshot at the given timestamp.

Trait Implementations

impl Debug for DashboardDataProvider

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

Formats the value using the given formatter.

impl Default for DashboardDataProvider

fn default() -> DashboardDataProvider

Returns the “default value” for a type.