Struct RateCounter 

pub struct RateCounter { /* private fields */ }

A lock-free, thread-safe rate counter with current in-flight tracking and peak water mark.

Wraps five atomic values in Arc so the counter is Clone — clones share the same underlying counters, making it easy to pass into concurrent tasks (e.g. [tokio::spawn]).

The speed field stores a true per-second rate as an f64 (encoded via f64::to_bits / f64::from_bits in the AtomicU64), normalised by the sampling interval passed to tick.

The current field tracks the current in-flight or active count. inc / incs increment both total and current simultaneously and update max to the new peak. dec / decs only decrement current without affecting max. tick does not affect current or max.

Serialisation

RateCounter serialises as a snapshot of the current counter values (total, speed, current, max). Deserialisation produces a fresh, independent counter initialised to those values — it does NOT share atomics with the original. This makes it safe for cross-node transfer (e.g. via gRPC).

Implementations

impl RateCounter

pub fn new() -> Self

Creates a new RateCounter with all values initialised to zero and StatsMergeMode::None.

pub fn new_with_mode(mode: StatsMergeMode) -> Self

Creates a new RateCounter with a given merge mode.

pub fn snapshot(&self) -> Self

Creates an independent deep copy (new atomics) with the same values.

pub fn inc(&self)

Increments total, current, and potentially updates max by 1.

pub fn incs(&self, n: u64)

Increments total, current, and potentially updates max by n.

pub fn total(&self) -> u64

Returns the cumulative total count.

pub fn speed(&self) -> f64

Returns the per-second rate computed by the most recent [tick].

Returns 0.0 if [tick] has never been called.

pub fn tick(&self, interval: Duration)

Computes the per-second rate: speed = (total - last_total) / interval.

Call this periodically at a known interval (e.g. every 3 s) to get a true per-second throughput, regardless of the sampling duration.

pub fn reset(&self)

Resets all counters to zero.

pub fn current(&self) -> i64

Returns the current (in-flight / active) count.

pub fn max(&self) -> i64

Returns the peak (historical maximum) of the current count.

pub fn to_json(&self) -> Value

Converts the rate counter to JSON format.

pub fn add(&self, other: &Self)

Sums total, current and max from other into self.

pub fn set(&self, other: &Self)

Replaces all fields with the values from other.

pub fn merge(&self, other: &Self)

Merges other into self according to self.mode.

• None — no-op.
• Sum — totals are summed, current / max take the larger value.
• Max / Min — only current and max are affected.

pub fn dec(&self)

Decrements the current count by 1 (total and max unchanged).

pub fn decs(&self, n: i64)

Decrements the current count by n (total and max unchanged).

Trait Implementations

impl Clone for RateCounter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RateCounter

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

Formats the value using the given formatter.

impl Default for RateCounter

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RateCounter

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl Serialize for RateCounter

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.