Struct CMSketchAtomicU32 

pub struct CMSketchAtomicU32 { /* private fields */ }

Count-Min Sketch that stores u32 counters using atomics for concurrent updates.

Each bucket is backed by AtomicU32, allowing lock-free increments and decrements.

Implementations

impl CMSketchAtomicU32

pub fn new(eps: f64, confidence: f64) -> Self

Creates a new atomic sketch sized by error eps and confidence.

See CMSketchU32::new for the mapping between confidence and depth.

Panics

Panics if eps <= 0.0 or confidence <= 0.0.

pub fn inc(&self, hash: u64)

Atomically increments the count associated with hash by 1.

pub fn inc_by(&self, hash: u64, count: u32)

Atomically increments the count associated with hash by count.

Saturates at the maximum value representable by the counter type and leaves the bucket unchanged if the update would overflow.

pub fn dec(&self, hash: u64)

Atomically decrements the count associated with hash by 1.

pub fn dec_by(&self, hash: u64, count: u32)

Atomically decrements the count associated with hash by count.

Leaves the counter unchanged if it would underflow.

pub fn estimate(&self, hash: u64) -> u32

Returns the minimum counter across all rows for hash.

pub fn clear(&self)

Resets all counters to zero.

pub fn halve(&self)

Divides every counter by two using an atomic fetch-update.

pub fn decay(&self, decay: f64)

Applies a floating-point decay factor to every counter.

pub fn width(&self) -> usize

Returns the configured table width (number of columns).

pub fn depth(&self) -> usize

Returns the number of hash rows.

pub fn capacity(&self) -> u32

Returns the maximum representable counter for this sketch.

pub fn memory(&self) -> usize

Returns the amount of memory used by the sketch in bytes.

Trait Implementations

impl Debug for CMSketchAtomicU32

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

Formats the value using the given formatter.