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§
Sourcefn batch_size(&self) -> usize
fn batch_size(&self) -> usize
Get the current batch size
Sourcefn set_batch_size(&mut self, size: usize)
fn set_batch_size(&mut self, size: usize)
Set the batch size
Sourcefn flush_interval(&self) -> Duration
fn flush_interval(&self) -> Duration
Get the flush interval
Sourcefn set_flush_interval(&mut self, interval: Duration)
fn set_flush_interval(&mut self, interval: Duration)
Set the flush interval
Sourcefn force_flush(&self) -> ObservabilityResult<()>
fn force_flush(&self) -> ObservabilityResult<()>
Force flush all batched data