Struct RouterCounters 

pub struct RouterCounters {

    pub routed: u64,
    pub delivered: u64,
    pub dropped: u64,
    pub dropped_queue_full: u64,
    pub dropped_all_full: u64,
    pub dropped_no_credit: u64,
    pub credit_waits: u64,
    pub detaches: u64,
    pub pressure_waits: u64,
    pub idle_waits: u64,
    pub batches: u64,
    pub batch_sum: u64,
    pub batch_max: u32,
    pub wake_waits: u64,
    pub wake_timeouts: u64,
}

Counters returned by routing loops.

These counters are best-effort observability signals. In particular, some drop attribution is only approximate for work-queue routing because the router may fail to find any eligible destination.

Fields

routed: u64

Number of messages routed (i.e. consumed from the producer queue).

delivered: u64

Total number of consumer enqueues performed.

dropped: u64

Total number of consumer enqueue failures.

dropped_queue_full: u64

Drops attributable to destination queue being full (best-effort, v1 fanout).

dropped_all_full: u64

Drops attributable to no eligible consumer having space (work-queue: all full).

dropped_no_credit: u64

Drops attributable to no eligible consumer having credit (best-effort).

credit_waits: u64

Number of times routing was throttled due to credit exhaustion.

detaches: u64

Number of consumer detach events.

pressure_waits: u64

Number of times routing was throttled because consumer queues had no capacity.

idle_waits: u64

Number of times the loop observed “no work” and invoked the wait strategy.

batches: u64

Number of batches routed.

batch_sum: u64

Sum of batch sizes (messages per batch).

batch_max: u32

Maximum batch size observed.

wake_waits: u64

Number of OS-backed wake waits performed (when BackpressurePolicy::Block is active).

wake_timeouts: u64

Number of OS-backed wake waits that timed out.

Trait Implementations

impl Clone for RouterCounters

fn clone(&self) -> RouterCounters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RouterCounters

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

Formats the value using the given formatter.

impl Default for RouterCounters

fn default() -> RouterCounters

Returns the “default value” for a type.

impl PartialEq for RouterCounters

fn eq(&self, other: &RouterCounters) -> 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 RouterCounters

impl Eq for RouterCounters

impl StructuralPartialEq for RouterCounters