Struct EngineStats

pub struct EngineStats {
    pub published: AtomicU64,
    pub delivered: AtomicU64,
    pub dropped: AtomicU64,
}

Running counters for publish fan-out.

Loads are relaxed. The three numbers are not a single snapshot: a publish can increment published before delivered or dropped. Nothing currently reports dropped to an operator.

Fields

published: AtomicU64

delivered: AtomicU64

dropped: AtomicU64

Implementations

impl EngineStats

pub fn published(&self) -> u64

Envelopes handed to Engine::publish, once each, not per subscriber.

pub fn delivered(&self) -> u64

Deliveries that try_send accepted.

pub fn dropped(&self) -> u64

Deliveries that try_send rejected because the channel was full or already closed.

Trait Implementations

impl Debug for EngineStats

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

Formats the value using the given formatter.

impl Default for EngineStats

fn default() -> EngineStats

Returns the “default value” for a type.