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.

Trait Implementations

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

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

Returns a copy 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 + Debug + '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.