datafusion-dist-cluster-postgres 0.1.0

A PostgreSQL cluster implementation for datafusion-dist
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use bb8_postgres::tokio_postgres::Error as PgError;
use datafusion_dist::DistError;
use thiserror::Error;

#[derive(Error, Debug)]
pub enum PostgresClusterError {
    #[error("PostgreSQL connection error: {0}")]
    Connection(#[from] PgError),

    #[error("Connection pool error: {0}")]
    Pool(#[from] bb8::RunError<PgError>),

    #[error("Cluster query error: {0}")]
    Query(String),
}

impl From<PostgresClusterError> for DistError {
    fn from(err: PostgresClusterError) -> Self {
        DistError::cluster(Box::new(err))
    }
}