Struct ReconnectPolicy 

pub struct ReconnectPolicy {
    pub max_retries: u32,
    pub initial_delay_ms: u64,
    pub max_delay_ms: u64,
    pub multiplier: f64,
}

重连策略（指数退避）

用于 QueueWrapper::with_reconnect，在网络错误（MqError::Connection）时自动重试。

• max_retries：最大重试次数（默认 5）
• initial_delay_ms：初始延迟毫秒（默认 100）
• max_delay_ms：最大延迟毫秒（默认 10000）
• multiplier：退避倍数（默认 2.0，指数退避）

Fields

max_retries: u32

最大重试次数（默认 5）

initial_delay_ms: u64

初始延迟（毫秒，默认 100）

max_delay_ms: u64

最大延迟（毫秒，默认 10000）

multiplier: f64

退避倍数（默认 2.0，指数退避）

Implementations

impl ReconnectPolicy

pub fn new() -> Self

pub fn next_delay(&self, attempt: u32) -> Duration

计算第 attempt 次重试的延迟（指数退避，封顶 max_delay_ms）

• attempt = 0：返回 initial_delay_ms
• attempt = 1：返回 initial_delay_ms * multiplier
• 以此类推，但不超过 max_delay_ms

使用 max(0.0) 防止负数 multiplier 导致负延迟。

Trait Implementations

impl Clone for ReconnectPolicy

fn clone(&self) -> ReconnectPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReconnectPolicy

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

Formats the value using the given formatter.

impl Default for ReconnectPolicy

fn default() -> Self

Returns the “default value” for a type.