Struct sod::RetryService

pub struct RetryService<E, S, F>
where
    F: Fn(usize) -> Result<(), RetryError<E>>,
{ /* private fields */ }

A Service, MutService, or AsyncService, which encapsulates a Retryable, blocking and retrying until a value is returned, an un-retryable error is encountered, or the idle function returns an Err.

When the underlying service’s Service::process function returns an Err, it is passed to the given Retryable, which must return an Ok(Input) to retry or an Err to return immediately. Between retries, the given idle function is called, given the attempt number as input, until Ok(Output) is returned by the underlying Service or Err is returned by the Retryable or idle function.

See the idle module for some provided idle functions.

Implementations

impl<E, S, F> RetryService<E, S, F>

where F: Fn(usize) -> Result<(), RetryError<E>>,

pub fn new(service: S, idle: F) -> Self

Trait Implementations

impl<S, F> AsyncService for RetryService<S::Error, S, F>

where S: AsyncService + Retryable<S::Input, S::Error> + Send + Sync, F: Fn(usize) -> Result<(), RetryError<S::Error>> + Send + Sync,

type Input = <S as AsyncService>::Input

type Output = <S as AsyncService>::Output

type Error = RetryError<<S as AsyncService>::Error>

fn process<'life0, 'async_trait>( &'life0 self, input: Self::Input ) -> Pin<Box<dyn Future<Output = Result<Self::Output, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<S, F> Service for RetryService<S::Error, S, F>

where S: Service + Retryable<S::Input, S::Error>, F: Fn(usize) -> Result<(), RetryError<S::Error>>,

type Input = <S as Service>::Input

type Output = <S as Service>::Output

type Error = RetryError<<S as Service>::Error>

fn process(&self, input: Self::Input) -> Result<Self::Output, Self::Error>

Process an input, producing a Result<Self::Output, Self::Error>

fn into_mut(self) -> ServiceMut<Self>

where Self: Sized,

Convert this Service into a ServiceMut which impls MutService

fn into_dyn<'a>(self) -> DynService<'a, Self::Input, Self::Output, Self::Error>

where Self: Sized + 'static,

Convert this Service into a DynService