Struct SharedHyperLogLog 

pub struct SharedHyperLogLog { /* private fields */ }

Implementations

impl SharedHyperLogLog

pub fn create(path: impl AsRef<Path>, precision: u8) -> Result<Self, HLLError>

pub fn open( path: impl AsRef<Path>, expected_precision: u8, ) -> Result<Self, HLLError>

pub fn precision(&self) -> u8

pub fn n_registers(&self) -> u32

pub fn insert(&self, item: &[u8])

Insert an item. One fetch_max on one register; no spinning.

pub fn estimate(&self) -> u64

Estimate cardinality (distinct count) via harmonic mean with bias correction.

pub fn reset(&self)

Reset all registers to zero (the empty state).

pub fn flush(&self) -> Result<(), HLLError>

pub fn flush_async(&self) -> Result<(), HLLError>

Trait Implementations

impl AdaptiveInstance for SharedHyperLogLog

fn header(&self) -> &HandshakeHeader

fn ring(&self) -> &ObservationRing

fn make_policy(&self) -> Box<dyn Policy>

fn apply_migration(&self, new_tag: u32)

Called by the sidecar when the policy returns a new strategy tag. Default implementation: just set the tag on the header. Primitives that need heavier migration (data-layout swap) override this to perform the swap before (or after) updating the tag.

impl Send for SharedHyperLogLog

impl Sync for SharedHyperLogLog