Struct ManagedPolicy

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

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

DoNotRetry can be added to the Context 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) -> Self

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> ManagedPolicy<Undefined, C, R>

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

add a backoff to this ManagedPolicy.

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

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

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

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

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

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

Trait Implementations

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

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

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

Formats the value using the given formatter.

impl Default for ManagedPolicy<Undefined, Undefined, Undefined>

fn default() -> Self

Returns the “default value” for a type.

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

where B: Backoff, C: CloneInput<State>, R: RetryRule<State, Response, Error>, State: Clone + Send + Sync + 'static, Response: Send + 'static, Error: Send + Sync + 'static,

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

Check the policy if a certain request should be retried.

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

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