Minimal wrapper library for general metrics writing using telegraf. Telegraf is a micro service provided by InfluxData for making metrics reporting easy for multiple services - see their docs for more information.

Install

Add it to your Cargo.toml:

[dependencies]
telegraf = "0.2.1"

Usage

Using this library assumes you have a socket listener input setup in your telegraf config, like so (currently only tcp is supported, but udp and unix are planned):

[[inputs.socket_listener]]
  service_address = "tcp://localhost:8094"

Example usage:

use telegraf::{Client, point};

let c = Client::new("tcp://localhost:8094").unwrap();

let p = point!("measurement", ("tag1", "tag1value"), ("field1", 10) ("field2", 20.5));

c.write_point(p)

Or directly from the Point::new method:

use telegraf::{Client, Point};

let c = Client::new("tcp://localhost:8094").unwrap();

let p = Point::new(
    String::from("measurement"),
    vec![
        (String::from("tag1"), String::from("tag1value"))
    ],
    vec![
        (String::from("field1"), Box::new(10)),
        (String::from("field2"), Box::new(20.5)),
        (String::from("field3"), Box::new("anything!"))
    ]
);

c.write_point(p)

The second value in the field tuples can be any type that implements the IntoFieldData trait provided by this lib. Out of the box support is provided for common types. You can always implement this trait on your own custom types or types I forgot!

pub trait IntoFieldData {
    fn into_field_data(&self) -> FieldData;
}