Struct r2d2_influxdb::InfluxDBConnectionManager

pub struct InfluxDBConnectionManager { /* fields omitted */ }

Methods

impl InfluxDBConnectionManager

pub fn new<T: Into<InfluxDBConnectionInfo>>(
    params: T
) -> InfluxDBConnectionManager

Trait Implementations

impl Debug for InfluxDBConnectionManager

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

Formats the value using the given formatter.

impl ManageConnection for InfluxDBConnectionManager

An r2d2::ConnectionManager for InfluxDB::Clients.

Example

extern crate r2d2_influxdb;

use r2d2_influxdb::{r2d2, InfluxDBConnectionManager, SimpleInfo};
use std::thread;

fn main() {
    let info = SimpleInfo {
        url: "http://localhost:8086".into(),
        database: "test".into(),
    };
    let manager = InfluxDBConnectionManager::new(info);
    let pool = r2d2::Pool::builder().build(manager).unwrap();

    let mut handles = vec![];

    for _i in 0..10i32 {
        let pool = pool.clone();
        handles.push(thread::spawn(move || {
            let conn = pool.get().unwrap();
            let reply = conn.ping();
            println!("{:?}", reply);
            assert!(reply.is_ok())
        }));
    }

    for h in handles {
        h.join().unwrap();
    }
}

type Connection = SyncClient

The connection type this manager deals with.

type Error = Error

The error type returned by Connections.

fn connect(&self) -> Result<SyncClient, Error>

Attempts to create a new connection.

fn is_valid(&self, conn: &mut SyncClient) -> Result<(), Error>

Determines if the connection is still connected to the database.

fn has_broken(&self, conn: &mut SyncClient) -> bool

Quickly determines if the connection is no longer usable.