Struct QueueGauge 

pub struct QueueGauge { /* private fields */ }

Live usage gauge for a single bounded queue.

Cloneable handles share one gauge through an Arc; the registry keeps a Weak so a gauge is auto-pruned from snapshots once its queue is dropped.

Implementations

impl QueueGauge

pub fn name(&self) -> TrackedLimit

Stable limit name (used in logs and snapshots).

pub fn category(&self) -> LimitCategory

The class of bounded resource this gauge tracks.

pub fn capacity(&self) -> usize

Configured queue capacity (slots). 0 means unbounded / untracked.

pub fn depth(&self) -> usize

Current observed depth.

pub fn high_water(&self) -> usize

Highest depth observed over the gauge’s lifetime.

pub fn observe_depth(&self, depth: usize)

Report the queue’s exact current depth (for queues whose backing channel exposes its live length, e.g. a Tokio mpsc via max_capacity - capacity).

pub fn record_enqueue(&self)

Account for one item entering the queue (for manually-tracked queues).

pub fn record_dequeue(&self)

Account for one item leaving the queue. Saturates at zero so a stray dequeue can never underflow the depth counter. Re-evaluates so a gauge that latched “warned” while full re-arms once the queue drains back below the re-arm threshold, even if the producer has since gone idle.

Trait Implementations

impl Debug for QueueGauge

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

Formats the value using the given formatter.