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 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.