Struct RetryBackoffLayer

pub struct RetryBackoffLayer<P: RetryPolicy = RateLimitRetryPolicy> { /* private fields */ }

A Transport Layer that is responsible for retrying requests based on the error type. See TransportError.

TransportError: crate::error::TransportError

Implementations

impl RetryBackoffLayer

pub const fn new( max_rate_limit_retries: u32, initial_backoff: u64, compute_units_per_second: u64, ) -> Self

Creates a new retry layer with the given parameters and the default RateLimitRetryPolicy.

pub const fn with_avg_unit_cost(self, avg_cost: u64)

Set the average cost of a request. Defaults to 17 CU The cost of requests are usually weighted and can vary from 10 CU to several 100 CU, cheaper requests are more common some example alchemy weights:

• eth_getStorageAt: 17
• eth_getBlockByNumber: 16
• eth_newFilter: 20

(coming from forking mode) assuming here that storage request will be the driver for Rate limits we choose 17 as the average cost of any request

impl<P: RetryPolicy> RetryBackoffLayer<P>

pub const fn new_with_policy( max_rate_limit_retries: u32, initial_backoff: u64, compute_units_per_second: u64, policy: P, ) -> Self

Creates a new retry layer with the given parameters and RetryPolicy.

Trait Implementations

impl<P: Clone + RetryPolicy> Clone for RetryBackoffLayer<P>

fn clone(&self) -> RetryBackoffLayer<P>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Debug + RetryPolicy> Debug for RetryBackoffLayer<P>

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

Formats the value using the given formatter.

impl<S, P: RetryPolicy + Clone> Layer<S> for RetryBackoffLayer<P>

type Service = RetryBackoffService<S, P>

The wrapped service

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

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