Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for upstream services.

Implementations

impl ConnectionPool

pub fn new(max_per_upstream: usize) -> Self

Create a new connection pool.

pub fn get_connection( &mut self, upstream_idx: usize, current_tick: u64, ) -> &mut Connection

Get an idle connection to a specific upstream, or create one.

pub fn release(&mut self, conn_id: u64)

Release a connection back to the pool.

pub fn drain_upstream(&mut self, upstream_idx: usize)

Drain connections to a specific upstream.

pub fn cleanup_drained(&mut self) -> usize

Remove drained connections.

pub fn active_count(&self) -> usize

Get the number of active connections.

pub fn total_count(&self) -> usize

Get total connection count.

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.