Struct Counter 

pub struct Counter { /* private fields */ }

A sharded atomic counter.

Shards cache-line aligned AtomicIsize values across a vector for faster updates in high contention scenarios.

Implementations

impl Counter

pub fn new(count: usize) -> Self

Creates a new Counter with at least count cells.

The count is rounded up to the next power of two for fast modulo.

pub fn add(&self, value: isize)

Adds a value to the counter using relaxed ordering.

pub fn inc(&self)

Increments the counter by 1.

pub fn add_with_ordering(&self, value: isize, ordering: Ordering)

Adds a value to the counter with the specified ordering.

pub fn sum(&self) -> isize

Returns the sum of all shards using relaxed ordering.

Eventual Consistency

Due to sharding, this may be slightly inaccurate under heavy concurrent modification - writes to already-summed shards won’t be reflected until the next call. The total is eventually consistent.

pub fn sum_with_ordering(&self, ordering: Ordering) -> isize

Returns the sum of all shards with the specified ordering.

pub fn swap(&self) -> isize

Resets all shards to zero and returns the previous sum.

Useful for delta-style metrics export.

Eventual Consistency

Writes that occur concurrently with swap() may be attributed to the next window rather than the current one. This is because shards are swapped sequentially - a write landing on an already-swapped shard will be picked up by the next swap() call. No counts are lost; they simply shift to the next export window. For telemetry purposes with multi-second export intervals, this timing skew is negligible.

Trait Implementations

impl ClickHouseExport for Counter

fn export_clickhouse( &self, batch: &mut ClickHouseMetricBatch, name: &str, description: &str, time_unix_nano: u64, )

impl Debug for Counter

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

Formats the value using the given formatter.

impl DogStatsDExport for Counter

fn export_dogstatsd( &self, output: &mut String, name: &str, tags: &[(&str, &str)], )

Export this metric to the output string in DogStatsD format.

impl OtlpExport for Counter

fn export_otlp( &self, metrics: &mut Vec<Metric>, name: &str, description: &str, time_unix_nano: u64, )

impl PrometheusExport for Counter

fn export_prometheus(&self, output: &mut String, name: &str, help: &str)

Export this metric to the output string.