Struct relay_config::aggregator::AggregatorServiceConfig
source · pub struct AggregatorServiceConfig {
pub aggregator: AggregatorConfig,
pub max_flush_bytes: usize,
pub flush_interval_ms: u64,
}
Expand description
Parameters used for metric aggregation.
Fields§
§aggregator: AggregatorConfig
The config used by the internal aggregator.
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 approxmate and some safety margin should be left to hard limits.
flush_interval_ms: u64
The flushing interval in milliseconds that determines how often the aggregator is polled for flushing new buckets.
Defaults to 100
milliseconds.
Trait Implementations§
source§impl Clone for AggregatorServiceConfig
impl Clone for AggregatorServiceConfig
source§fn clone(&self) -> AggregatorServiceConfig
fn clone(&self) -> AggregatorServiceConfig
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for AggregatorServiceConfig
impl Debug for AggregatorServiceConfig
source§impl Default for AggregatorServiceConfig
impl Default for AggregatorServiceConfig
source§impl<'de> Deserialize<'de> for AggregatorServiceConfigwhere
AggregatorServiceConfig: Default,
impl<'de> Deserialize<'de> for AggregatorServiceConfigwhere
AggregatorServiceConfig: Default,
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>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for AggregatorServiceConfig
impl RefUnwindSafe for AggregatorServiceConfig
impl Send for AggregatorServiceConfig
impl Sync for AggregatorServiceConfig
impl Unpin for AggregatorServiceConfig
impl UnwindSafe for AggregatorServiceConfig
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
Mutably borrows from an owned value. Read more
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)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)