Crate influx_db_client

InfluxDB Client

InfluxDB is an open source time series database with no external dependencies. It's useful for recording metrics, events, and performing analytics.

Usage

http

#[macro_use]
extern crate influx_db_client;

use influx_db_client::{Client, Point, Points, Value, Precision};

fn main() {
        // default with "http://127.0.0.1:8086", db with "test"
        let client = Client::default().set_authentication("root", "root");

        let mut point = point!("test1");
        point
            .add_field("foo", Value::String("bar".to_string()))
            .add_field("integer", Value::Integer(11))
            .add_field("float", Value::Float(22.3))
            .add_field("'boolean'", Value::Boolean(false));

        let point1 = Point::new("test1")
            .add_tag("tags", Value::String(String::from("\\\"fda")))
            .add_tag("number", Value::Integer(12))
            .add_tag("float", Value::Float(12.6))
            .add_field("fd", Value::String("'3'".to_string()))
            .add_field("quto", Value::String("\\\"fda".to_string()))
            .add_field("quto1", Value::String("\"fda".to_string()))
            .to_owned();

        let points = points!(point1, point);

        // if Precision is None, the default is second
        // Multiple write
        let _ = client.write_points(points, Some(Precision::Seconds), None).unwrap();

        // query, it's type is Option<Vec<Node>>
        let res = client.query("select * from test1", None).unwrap();
        println!("{:?}", res.unwrap()[0].series)
}

udp

#[macro_use]
extern crate influx_db_client;

use influx_db_client::{UdpClient, Point, Value};

fn main() {
    let mut udp = UdpClient::new("127.0.0.1:8089");
    udp.add_host("127.0.0.1:8090");

    let mut point = point!("test");
    point.add_field("foo", Value::String(String::from("bar")));

    let _ = udp.write_point(point).unwrap();
}

Re-exports

pub use client::Client;

pub use client::TLSOption;

pub use client::UdpClient;

pub use keys::Node;

pub use keys::Point;

pub use keys::Points;

pub use keys::Precision;

pub use keys::Query;

pub use keys::Series;

pub use keys::Value;

pub use error::Error;

Modules

client	All API on influxdb client, Including udp, http
error	Error module
keys	Points and Query Data Deserialize
serialization	Serialization module

Macros

point	Create Point by macro
points	Create Points by macro