swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
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

use std::sync::Arc;

use libcantal::{self, Name, NameVisitor, Value, Collection, Error};
use owning_ref::OwningHandle;

use runtime::Runtime;

pub use libcantal::{Counter, Integer};

pub type List = Vec<(Metric<'static>, &'static Value)>;

pub struct Metric<'a>(pub &'a str, pub &'a str);

// this is not actually static, but we have no lifetime name for it
struct Wrapper(libcantal::ActiveCollection<'static>);

pub struct ActiveCollection(OwningHandle<Box<Vec<Box<Collection>>>, Wrapper>);

impl<'a> Name for Metric<'a> {
    fn get(&self, key: &str) -> Option<&str> {
        match key {
            "metric" => Some(self.1),
            "group" => Some(self.0),
            _ => None,
        }
    }
    fn visit(&self, s: &mut NameVisitor) {
        s.visit_pair("group", self.0);
        s.visit_pair("metric", self.1);
    }
}

impl ::std::ops::Deref for Wrapper {
    type Target = ();
    fn deref(&self) -> &() { &() }
}

pub fn all(runtime: &Arc<Runtime>) -> Box<Vec<Box<Collection>>> {
    Box::new(vec![
        Box::new(::incoming::metrics()),
        Box::new(::chat::metrics()),
        Box::new(::http_pools::metrics()),
        Box::new(::http_pools::pool_metrics(&runtime.http_pools)),
    ])
}

pub fn start(runtime: &Arc<Runtime>) -> Result<ActiveCollection, Error> {
    OwningHandle::try_new(all(runtime), |m| {
        libcantal::start(unsafe { &*m }).map(Wrapper)
    }).map(ActiveCollection)
}