Struct MetricAggregator 

pub struct MetricAggregator {
    per_actor: RwLock<RawRwLock, HashMap<ActorId, ActorMetricState>>,
    ewma_alpha: f64,
    hlc_node_id: u64,
}

Aggregates per-actor metric counters and produces smoothed snapshots.

The aggregator is the CPU-side single source of truth for streaming metrics. Backends (CPU dispatcher, CUDA K2H processor) feed it raw counters via record_inbound, record_outbound, and record_latency; subscribers consume smoothed snapshots via snapshot / snapshot_all.

The aggregator is Send + Sync. Internal state is guarded by parking_lot::RwLock.

Fields

per_actor: RwLock<RawRwLock, HashMap<ActorId, ActorMetricState>>

ewma_alpha: f64

hlc_node_id: u64

Implementations

impl MetricAggregator

pub fn new() -> MetricAggregator

Create an aggregator with the default EWMA alpha (DEFAULT_EWMA_ALPHA).

pub fn with_alpha(alpha: f64) -> MetricAggregator

Create an aggregator with a custom EWMA smoothing factor.

alpha is clamped to (0.0, 1.0].

pub fn with_hlc_node_id(self, node_id: u64) -> MetricAggregator

Configure the HLC node identifier used when stamping snapshots.

pub fn ewma_alpha(&self) -> f64

Current EWMA smoothing factor.

pub fn record_inbound(&self, actor_id: ActorId, count: u64)

Record count inbound messages for actor_id.

pub fn record_outbound(&self, actor_id: ActorId, count: u64)

Record count outbound messages for actor_id.

pub fn record_latency(&self, actor_id: ActorId, d: Duration)

Record an observed processing latency sample for actor_id.

pub fn set_queue_depth(&self, actor_id: ActorId, depth: usize)

Set the current queue depth for actor_id.

pub fn set_state_size(&self, actor_id: ActorId, bytes: u64)

Set the current resident state size for actor_id.

pub fn set_gpu_utilization(&self, actor_id: ActorId, util: f32)

Set the current GPU utilization for actor_id. Values outside [0.0, 1.0] are clamped.

pub fn set_tenant(&self, actor_id: ActorId, tenant_id: u64)

Associate a tenant with actor_id.

pub fn remove_actor(&self, actor_id: &ActorId) -> bool

Remove an actor’s state. Returns true if the actor was tracked.

pub fn tracked_actors(&self) -> usize

Number of actors currently tracked.

pub fn snapshot(&self, actor_id: &ActorId) -> Option<LiveMetrics>

Produce a smoothed snapshot for actor_id, updating EWMA rates.

Returns None if the actor is unknown.

pub fn snapshot_all(&self) -> Vec<LiveMetrics>

Produce smoothed snapshots for all tracked actors.

Trait Implementations

impl Debug for MetricAggregator

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

Formats the value using the given formatter.

impl Default for MetricAggregator

fn default() -> MetricAggregator

Returns the “default value” for a type.