Struct AggregationEngine 

pub struct AggregationEngine { /* private fields */ }

Real-time aggregation engine

Implementations

impl AggregationEngine

pub async fn new(config: Arc<AnalyticsConfig>) -> Result<Self>

Create a new aggregation engine

pub fn add_point( &self, metric_name: &str, value: f64, timestamp: DateTime<Utc>, _tags: HashMap<String, String>, ) -> Result<()>

Add a data point to aggregation

pub fn get_aggregated( &self, metric_name: &str, window: TimeWindow, ) -> Option<AggregatedMetric>

Get aggregated metrics for a time window

pub fn get_all_aggregated(&self, window: TimeWindow) -> Vec<AggregatedMetric>

Get all aggregated metrics for a window

pub fn reset_metric(&self, metric_name: &str)

Reset aggregation state for a metric

pub fn clear_all(&self)

Clear all aggregation data

pub fn get_stats(&self) -> AggregationStats

Get aggregation statistics