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.

Panics

Panics if metric creation or registration fails. This can only happen if:

• A metric name is invalid (must match ^[a-zA-Z_:][a-zA-Z0-9_:]*$). All names are hardcoded below and comply with this requirement by convention.
• A metric is registered twice. This is impossible here because each call creates a fresh Registry.

Since both conditions are static invariants enforced by code review, these expect() calls are intentional and will never fail in practice.

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