Struct RobustProvider 

pub struct RobustProvider<N: Network = Ethereum> { /* private fields */ }

Provider wrapper with built-in retry and timeout mechanisms.

This wrapper around Alloy providers automatically handles retries, timeouts, and error logging for RPC calls.

Implementations

impl<N: Network> RobustProvider<N>

pub fn primary(&self) -> &RootProvider<N>

Get a reference to the primary provider

pub async fn get_block_by_number( &self, number: BlockNumberOrTag, ) -> Result<N::BlockResponse, Error>

Fetch a block by BlockNumberOrTag with retry and timeout.

This is a wrapper function for Provider::get_block_by_number.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).
• Error::BlockNotFound - if the block with the specified number/tag is not available. This is verified on Anvil, Reth, and Geth; other clients may surface this condition as Error::RpcError.

pub async fn get_block(&self, id: BlockId) -> Result<N::BlockResponse, Error>

Fetch a block number by BlockId with retry and timeout.

This is a wrapper function for Provider::get_block.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).
• Error::BlockNotFound - if the block for the specified identifier is not available. This is verified on Anvil, Reth, and Geth; other clients may surface this condition as Error::RpcError.

pub async fn get_block_number(&self) -> Result<BlockNumber, Error>

Fetch the latest block number with retry and timeout.

This is a wrapper function for Provider::get_block_number.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).

pub async fn get_block_number_by_id( &self, block_id: BlockId, ) -> Result<BlockNumber, Error>

Get the block number for a given block identifier.

This is a wrapper function for Provider::get_block_number_by_id.

Arguments

• block_id - The block identifier to fetch the block number for.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).
• Error::BlockNotFound - if the block for the specified identifier is not available. This is verified on Anvil, Reth, and Geth; other clients may surface this condition as Error::RpcError.

pub async fn get_latest_confirmed( &self, confirmations: u64, ) -> Result<u64, Error>

Fetch the latest confirmed block number with retry and timeout.

This method fetches the latest block number and subtracts the specified number of confirmations to get a “confirmed” block number.

Arguments

• confirmations - The number of block confirmations to wait for. The returned block number will be latest_block - confirmations.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).

pub async fn get_block_by_hash( &self, hash: BlockHash, ) -> Result<N::BlockResponse, Error>

Fetch a block by BlockHash with retry and timeout.

This is a wrapper function for Provider::get_block_by_hash.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).
• Error::BlockNotFound - if the block with the specified hash is not available. This is verified on Anvil, Reth, and Geth; other clients may surface this condition as Error::RpcError.

pub async fn get_logs(&self, filter: &Filter) -> Result<Vec<Log>, Error>

Fetch logs for the given Filter with retry and timeout.

This is a wrapper function for Provider::get_logs.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).

pub async fn subscribe_blocks(&self) -> Result<RobustSubscription<N>, Error>

Subscribe to new block headers with automatic failover and reconnection.

Returns a RobustSubscription that automatically:

• Handles connection errors by switching to fallback providers
• Detects and recovers from lagged subscriptions
• Periodically attempts to reconnect to the primary provider

This is a wrapper function for Provider::subscribe_blocks.

Errors

• Error::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• Error::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).

pub async fn try_operation_with_failover<T: Debug, F, Fut>( &self, operation: F, require_pubsub: bool, ) -> Result<T, CoreError>

where F: Fn(RootProvider<N>) -> Fut, Fut: Future<Output = Result<T, RpcError<TransportErrorKind>>>,

Execute operation with exponential backoff and a total timeout.

Wraps the retry logic with tokio::time::timeout so the entire operation (including time spent inside the RPC call) cannot exceed call_timeout.

If the timeout is exceeded and fallback providers are available, it will attempt to use each fallback provider in sequence.

If require_pubsub is true, providers that don’t support pubsub will be skipped.

Errors

• CoreError::RpcError - if no fallback providers succeeded; contains the last error returned by the last provider attempted on the last retry.
• CoreError::Timeout - if the overall operation timeout elapses (i.e. exceeds call_timeout).

Trait Implementations

impl<N: Clone + Network> Clone for RobustProvider<N>

fn clone(&self) -> RobustProvider<N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N: Debug + Network> Debug for RobustProvider<N>

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

Formats the value using the given formatter.

impl<N: Network> IntoRootProvider<N> for RobustProvider<N>

async fn into_root_provider(self) -> Result<RootProvider<N>, Error>

Convert self into a RootProvider.