Struct BatchingPolicy 

pub struct BatchingPolicy {
    pub duration: Option<Duration>,
    pub size: Option<usize>,
}

BatchingPolicy defines common configuration items for used in batching operations such as OutputBatch modules.

Example Configuration

output:
  elasticsearch:
    batch:
      duration: 10s
      size: 500

Fields

duration: Option<Duration>

Maximum duration to wait before flushing a batch

size: Option<usize>

Maximum number of messages in a batch before flushing

Implementations

impl BatchingPolicy

pub fn effective_size(&self) -> usize

Get the effective batch size, using default (500) if not specified.

pub fn effective_duration(&self) -> Duration

Get the effective interval, using default (10 seconds) if not specified.

Trait Implementations

impl Clone for BatchingPolicy

fn clone(&self) -> BatchingPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for BatchingPolicy

fn default() -> BatchingPolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BatchingPolicy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.