Struct RetryLayer 

pub struct RetryLayer<E, Sink = NullSink> { /* private fields */ }

Tower-native retry layer with optional telemetry.

Implementations

impl<E> RetryLayer<E, NullSink>

where E: Error + Send + Sync + 'static,

pub fn new( max_attempts: usize, backoff: Backoff, jitter: Jitter, should_retry: Arc<dyn Fn(&E) -> bool + Send + Sync>, sleeper: Arc<dyn Sleeper>, ) -> Result<Self, BuildError>

Create a new retry layer with explicit configuration and no telemetry.

Most users should use RetryPolicy::builder() instead.

Errors

Returns error if max_attempts is zero.

impl<E, Sink> RetryLayer<E, Sink>

where E: Error + Send + Sync + 'static, Sink: Clone,

pub fn with_sink<NewSink>(self, sink: NewSink) -> RetryLayer<E, NewSink>

where NewSink: Clone,

Attach a telemetry sink to this retry layer.

Trait Implementations

impl<E, Sink> Clone for RetryLayer<E, Sink>

where Sink: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, E, Sink> Layer<S> for RetryLayer<E, Sink>

where E: Error + Send + Sync + 'static, Sink: Clone,

type Service = RetryService<S, E, Sink>

The wrapped service

fn layer(&self, service: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.