Struct PollWorkerConfig 

pub struct PollWorkerConfig {
    pub concurrency: usize,
    pub idle_backoff: Duration,
    pub error_backoff: Duration,
}

通用轮询型后台任务参数（与具体 Broker 无关）

用于 MQ 消费者、定时轮询任务等

Fields

concurrency: usize

同时处理中的任务上限（如 Kafka 消费并发）

idle_backoff: Duration

fetch 无数据时的休眠间隔

error_backoff: Duration

fetch 失败后的退避间隔

Implementations

impl PollWorkerConfig

pub fn new() -> Self

创建默认配置

pub fn with_concurrency(self, concurrency: usize) -> Self

设置并发度

pub fn with_idle_backoff(self, d: Duration) -> Self

设置空闲退避时间

pub fn with_error_backoff(self, d: Duration) -> Self

设置错误退避时间

Trait Implementations

impl Clone for PollWorkerConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PollWorkerConfig

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

Formats the value using the given formatter.

impl Default for PollWorkerConfig

fn default() -> Self

Returns the “default value” for a type.