Struct MetricsAggregator

pub struct MetricsAggregator {
    metrics: Arc<RwLock<HashMap<String, ShardMetrics>>>,
    window_duration: Duration,
    monitoring_rx: Receiver<ProcessingEvent>,
}

Aggregates monitoring events into metrics

Fields

metrics: Arc<RwLock<HashMap<String, ShardMetrics>>>

window_duration: Duration

monitoring_rx: Receiver<ProcessingEvent>

Implementations

impl MetricsAggregator

pub fn new( window_duration: Duration, monitoring_rx: Receiver<ProcessingEvent>, ) -> Self

Create a new metrics aggregator

pub async fn run(self)

Start processing events and emitting metrics

async fn process_event(&self, event: ProcessingEvent)

async fn emit_metrics(&self)

pub async fn get_metrics(&self) -> HashMap<String, ShardMetrics>

Get current metrics for all shards

pub async fn get_shard_metrics(&self, shard_id: &str) -> Option<ShardMetrics>

Get metrics for a specific shard