Skip to main content

BatchingSupport

Trait BatchingSupport 

Source
pub trait BatchingSupport {
    // Required methods
    fn batch_size(&self) -> usize;
    fn set_batch_size(&mut self, size: usize);
    fn flush_interval(&self) -> Duration;
    fn set_flush_interval(&mut self, interval: Duration);
    fn force_flush(&self) -> ObservabilityResult<()>;
}
Expand description

Trait for plugins that support batching

Required Methods§

Source

fn batch_size(&self) -> usize

Get the current batch size

Source

fn set_batch_size(&mut self, size: usize)

Set the batch size

Source

fn flush_interval(&self) -> Duration

Get the flush interval

Source

fn set_flush_interval(&mut self, interval: Duration)

Set the flush interval

Source

fn force_flush(&self) -> ObservabilityResult<()>

Force flush all batched data

Implementors§