Struct MetricsCollector 

pub struct MetricsCollector {
    kernel_telemetry: RwLock<RawRwLock, HashMap<KernelId, TelemetryBuffer>>,
    kernel_histograms: RwLock<RawRwLock, HashMap<KernelId, LatencyHistogram>>,
    start_time: RwLock<RawRwLock, Option<Instant>>,
}

Metrics collector that aggregates metrics from multiple kernels.

Fields

kernel_telemetry: RwLock<RawRwLock, HashMap<KernelId, TelemetryBuffer>>

kernel_histograms: RwLock<RawRwLock, HashMap<KernelId, LatencyHistogram>>

start_time: RwLock<RawRwLock, Option<Instant>>

Implementations

impl MetricsCollector

pub fn new() -> MetricsCollector

Create a new metrics collector.

pub fn record_message_processed(&self, kernel_id: &KernelId, latency_us: u64)

Record a message processed event.

pub fn record_message_dropped(&self, kernel_id: &KernelId)

Record a message dropped event.

pub fn record_error(&self, kernel_id: &KernelId, error_code: u32)

Record an error.

pub fn get_telemetry(&self, kernel_id: &KernelId) -> Option<TelemetryBuffer>

Get telemetry for a kernel.

pub fn get_histogram(&self, kernel_id: &KernelId) -> Option<LatencyHistogram>

Get histogram for a kernel.

pub fn get_aggregate(&self) -> TelemetryBuffer

Get aggregate telemetry across all kernels.

pub fn reset(&self)

Reset all metrics.

pub fn elapsed(&self) -> Duration

Get elapsed time since start.

Trait Implementations

impl Default for MetricsCollector

fn default() -> MetricsCollector

Returns the “default value” for a type.