Struct Limits 

#[non_exhaustive]
pub struct Limits { /* private fields */ }

Limits on batch sizes, queueing and concurrency, applied per key.

New items are rejected when the batch queue for their key is full: max_batch_queue_size batches are queued, and the newest batch already contains max_batch_size items.

max_key_concurrency * max_batch_size is the maximum number of items that can be processed concurrently for a key, and max_batch_queue_size * max_batch_size is the maximum number of items that can be queued for a key.

Implementations

impl Limits

pub fn builder() -> LimitsBuilder

Create new limits.

Panics

Panics if any of the limits are zero.

Trait Implementations

impl Clone for Limits

fn clone(&self) -> Limits

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Limits

impl Debug for Limits

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

Formats the value using the given formatter.

impl Default for Limits

fn default() -> Self

Returns the “default value” for a type.

impl Display for Limits

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

Formats the value using the given formatter.