Struct ServiceCounters 

pub struct ServiceCounters {
    pub active_conns: AtomicU32,
    pub total_requests: AtomicU64,
    pub failed_requests: AtomicU64,
    /* private fields */
}

Atomic counters that services increment in their hot paths.

The 1-minute sampler calls [snapshot_and_reset] to drain deltas and produce a MetricSample.

Fields

active_conns: AtomicU32

Current open connections (gauge — not reset on snapshot).

total_requests: AtomicU64

Monotonic total requests since last snapshot.

failed_requests: AtomicU64

Monotonic failed requests since last snapshot.

Implementations

impl ServiceCounters

pub fn new() -> Self

pub fn inc_conns(&self)

Increment the active-connections gauge.

pub fn dec_conns(&self)

Decrement the active-connections gauge.

pub async fn record_request(&self, success: bool, latency_ms: f64)

Record one completed request.

Increments total_requests unconditionally, and failed_requests when success is false. The latency value is pushed into a buffer that will be drained when the next sample is taken.

pub async fn snapshot_and_reset(&self) -> MetricSample

Take a point-in-time snapshot and reset the delta counters.

• active_conns is read but not reset (it is a gauge).
• total_requests and failed_requests are swapped to zero.
• Latencies are drained and the p95 value is computed.

Trait Implementations

impl Debug for ServiceCounters

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

Formats the value using the given formatter.

impl Default for ServiceCounters

fn default() -> Self

Returns the “default value” for a type.