Struct SharedHistogram 

pub struct SharedHistogram { /* private fields */ }

Implementations

impl SharedHistogram

pub fn create( path: impl AsRef<Path>, boundaries: &[u64], ) -> Result<Self, HistogramError>

pub fn open( path: impl AsRef<Path>, expected_boundaries: &[u64], ) -> Result<Self, HistogramError>

pub fn n_buckets(&self) -> usize

Number of buckets (n_boundaries + 1).

pub fn total_count(&self) -> u64

Total count across all buckets.

pub fn bucket_for(&self, value: u64) -> usize

Find the bucket index for value. Binary search on boundaries.

pub fn record(&self, value: u64) -> usize

Record one observation of value. Atomically increments the matching bucket counter and the total. Returns the bucket index it landed in.

pub fn count(&self, bucket_idx: usize) -> Result<u64, HistogramError>

Read a specific bucket’s count.

pub fn counts(&self) -> Vec<u64>

Snapshot all bucket counts as a Vec.

pub fn boundaries_vec(&self) -> Vec<u64>

Get the boundaries vector (copy).

pub fn percentile(&self, p: f64) -> u64

Estimate the p-th percentile (p in 0.0..=1.0). Walks buckets accumulating counts until p of total is covered, then linearly interpolates within the target bucket. Returns 0 if total is 0.

pub fn reset(&self)

Reset all counters to 0. Not concurrency-coordinated; expect transient race with concurrent recorders.

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

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

Trait Implementations

impl AdaptiveInstance for SharedHistogram

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 SharedHistogram

impl Sync for SharedHistogram