Struct RealTimeMetricsCollector 

pub struct RealTimeMetricsCollector {
    pub metric_streams: Arc<RwLock<HashMap<MetricType, MetricStream>>>,
    pub schedulers: Arc<RwLock<HashMap<MetricType, MetricCollectionScheduler>>>,
    pub aggregation_engine: Arc<MetricsAggregationEngine>,
    pub real_time_buffer: Arc<RwLock<MetricsBuffer>>,
    pub collection_stats: Arc<Mutex<CollectionStatistics>>,
}

Real-time metrics collector

Fields

metric_streams: Arc<RwLock<HashMap<MetricType, MetricStream>>>

Metric data streams

schedulers: Arc<RwLock<HashMap<MetricType, MetricCollectionScheduler>>>

Collection schedulers

aggregation_engine: Arc<MetricsAggregationEngine>

Data aggregation engine

real_time_buffer: Arc<RwLock<MetricsBuffer>>

Real-time data buffer

collection_stats: Arc<Mutex<CollectionStatistics>>

Collection statistics

Implementations

impl RealTimeMetricsCollector

pub fn new(_config: &impl Debug) -> Self

impl RealTimeMetricsCollector

pub async fn start_collection(&self) -> Result<()>

pub async fn stop_collection(&self) -> Result<()>

pub async fn get_status(&self) -> Result<ComponentStatus>

pub async fn get_real_time_metrics( &self, _metric_types: &[MetricType], ) -> Result<Vec<MetricDataPoint>>

pub async fn get_collection_statistics(&self) -> Result<CollectionStatistics>

pub async fn get_health_score(&self) -> Result<f64>

Trait Implementations

impl Debug for RealTimeMetricsCollector

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

Formats the value using the given formatter.