patoka 0.1.0

Try this if you can decompose your problem into actors
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

#[macro_use]
extern crate slog;

use actix::prelude::*;
use clap::{App, Arg, crate_version};

use crate::{
    core::{env, app_state},
    worker::{dispatcher, router, processor, task_tree},
};

pub mod center;
#[macro_use]
pub mod control;
pub mod core;
pub mod storage;
#[macro_use]
pub mod worker;
pub mod transport;
pub mod utils;

pub fn run_app<F>(app_name: &str, run_tasks: F)
where
    F: FnOnce() + 'static
{
    let matches = App::new(app_name)
        .version(crate_version!())
        .arg(Arg::with_name("config")
            .short('c')
            .long("config")
            .value_name("FILE")
            .help("Configuration file")
            .takes_value(true)
        )
        .get_matches();

    let config = matches.value_of("config").unwrap_or("cfg/patoka.toml");
    if let Err(_) = env::load(config) {
        std::process::exit(0);
    }

    let system = System::new();

    system.block_on(async {
        app_state::start();
        dispatcher::start();
        router::start();
        task_tree::start();
        processor::start();
        center::router::start();
        run_tasks();
    });

    system.run();
}