Struct MetricStream 

pub struct MetricStream { /* private fields */ }

Real-time metric streaming system.

Implementations

impl MetricStream

pub fn new() -> Self

Create new metric stream.

pub fn with_rate_limit(min_interval: Duration) -> Self

Create with custom rate limit.

pub fn subscribe<F>(&mut self, callback: F)

where F: Fn(&MetricEvent) + Send + Sync + 'static,

Subscribe to metric events.

pub fn add_threshold_alert( &mut self, metric: impl Into<String>, threshold: f64, above: bool, )

Add threshold alert.

pub fn publish_counter(&self, name: impl Into<String>, value: u64)

Publish counter metric.

pub fn publish_gauge(&self, name: impl Into<String>, value: f64)

Publish gauge metric.

pub fn publish_timing(&self, name: impl Into<String>, duration_us: u64)

Publish timing metric.

pub fn subscriber_count(&self) -> usize

Get subscriber count.

pub fn clear_subscribers(&mut self)

Clear all subscribers.

Trait Implementations

impl Default for MetricStream

fn default() -> Self

Returns the “default value” for a type.