Struct ProtocolMetrics 

pub struct ProtocolMetrics {
    pub connections_total: AtomicU64,
    pub connections_active: AtomicU64,
    pub messages_total: AtomicU64,
    pub errors_total: AtomicU64,
    pub bytes_sent: AtomicU64,
    pub bytes_received: AtomicU64,
    pub latency_micros: AtomicU64,
}

Generic metrics collector shared by all protocol crates.

Contains the common counters that every protocol needs. Protocol crates can embed this struct and add protocol-specific fields alongside it.

Fields

connections_total: AtomicU64

Total number of connections ever established

connections_active: AtomicU64

Currently active connections

messages_total: AtomicU64

Total messages processed (sent or received, depending on protocol)

errors_total: AtomicU64

Total errors encountered

bytes_sent: AtomicU64

Total bytes sent

bytes_received: AtomicU64

Total bytes received

latency_micros: AtomicU64

Average latency in microseconds (simple moving average)

Implementations

impl ProtocolMetrics

pub fn new() -> Self

Create a new metrics collector with all counters at zero.

pub fn record_connection(&self)

Record a new connection (increments both total and active).

pub fn record_disconnection(&self)

Record a disconnection (decrements active connections).

pub fn record_message(&self)

Record a message processed.

pub fn record_messages(&self, count: u64)

Record multiple messages processed at once.

pub fn record_error(&self)

Record an error.

pub fn record_bytes_sent(&self, bytes: u64)

Record bytes sent.

pub fn record_bytes_received(&self, bytes: u64)

Record bytes received.

pub fn record_latency(&self, latency_micros: u64)

Record latency in microseconds (simple moving average).

pub fn snapshot(&self) -> ProtocolMetricsSnapshot

Take a point-in-time snapshot of all counters.

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

Export common metrics in Prometheus format with a given protocol prefix.

Arguments

• prefix - Protocol name for metric labels (e.g., “kafka”, “mqtt”)

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() -> Self

Returns the “default value” for a type.