Struct ManagedPolicy 

pub struct ManagedPolicy<B = Undefined, C = Undefined, R = Undefined, P = Undefined> { /* private fields */ }

Available on crate features http and std only.

A managed retry Policy, which allows for an easier interface to configure retrying requests.

By default, replay preparation collects without a bound. Use Self::with_prepare_body with CollectOptions::with_max_size and/or CollectOptions::with_timeout to bound it or decline collection entirely.

DoNotRetry can be added to the Extensions of a Request to signal that the request should not be retried, regardless of the retry functionality defined.

Implementations

impl<F> ManagedPolicy<Undefined, Undefined, F>

pub fn new(retry: F) -> ManagedPolicy<Undefined, Undefined, F>

Create a new ManagedPolicy which uses the provided function to determine if a request should be retried.

The default cloning is used and no backoff is applied.

impl<C, R, P> ManagedPolicy<Undefined, C, R, P>

pub fn with_backoff<B>(self, backoff: B) -> ManagedPolicy<B, C, R, P>

add a backoff to this ManagedPolicy.

impl<B, R, P> ManagedPolicy<B, Undefined, R, P>

pub fn with_clone<C>(self, clone: C) -> ManagedPolicy<B, C, R, P>

add a cloning function to this ManagedPolicy. to determine if a request should be cloned

impl<B, C, P> ManagedPolicy<B, C, Undefined, P>

pub fn with_retry<R>(self, retry: R) -> ManagedPolicy<B, C, R, P>

add a retry function to this ManagedPolicy. to determine if a request should be retried.

impl<B, C, R> ManagedPolicy<B, C, R>

pub fn with_prepare_body<P>(self, prepare: P) -> ManagedPolicy<B, C, R, P>

Configure replay preparation before the body is read.

Return None to stream once, or collection options to prepare a replay. DoNotRetry takes precedence over this function.

Trait Implementations

impl<B, C, R, P> Clone for ManagedPolicy<B, C, R, P>

where B: Clone, C: Clone, R: Clone, P: Clone,

fn clone(&self) -> ManagedPolicy<B, C, R, P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B, C, R, P> Debug for ManagedPolicy<B, C, R, P>

where B: Debug, C: Debug, R: Debug, P: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for ManagedPolicy

fn default() -> ManagedPolicy

Returns the “default value” for a type.

impl<B, C, R, P, Response, Error> Policy<Response, Error> for ManagedPolicy<B, C, R, P>

where B: Backoff, P: PrepareBody, C: CloneInput, R: RetryRule<Request<RetryBody>, Response, Error>, Response: Send + 'static, Error: Send + 'static,

fn prepare_body( &self, parts: &Parts, is_end_stream: bool, size_hint: &SizeHint, ) -> Option<CollectOptions>

Decide whether to prepare a replay before polling the request body.

async fn retry( &self, req: Request<RetryBody>, result: Result<Response, Error>, ) -> PolicyResult<Response, Error>

Check the policy if a certain request should be retried.

fn clone_input(&self, req: &Request<RetryBody>) -> Option<Request<RetryBody>>

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