Struct BatchConfig 

pub struct BatchConfig {
    pub window: Duration,
    pub max: usize,
    pub channel_capacity: usize,
}

Batching policy for watch_applied.

A flush fires when either bound is hit, whichever comes first: window time has elapsed since the batch opened, or max updates have accumulated. The window amortizes the cost of apply (e.g. one route-table clone per flush instead of one per update); max caps memory and latency when updates arrive faster than the window.

Fields

window: Duration

Maximum time a batch stays open before being flushed.

max: usize

Maximum number of parsed updates in a batch before forcing a flush.

channel_capacity: usize

Capacity of the internal watch-task → main-loop channel. When the main loop falls behind (slow apply, blocking store flush), a full channel backpressures the watch task — that is the design — but during initial state-sync hydration of a large bucket the channel can fill faster than the window flushes, making this the effective batch boundary rather than max. Tune it together with max for high-fanout hydration; clamped to a minimum of 1.

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 Copy for BatchConfig

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

10 ms / 100 updates — the de-facto default every hand-rolled caller already used, lifted into one place — and the 256-deep channel the loop always allocated, now tunable.