Struct QueueMetrics 

pub struct QueueMetrics { /* private fields */ }

Queue-edge handles (spate_queue_*).

Implementations

impl QueueMetrics

pub fn new(labels: &ComponentLabels, queue: &str, capacity: usize) -> Self

Resolve handles for one queue edge (e.g. chain->sink/shard-3) and publish its configured capacity.

Claims this edge’s series (the labels plus the queue name); a second live handle set for the same edge logs and becomes a shadow, counting but publishing neither depth nor capacity (see “Series ownership” in docs/METRICS.md).

pub fn try_new( labels: &ComponentLabels, queue: &str, capacity: usize, ) -> Result<Self, MetricsError>

Resolve handles for one queue edge, failing when another live handle set already owns it. The pipeline builder’s path.

Errors

MetricsError::DuplicateSeries on a collision.

pub fn set_depth(&self, depth: usize)

Set the current queue depth.

pub fn full_events(&self, n: u64)

Count try_send rejections.

Trait Implementations

impl Debug for QueueMetrics

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

Formats the value using the given formatter.