Struct MetricsStream 

pub struct MetricsStream {
    pub throughput: TimeSeries,
    pub latency: StreamingHistogram,
    pub error_rate: TimeSeries,
    pub active_users: TimeSeries,
}

Metrics stream for real-time dashboard

Fields

throughput: TimeSeries

Throughput time series (req/s)

latency: StreamingHistogram

Latency histogram

error_rate: TimeSeries

Error rate time series (%)

active_users: TimeSeries

Active users time series

Implementations

impl MetricsStream

pub fn new() -> Self

Create a new metrics stream

pub fn record_request( &mut self, timestamp_ms: u64, latency_ms: u64, success: bool, )

Record a request

pub fn update_throughput(&mut self, timestamp_ms: u64, requests_per_sec: f64)

Update throughput

pub fn update_error_rate(&mut self, timestamp_ms: u64, error_percent: f64)

Update error rate

pub fn update_active_users(&mut self, timestamp_ms: u64, users: u32)

Update active users

Trait Implementations

impl Clone for MetricsStream

fn clone(&self) -> MetricsStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MetricsStream

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

Formats the value using the given formatter.

impl Default for MetricsStream

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MetricsStream

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MetricsStream

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.