Struct PerformanceMonitor 

pub struct PerformanceMonitor {
    pub metrics_history: Arc<Mutex<VecDeque<PerformanceMetrics>>>,
    pub resource_usage: Arc<Mutex<VecDeque<ResourceUsage>>>,
    pub worker_metrics: HashMap<usize, WorkerMetrics>,
    pub config: MonitoringConfig,
    pub alert_thresholds: AlertThresholds,
    pub start_time: Instant,
}

Performance monitoring coordinator

Fields

metrics_history: Arc<Mutex<VecDeque<PerformanceMetrics>>>

resource_usage: Arc<Mutex<VecDeque<ResourceUsage>>>

worker_metrics: HashMap<usize, WorkerMetrics>

config: MonitoringConfig

alert_thresholds: AlertThresholds

start_time: Instant

Implementations

impl PerformanceMonitor

pub fn new(config: MonitoringConfig) -> Self

Create new performance monitor

pub fn register_worker(&mut self, workerid: usize)

Register worker for monitoring

pub fn record_performance_metrics( &self, metrics: PerformanceMetrics, ) -> Result<()>

Record performance metrics

pub fn record_resource_usage(&self, usage: ResourceUsage) -> Result<()>

Record resource usage metrics

pub fn update_worker_metrics( &mut self, worker_id: usize, cpu_usage: f64, memory_usage: f64, throughput: f64, latency: f64, ) -> Result<()>

Update worker metrics

pub fn check_alerts(&self) -> Result<Vec<PerformanceAlert>>

Check for performance alerts

pub fn analyze_system_efficiency(&self) -> Result<EfficiencyAnalysis>

Perform comprehensive system analysis

pub fn generate_report(&self) -> MonitoringReport

Generate monitoring report

pub fn export_metrics_csv(&self, filepath: &str) -> Result<()>

Export metrics for external analysis

pub fn get_worker_metrics(&self) -> &HashMap<usize, WorkerMetrics>

Get current worker metrics

pub fn get_config(&self) -> &MonitoringConfig

Get monitoring configuration

pub fn get_uptime(&self) -> Duration

Get system uptime

Trait Implementations

impl Debug for PerformanceMonitor

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

Formats the value using the given formatter.