Struct FallbackService 

pub struct FallbackService<S> { /* private fields */ }

The FallbackService consumes multiple transports and is able to query them in parallel, returning the first successful response.

The service ranks transports based on latency and stability metrics, and will attempt to always use the best available transports.

Implementations

impl<S: Clone> FallbackService<S>

pub fn new(transports: Vec<S>, active_transport_count: usize) -> Self

Create a new fallback service from a list of transports.

The active_transport_count parameter controls how many transports are used for requests at any one time.

Uses the default set of sequential methods (eth_sendRawTransactionSync, eth_sendTransactionSync).

pub fn new_with_sequential_methods( transports: Vec<S>, active_transport_count: usize, sequential_methods: HashSet<String>, ) -> Self

Create a new fallback service from a list of transports.

The active_transport_count parameter controls how many transports are used for requests at any one time.

Uses the given set of sequential methods (eth_sendRawTransactionSync, eth_sendTransactionSync).

pub fn append_sequential_method( self, sequential_method: impl Into<String>, ) -> Self

Inserts the sequential method into the set.

pub fn with_sequential_methods( self, sequential_methods: HashSet<String>, ) -> Self

Configures the sequential_methods parameter specifies which RPC methods require sequential execution due to non-deterministic results in parallel execution.

Trait Implementations

impl<S: Clone> Clone for FallbackService<S>

fn clone(&self) -> FallbackService<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for FallbackService<S>

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

Formats the value using the given formatter.

impl<S> Service<RequestPacket> for FallbackService<S>

where S: Service<RequestPacket, Future = TransportFut<'static>, Error = TransportError> + Send + Sync + Clone + 'static,

type Response = ResponsePacket

Responses given by the service.

type Error = RpcError<TransportErrorKind>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<ResponsePacket, RpcError<TransportErrorKind>>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: RequestPacket) -> Self::Future

Process the request and return the response asynchronously.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 24 bytes