Struct merino_adm::remote_settings::connection_pool::ConnectionPool

pub struct ConnectionPool {
    condvar: Condvar,
    connections: Mutex<VecDeque<Client>>,
}

The connection pool for Remote Settings.

Fields

condvar: Condvar

Semaphore to coordinate the connection pool.

connections: Mutex<VecDeque<Client>>

The underlying connections of the pool.

Implementations

impl ConnectionPool

pub fn new(clients: impl IntoIterator<Item = Client>) -> Self

Create a new connection pool with the given clients.

pub fn try_acquire(&self) -> Option<Connection<'_>>

Try acquiring a connection from the pool, return None if it’s not available without blocking.

pub async fn acquire(&self) -> Connection<'_>

Acquire a connection from the pool, it will spin until a connection is acquired from the pool.

pub fn insert(&self, client: Client)

Insert the connection to the pool, this is used to return a connection back to the pool.