rust_raft 0.1.1

A rust implementation for raft.
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

use std::sync::mpsc;
use std::{thread, time};
use crate::raft::raft_conf::{CONF, RaftVar, ConfigRaft};
use super::router::app_router;
use std::sync::{Arc, Mutex};
use crate::raft::raft_enum::{Fields, Role};
use crate::raft::db::insert;

pub fn init_app(conf: ConfigRaft) -> anyhow::Result<()> {
    CONF.set(conf).unwrap();
    let conf = CONF.get().expect("can not get config raft");
    if conf.first_node {
        RaftVar::set_role(Role::leader.name());
        RaftVar::set_leader_url(&conf.url_me);
    }
    Ok(())
}

pub fn run_app() {
    let (tx, rx) = mpsc::channel();
    thread::spawn(move || {
        let _ = app_router(tx);
    });

    // let srv = rx.recv().unwrap();
    // println!("WATING 40 SECONDS");
    // thread::sleep(time::Duration::from_secs(40));
    // println!("STOPPING SERVER");
    // rt::System::new("").block_on(srv.stop(true));
}