Struct RetryExecutor

pub struct RetryExecutor<E> { /* private fields */ }

Executor for retry operations

Implementations

impl<E> RetryExecutor<E>

where E: Error + 'static,

pub fn new_exponential() -> Self

Create a new retry executor with an exponential backoff strategy

pub fn new_linear() -> Self

Create a new retry executor with a linear backoff strategy

pub fn new_fixed(delay_ms: u64) -> Self

Create a new retry executor with a fixed backoff strategy

pub fn with_max_retries(self, max_retries: usize) -> Self

Set the maximum number of retries

pub fn with_retry_if<F>(self, predicate: F) -> Self

where F: Fn(&E) -> bool + Send + Sync + 'static,

Set a predicate to determine if an error should be retried

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

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

Execute a fallible operation with retries

pub fn retry_with_handler<F, H, T>( &self, operation: F, on_error: H, ) -> Result<T, E>

where F: FnMut() -> Result<T, E>, H: FnMut(&E, usize, Duration),

Execute a fallible operation with retries using a custom error handler