woddle 0.5.0

An async, synchronized, database-backed Rust job scheduler
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

use crate::db::DBError;
use mobc::Pool;
use mobc_postgres::{tokio_postgres, PgConnectionManager};
use tokio_postgres::{Client, NoTls};

pub(crate) type DBPool = Pool<PgConnectionManager<NoTls>>;

// Gets a database connection from the connection pool
pub(crate) async fn get_con(pool: &DBPool) -> Result<Client, DBError> {
    let con = pool.get().await.map_err(DBError::PoolError)?;
    Ok(con.into_inner())
}