bronzedb-client 0.1.1

client lib for bronzedb
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use super::Connection;
use bronzedb_util::status::Error;
use std::net::TcpStream;

pub struct BronzeConnManager {
    db_addr: String,
}

impl BronzeConnManager {
    pub fn new(addr: impl Into<String>) -> Self {
        Self {
            db_addr: addr.into(),
        }
    }
}

impl r2d2::ManageConnection for BronzeConnManager {
    type Connection = Connection<TcpStream>;
    type Error = Error;

    fn connect(&self) -> Result<Self::Connection, Self::Error> {
        let stream = TcpStream::connect(&self.db_addr)?;
        Ok(Self::Connection::new(stream))
    }

    fn is_valid(&self, conn: &mut Self::Connection) -> Result<(), Self::Error> {
        conn.ping()
    }

    fn has_broken(&self, conn: &mut Self::Connection) -> bool {
        match conn.no_response() {
            Ok(()) => false,
            Err(_) => true,
        }
    }
}