tic 0.6.0

a high-performance stats library focused on rates and latencies from timestamped events
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

use common::ControlMessage;
use data::Meters;
use mio_extras::channel;
use mio_extras::channel::TrySendError;
use std::io;
use std::sync::mpsc;

/// a `Controller` allows interacting with a remote `Receiver`
pub struct Controller<T> {
    control_tx: channel::SyncSender<ControlMessage<T>>,
}

impl<T> Controller<T> {
    pub fn new(control_tx: channel::SyncSender<ControlMessage<T>>) -> Controller<T> {
        Controller { control_tx: control_tx }
    }

    /// takes a snapshot of the current meters by cloning them
    ///
    /// this will block until the `Receiver` responds
    pub fn get_meters(&self) -> Result<Meters<T>, io::Error> {
        let (tx, rx) = mpsc::sync_channel(1);
        let msg = ControlMessage::SnapshotMeters(tx);

        match self.control_tx.try_send(msg) {
            Ok(_) => {
                match rx.recv() {
                    Ok(result) => Ok(result),
                    Err(_) => Err(io::Error::new(
                        io::ErrorKind::Other,
                        "failed to receive snapshot",
                    )),
                }
            }
            Err(e) => {
                match e {
                    TrySendError::Io(e) => {
                        error!("io error: {}", e);
                        Err(e)
                    }
                    TrySendError::Full(_) |
                    TrySendError::Disconnected(_) => Err(io::Error::new(
                        io::ErrorKind::Other,
                        "failed to send snapshot command",
                    )),
                }
            }
        }
    }
}