Struct Limits 

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

A policy controlling limits on batch sizes and concurrency.

New items will be rejected when both the limits have been reached.

max_key_concurrency * max_batch_size is both:

• The number of items that can be processed concurrently.
• The number of items that can be queued concurrently.

So the total number of items in the system can be up to 2 * max_key_concurrency * max_batch_size.

Implementations

impl Limits

pub fn max_batch_size(self, max: usize) -> Self

Limits the maximum size of a batch.

pub fn max_key_concurrency(self, max: usize) -> Self

Limits the maximum number of batches that can be processed concurrently for a key.

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