rockraft 0.1.6

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

//! RocksDB-based storage backends for Raft.
//!
//! Implements OpenRaft's storage traits using RocksDB:
//! - [`RocksLogStore`]: Persistent Raft log storage
//! - [`RocksStateMachine`]: Key-value state machine with snapshot support
//!
//! Column families separate different data types for efficient access.

pub(crate) mod keys;
mod log_store;
mod meta;
mod snapshot;
mod statemachine;

pub use log_store::RocksLogStore;
pub use meta::StoreMeta;
pub use statemachine::RocksStateMachine;

use std::path::PathBuf;

use crate::engine::RocksDBEngine;
use crate::error::Result;
use crate::raft::types::TypeConfig;

/// Create a RocksDB engine pre-configured with all column families needed by
/// the log store and state machine.
///
/// Callers that need a shared database for both stores should use this
/// instead of assembling the column family list themselves.
pub(crate) fn create_storage_engine(data_path: &str, max_open_files: i32) -> Result<RocksDBEngine> {
  RocksDBEngine::new(data_path, max_open_files, keys::column_family_list())
}

/// Create both the log store and state machine from a shared RocksDB engine.
///
/// This encapsulates the coordination of constructing the two storage
/// components, so callers don't need to reach into engine internals.
pub(crate) async fn create_stores(
  engine: &RocksDBEngine,
  data_dir: PathBuf,
) -> Result<(RocksLogStore<TypeConfig>, RocksStateMachine)> {
  let db = engine.db().clone();
  let log_store = RocksLogStore::create(db.clone())?;
  let state_machine = RocksStateMachine::new(db, data_dir).await?;
  Ok((log_store, state_machine))
}