Trait MetricsCollector 

pub trait MetricsCollector: Send + Sync {
    // Required methods
    fn record_exchange_duration(&self, route_id: &str, duration: Duration);
    fn increment_errors(&self, route_id: &str, error_type: &str);
    fn increment_exchanges(&self, route_id: &str);
    fn set_queue_depth(&self, route_id: &str, depth: usize);
    fn record_circuit_breaker_change(
        &self,
        route_id: &str,
        from: &str,
        to: &str,
    );
}

Trait for collecting metrics from the Camel runtime. Implementations can integrate with Prometheus, OpenTelemetry, etc.

Required Methods

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

Implementors

impl MetricsCollector for NoOpMetrics

impl MetricsCollector for PrometheusMetrics