Struct AggregatorConfig

pub struct AggregatorConfig {
    pub bucket_interval: u32,
    pub aggregator_size: u32,
    pub initial_delay: u32,
    pub max_secs_in_past: u64,
    pub max_secs_in_future: u64,
    pub max_project_key_bucket_bytes: Option<u64>,
    pub max_total_bucket_bytes: Option<u64>,
    pub flush_partitions: Option<u32>,
    pub flush_batching: FlushBatching,
}

Parameters used by the crate::aggregator::Aggregator.

Fields

bucket_interval: u32

Determines the wall clock time interval for buckets in seconds.

Defaults to 10 seconds. Every metric is sorted into a bucket of this size based on its timestamp. This defines the minimum granularity with which metrics can be queried later.

aggregator_size: u32

The aggregator size.

This determines how many individual bucket intervals, are stored in the aggregator. Increasing this number will add additional delay for backdated and future buckets.

Defaults to: 1.

initial_delay: u32

The initial delay in seconds to wait before flushing a bucket.

Defaults to 30 seconds. Before sending an aggregated bucket, this is the time Relay waits for buckets that are being reported in real time.

max_secs_in_past: u64

The age in seconds of the oldest allowed bucket timestamp.

Defaults to 5 days.

max_secs_in_future: u64

The time in seconds that a timestamp may be in the future.

Defaults to 1 minute.

max_project_key_bucket_bytes: Option<u64>

Maximum amount of bytes used for metrics aggregation per project key.

Similar measuring technique to Self::max_total_bucket_bytes, but instead of a global/process-wide limit, it is enforced per project key.

Defaults to None, i.e. no limit.

max_total_bucket_bytes: Option<u64>

Maximum amount of bytes used for metrics aggregation.

When aggregating metrics, Relay keeps track of how many bytes a metric takes in memory. This is only an approximation and does not take into account things such as pre-allocation in hashmaps.

Defaults to None, i.e. no limit.

flush_partitions: Option<u32>

The number of logical partitions that can receive flushed buckets.

flush_batching: FlushBatching

The batching mode for the flushing of the aggregator.

Batching is applied via shifts to the flushing time that is determined when the first bucket is inserted. Thanks to the shifts, Relay is able to prevent flushing all buckets from a bucket interval at the same time.

For example, the aggregator can choose to shift by the same value all buckets within a given partition, effectively allowing all the elements of that partition to be flushed together.

Trait Implementations

impl Clone for AggregatorConfig

fn clone(&self) -> AggregatorConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AggregatorConfig

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

Formats the value using the given formatter.

impl Default for AggregatorConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AggregatorConfig

where AggregatorConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AggregatorConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.