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() -> RetryPolicy<T, U, F>

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 for RetryPolicy<T, U, F>

where F: Clone,

fn clone(&self) -> RetryPolicy<T, U, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

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

where T: Debug, U: Debug, F: Debug,

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

Formats the value using the given formatter.

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

fn default() -> RetryPolicy<T, U>

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>>

The Future type returned by Policy::retry.

fn retry( &self, _req: &T, result: Result<&U, &E> ) -> Option<<RetryPolicy<T, U, F> as Policy<T, U, E>>::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 for RetryPolicy<T, U, F>

where F: Copy,