Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff_ms: u64,
    pub strategy: BackoffStrategy,
}

Fields

max_attempts: u32

backoff_ms: u64

strategy: BackoffStrategy

Implementations

impl RetryPolicy

pub fn new( max_attempts: u32, backoff_ms: u64, strategy: BackoffStrategy, ) -> Self

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

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

Run f up to max_attempts times, each under timeout.

• The first Ok is returned immediately.
• Err is retained as the last error and retried.
• A timeout is recorded and retried (no error value is produced by a timeout).

If attempts are exhausted with a captured handler error, that error is returned as RetryError::Exhausted. If they are exhausted with only timeouts (or max_attempts == 0), RetryError::TimedOut is returned. This method never panics.

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.