Struct tang_rs::Pool

pub struct Pool<M: Manager + Send>(_);

Methods

impl<M: Manager + Send> Pool<M>

pub async fn init<'_>(&'_ self) -> Result<(), M::Error>

manually initialize pool. this is usually called when the Pool is built with build_uninitialized This is useful when you want to make a empty Pool and init it later.

example:

#[macro_use]
extern crate lazy_static;

use tang_rs::{Pool, PostgresManager, Builder};
use tokio_postgres::NoTls;

lazy_static! {
   static ref POOL: Pool<PostgresManager<NoTls>> = Builder::new()
        .always_check(false)
        .idle_timeout(None)
        .max_lifetime(None)
        .min_idle(24)
        .max_size(24)
        .build_uninitialized(
            PostgresManager::new_from_stringlike("postgres://postgres:123@localhost/test", NoTls)
                .expect("can't make postgres manager")
        )
        .unwrap_or_else(|e| panic!("{:?}", e));
}

#[tokio::main]
async fn main() -> std::io::Result<()> {
    POOL.init().await.expect("Failed to initialize postgres pool");
    Ok(())
}

pub async fn get<'_, '_>(&'_ self) -> Result<PoolRef<'_, M>, M::Error>

Return a reference of Arc<SharedPool<Manager>> and a Option<Manager::Connection>. The PoolRef should be drop asap when you finish the use of it.

pub async fn run<'_, T, E, F>(&'_ self, f: F) -> Result<T, E> where
    F: FnOnce(&mut M::Connection) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send>>,
    E: From<M::Error>,
    T: Send + 'static, 

Run the pool with a closure. Usually slightly faster than Pool.get() as we only do conditional broken check according to the closure result.

pub fn get_manager(&self) -> &M

pub fn state(&self) -> State

Return a state of the pool inner. This call will block the thread and wait for lock.

Trait Implementations

impl<M: Manager + Send> Clone for Pool<M>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M: Manager + Send> Debug for Pool<M>

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

Formats the value using the given formatter.