Struct ethers_providers::RetryClient
source · pub struct RetryClient<T>{ /* private fields */ }
Expand description
RetryClient presents as a wrapper around JsonRpcClient that will retry requests based with an exponential backoff and filtering based on RetryPolicy.
The RetryPolicy
, mainly for rate-limiting errors, can be adjusted for specific applications,
endpoints. In addition to the RetryPolicy
errors due to connectivity issues, like timed out
connections or responses in range 5xx
can be retried separately.
§Example
use ethers_providers::{Http, RetryClient, RetryClientBuilder, HttpRateLimitRetryPolicy};
use std::time::Duration;
use url::Url;
let http = Http::new(Url::parse("http://localhost:8545").unwrap());
let client = RetryClientBuilder::default()
.rate_limit_retries(10)
.timeout_retries(3)
.initial_backoff(Duration::from_millis(500))
.build(http, Box::new(HttpRateLimitRetryPolicy::default()));
Implementations§
source§impl<T> RetryClient<T>
impl<T> RetryClient<T>
sourcepub fn new(
inner: T,
policy: Box<dyn RetryPolicy<T::Error>>,
max_retry: u32,
initial_backoff: u64
) -> Self
pub fn new( inner: T, policy: Box<dyn RetryPolicy<T::Error>>, max_retry: u32, initial_backoff: u64 ) -> Self
Creates a new RetryClient
that wraps a client and adds retry and backoff support
§Example
use ethers_providers::{Http, RetryClient, HttpRateLimitRetryPolicy};
use std::time::Duration;
use url::Url;
let http = Http::new(Url::parse("http://localhost:8545").unwrap());
let backoff_timeout = 3000; // in ms
let max_retries = 10;
let client = RetryClient::new(http, Box::new(HttpRateLimitRetryPolicy::default()), max_retries, backoff_timeout);
sourcepub fn set_compute_units(&mut self, cpus: u64) -> &mut Self
pub fn set_compute_units(&mut self, cpus: u64) -> &mut Self
Sets the free compute units per second limit.
This is the maximum number of weighted request that can be handled per second by the endpoint before rate limit kicks in.
This is used to guesstimate how long to wait until to retry again
Trait Implementations§
source§impl<T> Debug for RetryClient<T>
impl<T> Debug for RetryClient<T>
source§impl<T> JsonRpcClient for RetryClient<T>
impl<T> JsonRpcClient for RetryClient<T>
§type Error = RetryClientError
type Error = RetryClientError
A JSON-RPC Error
Auto Trait Implementations§
impl<T> !RefUnwindSafe for RetryClient<T>
impl<T> Send for RetryClient<T>
impl<T> Sync for RetryClient<T>
impl<T> Unpin for RetryClient<T>where
T: Unpin,
impl<T> !UnwindSafe for RetryClient<T>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more