Struct backoff_tower::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

pub fn new_from_retry( retry: Retry<BackoffPolicy<P>, BackoffInnerService<S, 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 copy 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.