mocra-cluster 0.4.1

Embedded Raft + redb control plane for the mocra distributed crawler framework: leader election, distributed locks with fencing, membership, partition ownership.
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

//! openraft type configuration: wires the control plane's [`Cmd`] / [`CmdResult`] into Raft
//! (openraft 0.9.24).
//!
//! The application data Raft replicates (`D`) is [`Cmd`] and the response (`R`) is [`CmdResult`];
//! once a log entry is committed, every node hands the `Cmd` to the redb state machine's
//! [`apply`](crate::state_machine::StateMachine::apply).

use std::io::Cursor;

use crate::cmd::{Cmd, CmdResult};

/// Node identifier.
pub type NodeId = u64;

/// Node information (openraft's built-in `BasicNode` is used here; it carries an address string).
pub type Node = openraft::BasicNode;

/// Snapshot data carrier (the default cursor).
pub type SnapshotData = Cursor<Vec<u8>>;

openraft::declare_raft_types!(
    /// Raft type configuration for the mocra control plane.
    pub TypeConfig:
        D = Cmd,
        R = CmdResult,
);

/// Type alias for the Raft instance.
pub type MocraRaft = openraft::Raft<TypeConfig>;

/// Common openraft type aliases (mirrors the `typ` module from the official examples).
pub mod typ {
    use openraft::error::Infallible;

    use super::{Node, NodeId, TypeConfig};

    pub type Entry = openraft::Entry<TypeConfig>;

    pub type RaftError<E = Infallible> = openraft::error::RaftError<NodeId, E>;
    pub type RPCError<E = Infallible> = openraft::error::RPCError<NodeId, Node, RaftError<E>>;

    pub type ClientWriteError = openraft::error::ClientWriteError<NodeId, Node>;
    pub type InitializeError = openraft::error::InitializeError<NodeId, Node>;
    pub type ClientWriteResponse = openraft::raft::ClientWriteResponse<TypeConfig>;
}