rustmann 0.2.2

Rust/Tokio client for Riemann
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

#![feature(await_macro, async_await)]

use std::error::Error;

use tokio::await;
use tokio::codec::{FramedRead, LinesCodec};
use tokio::io::stdin;
use tokio::prelude::*;

use protobuf::Chars;
use rustmann::protos::riemann::Event;
use rustmann::{Client, ClientOptions};

fn main() -> Result<(), Box<Error>> {
    let mut client = Client::new(&ClientOptions::default());
    let mut input = FramedRead::new(stdin(), LinesCodec::new());

    tokio::run_async(
        async move {
            while let Some(Ok(line)) = await!(input.next()) {
                let mut event = Event::new();
                event.set_host(Chars::from("thinkless"));
                event.set_service(Chars::from("rustmann_interactive"));
                event.set_description(line.into());

                let response = await!(client.send_events(vec![event]));
                println!("{:?}", response);
            }
        },
    );
    Ok(())
}