pub trait AggregationRule { // Required methods fn aggregate(&self, events: &[StreamEvent]) -> Result<f64>; fn rule_name(&self) -> &str; }
Trait for custom aggregation rules