Struct ProtocolMetrics 

pub struct ProtocolMetrics {

    pub requests_total: AtomicU64,
    pub responses_total: AtomicU64,
    pub timeouts_total: AtomicU64,
    pub connection_errors_total: AtomicU64,
    pub serialization_errors_total: AtomicU64,
    pub flow_control_pauses_total: AtomicU64,
    pub flow_control_resumes_total: AtomicU64,
    pub flow_control_rejections_total: AtomicU64,
    pub in_flight_requests: AtomicU64,
    pub buffer_utilization_percent: AtomicU64,
    pub healthy_connections: AtomicU64,
    pub paused_connections: AtomicU64,
    pub serialization_time: HistogramMetric,
    pub request_duration: HistogramMetric,
}

Protocol-level metrics for the agent pool.

Fields

requests_total: AtomicU64

Total requests sent

responses_total: AtomicU64

Total responses received

timeouts_total: AtomicU64

Requests that timed out

connection_errors_total: AtomicU64

Connection errors

serialization_errors_total: AtomicU64

Serialization errors

flow_control_pauses_total: AtomicU64

Flow control pause events

flow_control_resumes_total: AtomicU64

Flow control resume events

flow_control_rejections_total: AtomicU64

Requests rejected due to flow control

in_flight_requests: AtomicU64

Current in-flight requests

buffer_utilization_percent: AtomicU64

Current buffer utilization (0-100)

healthy_connections: AtomicU64

Number of healthy connections

paused_connections: AtomicU64

Number of paused connections (flow control)

serialization_time: HistogramMetric

Serialization time histogram

request_duration: HistogramMetric

Request duration histogram (end-to-end)

Implementations

impl ProtocolMetrics

pub fn new() -> Self

Create new protocol metrics.

pub fn inc_requests(&self)

Increment requests total.

pub fn inc_responses(&self)

Increment responses total.

pub fn inc_timeouts(&self)

Increment timeouts.

pub fn inc_connection_errors(&self)

Increment connection errors.

pub fn inc_serialization_errors(&self)

Increment serialization errors.

pub fn record_flow_pause(&self)

Record flow control pause.

pub fn record_flow_resume(&self)

Record flow control resume.

pub fn record_flow_rejection(&self)

Record flow control rejection.

pub fn set_in_flight(&self, count: u64)

Set in-flight requests gauge.

pub fn inc_in_flight(&self)

Increment in-flight requests.

pub fn dec_in_flight(&self)

Decrement in-flight requests.

pub fn set_buffer_utilization(&self, percent: u64)

Set buffer utilization percentage.

pub fn set_healthy_connections(&self, count: u64)

Set healthy connections gauge.

pub fn set_paused_connections(&self, count: u64)

Set paused connections gauge.

pub fn record_serialization_time(&self, duration: Duration)

Record serialization time.

pub fn record_request_duration(&self, duration: Duration)

Record request duration.

pub fn snapshot(&self) -> ProtocolMetricsSnapshot

Get a snapshot of all metrics.

pub fn to_prometheus(&self, prefix: &str) -> String

Export metrics in Prometheus text format.

Trait Implementations

impl Debug for ProtocolMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ProtocolMetrics

fn default() -> ProtocolMetrics

Returns the “default value” for a type.