Struct ConnectionManager 

pub struct ConnectionManager<T: ClientFormat> { /* private fields */ }

ConnectionManager is the underlying manager that bb8::Pool uses to manage connections.

Implementations

impl<T: ClientFormat> ConnectionManager<T>

pub async fn try_new<A: Into<Destination>, S: Into<Settings>>( destination: A, options: ClientOptions, settings: Option<S>, span: Option<NonZeroU64>, ) -> Result<Self>

Creates a new connection manager for the pool.

This method builds a ConnectionManager that the pool will use to create and manage connections to ClickHouse. Each connection will be built using the provided destination, options, and settings.

Arguments

• destination - The ClickHouse server address (host:port or socket address)
• options - Client configuration options
• settings - Optional ClickHouse settings to apply to all connections
• span - Optional tracing span ID for distributed tracing

Errors

Returns an error if the destination cannot be resolved or is invalid

pub async fn try_new_with_builder(builder: ClientBuilder) -> Result<Self>

Creates a new connection manager from an existing ClientBuilder.

This is an alternative constructor that allows you to pre-configure a ClientBuilder with custom settings before creating the connection manager. This is useful when you need fine-grained control over the client configuration.

Unlike Self::try_new, which creates a ClientBuilder internally, this method accepts a pre-configured builder directly.

Errors

Returns an error if the builder’s destination cannot be verified

pub fn with_check(self, check: bool) -> Self

Whether the underlying connection will issue a ping when checking health.

pub fn connection_identifier(&self) -> String

Useful to determine if 2 connections are essentially the same

Trait Implementations

impl<T: Clone + ClientFormat> Clone for ConnectionManager<T>

fn clone(&self) -> ConnectionManager<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: ClientFormat> ManageConnection for ConnectionManager<T>

type Connection = Client<T>

The connection type this manager deals with.

type Error = Error

The error type returned by Connections.

async fn connect(&self) -> Result<Self::Connection, Self::Error>

Attempts to create a new connection.

async fn is_valid(&self, conn: &mut Self::Connection) -> Result<(), Self::Error>

Determines if the connection is still connected to the database.

fn has_broken(&self, conn: &mut Self::Connection) -> bool

Synchronously determine if the connection is no longer usable, if possible.