actix-tools 0.1.0

Provide Plug&Play components for Actix and Actix-web to build modular, 12-factor compliant apps.
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use actix::prelude::*;
use influx_db_client::{Client, Point, Value};

#[derive(Clone, Deserialize)]
pub struct InfluxSettings {
    pub uri:      String,
    pub db:       String,
    pub user:     String,
    pub password: String,
}

pub fn get_client(settings: InfluxSettings) -> Client {
    Client::new(settings.uri, settings.db)
        .set_authentication(settings.user, settings.password)
}

pub fn send(client: Client) {
    let point = Point::new("test1")
        .add_tag("tags", Value::String("filter".to_string()))
        .add_field("count", Value::Integer(1))
        .to_owned();

    // if Precision is None, the default is second
    // Multiple write
    let _ = client.write_point(point, None, None).unwrap();
}

pub struct InfluxEmitter {
    client: Client,
}

impl InfluxEmitter {
    pub fn from_settings(settings: InfluxSettings) -> Self {
        let client = get_client(settings);
        Self { client }
    }
}

#[derive(Message, Debug)]
pub struct Metric(pub Point);

impl Actor for InfluxEmitter {
    type Context = Context<Self>;

    fn started(&mut self, _ctx: &mut Self::Context) {
        info!("Starting Influx Emitter");
    }

    fn stopped(&mut self, _ctx: &mut Self::Context) {
        info!("Stopping Influx Emitter");
    }
}

impl Handler<Metric> for InfluxEmitter {
    type Result = ();

    fn handle(&mut self, msg: Metric, _ctx: &mut Self::Context) {
        self.client.write_point(msg.0, None, None).unwrap();
    }
}