Struct TransportMetrics 

pub struct TransportMetrics {
    pub bytes_sent: u64,
    pub bytes_received: u64,
    pub messages_sent: u64,
    pub messages_received: u64,
    pub connections: u64,
    pub failed_connections: u64,
    pub average_latency_ms: f64,
    pub active_connections: u64,
    pub compression_ratio: Option<f64>,
    pub metadata: HashMap<String, Value>,
}

A serializable snapshot of a transport’s performance metrics.

This struct provides a consistent view of metrics for external monitoring. For internal, high-performance updates, AtomicMetrics is preferred.

Custom Transport Metrics

Transport implementations can store custom metrics in the metadata field.

let mut metrics = TransportMetrics::default();
metrics.metadata.insert("active_correlations".to_string(), json!(42));

Fields

bytes_sent: u64

Total number of bytes sent.

bytes_received: u64

Total number of bytes received.

messages_sent: u64

Total number of messages sent.

messages_received: u64

Total number of messages received.

connections: u64

Total number of connection attempts.

failed_connections: u64

Total number of failed connection attempts.

average_latency_ms: f64

The average latency of operations, in milliseconds.

active_connections: u64

The current number of active connections.

compression_ratio: Option<f64>

The compression ratio (uncompressed size / compressed size), if applicable.

metadata: HashMap<String, Value>

A map for custom, transport-specific metrics.

Trait Implementations

impl Clone for TransportMetrics

fn clone(&self) -> TransportMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransportMetrics

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

Formats the value using the given formatter.

impl Default for TransportMetrics

fn default() -> TransportMetrics

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TransportMetrics

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TransportMetrics

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

where __S: Serializer,

Serialize this value into the given Serde serializer.