Struct QueueReceiveConfig

pub struct QueueReceiveConfig {
    pub poll_interval: Duration,
    pub max_wait: Option<Duration>,
    pub max_chunk_size: Option<usize>,
    pub min_chunk_size: usize,
    pub cooldown: Option<Duration>,
    pub batch_strategy: BatchStrategy,
}

Fields

poll_interval: Duration

How long to wait between polling attempts when the queue is empty

max_wait: Option<Duration>

The longest period to wait before returning an empty vec. None means wait forever

max_chunk_size: Option<usize>

The largest number of items to return per method call. None means no limit.

min_chunk_size: usize

cooldown: Option<Duration>

If an identical item is read from the queue multiple times within this many seconds, only the first one is used. None disables deduplication.

batch_strategy: BatchStrategy

How to behave when the number of items in the queue is between 0 and max_chunk_size.

Trait Implementations

impl Clone for QueueReceiveConfig

fn clone(&self) -> QueueReceiveConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueReceiveConfig

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

Formats the value using the given formatter.

impl Default for QueueReceiveConfig

fn default() -> Self

Returns the “default value” for a type.

impl From<QueueReceiveConfig> for Vec<Override>

fn from(value: QueueReceiveConfig) -> Self

Converts to this type from the input type.

impl Copy for QueueReceiveConfig