Struct CompositeAggregator 

pub struct CompositeAggregator { /* private fields */ }

A composite aggregator that runs multiple aggregations in parallel

This is useful when you want to compute multiple statistics at once (e.g., count, avg, p95, stddev) without making multiple passes over the data.

Examples

use processor::aggregation::{CompositeAggregator, AggregationResult};

let mut composite = CompositeAggregator::new();
composite.add_count("request_count");
composite.add_avg("avg_latency");
composite.add_p95("p95_latency");
composite.add_stddev("stddev_latency");

// Feed values
for latency in vec![100.0, 150.0, 200.0, 250.0, 300.0] {
    composite.update(latency).unwrap();
}

// Get all results
let results = composite.finalize().unwrap();
println!("Count: {}", results.get_count("request_count").unwrap());
println!("Avg: {}", results.get_value("avg_latency").unwrap());
println!("P95: {}", results.get_value("p95_latency").unwrap());
println!("StdDev: {}", results.get_value("stddev_latency").unwrap());

Implementations

impl CompositeAggregator

pub fn new() -> Self

Create a new composite aggregator

pub fn add_count(&mut self, name: impl Into<String>) -> &mut Self

Add a count aggregation

pub fn add_sum(&mut self, name: impl Into<String>) -> &mut Self

Add a sum aggregation

pub fn add_avg(&mut self, name: impl Into<String>) -> &mut Self

Add an average aggregation

pub fn add_min(&mut self, name: impl Into<String>) -> &mut Self

Add a min aggregation

pub fn add_max(&mut self, name: impl Into<String>) -> &mut Self

Add a max aggregation

pub fn add_percentile( &mut self, name: impl Into<String>, percentile: f64, ) -> Result<&mut Self>

Add a percentile aggregation

pub fn add_p50(&mut self, name: impl Into<String>) -> &mut Self

Add a p50 (median) aggregation

pub fn add_p95(&mut self, name: impl Into<String>) -> &mut Self

Add a p95 aggregation

pub fn add_p99(&mut self, name: impl Into<String>) -> &mut Self

Add a p99 aggregation

pub fn add_stddev(&mut self, name: impl Into<String>) -> &mut Self

Add a standard deviation aggregation

pub fn update(&mut self, value: f64) -> Result<()>

Update all aggregations with a new value

pub fn update_batch(&mut self, values: &[f64]) -> Result<()>

Update all aggregations with multiple values

pub fn finalize(&self) -> Result<AggregationResult>

Compute final results for all aggregations

pub fn reset(&mut self)

Reset all aggregations to initial state

pub fn len(&self) -> usize

Get the number of aggregations

pub fn is_empty(&self) -> bool

Check if there are no aggregations

Trait Implementations

impl Debug for CompositeAggregator

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

Formats the value using the given formatter.

impl Default for CompositeAggregator

fn default() -> Self

Returns the “default value” for a type.