Struct RequestMetrics 

pub struct RequestMetrics { /* private fields */ }

Request metrics collector

Implementations

impl RequestMetrics

pub fn new() -> Result<Self>

Create new metrics collector and register with Prometheus

pub fn record_request( &self, route: &str, method: &str, status: u16, duration: Duration, )

Record a completed request

pub fn inc_active_requests(&self)

Increment active request counter

pub fn dec_active_requests(&self)

Decrement active request counter

pub fn record_upstream_attempt(&self, upstream: &str, route: &str)

Record an upstream attempt

pub fn record_upstream_failure(&self, upstream: &str, route: &str, reason: &str)

Record an upstream failure

pub fn set_circuit_breaker_state( &self, component: &str, route: &str, is_open: bool, )

Update circuit breaker state

pub fn record_agent_latency(&self, agent: &str, event: &str, duration: Duration)

Record agent call latency

pub fn record_agent_timeout(&self, agent: &str, event: &str)

Record agent timeout

pub fn record_blocked_request(&self, reason: &str)

Record a blocked request

pub fn record_pii_detected(&self, route: &str, category: &str)

Record PII detection in inference response

pub fn record_request_body_size(&self, route: &str, size_bytes: usize)

Record request body size

pub fn record_response_body_size(&self, route: &str, size_bytes: usize)

Record response body size

pub fn record_tls_handshake(&self, version: &str, duration: Duration)

Record TLS handshake duration

pub fn update_connection_pool(&self, upstream: &str, size: i64, idle: i64)

Update connection pool metrics

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

Record connection acquisition from pool

pub fn update_system_metrics(&self)

Update system metrics

pub fn set_open_connections(&self, count: i64)

Set open connections count

pub fn record_websocket_frame( &self, route: &str, direction: &str, opcode: &str, decision: &str, )

Record a WebSocket frame being processed

Arguments

• route - The route ID
• direction - Frame direction: “c2s” (client to server) or “s2c” (server to client)
• opcode - Frame opcode: “text”, “binary”, “ping”, “pong”, “close”, “continuation”
• decision - Inspection decision: “allow”, “drop”, or “close”

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

Record a WebSocket connection with inspection enabled

pub fn record_websocket_inspection_duration( &self, route: &str, duration: Duration, )

Record WebSocket frame inspection duration

pub fn record_websocket_frame_size( &self, route: &str, direction: &str, opcode: &str, size_bytes: usize, )

Record WebSocket frame size

Arguments

• route - The route ID
• direction - Frame direction: “c2s” or “s2c”
• opcode - Frame opcode
• size_bytes - Frame payload size in bytes

pub fn record_decompression_success(&self, encoding: &str, ratio: f64)

Record a successful body decompression

Arguments

• encoding - Content-Encoding (gzip, deflate, br)
• ratio - Decompression ratio (decompressed_size / compressed_size)

pub fn record_decompression_failure(&self, encoding: &str, reason: &str)

Record a failed body decompression

Arguments

• encoding - Content-Encoding (gzip, deflate, br)
• reason - Failure reason (ratio_exceeded, size_exceeded, invalid_data, unsupported)

pub fn record_shadow_success( &self, route: &str, upstream: &str, duration: Duration, )

Record a successful shadow request

Arguments

• route - Route ID
• upstream - Shadow upstream ID
• duration - Shadow request duration

pub fn record_shadow_error(&self, route: &str, upstream: &str, error_type: &str)

Record a failed shadow request

Arguments

• route - Route ID
• upstream - Shadow upstream ID
• error_type - Error type (upstream_not_found, timeout, connection_failed, request_failed)

pub fn record_shadow_timeout( &self, route: &str, upstream: &str, duration: Duration, )

Record a shadow request timeout

Arguments

• route - Route ID
• upstream - Shadow upstream ID
• duration - Time before timeout