pub struct RetryClient<T>{ /* private fields */ }
Expand description
RetryClient presents as a wrapper around JsonRpcProvider 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 neo3::neo_clients::{HttpProvider, HttpRateLimitRetryPolicy, RetryClientBuilder};
use std::time::Duration;
use url::Url;
async fn demo() {
let http = HttpProvider::new(Url::parse("http://localhost:8545").unwrap()).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 neo3::neo_clients::{HttpProvider, HttpRateLimitRetryPolicy, RetryClient};
use std::time::Duration;
use url::Url;
async fn demo() {
let http = HttpProvider::new(Url::parse("http://localhost:8545").unwrap()).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> JsonRpcProvider for RetryClient<T>
impl<T> JsonRpcProvider for RetryClient<T>
Source§type Error = RetryClientError
type Error = RetryClientError
A JSON-RPC Error
Auto Trait Implementations§
impl<T> !Freeze for RetryClient<T>
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more