Struct CompositeMetricsCollector 

pub struct CompositeMetricsCollector { /* private fields */ }

A MetricsCollector that fans every observation out to a list of collectors, in registration order.

Built by MetricsHandle::register — the second registration stores a composite of [first, second]; a third composes over that composite, so ordering and prior observation are preserved (composition, not replacement).

Implementations

impl CompositeMetricsCollector

pub fn new(collectors: Vec<Arc<dyn MetricsCollector>>) -> Self

Creates a composite that delegates to collectors in order.

Trait Implementations

impl MetricsCollector for CompositeMetricsCollector

fn record_exchange_duration(&self, route_id: &str, duration: Duration)

Record exchange processing time

fn increment_errors(&self, route_id: &str, error_type: &str)

Increment error counter

fn increment_exchanges(&self, route_id: &str)

Increment exchange counter

fn set_queue_depth(&self, route_id: &str, depth: usize)

Update queue depth

fn record_circuit_breaker_change(&self, route_id: &str, from: &str, to: &str)

Record circuit breaker state change

fn record_histogram(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a histogram observation (e.g., cost, latency distribution). Default: no-op (backward-compatible).

fn record_counter(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a monotonically-increasing counter (e.g. foo_total). Default: no-op (backward-compatible).