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

#![feature(async_await)]

use std::error::Error;

use futures::future::{FutureExt, TryFutureExt};
use protobuf::Chars;
use rustmann::protos::riemann::Event;
use rustmann::{Client, ClientOptions};

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

    let mut event = Event::new();
    event.set_service(Chars::from("test"));

    let fut = async move {
        let response = client.send_events(vec![event]).await;

        println!("{:?}", response);
    };
    tokio::run(fut.unit_error().boxed().compat());
    Ok(())
}