Struct BatchPolicy 

pub struct BatchPolicy {
    pub max_changes: usize,
    pub max_delay: Duration,
}

How the worker groups changes into one sink flush.

Batching trades a little latency for far fewer round-trips: up to max_changes changes (or whatever has arrived after max_delay, whichever comes first) are buffered and flushed together. max_changes: 1 reproduces the original flush-per-change behavior.

Acks respect the batch boundary — see the module docs. The source ack for a change is confirmed only after the flush that made its documents durable, so at-least-once delivery holds regardless of batch size.

Fields

max_changes: usize

Flush once this many changes have accumulated. Clamped to at least 1.

max_delay: Duration

Flush a partial batch this long after its first change, so a trickle of changes still lands promptly instead of waiting for a full batch.

Trait Implementations

impl Clone for BatchPolicy

fn clone(&self) -> BatchPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BatchPolicy

impl Debug for BatchPolicy

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

Formats the value using the given formatter.

impl Default for BatchPolicy

fn default() -> Self

Returns the “default value” for a type.