Struct SumAggregator 

pub struct SumAggregator<T> { /* private fields */ }

Sum aggregator - computes the sum of all values

This aggregator computes the running sum of all values processed. Useful for tracking total latency, total cost, total tokens, etc.

Examples

use processor::aggregation::{Aggregator, SumAggregator};

let mut agg = SumAggregator::new();
agg.update(1.0).unwrap();
agg.update(2.0).unwrap();
agg.update(3.0).unwrap();

assert_eq!(agg.finalize().unwrap(), 6.0);

Implementations

impl<T: ToF64 + Clone> SumAggregator<T>

pub fn new() -> Self

Create a new sum aggregator

Trait Implementations

impl<T: ToF64 + Clone + Send + Sync + Debug> Aggregator for SumAggregator<T>

type Input = T

The type of values this aggregator accepts

type Output = f64

The type of the final aggregation result

type Accumulator = SumAccumulator

The type of the internal accumulator state (must be serializable)

fn new() -> Self

Create a new aggregator instance

fn update(&mut self, value: <Self as Aggregator>::Input) -> Result<()>

Update the aggregator with a new value

fn finalize(&self) -> Result<<Self as Aggregator>::Output>

Compute the final aggregation result

fn accumulator(&self) -> <Self as Aggregator>::Accumulator

Get the current accumulator state (for serialization/merging)

fn merge(&mut self, other: <Self as Aggregator>::Accumulator) -> Result<()>

Merge another accumulator into this one (for distributed processing)

fn reset(&mut self)

Reset the aggregator to initial state

fn count(&self) -> u64

Get the number of values processed so far

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

Update with multiple values at once

fn is_empty(&self) -> bool

Check if the aggregator has processed any values

impl<T: Clone> Clone for SumAggregator<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for SumAggregator<T>

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

Formats the value using the given formatter.

impl<T: ToF64 + Clone> Default for SumAggregator<T>

fn default() -> Self

Returns the “default value” for a type.