Struct BatchConfig 

pub struct BatchConfig {
    pub batch_size: usize,
    pub flush_interval: Duration,
    pub wait_for_full_batch: bool,
    pub processing_timeout: Duration,
}

Configuration for batch processing

Fields

batch_size: usize

Maximum number of messages per batch

flush_interval: Duration

Maximum time to wait before flushing (even if batch not full)

wait_for_full_batch: bool

Whether to wait for full batch before processing

processing_timeout: Duration

Timeout for batch processing

Implementations

impl BatchConfig

pub fn with_batch_size(self, size: usize) -> Self

Create a new batch config with custom batch size

pub fn with_flush_interval(self, interval: Duration) -> Self

Set the flush interval

pub fn wait_for_full_batch(self, wait: bool) -> Self

Configure whether to wait for full batch

pub fn with_processing_timeout(self, timeout: Duration) -> Self

Set processing timeout

Trait Implementations

impl Clone for BatchConfig

fn clone(&self) -> BatchConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchConfig

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

Formats the value using the given formatter.

impl Default for BatchConfig

fn default() -> Self

Returns the “default value” for a type.