Struct StreamMaxTracker 

pub struct StreamMaxTracker {
    pub per_stream: BTreeMap<u64, Vec<(f64, u64)>>,
    pub flat: BTreeMap<u64, u64>,
    pub sum_series: Vec<(f64, u64)>,
    /* private fields */
}

Tracks monotonically increasing per-stream values with efficient sum calculation. Handles out-of-order events by taking max value seen per stream.

Fields

per_stream: BTreeMap<u64, Vec<(f64, u64)>>

Full time series per stream.

flat: BTreeMap<u64, u64>

Current maximum per stream.

sum_series: Vec<(f64, u64)>

Cumulative sum time series.

Implementations

impl StreamMaxTracker

pub fn new() -> Self

pub fn update( &mut self, stream_id: u64, new_value: u64, ev_time: f64, init_val: u64, ) -> Option<(u64, u64)>

Updates stream value, returns Some((old_max, new_max)) if changed.

pub fn get_stream_max(&self, stream_id: u64) -> Option<u64>

pub fn current_sum(&self) -> u64

Trait Implementations

impl Debug for StreamMaxTracker

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

Formats the value using the given formatter.

impl Default for StreamMaxTracker

fn default() -> Self

Returns the “default value” for a type.