Struct JitteredRetryPolicy

Source
pub struct JitteredRetryPolicy<T: RetryPolicy> { /* private fields */ }
Expand description

Decorates the given RetryPolicy and adds jitter (random delay) to it. This can make retries more spread out and less likely to all fail at once.

Trait Implementations§

Source§

impl<T: RetryPolicy> RetryPolicy for JitteredRetryPolicy<T>

Source§

type E = <T as RetryPolicy>::E

The error type returned by the operation in retry.
Source§

fn next_delay(&self, context: &RetryContext<'_, Self::E>) -> Option<Duration>

Returns the duration to wait before trying the next attempt. context represents the context of a retry operation. Read more
Source§

fn with_max_attempts(self, max_attempts: u32) -> MaxAttemptsRetryPolicy<Self>

Returns a new RetryPolicy that respects the given maximum attempts.
Source§

fn with_max_total_delay( self, max_total_delay: Duration, ) -> MaxTotalDelayRetryPolicy<Self>

Returns a new RetryPolicy that respects the given total delay.
Source§

fn with_max_jitter(self, max_jitter: Duration) -> JitteredRetryPolicy<Self>

Returns a new RetryPolicy that adds jitter(random delay) to underlying policy.
Source§

fn skip_retry_on_error<F>(self, function: F) -> FilteredRetryPolicy<Self, F>
where F: 'static + Fn(&Self::E) -> bool,

Skips retrying on errors that evaluate to true after applying function.

Auto Trait Implementations§

§

impl<T> Freeze for JitteredRetryPolicy<T>
where T: Freeze,

§

impl<T> RefUnwindSafe for JitteredRetryPolicy<T>
where T: RefUnwindSafe,

§

impl<T> Send for JitteredRetryPolicy<T>
where T: Send,

§

impl<T> Sync for JitteredRetryPolicy<T>
where T: Sync,

§

impl<T> Unpin for JitteredRetryPolicy<T>
where T: Unpin,

§

impl<T> UnwindSafe for JitteredRetryPolicy<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,