Struct WorkflowMonitor

pub struct WorkflowMonitor { /* private fields */ }

Workflow monitor for real-time monitoring

Implementations

impl WorkflowMonitor

pub fn new(config: MonitoringConfig) -> Self

Create a new workflow monitor

pub async fn start(&self) -> Result<(), WorkflowError>

Start the monitor

pub async fn register_alert_handler(&self, handler: Box<dyn AlertHandler>)

Register an alert handler

pub async fn record_event( &self, event: MonitoringEvent, ) -> Result<(), WorkflowError>

Record a monitoring event

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

Get workflow metrics

pub async fn get_system_metrics(&self) -> SystemMetrics

Get system metrics

pub async fn get_recent_events(&self, count: usize) -> Vec<MonitoringEvent>

Get recent events

pub async fn get_workflow_summary(&self) -> WorkflowSummary

Get workflow summary

Trait Implementations

impl Clone for WorkflowMonitor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.