Struct SharedReservoirSampler 

pub struct SharedReservoirSampler<T: Copy + 'static> { /* private fields */ }

Implementations

impl<T: Copy + 'static> SharedReservoirSampler<T>

pub fn create( path: impl AsRef<Path>, capacity: usize, ) -> Result<Self, ReservoirError>

pub fn open( path: impl AsRef<Path>, expected_capacity: usize, ) -> Result<Self, ReservoirError>

pub fn capacity(&self) -> usize

pub fn total_seen(&self) -> u64

pub fn record(&self, value: T) -> Option<usize>

Record a value. Returns the slot index it landed in, or None if the value was rejected (the reservoir kept its existing sample for this position).

pub fn snapshot(&self) -> Vec<T>

Snapshot the current reservoir. Returns min(total_seen, k) slots filled so far; the rest are unused.

pub fn reset(&self)

Reset to empty (total_seen = 0; slots become invalid but not zeroed - next record overwrites them).

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

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

Trait Implementations

impl<T: Copy + Send + Sync + 'static> AdaptiveInstance for SharedReservoirSampler<T>

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<T: Copy + Send + 'static> Send for SharedReservoirSampler<T>

impl<T: Copy + Sync + 'static> Sync for SharedReservoirSampler<T>