Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub initial_delay: Duration,
    pub max_delay: Duration,
    pub strategy: BackoffStrategy,
}

Configurable retry policy with back-off.

Example

use scirs2_core::concurrent::async_utils::{RetryPolicy, BackoffStrategy};
use std::time::Duration;

let policy = RetryPolicy::new(5, Duration::from_millis(10), BackoffStrategy::Exponential);
let mut attempts = 0u32;
let result = policy.retry(|| {
    attempts += 1;
    if attempts < 3 { Err("not yet") } else { Ok(42u32) }
});
assert_eq!(result.expect("should succeed"), 42);

Fields

max_attempts: u32

Maximum number of attempts (including the first).

initial_delay: Duration

Initial delay between attempts.

max_delay: Duration

Maximum delay cap.

strategy: BackoffStrategy

Back-off strategy.

Implementations

impl RetryPolicy

pub fn new( max_attempts: u32, initial_delay: Duration, strategy: BackoffStrategy, ) -> Self

Create a new retry policy.

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

Override the maximum delay cap.

pub fn retry<T, E, F>(&self, f: F) -> Result<T, E>

where F: FnMut() -> Result<T, E>,

Execute f, retrying on Err according to the policy.

Returns the first Ok result, or the last Err if all attempts fail.

pub fn retry_with_timeout<T, E, F>( &self, total_timeout: Duration, f: F, ) -> CoreResult<T>

where F: FnMut() -> Result<T, E>, E: Display,

Execute f with a per-attempt timeout.

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.