Struct MetricsSnapshot 

pub struct MetricsSnapshot {
    pub published: u64,
    pub consumed: u64,
    pub overruns: u64,
    pub backpressure_events: u64,
}

A point-in-time snapshot of metrics.

Fields

published: u64

Total messages published.

consumed: u64

Total messages consumed.

overruns: u64

Total overruns detected.

backpressure_events: u64

Total backpressure events.

Implementations

impl MetricsSnapshot

pub fn lag(&self) -> u64

Returns the current consumer lag (published - consumed).

Trait Implementations

impl Clone for MetricsSnapshot

fn clone(&self) -> MetricsSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsSnapshot

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

Formats the value using the given formatter.

impl Default for MetricsSnapshot

fn default() -> MetricsSnapshot

Returns the “default value” for a type.

impl Display for MetricsSnapshot

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

Formats the value using the given formatter.

impl PartialEq for MetricsSnapshot

fn eq(&self, other: &MetricsSnapshot) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for MetricsSnapshot

impl Eq for MetricsSnapshot

impl StructuralPartialEq for MetricsSnapshot