Struct ClickhouseConnectionManager 

pub struct ClickhouseConnectionManager { /* private fields */ }

Implementations

impl ClickhouseConnectionManager

pub fn new( config: Arc<ClickhouseConfig>, metrics: Option<SharedRegistrar>, ) -> Self

pub fn initiate_shutdown(&self)

pub fn create_client(&self) -> Result<Client, ClickhouseError>

Trait Implementations

impl Debug for ClickhouseConnectionManager

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

Formats the value using the given formatter.

impl Manager for ClickhouseConnectionManager

type Type = ClickhouseConnection

Type of super::Objects that this Manager creates and recycles.

type Error = ClickhouseError

Error that this Manager can return when creating and/or recycling super::Objects.

async fn create(&self) -> Result<Self::Type, Self::Error>

Creates a new instance of Manager::Type.

async fn recycle( &self, conn: &mut Self::Type, _: &Metrics, ) -> Result<(), RecycleError<Self::Error>>

Tries to recycle an instance of Manager::Type.

fn detach(&self, _obj: &mut Self::Type)

Detaches an instance of Manager::Type from this Manager.