Struct BatchConfig 

pub struct BatchConfig {
    pub min_size: usize,
    pub max_size: usize,
    pub max_delay: Duration,
    pub adaptive: bool,
    pub velocity_window: Duration,
}

Batch aggregation configuration.

Fields

min_size: usize

Minimum batch size (floor for adaptive sizing). Default: 1,000 events.

max_size: usize

Maximum batch size (ceiling for adaptive sizing). Default: 10,000 events.

max_delay: Duration

Maximum time to wait before flushing a partial batch. Default: 10ms.

adaptive: bool

Enable adaptive batch sizing based on ingestion velocity. Default: true.

velocity_window: Duration

Window size for velocity calculation (adaptive mode). Default: 100ms.

Implementations

impl BatchConfig

pub const MAX_BATCH_SIZE_LIMIT: usize = 1_000_000

Upper bound on max_size. The adaptive-batching code in shard/batch.rs uses arithmetic like current_batch_size * 3 + target against max_size-clamped values; with max_size = usize::MAX the multiplication panics in debug builds and wraps in release. The default production max_size = 10_000 is far below this cap, so this is purely a hostile-config guard. Set well above any plausible workload (high_throughput ships 50_000) but well below the arithmetic-blast radius.

pub fn validate(&self) -> Result<(), ConfigError>

Validate the batch configuration.

pub fn high_throughput() -> Self

Create a high-throughput configuration optimized for Blackwell workloads.

pub fn low_latency() -> Self

Create a low-latency configuration for interactive workloads.

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.