Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub base_delay: Duration,
    pub max_delay: Duration,
    pub jitter_factor: f64,
    /* private fields */
}

Configuration for retry behavior with exponential backoff support.

Fields

max_attempts: u32

base_delay: Duration

max_delay: Duration

jitter_factor: f64

Implementations

impl RetryPolicy

pub fn new(max_attempts: u32, delay_ms: u64) -> Self

Fixed delay retry (legacy).

pub fn with_exponential_backoff( max_attempts: u32, base_delay: Duration, max_delay: Duration, jitter_factor: f64, ) -> Self

Exponential backoff retry with jitter.

pub fn with_retryable_predicate(self, predicate: fn(&str) -> bool) -> Self

Sets a predicate function to determine if an error should trigger a retry.

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

Computes the delay for a given attempt number.

This method contains self-contained exponential backoff logic (base_delay * 2^attempt, capped at max_delay, with optional jitter). There is a separate super::ExponentialBackoff type elsewhere in the resilience module, but this implementation is intentionally kept inline: RetryPolicy needs tight control over attempt numbering and jitter that would not benefit from an extra layer of indirection.

pub async fn execute<F, Fut, T, E>(&self, operation: F) -> Result<T, E>

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

Executes an async operation with retry logic.

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.