Struct BufferedBatchConfig 

pub struct BufferedBatchConfig {
    pub queue_capacity: usize,
    pub batch_size: usize,
    pub delayed_flush_after: Duration,
    pub overflow_label: &'static str,
}

Runtime buffering policy for BufferedBatchWriter.

Fields

queue_capacity: usize

Maximum number of records kept in memory before overflow records use the direct writer.

batch_size: usize

Number of queued records that triggers an immediate flush.

delayed_flush_after: Duration

Delay before flushing a partial batch.

overflow_label: &'static str

Label used in overflow warning logs.

Implementations

impl BufferedBatchConfig

pub fn new( queue_capacity: usize, batch_size: usize, delayed_flush_after: Duration, overflow_label: &'static str, ) -> Self

Creates a buffering policy.

Trait Implementations

impl Clone for BufferedBatchConfig

fn clone(&self) -> BufferedBatchConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BufferedBatchConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.