hirnd 0.1.0

hirn standalone daemon — gRPC, HTTP, and MCP server for cognitive memory
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
62
63
64
65
66
67

//! OpenRaft-based metadata consensus for multi-node hirnd deployments.
//!
//! This module implements:
//! - Raft type configuration (`TypeConfig`)
//! - State machine for cluster metadata (`HirnStateMachine`)
//! - Durable log storage (`DurableLogStore`) — **use in production**
//! - In-memory dev log storage (`DevMemLogStore`) — **single-node / dev only**
//! - HTTP network transport (`HirnRaftNetwork`)
//! - Consolidation lease protocol (`ConsolidationLease`)
//! - Realm-to-node shard affinity (via state machine)

pub mod durable_store;
pub mod lease;
pub mod network;
pub mod state_machine;
pub mod store;
pub mod types;

pub use durable_store::DurableLogStore;
pub use lease::ConsolidationLease;
pub use state_machine::HirnStateMachine;
pub use store::DevMemLogStore;
pub use types::*;

use std::sync::Arc;

use openraft::Config;

/// Create a default Raft config for hirnd.
///
/// Heartbeat: 150ms, election timeout: 300–500ms.
pub fn default_raft_config() -> Config {
    Config {
        heartbeat_interval: 150,
        election_timeout_min: 300,
        election_timeout_max: 500,
        snapshot_policy: openraft::SnapshotPolicy::LogsSinceLast(1000),
        ..Config::default()
    }
}

/// Convenience alias for the fully-typed Raft instance.
pub type HirnRaft = openraft::Raft<TypeConfig>;

/// Build and initialize a Raft node with a durable log store.
pub async fn new_raft(
    node_id: NodeId,
    config: Arc<Config>,
    log_store: DurableLogStore,
    state_machine: Arc<HirnStateMachine>,
    network: network::HirnRaftNetworkFactory,
) -> Result<HirnRaft, openraft::error::Fatal<NodeId>> {
    openraft::Raft::new(node_id, config, network, log_store, state_machine).await
}

/// Build and initialize a Raft node with an in-memory (dev-only) log store.
///
/// **Do not use in multi-node production deployments** — state is lost on restart.
pub async fn new_raft_dev(
    node_id: NodeId,
    config: Arc<Config>,
    log_store: DevMemLogStore,
    state_machine: Arc<HirnStateMachine>,
    network: network::HirnRaftNetworkFactory,
) -> Result<HirnRaft, openraft::error::Fatal<NodeId>> {
    openraft::Raft::new(node_id, config, network, log_store, state_machine).await
}