Struct SlidingWindowAggregator 

pub struct SlidingWindowAggregator { /* private fields */ }

A sliding window analytics aggregator for real-time media metrics.

Events are ingested in order via SlidingWindowAggregator::ingest. The aggregator maintains a rolling window of window_duration_ms worth of time buckets, each bucket_ms wide. Old buckets outside the window are automatically evicted.

Implementations

impl SlidingWindowAggregator

pub fn new( window_duration_ms: i64, bucket_ms: i64, ) -> Result<Self, AnalyticsError>

Create a new aggregator.

Returns an error if window_duration_ms < bucket_ms or either is zero.

pub fn ingest(&mut self, event: RealtimeEvent)

Ingest a real-time event.

Events should be delivered roughly in time order; out-of-order events within the current bucket are merged correctly, but events older than the window start are silently dropped.

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

Return a snapshot of all active buckets (oldest first).

pub fn concurrent_viewers(&self) -> u32

Current instantaneous concurrent viewer count.

pub fn window_bitrate_stats(&self) -> (f64, u64, u64)

Aggregate bitrate statistics across all active buckets.

Returns (avg_bps, min_bps, max_bps). Returns (0.0, 0, 0) if no bitrate samples exist in the window.

pub fn window_buffer_events(&self) -> u32

Total buffer events in the current window.

pub fn window_peak_concurrent(&self) -> u32

Peak concurrent viewers across all active buckets.

Trait Implementations

impl Debug for SlidingWindowAggregator

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

Formats the value using the given formatter.