Struct BufferedBatchConfig 

pub struct BufferedBatchConfig {
    pub queue_capacity: usize,
    pub batch_size: usize,
    pub delayed_flush_after: Duration,
}

Bounded in-memory buffering policy. Zero capacities normalize to one.

Fields

queue_capacity: usize

Maximum unacknowledged batch records, including the batch currently being written.

batch_size: usize

Immediate-flush threshold and maximum records passed to a batch sink call.

delayed_flush_after: Duration

Maximum delay from the first queued record before attempting a partial batch.

Implementations

impl BufferedBatchConfig

pub const fn new( queue_capacity: usize, batch_size: usize, delayed_flush_after: Duration, ) -> Self

Creates a policy; the writer normalizes zero capacity and batch size to one.

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.

impl Copy for BufferedBatchConfig