Struct MetricsManager 

pub struct MetricsManager { /* private fields */ }

Metrics manager for the proxy.

This manages all proxy metrics and provides a Prometheus-compatible export endpoint.

Implementations

impl MetricsManager

pub fn new( service_name: impl Into<String>, instance_id: impl Into<String>, ) -> Self

Create a new metrics manager.

pub fn with_aggregator(aggregator: Arc<UnifiedMetricsAggregator>) -> Self

Create from an existing aggregator.

pub fn from_config( config: &MetricsConfig, service_name: impl Into<String>, instance_id: impl Into<String>, ) -> Self

Create from metrics configuration.

Applies enabled and path from the config. The address field determines which listener serves the metrics endpoint but is handled at the listener level, not here.

pub fn path(self, path: impl Into<String>) -> Self

Set the metrics endpoint path.

pub fn allowed_ips(self, ips: Vec<String>) -> Self

Set allowed IPs for metrics access.

pub fn disable(self) -> Self

Disable metrics collection.

pub fn is_enabled(&self) -> bool

Check if metrics are enabled.

pub fn metrics_path(&self) -> &str

Get the metrics path.

pub fn aggregator(&self) -> &UnifiedMetricsAggregator

Get a reference to the aggregator.

pub fn aggregator_arc(&self) -> Arc<UnifiedMetricsAggregator>

Get an Arc to the aggregator.

pub fn is_ip_allowed(&self, ip: &str) -> bool

Check if an IP is allowed to access metrics.

pub async fn register_pool_metrics( &self, agent_id: impl Into<String>, collector: Arc<MetricsCollector>, )

Register a pool metrics collector for a v2 agent.

Pool metrics will be included in the /metrics output.

pub async fn unregister_pool_metrics(&self, agent_id: &str)

Unregister a pool metrics collector.

pub fn handle_metrics_request(&self) -> MetricsResponse

Handle a metrics request.

Returns the Prometheus text format metrics body, including:

• Proxy metrics from the UnifiedMetricsAggregator
• Pool metrics from all registered v2 agent pools

pub fn inc_requests_total(&self, method: &str, status: u16, route: &str)

Increment total requests counter.

pub fn observe_request_duration( &self, method: &str, route: &str, duration_secs: f64, )

Record request duration.

pub fn set_active_connections(&self, count: f64)

Set active connections gauge.

pub fn set_active_requests(&self, count: f64)

Set active requests gauge.

pub fn inc_upstream_requests(&self, upstream: &str, status: u16, success: bool)

Increment upstream requests.

pub fn observe_upstream_duration(&self, upstream: &str, duration_secs: f64)

Record upstream latency.

pub fn inc_agent_requests(&self, agent: &str, decision: &str)

Increment agent requests.

pub fn observe_agent_duration(&self, agent: &str, duration_secs: f64)

Record agent processing time.

pub fn inc_circuit_breaker_trips(&self, upstream: &str)

Increment circuit breaker trips.

pub fn set_circuit_breaker_state(&self, upstream: &str, open: bool)

Set circuit breaker state.

pub fn inc_rate_limited(&self, route: &str)

Increment rate limited requests.

pub fn inc_cache_access(&self, hit: bool)

Increment cache hits/misses.

pub fn set_cache_size(&self, size_bytes: f64)

Set cache size.