extern crate libcantal; extern crate env_logger; #[macro_use] extern crate lazy_static; #[macro_use] extern crate serde_json; use std::env; use std::io::stdout; use std::time::Duration; use std::thread::sleep; use libcantal::{Collection, Counter, Integer, Value, start, print}; lazy_static! { static ref COUNTER: Counter = Counter::new(); static ref INTEGER: Integer = Integer::new(); } fn counters() -> Box { Box::new(vec![ (json!({"metric": "counter"}), &*COUNTER as &Value), ]) } fn integers() -> Box { Box::new(vec![ (json!({"metric": "integer"}), &*INTEGER as &Value), ]) } fn metrics() -> Box { Box::new(vec![counters(), integers()]) } fn main() { if env::var("RUST_LOG").is_err() { env::set_var("RUST_LOG", "warn"); } env_logger::init().unwrap(); let met = metrics(); let _coll = start(&met).expect("cantal works"); loop { COUNTER.incr(1); INTEGER.set((COUNTER.get() / 7) as i64); print(&met, stdout()).expect("can always print"); sleep(Duration::new(1, 0)); } }