Enum batch_aint_one::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.

Will process as many batches concurrently as the limit allows. When concurrency is maximised, as soon as a batch finishes the next batch will start. When concurrency is limited to 1, it will run batches serially.

Size

Process the batch when it reaches the maximum size.

Duration(Duration, OnFull)

Process the batch a given duration after it was created.

Trait Implementations

impl Debug for BatchingPolicy

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

Formats the value using the given formatter.