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

//! Raft type configuration for hirnd.

use std::io::Cursor;

use openraft::BasicNode;
use serde::{Deserialize, Serialize};

/// Raft node identifier — simple `u64`.
pub type NodeId = u64;

/// Application-level request applied through Raft consensus.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum RaftRequest {
    /// Assign a realm to a preferred owner node.
    AssignRealm { realm: String, owner_node: NodeId },
    /// Release realm ownership (e.g. node leaving).
    ReleaseRealm { realm: String },
    /// Acquire a consolidation lease for a realm.
    AcquireLease {
        realm: String,
        holder: NodeId,
        duration_secs: u64,
    },
    /// Release a consolidation lease.
    ReleaseLease { realm: String, holder: NodeId },
    /// Renew an existing consolidation lease.
    RenewLease {
        realm: String,
        holder: NodeId,
        duration_secs: u64,
    },
    /// Register a new node in the cluster metadata.
    RegisterNode { node_id: NodeId, addr: String },
    /// Deregister a node from the cluster metadata.
    DeregisterNode { node_id: NodeId },
}

/// Response from applying a [`RaftRequest`].
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum RaftResponse {
    /// Operation succeeded.
    Ok,
    /// Lease acquisition failed (held by another node).
    LeaseConflict {
        holder: NodeId,
        expires_at_epoch_secs: u64,
    },
    /// Lease renewal failed (not held by requester or no active lease).
    LeaseRenewalFailed { realm: String },
    /// Node info from registration.
    NodeRegistered { node_id: NodeId },
    /// Realm assignment result.
    RealmAssigned { realm: String, owner: NodeId },
}

openraft::declare_raft_types!(
    /// hirnd Raft type configuration.
    pub TypeConfig:
        D = RaftRequest,
        R = RaftResponse,
        Node = BasicNode,
);