Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff: BackoffStrategy,
    pub timeout: Option<Duration>,
}

Retry policy for activities.

Configures automatic retry behavior including maximum attempts, backoff strategy, and optional total timeout spanning all attempts.

Example

use std::time::Duration;
use duroxide::{RetryPolicy, BackoffStrategy};

// Simple retry with defaults (3 attempts, exponential backoff)
let policy = RetryPolicy::new(3);

// Custom policy with timeout and fixed backoff
let policy = RetryPolicy::new(5)
    .with_timeout(Duration::from_secs(30))
    .with_backoff(BackoffStrategy::Fixed {
        delay: Duration::from_secs(1),
    });

Fields

max_attempts: u32

Maximum number of attempts (including initial). Must be >= 1.

backoff: BackoffStrategy

Backoff strategy between retries.

timeout: Option<Duration>

Per-attempt timeout. If set, each activity attempt is raced against this timeout. If timeout fires, returns error immediately (no retry). Retries only occur for activity errors, not timeouts. None = no timeout.

Implementations

impl RetryPolicy

pub fn new(max_attempts: u32) -> Self

Create a new retry policy with specified max attempts and default backoff.

Panics

Panics if max_attempts is 0.

pub fn with_timeout(self, timeout: Duration) -> Self

Set per-attempt timeout.

Each activity attempt is raced against this timeout. If the timeout fires before the activity completes, returns an error immediately (no retry). Retries only occur for activity errors, not timeouts.

pub fn with_backoff(self, backoff: BackoffStrategy) -> Self

Set backoff strategy.

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

Compute delay for given attempt using the configured backoff strategy.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.