Struct ReconnectPolicy 

pub struct ReconnectPolicy {
    pub initial_delay: Duration,
    pub max_delay: Duration,
    pub multiplier: f64,
    pub max_attempts: Option<u32>,
    pub jitter: bool,
}

Exponential-backoff policy used by TaskHubGrpcWorker when the sidecar is unavailable.

The worker applies this policy for both the initial connection attempt and every subsequent reconnect after the gRPC stream drops. On a successful connection the delay is reset to initial_delay.

Delay calculation

delay[0] = initial_delay
delay[n] = min(delay[n-1] * multiplier, max_delay) ± jitter

Jitter (when enabled) adds a uniformly-distributed ±10 % random offset to each delay, which reduces “thundering herd” reconnects in environments with many workers.

Examples

use std::time::Duration;
use dapr_durabletask::worker::ReconnectPolicy;

// Fast reconnect for development (no jitter, 2 max attempts):
let policy = ReconnectPolicy::new()
    .with_initial_delay(Duration::from_millis(200))
    .with_max_delay(Duration::from_secs(5))
    .with_multiplier(2.0)
    .with_max_attempts(2);

// Production policy with jitter:
let policy = ReconnectPolicy::new()
    .with_initial_delay(Duration::from_secs(1))
    .with_max_delay(Duration::from_secs(60))
    .with_multiplier(1.5)
    .with_jitter(true);

Fields

initial_delay: Duration

Delay before the first reconnect attempt. Defaults to 1 s.

max_delay: Duration

Upper bound on the delay between reconnect attempts. Defaults to 30 s.

multiplier: f64

Multiplier applied to the current delay after each failed attempt. Must be ≥ 1.0. Defaults to 1.5.

max_attempts: Option<u32>

Maximum number of reconnect attempts before start() returns an error. None means retry indefinitely. Defaults to None.

jitter: bool

When true, add a uniformly-distributed ±10 % random offset to each delay. Defaults to true.

Implementations

impl ReconnectPolicy

pub fn new() -> Self

Create a policy with default values.

pub fn with_initial_delay(self, delay: Duration) -> Self

Set the initial delay before the first reconnect attempt.

pub fn with_max_delay(self, max: Duration) -> Self

Set the maximum delay between reconnect attempts.

pub fn with_multiplier(self, mult: f64) -> Self

Set the backoff multiplier (must be ≥ 1.0).

pub fn with_max_attempts(self, n: u32) -> Self

Set the maximum number of reconnect attempts. None retries indefinitely.

pub fn with_jitter(self, jitter: bool) -> Self

Enable or disable ±10 % random jitter on each delay.

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.