Struct ProviderPool 

pub struct ProviderPool { /* private fields */ }

A thread-safe pool of providers indexed by chain

The pool uses read-write locks for efficient concurrent access:

• Multiple readers can access providers simultaneously
• Writers acquire exclusive access when adding new providers

Thread Safety

The pool is safe to share across threads via Arc<ProviderPool> or by storing it in a static variable with LazyLock.

Implementations

impl ProviderPool

pub fn new() -> Self

Create a new empty provider pool

pub fn with_defaults(rate_limit: Option<u32>) -> Self

Create a pool with default rate limit for new providers

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

Set the default per-request timeout used when an endpoint does not override its own.

pub fn from_endpoints( endpoints: Vec<ChainEndpoint>, rate_limit: Option<u32>, ) -> Result<Self, RpcError>

Create a pool from a list of chain endpoints

Errors

Returns an error if any endpoint URL is invalid

pub fn add( &self, chain: NamedChain, url: &str, rate_limit: Option<u32>, ) -> Result<(), RpcError>

Add a provider for a specific chain

If a provider already exists for this chain, it will be replaced.

Arguments

• chain - The chain to add the provider for
• url - The RPC endpoint URL
• rate_limit - Optional rate limit in requests per second

The per-request timeout is taken from the pool’s default (see with_default_timeout). Use add_endpoint to set a per-chain timeout or minimum-delay pacing.

Errors

Returns an error if the URL is invalid

pub fn add_endpoint(&self, endpoint: &ChainEndpoint) -> Result<(), RpcError>

Add a chain endpoint to the pool.

Uses the endpoint’s rate_limit, timeout, and min_delay when set, otherwise falls back to the pool defaults.

Errors

Returns an error if the endpoint URL is invalid.

pub fn get(&self, chain: NamedChain) -> Option<PooledProvider>

Get a provider for a specific chain

Returns None if no provider is configured for the chain.

pub fn get_or_add( &self, chain: NamedChain, url: &str, rate_limit: Option<u32>, ) -> Result<PooledProvider, RpcError>

Get a provider for a chain, or add it if not present

This is useful for lazy initialization of providers.

Errors

Returns an error if the URL is invalid and the provider needs to be created

pub fn remove(&self, chain: NamedChain) -> Option<PooledProvider>

Remove a provider from the pool

Returns the removed provider if it existed.

pub fn contains(&self, chain: NamedChain) -> bool

Check if a provider exists for a chain

pub fn len(&self) -> usize

Get the number of providers in the pool

pub fn is_empty(&self) -> bool

Check if the pool is empty

pub fn chains(&self) -> Vec<NamedChain>

Get all configured chains

pub fn clear(&self)

Clear all providers from the pool

Trait Implementations

impl Debug for ProviderPool

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

Formats the value using the given formatter.

impl Default for ProviderPool

fn default() -> ProviderPool

Returns the “default value” for a type.