Struct ProviderPool 

pub struct ProviderPool { /* private fields */ }

Round-robin provider pool with per-provider circuit breakers.

Automatically skips unhealthy (circuit-open) providers and falls back to the next available one.

Implementations

impl ProviderPool

pub fn new( transports: Vec<Arc<dyn RpcTransport>>, config: ProviderPoolConfig, ) -> Self

Build a pool from a list of transports.

pub fn new_with_metrics( transports: Vec<Arc<dyn RpcTransport>>, config: ProviderPoolConfig, ) -> Self

Build a pool with per-provider metrics automatically created.

pub fn len(&self) -> usize

Number of providers in the pool.

pub fn is_empty(&self) -> bool

Returns true if the pool has no providers.

pub fn health_summary(&self) -> Vec<(String, HealthStatus, String)>

Returns summary of each provider’s health.

pub fn healthy_count(&self) -> usize

Number of providers whose circuit breaker allows requests.

pub fn metrics(&self) -> Vec<MetricsSnapshot>

Return metrics snapshots for all providers that have metrics enabled.

pub fn health_report(&self) -> Vec<Value>

Detailed health report for each provider as JSON-serializable values.

When per-provider metrics are available the report includes additional fields such as total_requests, success_rate, and avg_latency_ms.

Trait Implementations

impl RpcTransport for ProviderPool

fn send<'life0, 'async_trait>( &'life0 self, req: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a single JSON-RPC request and return the response.

fn health(&self) -> HealthStatus

Return the current health status of this transport.

fn url(&self) -> &str

Return the transport’s identifier (URL or name).

fn send_batch<'life0, 'async_trait>( &'life0 self, reqs: Vec<JsonRpcRequest>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JsonRpcResponse>, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a batch of JSON-RPC requests.

fn call<'life0, 'life1, 'async_trait, T>( &'life0 self, id: u64, method: &'life1 str, params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<T, TransportError>> + Send + 'async_trait>>

where Self: Sized + 'async_trait, T: 'async_trait + DeserializeOwned, 'life0: 'async_trait, 'life1: 'async_trait,

Convenience: call a method and deserialize the result.