Struct ProtocolMetrics 

pub struct ProtocolMetrics { /* private fields */ }

Protocol metrics for observability

Implementations

impl ProtocolMetrics

pub fn new() -> Self

Create new metrics instance

pub fn record_connection_start(&self)

Record connection start

pub fn record_message_sent(&self, bytes: u64)

Record message sent

pub fn record_message_failed(&self)

Record message failed

pub fn record_bytes_received(&self, bytes: u64)

Record bytes received

pub fn record_compression(&self, uncompressed: u64, compressed: u64)

Record compression ratio (uncompressed -> compressed)

pub fn record_latency(&self, latency: Duration)

Record message latency (one-way)

pub fn record_roundtrip(&self, roundtrip: Duration)

Record command roundtrip time

pub fn snapshot(&self) -> MetricsSnapshot

Get current metrics snapshot

pub fn reset(&self)

Reset all metrics

Trait Implementations

impl Debug for ProtocolMetrics

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

Formats the value using the given formatter.

impl Default for ProtocolMetrics

fn default() -> ProtocolMetrics

Returns the “default value” for a type.