Struct backoff_tower::Backoff

pub struct Backoff<R> { /* private fields */ }

Request wrapper to track the number of retries of the request

Trait Implementations

impl<P, Req, Res, Err> Policy<Backoff<Req>, Res, Err> for BackoffPolicy<P>where P: Policy<Req, Res, Err>,

type Future = IntoBackOffPolicyFut<<P as Policy<Req, Res, Err>>::Future>

The Future type returned by Policy::retry.

fn retry( &self, req: &Backoff<Req>, result: Result<&Res, &Err> ) -> Option<Self::Future>

Check the policy if a certain request should be retried.

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

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

impl<S, B, Req> Service<Backoff<Req>> for BackoffInnerService<S, B>where S: Service<Req>, B: BackoffStrategy,

type Response = <S as Service<Req>>::Response

Responses given by the service.

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

Errors produced by the service.

type Future = BackoffFut<<S as Service<Req>>::Future>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Backoff<Req>) -> Self::Future

Process the request and return the response asynchronously.