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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use std::net::SocketAddr;

use serde::Deserialize;
use serde::Serialize;

use super::default::default_raft_config;
use super::default::default_rocksdb_config;
use crate::error::Result;
use crate::error::StartupError;

#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct Config {
  pub node_id: u64,

  #[serde(default = "default_raft_config")]
  pub raft: RaftConfig,

  #[serde(default = "default_rocksdb_config")]
  pub rocksdb: RocksdbConfig,
}

#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct RocksdbConfig {
  pub data_path: String,
  pub max_open_files: i32,
}

#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct RaftConfig {
  pub address: String,

  pub advertise_host: String,

  /// Single node raft cluster.
  pub single: bool,

  /// Bring up a raft node and join a cluster.
  ///
  /// The value is one or more addresses of a node in the cluster, to which this node sends a `join` request.
  pub join: Vec<String>,
}

impl Config {
  /// Validate the configuration to ensure it is correct.
  pub fn validate(&self) -> Result<()> {
    if self.raft.single && !self.raft.join.is_empty() {
      return Err(
        StartupError::invalid_config(
          "'single' mode cannot be used together with 'join' configuration",
        )
        .into(),
      );
    }

    let _a: SocketAddr = self.raft.address.parse().map_err(|e| {
      StartupError::InvalidConfig(format!("{} while parsing {}", e, self.raft.address))
    })?;

    Ok(())
  }
}