Struct FallbackClient 

pub struct FallbackClient<T> {
    fallback_delay: Duration,
    clients: Vec<T>,
}

Fields

fallback_delay: Duration

Duration to wait on one client before starting a fallback request on the next.

When a fallback request is started, the original request will not be cancelled, and so the overall operation can complete if the original request completes shortly after the fallback request is spawned. However, in the event that the original request takes a very long time or does not complete at all, the fallback allows the overall request to complete without much delay.

clients: Vec<T>

Ordered list of clients.

Requests to the FallbackClient will be tried on each client successively, falling back down the list until success.

Implementations

impl<T> FallbackClient<T>

pub fn new(clients: Vec<T>) -> Result<Self, FallbackClientBuilderError>

pub fn builder() -> FallbackClientBuilder<T>

impl<T> FallbackClient<T>

async fn get_any<C, F>( &self, clients: impl IntoIterator<Item = C, IntoIter: Send>, get: impl Fn(C) -> F + Send, ) -> Result<F::Ok>

where C: Send + Sync, F: TryFuture<Ok: Send, Error = Error> + Send,

fn get_any_recursive<'a, C, F>( i: usize, timeout: Duration, clients: impl Iterator<Item = C> + Send + 'a, get: impl Fn(C) -> F + Send + 'a, prev_err: Option<Error>, ) -> BoxFuture<'a, Result<F::Ok>>

where C: Send + Sync + 'a, F: TryFuture<Ok: Send, Error = Error> + Send + 'a,

Trait Implementations

impl<T> Client for FallbackClient<T>

where T: Client,

Available on crate feature client only.

async fn block_height(&self) -> Result<u64>

Get the number of blocks known to be in the chain.

async fn get_leaves_in_range( &self, start: usize, end: usize, ) -> Result<Vec<LeafQueryData<SeqTypes>>>

Get all leaves in the given range [start, end).

async fn get_leaves_for_ranges( &self, ranges: &[Range<u64>], ) -> Result<Vec<LeafQueryData<SeqTypes>>>

Get the leaves the server has in the given ranges, in one request.

async fn header_proof( &self, root: u64, id: BlockId<SeqTypes>, ) -> Result<HeaderProof>

Get an inclusion proof for the requested header relative to the Merkle tree at height root.

async fn leaf_proof( &self, id: impl Into<LeafRequest> + Send, finalized: Option<u64>, ) -> Result<LeafProof>

Get a finality proof for the requested leaf.

async fn namespace_proof( &self, height: u64, namespace: NamespaceId, ) -> Result<NamespaceProof>

Get a proof for the requested namespace.

async fn namespace_proofs_in_range( &self, start: u64, end: u64, namespace: NamespaceId, ) -> Result<Vec<NamespaceProof>>

Get proofs for the requested namespace for each block in [start, end).

async fn namespaces_proofs_in_range( &self, start: u64, end: u64, namespaces: &[NamespaceId], ) -> Result<Vec<HashMap<NamespaceId, NamespaceProof>>>

Get proofs for the requested namespaces for each block in [start, end).

async fn payload_proof(&self, height: u64) -> Result<PayloadProof>

Get a proof for the requested payload.

async fn payload_proofs_in_range( &self, start: u64, end: u64, ) -> Result<Vec<PayloadProof>>

Get proofs for the payloads in [start, end).

async fn payload_proofs_for_ranges( &self, ranges: &[Range<u64>], ) -> Result<Vec<PayloadProof>>

Get payload proofs for a set of height ranges, in one request.

async fn stake_table_events( &self, epoch: EpochNumber, ) -> Result<Vec<StakeTableEvent>>

Get stake table events for the given epoch.

async fn cert2(&self, height: u64) -> Result<Option<Certificate2<SeqTypes>>>

Get the finality certificate at the given height.

impl<T: Clone> Clone for FallbackClient<T>

fn clone(&self) -> FallbackClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for FallbackClient<T>

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

Formats the value using the given formatter.