Struct StreamAnalytics 

pub struct StreamAnalytics { /* private fields */ }

Stream analytics helper for complex aggregations

Implementations

impl StreamAnalytics

pub fn new(cache_ttl_ms: u64) -> Self

Create new stream analytics instance

pub fn aggregate_cached( &mut self, key: &str, window: &TimeWindow, aggregator: &Aggregator, current_time: u64, ) -> AggregationResult

Perform cached aggregation

pub fn moving_average( &self, windows: &[TimeWindow], field: &str, window_count: usize, ) -> Option<f64>

Calculate moving average over multiple windows

pub fn detect_anomalies( &self, windows: &[TimeWindow], field: &str, threshold: f64, ) -> Vec<String>

Detect anomalies using z-score

pub fn calculate_trend( &self, windows: &[TimeWindow], field: &str, ) -> TrendDirection

Calculate trend direction

Trait Implementations

impl Debug for StreamAnalytics

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

Formats the value using the given formatter.