rockraft 0.1.5

A strong consistency KV service library base on Raft and Rocksdb
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

use crate::config::Config;
use crate::error::Result;
use crate::raft::types::Endpoint;

pub struct ParsedConfig {
  pub node_id: u64,

  pub raft_endpoint: Endpoint,

  pub raft_advertise_endpoint: Endpoint,

  pub raft_single: bool,

  pub raft_join: Vec<String>,

  #[allow(dead_code)]
  pub rocksdb_data_path: String,

  #[allow(dead_code)]
  pub rocksdb_max_open_files: i32,
}

impl ParsedConfig {
  pub fn from(config: &Config) -> Result<Self> {
    let raft_endpoint = Endpoint::parse(&config.raft.address)?;
    let raft_advertise_endpoint = Endpoint::new(&config.raft.advertise_host, raft_endpoint.port());

    Ok(ParsedConfig {
      node_id: config.node_id,
      raft_endpoint,
      raft_advertise_endpoint,
      raft_single: config.raft.single,
      raft_join: config.raft.join.clone(),
      rocksdb_data_path: config.rocksdb.data_path.clone(),
      rocksdb_max_open_files: config.rocksdb.max_open_files,
    })
  }
}