Struct AggregatedMetricsProcessor 

pub struct AggregatedMetricsProcessor;

Aggregated metrics processor.

This processor maintains a map of aggregated metrics, where each metric is represented by its context (name and tags), and the aggregated value of the metric. Counters, gauges, and histograms are supported; all other metric types are ignored.

Aggregation follows the following rules:

• Counters are summed together.
• Gauges are represented by the latest value (by timestamp).
• Histograms are merged: per-bucket counts, sum, and total count are summed.

Aggregated values have no concept of “points” – specific values at a specific timestamp – or multiple data points: each metric simply has a single value that represents the aggregated amount since the processor was created.

Trait Implementations

impl Clone for AggregatedMetricsProcessor

fn clone(&self) -> AggregatedMetricsProcessor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Processor for AggregatedMetricsProcessor

type Input = Event

The type of input to the processor.

type State = AggregatedMetricsState

The state that the processor acts on.

fn build_initial_state(&self) -> Self::State

Builds the initial state for the processor.

fn process(&self, input: Self::Input, state: &Self::State)

Processes the input, potentially updating the reflector state.