Struct WindowedQuantiles 

pub struct WindowedQuantiles { /* private fields */ }

Available on crate feature tracker only.

Sliding-window quantiles: rotate DdSketches through time buckets so a query answers “quantile over the last window”.

Mirrors TimeBucketedCounter’s bucket rotation. record is O(1); quantile clones and merges the live buckets (alloc per query, not per record).

Implementations

impl WindowedQuantiles

pub fn new( window: Duration, bucket_width: Duration, alpha: f64, max_bins: usize, ) -> Self

New windowed sketch. window = observation period; bucket_width = resolution; alpha / max_bins size each per-bucket DdSketch.

pub fn record(&mut self, value: f64, now: Timestamp)

Record value at now.

pub fn quantile(&self, q: f64, now: Timestamp) -> Option<f64>

Estimate quantile q over [now - window, now]. Returns None if no live observations. Clones + merges the active buckets — O(live buckets) allocation per call.

pub fn evict_expired(&mut self, now: Timestamp)

Drop buckets older than now - window.

pub fn len(&self) -> usize

Live bucket count.

pub fn is_empty(&self) -> bool

true if there are no buckets.

Trait Implementations

impl Clone for WindowedQuantiles

fn clone(&self) -> WindowedQuantiles

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowedQuantiles

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

Formats the value using the given formatter.

impl Mergeable for WindowedQuantiles

fn merge(&mut self, other: Self)

Union same-aligned buckets. Panics on window / bucket_width / alpha / max_bins mismatch.

fn merge_all(&mut self, others: impl IntoIterator<Item = Self>)

where Self: Sized,

Combine all elements of others into self.