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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
extern crate byteorder;
extern crate serde;
extern crate serde_json;
extern crate tdb_core;
#[macro_use] extern crate log;
pub mod error;
pub mod client;
use std::env;
use crate::client::TectonicClient;
use crate::error::TectonicError;
use std::time::SystemTime;
use tdb_core::dtf::update::Update;
fn key_or_default(key: &str, default: &str) -> String {
match env::var(key) {
Ok(val) => val,
Err(_) => default.into(),
}
}
fn get_tectonic_conf_from_env() -> (String, String) {
let tectonic_hostname: String = key_or_default("TDB_HOSTNAME", "localhost");
let tectonic_port: String = key_or_default("TDB_PORT", "9001");
(tectonic_hostname, tectonic_port)
}
pub fn client_from_env() -> TectonicClient {
let (tectonic_hostname, tectonic_port) = get_tectonic_conf_from_env();
match TectonicClient::new(&tectonic_hostname, &tectonic_port) {
Ok(cli) => cli,
Err(TectonicError::ConnectionError) => {
panic!("DB cannot be connected!");
},
_ => unreachable!(),
}
}
pub fn benchmark(mut cli: TectonicClient, times: usize) {
let mut t = SystemTime::now();
let mut acc = vec![];
let create = cli.cmd("CREATE benchmark\n");
println!("{:?}", create);
for i in 0..times {
if i % 10_000 == 0 {
dbg!(i);
}
let ts = SystemTime::now().duration_since(SystemTime::UNIX_EPOCH).unwrap().as_nanos() as u64 / 1000;
let res = cli.insert(
Some("benchmark"),
&Update { ts, seq: 0, is_bid: true, is_trade: false, price: 0.001939, size: 22.85 },
true,
);
res.unwrap();
acc.push(t.elapsed().unwrap().subsec_nanos() as usize);
t = SystemTime::now();
}
::std::thread::sleep(std::time::Duration::new(1, 0));
cli.shutdown();
let avg_ns = acc.iter().fold(0, |s, i| s + i) as f32 / acc.len() as f32;
println!("AVG ns/insert: {}", avg_ns);
println!("AVG inserts/s: {}", 1. / (avg_ns / 1_000_000_000.));
}