Struct BackoffService 

pub struct BackoffService<P, S, B> { /* private fields */ }

A service for the retrying of a call with back offs.

This service adds the backoff wrapper to the request so that the inner service can choose an appropriate backoff period before reattempting its service call

Implementations

impl<P, S, B> BackoffService<P, S, B>

pub fn new(policy: P, inner: S, backoff: B) -> Self

Trait Implementations

impl<P: Clone, S: Clone, B: Clone> Clone for BackoffService<P, S, B>

fn clone(&self) -> BackoffService<P, S, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P, S, B, Req> Service<Req> for BackoffService<P, S, B>

where P: Policy<Req, S::Response, S::Error> + Clone, B: BackoffStrategy, S: Service<Req> + Clone,

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 = ResponseFuture<BackoffPolicy<P>, BackoffInnerService<S, B>, BackoffRequest<Req>>

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: Req) -> Self::Future

Process the request and return the response asynchronously.