Struct ConsumerConfig

pub struct ConsumerConfig {
    pub max_in_flight: i32,
    pub max_attempts: u16,
    pub dial_timeout: Duration,
    pub read_timeout: Duration,
    pub write_timeout: Duration,
    pub lookup_poll_interval: Duration,
    pub lookup_poll_jitter: f64,
    pub max_requeue_delay: Duration,
    pub default_requeue_delay: Duration,
    pub shutdown_timeout: Duration,
    pub backoff_strategy: bool,
}

Fields

max_in_flight: i32

max_attempts: u16

dial_timeout: Duration

read_timeout: Duration

write_timeout: Duration

lookup_poll_interval: Duration

lookup_poll_jitter: f64

max_requeue_delay: Duration

default_requeue_delay: Duration

shutdown_timeout: Duration

backoff_strategy: bool

是否使用指数退避策略进行重连

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> ConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerConfig

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

Formats the value using the given formatter.

impl Default for ConsumerConfig

fn default() -> Self

Returns the “default value” for a type.