Enum relay_metrics::Aggregator

pub enum Aggregator {
    AcceptsMetrics(AcceptsMetrics, Sender<bool>),
    MergeBuckets(MergeBuckets),
}

Aggregator for metric buckets.

Buckets are flushed to a receiver after their time window and a grace period have passed. Metrics with a recent timestamp are given a longer grace period than backdated metrics, which are flushed after a shorter debounce delay. See AggregatorServiceConfig for configuration options.

Internally, the aggregator maintains a continuous flush cycle every 100ms. It guarantees that all elapsed buckets belonging to the same ProjectKey are flushed together.

Receivers must implement a handler for the FlushBuckets message.

Variants

AcceptsMetrics(AcceptsMetrics, Sender<bool>)

The health check message which makes sure that the service can accept the requests now.

MergeBuckets(MergeBuckets)

Merge the buckets.

Trait Implementations

impl Debug for Aggregator

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

Formats the value using the given formatter.

impl FromMessage<AcceptsMetrics> for Aggregator

type Response = AsyncResponse<bool>

The behavior declaring the return value when sending this message.

fn from_message(message: AcceptsMetrics, sender: Sender<bool>) -> Self

Converts the message into the service interface.

impl FromMessage<MergeBuckets> for Aggregator

type Response = NoResponse

The behavior declaring the return value when sending this message.

fn from_message(message: MergeBuckets, _: ()) -> Self

Converts the message into the service interface.

impl Interface for Aggregator