Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

A pool of connections to multiple Talos endpoints.

The pool maintains connections to multiple Talos nodes and routes requests to healthy endpoints based on the configured load balancing strategy.

Implementations

impl ConnectionPool

pub async fn new(config: ConnectionPoolConfig) -> Result<Self>

Create a new connection pool.

Errors

Returns an error if no endpoints are provided or if initial connection fails.

pub async fn get_client(&self) -> Result<TalosClient>

Get a healthy client using the configured load balancing strategy.

Errors

Returns an error if no healthy endpoints are available.

pub fn get_healthy_endpoints(&self) -> Vec<String>

Get a list of healthy endpoint URLs.

pub fn get_endpoint_health( &self, endpoint: &str, ) -> Option<&Arc<EndpointHealth>>

Get health information for an endpoint.

pub fn get_all_health(&self) -> &HashMap<String, Arc<EndpointHealth>>

Get health information for all endpoints.

pub async fn health_check(&self, endpoint: &str) -> Result<bool>

Perform a health check on a specific endpoint.

Errors

Returns an error if the health check fails.

pub async fn health_check_all(&self)

Perform health checks on all endpoints.

pub async fn record_success(&self, endpoint: &str)

Record a successful operation for an endpoint.

pub async fn record_failure(&self, endpoint: &str)

Record a failed operation for an endpoint.

pub fn shutdown(&self)

Shutdown the connection pool.

pub fn is_shutdown(&self) -> bool

Check if the pool is shut down.

pub async fn connected_count(&self) -> usize

Get the number of connected clients.

pub fn endpoint_count(&self) -> usize

Get the total number of endpoints.

Trait Implementations

impl Drop for ConnectionPool

fn drop(&mut self)

Executes the destructor for this type.