Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub base_delay: Duration,
    pub max_delay: Duration,
}

Defines a policy for retrying failed operations.

Fields

max_attempts: u32

The maximum number of attempts to make.

base_delay: Duration

The base delay between retries.

max_delay: Duration

The maximum delay between retries.

Implementations

impl RetryPolicy

pub fn new(max_attempts: u32, base_delay: Duration, max_delay: Duration) -> Self

Creates a new RetryPolicy.

Arguments

• max_attempts - The maximum number of attempts.
• base_delay - The initial delay before the first retry.
• max_delay - The maximum allowed delay between retries.

pub fn fast_mailbox() -> Self

Creates a fast retry policy suitable for responsive mailbox operations.

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

Calculates an exponential backoff delay based on the attempt number.

The delay increases exponentially with each attempt, up to max_delay.

Arguments

• attempt - The current attempt number (0-indexed).

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

Calculates an exponential backoff delay with added jitter.

Jitter helps to prevent “thundering herd” problems when many clients retry simultaneously.

Arguments

• attempt - The current attempt number (0-indexed).

pub async fn retry_with_jitter<F, T, Fut>(&self, op: F) -> Result<T>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T>>,

Retries an asynchronous operation using the defined retry policy.

The operation op will be retried max_attempts times, with exponential backoff and jitter between attempts.

Arguments

• op - A closure that returns a Future representing the operation to retry.

Returns

The Result of the operation if successful, or the last error encountered.