Struct MaxAggregator 

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

Max aggregator - tracks the maximum value seen

This aggregator tracks the maximum value across all values processed. Useful for tracking worst-case latency, maximum cost, peak usage, etc.

Examples

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

let mut agg = MaxAggregator::new();
agg.update(10.0).unwrap();
agg.update(30.0).unwrap();
agg.update(20.0).unwrap();

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

Implementations

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

pub fn new() -> Self

Create a new max aggregator

pub fn max(&self) -> Option<f64>

Get the current maximum value

Trait Implementations

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

type Input = T

The type of values this aggregator accepts

type Output = f64

The type of the final aggregation result

type Accumulator = MaxAccumulator

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 MaxAggregator<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 MaxAggregator<T>

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

Formats the value using the given formatter.

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

fn default() -> Self

Returns the “default value” for a type.