Struct AggregateConfiguration 

pub struct AggregateConfiguration { /* private fields */ }

Aggregate transform.

Aggregates metrics into fixed-size windows, flushing them at a regular interval.

Zero-value counters

When metrics are aggregated and then flushed, they are typically removed entirely from the aggregation state. Unless they are updated again, they will not be emitted again. However, for counters, a slightly different approach is taken by tracking “zero-value” counters.

Counters are aggregated and flushed normally. However, when flushed, counters are added to a list of “zero-value” counters, and if those counters are not updated again, the transform emits a copy of the counter with a value of zero. It does this until the counter is updated again, or the zero-value counter expires (no updates), whichever comes first.

This provides a continuity in the output of a counter, from the perspective of a downstream system, when counters are otherwise sparse. The expiration period is configurable, and allows a trade-off in how sparse/infrequent the updates to counters can be versus how long it takes for counters that don’t exist anymore to actually cease to be emitted.

Implementations

impl AggregateConfiguration

pub fn from_configuration( config: &GenericConfiguration, ) -> Result<Self, GenericError>

Creates a new AggregateConfiguration from the given configuration.

pub fn with_defaults() -> Self

Creates a new AggregateConfiguration with default values.

Trait Implementations

impl<'de> Deserialize<'de> for AggregateConfiguration

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl MemoryBounds for AggregateConfiguration

fn specify_bounds(&self, builder: &mut MemoryBoundsBuilder<'_>)

Specifies the minimum and firm memory bounds for this component and its subcomponents.

impl TransformBuilder for AggregateConfiguration

fn build<'life0, 'async_trait>( &'life0 self, context: ComponentContext, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transform + Send>, GenericError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Builds an instance of the transform.

fn input_event_type(&self) -> EventType

Event type allowed as input events to this transform.

fn outputs(&self) -> &[OutputDefinition]

Event outputs exposed by this transform.