Struct MonitoringService 

pub struct MonitoringService { /* private fields */ }

Monitoring service for tracking workflow execution.

Implementations

impl MonitoringService

pub fn new() -> Self

Create a new monitoring service.

pub fn start_workflow( &self, workflow_id: WorkflowId, workflow_name: String, total_tasks: usize, )

Start tracking a workflow.

pub fn update_task( &self, workflow_id: WorkflowId, task_id: TaskId, task_name: String, state: TaskState, error: Option<String>, )

Update task progress.

pub fn complete_workflow(&self, workflow_id: WorkflowId, success: bool)

Complete workflow tracking.

pub fn get_workflow_metrics( &self, workflow_id: &WorkflowId, ) -> Option<WorkflowMetrics>

Get workflow metrics.

pub fn get_active_workflows(&self) -> Vec<WorkflowMetrics>

Get all active workflow metrics.

pub fn get_history(&self, limit: Option<usize>) -> Vec<WorkflowMetrics>

Get workflow history.

pub fn clear_history(&self, older_than: DateTime<Utc>)

Clear old history entries.

pub fn get_statistics(&self) -> SystemStatistics

Get system-wide statistics.

Trait Implementations

impl Default for MonitoringService

fn default() -> Self

Returns the “default value” for a type.