Struct AggregatorServiceConfig 

pub struct AggregatorServiceConfig {
    pub aggregator: AggregatorConfig,
    pub max_name_length: usize,
    pub max_tag_key_length: usize,
    pub max_tag_value_length: usize,
    pub max_flush_bytes: usize,
}

Parameters used for metric aggregation.

Fields

aggregator: AggregatorConfig

The config used by the internal aggregator.

max_name_length: usize

The length the name of a metric is allowed to be.

Defaults to 200 bytes.

max_tag_key_length: usize

The length the tag key is allowed to be.

Defaults to 200 bytes.

max_tag_value_length: usize

The length the tag value is allowed to be.

Defaults to 200 chars.

max_flush_bytes: usize

The approximate maximum number of bytes submitted within one flush cycle.

This controls how big flushed batches of buckets get, depending on the number of buckets, the cumulative length of their keys, and the number of raw values. Since final serialization adds some additional overhead, this number is approximate and some safety margin should be left to hard limits.

Implementations

impl AggregatorServiceConfig

pub fn timestamp_range(&self) -> Range<UnixTimestamp>

Returns the valid range for metrics timestamps.

Metrics or buckets outside of this range should be discarded.

Trait Implementations

impl Clone for AggregatorServiceConfig

fn clone(&self) -> AggregatorServiceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AggregatorServiceConfig

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

Formats the value using the given formatter.

impl Default for AggregatorServiceConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AggregatorServiceConfig

where AggregatorServiceConfig: 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 AggregatorServiceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.