Struct CountMinSketch 

pub struct CountMinSketch { /* private fields */ }

Fixed-depth Count-Min sketch for compact megakernel telemetry.

The layout is intentionally plain Vec<u64> plus (depth, width) so the same shape can be mirrored by GPU control buffers later. Hashing is deterministic and seed-indexed; no host randomness is involved, which keeps replay and regression tests stable.

Implementations

impl CountMinSketch

pub fn new(depth: usize, width: usize) -> Result<Self, PipelineError>

Create a zeroed sketch with the requested dimensions.

Errors

Returns PipelineError when either dimension is zero or the counter table size overflows host address space.

pub const fn depth(&self) -> usize

Number of independent hash rows.

pub const fn width(&self) -> usize

Number of counters per hash row.

pub fn counters(&self) -> &[u64]

Raw row-major counters. Intended for readback, replay, and tests.

pub fn clear(&mut self)

Reset all counters to zero while retaining allocation.

pub fn reset_shape( &mut self, depth: usize, width: usize, ) -> Result<(), PipelineError>

Resize this sketch shape and clear counters.

Errors

Returns PipelineError when either dimension is zero or the counter table size overflows host address space.

pub fn add(&mut self, key: u32, amount: u64)

Add amount to every row bucket selected for key.

pub fn try_add(&mut self, key: u32, amount: u64) -> Result<(), PipelineError>

Checked add of amount to every row bucket selected for key.

Errors

Returns PipelineError when a counter would overflow u64.

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

Conservative point estimate for key.

pub fn merge(&mut self, other: &Self) -> Result<(), PipelineError>

Merge another sketch with identical dimensions into this sketch.

Errors

Returns PipelineError if the sketches have different shapes.

Trait Implementations

impl Clone for CountMinSketch

fn clone(&self) -> CountMinSketch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CountMinSketch

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

Formats the value using the given formatter.

impl Eq for CountMinSketch

impl PartialEq for CountMinSketch

fn eq(&self, other: &CountMinSketch) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for CountMinSketch