Struct RetryExecutor 

pub struct RetryExecutor<P: RetryPolicy = AlwaysRetry> { /* private fields */ }

Available on crate feature resilience only.

Executes async operations with exponential backoff and jitter.

Implementations

impl RetryExecutor<AlwaysRetry>

pub fn new(config: RetryConfig) -> Self

Create a new retry executor with default policy.

impl<P: RetryPolicy> RetryExecutor<P>

pub fn with_policy(config: RetryConfig, policy: P) -> Self

Create a retry executor with a custom policy.

pub async fn execute<F, Fut, T, E>( &self, name: &str, f: F, ) -> Result<T, RetryError<E>>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, E>>, E: Error + 'static,

Execute an async operation with retries.

The operation will be retried according to the configuration until:

• It succeeds
• Max retries is reached
• Max elapsed time is reached
• The retry policy says not to retry

pub fn config(&self) -> &RetryConfig

Get the configuration.