Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Implementations

impl ConnectionPool

pub async fn spawn( params: impl Into<String>, count: usize, ) -> Result<Self, Error>

Spawns a new connection pool, given the address to the ClickHouse server, and the maximum number of connections that the pool can spawn.

Errors

Returns an error if any of the connections failed to instantiate.

pub async fn acquire(&self) -> Result<ClientWrapper, Error>

Acquires a Client from the pool.

Returns a ClientWrapper which will automatically return the client to the pool when dropped.

Errors

Returns an error if the semaphore is closed or no clients are available.

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionPool

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

Formats the value using the given formatter.