Enum exc_core::retry::RetryPolicy

pub enum RetryPolicy<T, U, F = ()> {
    On {
        f: F,
        times: usize,
        max_secs: u64,
    },
    Never(PhantomData<fn() -> (T, U)>),
}

Retry Policy.

Variants

On

Fields

f: F

Error filter.

times: usize

Retry times.

max_secs: u64

Max secs to wait.

On.

Never(PhantomData<fn() -> (T, U)>)

Never.

Implementations

impl<T, U, F> RetryPolicy<T, U, F>

pub fn never() -> Self

Never retry.

pub fn retry_on<E, F2>(self, f: F2) -> RetryPolicy<T, U, F2>where
    F2: Fn(&E) -> bool + Send + 'static + Clone,

Retry on.

pub fn retry_on_with_max_wait_secs<E, F2>(
    self,
    f: F2,
    secs: u64
) -> RetryPolicy<T, U, F2>where
    F2: Fn(&E) -> bool + Send + 'static + Clone,

Retry on with max wait secs.

Trait Implementations

impl<T, U, F: Clone> Clone for RetryPolicy<T, U, F>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, U: Debug, F: Debug> Debug for RetryPolicy<T, U, F>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, U> Default for RetryPolicy<T, U, ()>

fn default() -> Self

Returns the “default value” for a type.

impl<T, U, E, F> Policy<T, U, E> for RetryPolicy<T, U, F>where
    T: 'static + Clone,
    U: 'static,
    F: Fn(&E) -> bool + Send + 'static + Clone,

type Future = Pin<Box<dyn Future<Output = RetryPolicy<T, U, F>> + Send + 'static, Global>>

The Future type returned by Policy::retry.

fn retry(&self, _req: &T, result: Result<&U, &E>) -> Option<Self::Future>

Check the policy if a certain request should be retried.

fn clone_request(&self, req: &T) -> Option<T>

Tries to clone a request before being passed to the inner service.

impl<T, U, F: Copy> Copy for RetryPolicy<T, U, F>