Struct ChannelMetrics 

pub struct ChannelMetrics { /* private fields */ }

Atomic metrics counters for thread-safe updates.

Implementations

impl ChannelMetrics

pub fn new() -> Self

Create a new metrics instance.

pub fn record_send(&self, bytes: usize)

Record a message sent.

pub fn record_recv(&self, bytes: usize)

Record a message received.

pub fn record_send_error(&self)

Record a send error.

pub fn record_recv_error(&self)

Record a receive error.

pub fn record_latency(&self, latency: Duration)

Record latency for a message.

pub fn set_queue_depth(&self, depth: u64)

Update queue depth.

pub fn messages_sent(&self) -> u64

Get messages sent count.

pub fn messages_received(&self) -> u64

Get messages received count.

pub fn bytes_sent(&self) -> u64

Get bytes sent count.

pub fn bytes_received(&self) -> u64

Get bytes received count.

pub fn send_errors(&self) -> u64

Get send errors count.

pub fn receive_errors(&self) -> u64

Get receive errors count.

pub fn queue_depth(&self) -> u64

Get current queue depth.

pub fn peak_queue_depth(&self) -> u64

Get peak queue depth.

pub fn avg_latency_us(&self) -> u64

Get average latency in microseconds.

pub fn min_latency_us(&self) -> Option<u64>

Get minimum latency in microseconds.

pub fn max_latency_us(&self) -> u64

Get maximum latency in microseconds.

pub fn latency_percentile(&self, percentile: u8) -> u64

Get latency percentile (e.g., 99 for p99).

pub fn elapsed(&self) -> Duration

Get elapsed time since metrics started.

pub fn send_throughput(&self) -> f64

Get send throughput in messages per second.

pub fn recv_throughput(&self) -> f64

Get receive throughput in messages per second.

pub fn send_bandwidth(&self) -> f64

Get send bandwidth in bytes per second.

pub fn recv_bandwidth(&self) -> f64

Get receive bandwidth in bytes per second.

pub fn reset(&self)

Reset all metrics.

pub fn snapshot(&self) -> MetricsSnapshot

Get a snapshot of all metrics.

pub fn to_json(&self) -> String

Export metrics as JSON string.

pub fn to_json_pretty(&self) -> String

Export metrics as pretty JSON string.

pub fn to_prometheus(&self, prefix: &str) -> String

Export metrics in Prometheus format.

Trait Implementations

impl Debug for ChannelMetrics

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

Formats the value using the given formatter.

impl Default for ChannelMetrics

fn default() -> ChannelMetrics

Returns the “default value” for a type.