Struct PoolManager 

pub struct PoolManager { /* private fields */ }

Implementations

impl PoolManager

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

pub fn get_pool(&self) -> Arc<ClickhouseConnectionPool>

pub fn seconds_since_last_recycle(&self) -> u64

pub async fn refill_connection_pool(&self) -> Result<usize, ClickhouseError>

pub async fn recycle_idle_connections( &mut self, max_to_recycle: usize, ) -> Result<usize, ClickhouseError>

pub async fn execute_with_retry( &self, query: &str, ) -> Result<(), ClickhouseError>

pub async fn execute_select_with_retry<T>( &self, query: &str, ) -> Result<Vec<T>, ClickhouseError>

where T: Row + DeserializeOwned + Send + 'static,

pub fn create_batch_processor<M>( &self, batch_size: usize, max_wait_ms: u64, ) -> BatchSender<M::T>

where M: Model + Send + Sync + 'static, M::T: Clone + Send + 'static,

pub fn create_partition_aware_batch_processor<M>( &self, batch_size: usize, max_wait_ms: u64, max_partitions_per_batch: usize, ) -> BatchSender<M::T>

where M: Model + Send + Sync + 'static, M::T: Clone + Send + PartitionKey + 'static,

Trait Implementations

impl Clone for PoolManager

fn clone(&self) -> PoolManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.