Struct StreamBufferTracker 

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

Tracks monotonically increasing stream buffer positions with efficient sum calculation. Handles out-of-order events by taking max end position (offset

• length) seen per stream.

Fields

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

Full time series per stream with StreamAccess details.

flat: BTreeMap<u64, u64>

Current maximum end position (offset + length) per stream.

sum_series: Vec<(f64, u64)>

Cumulative sum time series.

Implementations

impl StreamBufferTracker

pub fn new() -> Self

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

Updates stream buffer position, 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 StreamBufferTracker

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

Formats the value using the given formatter.

impl Default for StreamBufferTracker

fn default() -> Self

Returns the “default value” for a type.