Struct RetryService 

pub struct RetryService<S> { /* private fields */ }

Service that implements retry logic with exponential backoff

Retries on both Err(HttpError) and Ok(Response) based on status codes. When retrying on status codes, drains response body up to configured limit to allow connection reuse.

send() returns Ok(Response) for ALL HTTP statuses after retries exhaust. send() returns Err only for transport/timeout errors.

Total Timeout (Deadline)

When total_timeout is set, the entire operation (including all retries and backoff delays) must complete within that duration. This provides a hard deadline for the caller, regardless of how many retries are configured.

Trait Implementations

impl<S: Clone> Clone for RetryService<S>

fn clone(&self) -> RetryService<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S> Service<Request<Full<Bytes>>> for RetryService<S>

where S: Service<Request<Full<Bytes>>, Response = Response<ResponseBody>, Error = HttpError> + Clone + Send + 'static, S::Future: Send,

type Response = <S as Service<Request<Full<Bytes>>>>::Response

Responses given by the service.

type Error = HttpError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<RetryService<S> as Service<Request<Full<Bytes>>>>::Response, <RetryService<S> as Service<Request<Full<Bytes>>>>::Error>> + Send>>

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: Request<Full<Bytes>>) -> Self::Future

Process the request and return the response asynchronously.