kalavara 0.2.0

A distributed persistent key value store that speaks http.
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
51
52
53
54
55
56
57
58
59

use argparse::{ArgumentParser, Store, StoreOption};

use kalavara::volume::start;
use std::process::exit;

fn main() {
    let mut port = 7000;
    let mut data_dir = "/tmp/kalavarastore".to_string();
    let mut threads = num_cpus::get() as u16;
    let mut master: Option<String> = None;
    let mut base: Option<String> = None;

    {
        // this block limits scope of borrows by ap.refer() method
        let mut cli = ArgumentParser::new();
        cli.set_description("kalavara volume server.");
        cli.refer(&mut port)
            .add_option(&["-p", "--port"], Store, "Port");
        cli.refer(&mut data_dir)
            .add_option(&["-d", "--data_dir"], Store, "Data directory");

        cli.refer(&mut threads).add_option(
            &["-t", "--threads"],
            Store,
            "Number of threads, defaults to number of cpu cores",
        );

        cli.refer(&mut master).add_option(
            &["-m", "--master"],
            StoreOption,
            "Master server to register at",
        );

        cli.refer(&mut base).add_option(
            &["-b", "--base-url"],
            StoreOption,
            "Base url of server to register with master",
        );

        cli.parse_args_or_exit();
    }

    if master.is_some() && base.is_none() {
        eprintln!("base url is required to register with master");
        exit(2);
    }

    // remove trailing slash
    if data_dir.ends_with('/') {
        data_dir.pop();
    }

    println!(
        "port: {}, data_dir: {}, threads: {}, master: {:?}",
        port, data_dir, threads, master
    );

    start(port, data_dir, threads, master, base);
}