Struct Metrics 

pub struct Metrics { /* private fields */ }

Metrics for observability and monitoring.

All counters are atomically updated and can be read from any thread. Use snapshot() to get a consistent point-in-time view.

Implementations

impl Metrics

pub fn new() -> Self

Create a new metrics instance with all counters at zero.

pub fn record_publish(&self)

Record a published message.

pub fn record_consume(&self)

Record a consumed message.

pub fn record_overrun(&self)

Record an overrun event.

pub fn record_backpressure(&self)

Record a backpressure event (producer blocked on credits).

pub fn snapshot(&self) -> MetricsSnapshot

Get a consistent snapshot of all metrics.

pub fn reset(&self)

Reset all counters to zero.

Trait Implementations

impl Debug for Metrics

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

Formats the value using the given formatter.

impl Default for Metrics

fn default() -> Self

Returns the “default value” for a type.