Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing gRPC connections

Implementations

impl ConnectionPool

pub fn new(config: PoolConfig) -> Self

Create a new connection pool

pub fn add_endpoint(&self, id: EndpointId, address: String)

Add an endpoint to the connection pool

pub fn add_endpoint_with_weight( &self, id: EndpointId, address: String, weight: u32, )

Add an endpoint with weight

pub fn remove_endpoint(&self, endpoint_id: &str) -> bool

Remove an endpoint from the connection pool

pub async fn get_connection(&self) -> NetResult<PooledConnection>

Get a connection from the pool

pub fn stats(&self) -> PoolStats

Get pool statistics

pub fn circuit_breaker_stats(&self) -> Option<CircuitBreakerStats>

Get circuit breaker statistics

pub async fn shutdown(self) -> NetResult<()>

Shutdown the connection pool gracefully

pub async fn drain(&self) -> NetResult<()>

Drain the pool (prepare for graceful shutdown)