Struct BucketedTimeSeries 

pub struct BucketedTimeSeries { /* private fields */ }

Bucketed time series for aggregating metrics into fixed time intervals.

Implementations

impl BucketedTimeSeries

pub fn new(bucket_size_ms: u64, max_buckets: usize) -> Self

Create a new bucketed time series.

Arguments

• bucket_size_ms - Size of each bucket in milliseconds
• max_buckets - Maximum number of buckets to retain

pub fn add_value(&mut self, timestamp_ms: i64, value: f64)

Add a value at the given timestamp.

pub fn buckets(&self) -> &VecDeque<TimeBucket>

Get all buckets.

pub fn buckets_in_range(&self, start_ms: i64, end_ms: i64) -> Vec<&TimeBucket>

Get buckets within a time range.

pub fn aggregate_stats(&self) -> Option<(f64, f64, f64, u64)>

Calculate aggregate statistics across all buckets.

pub fn clear(&mut self)

Clear all buckets.

Trait Implementations

impl Clone for BucketedTimeSeries

fn clone(&self) -> BucketedTimeSeries

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BucketedTimeSeries

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

Formats the value using the given formatter.