Enum relay_metrics::aggregator::FlushBatching
source · pub enum FlushBatching {
Project,
Bucket,
Partition,
None,
}
Expand description
Configuration value for AggregatorConfig::flush_batching
.
Variants§
Project
Shifts the flush time by an offset based on the ProjectKey
.
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§
source§impl Clone for FlushBatching
impl Clone for FlushBatching
source§fn clone(&self) -> FlushBatching
fn clone(&self) -> FlushBatching
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for FlushBatching
impl Debug for FlushBatching
source§impl Default for FlushBatching
impl Default for FlushBatching
source§fn default() -> FlushBatching
fn default() -> FlushBatching
source§impl<'de> Deserialize<'de> for FlushBatching
impl<'de> Deserialize<'de> for FlushBatching
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
source§impl Serialize for FlushBatching
impl Serialize for FlushBatching
impl Copy for FlushBatching
Auto Trait Implementations§
impl Freeze for FlushBatching
impl RefUnwindSafe for FlushBatching
impl Send for FlushBatching
impl Sync for FlushBatching
impl Unpin for FlushBatching
impl UnwindSafe for FlushBatching
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Copy,
impl<T> CloneToUninit for Twhere
T: Copy,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)