Struct RobustProviderBuilder 

pub struct RobustProviderBuilder<N: Network, P: IntoRootProvider<N>> { /* private fields */ }

Builder for constructing a RobustProvider.

Use this to configure timeouts, retry/backoff, and one or more fallback providers.

Implementations

impl<N: Network, P: IntoRootProvider<N>> RobustProviderBuilder<N, P>

pub fn new(provider: P) -> Self

Create a new RobustProvider with default settings.

The provided provider is treated as the primary provider. Any type implementing IntoRootProvider can be used.

pub fn fragile(provider: P) -> Self

Create a new RobustProvider with no retry attempts and only timeout set.

The provided provider is treated as the primary provider.

pub fn fallback<F: IntoRootProvider<N> + Send + 'static>( self, provider: F, ) -> Self

Add a fallback provider to the list.

Fallback providers are used when the primary provider times out or fails.

pub fn call_timeout(self, timeout: Duration) -> Self

Set the maximum timeout for RPC operations.

pub fn subscription_timeout(self, timeout: Duration) -> Self

Set the timeout for subscription operations.

This should be set higher than call_timeout to accommodate chains with slow block times. Default is DEFAULT_SUBSCRIPTION_TIMEOUT.

pub fn subscription_buffer_capacity(self, buffer_capacity: usize) -> Self

Set the subscription stream buffer capacity.

Controls the buffer capacity for subscription streams. If new blocks arrive while the stream buffer is full, a lagged error will be emitted, indicating that stream items were dropped due to the consumer not keeping pace with the stream.

Default is DEFAULT_SUBSCRIPTION_BUFFER_CAPACITY.

pub fn max_retries(self, max_retries: usize) -> Self

Set the maximum number of retry attempts.

pub fn min_delay(self, min_delay: Duration) -> Self

Set the base delay for exponential backoff retries.

pub fn reconnect_interval(self, reconnect_interval: Duration) -> Self

Set the interval for attempting to reconnect to the primary provider.

After a failover to a fallback provider, the subscription will periodically attempt to reconnect to the primary provider at this interval. Default is DEFAULT_RECONNECT_INTERVAL.

pub async fn build(self) -> Result<RobustProvider<N>, Error>

Build the RobustProvider.

Final builder method: consumes the builder and returns the built RobustProvider.

Errors

Returns an error if any of the providers fail to connect.