meter_proxy 0.2.3

A TCP proxy that measures latency and throughput of a client-server application
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

extern crate meter_proxy;

use meter_proxy::proxy::sync::SyncMeterProxy;
use std::thread;
use std::time::Duration;

fn main() {
    println!("Starting Proxy");
    let meter_proxy = SyncMeterProxy::new("127.0.0.1".to_string(),
                                          12347,
                                          "127.0.0.1".to_string(),
                                          12349);

    let meter_proxy_c = meter_proxy.clone();
    let child_proxy = thread::spawn(move || {
        meter_proxy_c.start();
    });

    let mut n = 0;
    let sleep_time = 2000;
    while n < 100 {
        n += 1;

        // Do something
        thread::sleep(Duration::from_millis(sleep_time));

        println!("The measured latency 'till now: {:.3} ms",
                 meter_proxy.get_latency_ms());
        println!("The measured throughput 'till now: {:.3}",
                 meter_proxy.get_num_bytes_rcvd() as f64 / (n * sleep_time) as f64);
    }

    meter_proxy.stop_and_reset();
    let _ = child_proxy.join();

}