Enum FlushBatching

pub enum FlushBatching {
    Project,
    Bucket,
    Partition,
    None,
}

Configuration value for AggregatorConfig::flush_batching.

Variants

Project

Shifts the flush time by an offset based on the project key.

This allows buckets from the same project to be flushed together.

Bucket

Shifts the flush time by an offset based on the bucket key itself.

This allows for a completely random distribution of bucket flush times.

It should only be used in processing Relays since this flushing behavior it’s better suited for how Relay emits metrics to Kafka.

Partition

Shifts the flush time by an offset based on the partition key.

This allows buckets belonging to the same partition to be flushed together. Requires flush_partitions to be set, otherwise this will fall back to FlushBatching::Project.

It should only be used in Relays with the http.global_metrics option set since when encoding metrics via the global endpoint we can leverage partitioning.

None

Do not apply shift.

Trait Implementations

impl Clone for FlushBatching

fn clone(&self) -> FlushBatching

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FlushBatching

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

Formats the value using the given formatter.

impl Default for FlushBatching

fn default() -> FlushBatching

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FlushBatching

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FlushBatching

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for FlushBatching