Struct PrometheusMetrics 

pub struct PrometheusMetrics { /* private fields */ }

Prometheus metrics collector for rust-camel

This struct implements the MetricsCollector trait and exposes metrics in Prometheus format via the /metrics endpoint.

Implementations

impl PrometheusMetrics

pub fn new() -> Self

Creates a new PrometheusMetrics instance with all metrics registered

pub fn registry(&self) -> &Registry

Returns a reference to the underlying Prometheus registry

pub fn gather(&self) -> String

Gathers all metrics and returns them in Prometheus text format

Trait Implementations

impl Default for PrometheusMetrics

fn default() -> Self

Returns the “default value” for a type.

impl MetricsCollector for PrometheusMetrics

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