Struct SwitchingTransport

pub struct SwitchingTransport {
    pub(crate) current_transport: Arc<RwLock<SingleTransport>>,
    pub(crate) urls: Arc<Vec<Url>>,
    pub(crate) opt: Arc<L1ClientOptions>,
    pub(crate) metrics: L1ClientMetrics,
    pub(crate) switch_notify: Arc<Notify>,
}

An RPC client with multiple remote (HTTP) providers.

This client utilizes one RPC provider at a time, but if it detects that the provider is in a failing state, it will automatically switch to the next provider in its list.

Fields

current_transport: Arc<RwLock<SingleTransport>>

The transport currently being used by the client

urls: Arc<Vec<Url>>

The list of configured HTTP URLs to use for RPC requests

opt: Arc<L1ClientOptions>

metrics: L1ClientMetrics

switch_notify: Arc<Notify>

Implementations

impl SwitchingTransport

fn new(opt: L1ClientOptions, urls: Vec<Url>) -> Result<Self>

Create a new SwitchingTransport with the given options and URLs

async fn wait_switch(&self)

Returns when the transport has been switched

fn options(&self) -> &L1ClientOptions

fn metrics(&self) -> &L1ClientMetrics

impl SwitchingTransport

fn switch_to( &self, next_gen: usize, current_transport: SingleTransport, ) -> SingleTransport

Trait Implementations

impl Clone for SwitchingTransport

fn clone(&self) -> SwitchingTransport

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SwitchingTransport

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

Formats the value using the given formatter.

impl Service<RequestPacket> for SwitchingTransport

SwitchingTransport is an alternative Client which by implementing tower_service::Service, traits like Transport are auto-derived, thus can be used as an alt RpcClient that can be further hooked with Provider via Provider::on_client().

type Error = RpcError<TransportErrorKind>

Errors produced by the service.

type Response = ResponsePacket

Responses given 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<StdResult<(), 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.