Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool managing multiple blockchain connections with automatic failover

Implementations

impl ConnectionPool

pub fn new(endpoints: Vec<String>, max_connections: usize) -> Self

Creates a new connection pool

Arguments

• endpoints - List of WebSocket endpoints to connect to
• max_connections - Maximum number of concurrent connections to maintain

pub async fn initialize(&self) -> Result<(), BittensorError>

Initialize the connection pool with at least one working connection

pub async fn get_healthy_client( &self, ) -> Result<Arc<OnlineClient<PolkadotConfig>>, BittensorError>

Get a healthy client from the pool, reconnecting if necessary

pub async fn reconnect_with_backoff( &self, ) -> Result<Arc<OnlineClient<PolkadotConfig>>, BittensorError>

Reconnect to endpoints with exponential backoff

pub async fn healthy_connection_count(&self) -> usize

Get the current number of healthy connections

pub async fn refresh_connections(&self) -> Result<(), BittensorError>

Force refresh all connections

pub async fn total_connections(&self) -> usize

Get total number of connections (healthy and unhealthy)

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> ConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConnectionPoolTrait for ConnectionPool

fn connections<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Arc<RwLock<Vec<Arc<OnlineClient<PolkadotConfig>>>>>> + Send + 'async_trait>>

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

fn reconnect_with_backoff<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<OnlineClient<PolkadotConfig>>, BittensorError>> + Send + 'async_trait>>

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

fn get_healthy_client<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Arc<OnlineClient<PolkadotConfig>>, BittensorError>> + Send + 'async_trait>>

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

impl Debug for ConnectionPool

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

Formats the value using the given formatter.