Enum BatchingPolicy 

#[non_exhaustive]
pub enum BatchingPolicy {
    Immediate,
    Size,
    Duration(Duration, OnFull),
}

A policy controlling when batches get processed.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Immediate

Immediately process the batch if possible.

When concurrency is available, new items will be processed immediately (with a batch size of one).

When concurrency is maximised, new items will added to the next batch (up to the maximum batch size). As soon as a batch finishes the next batch will start. When concurrency is limited to 1, it will run batches serially.

Prioritises low latency.

Size

Process the batch when it reaches the maximum size.

Prioritises high batch utilisation.

Duration(Duration, OnFull)

Process the batch a given duration after it was created.

Prioritises regularity.

Trait Implementations

impl Debug for BatchingPolicy

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

Formats the value using the given formatter.