yantrikdb-server 0.5.12

YantrikDB database server — multi-tenant cognitive memory with wire protocol, HTTP gateway, replication, auto-failover, and at-rest encryption
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

//! Internal Command enum — the unified representation that both the wire
//! protocol handler and HTTP gateway produce. The handler module executes
//! these against the engine.

use serde_json::Value;

/// A database command ready for execution.
#[derive(Debug)]
pub enum Command {
    // ── Memory ────────────────────────────────────────────
    Remember {
        text: String,
        memory_type: String,
        importance: f64,
        valence: f64,
        half_life: f64,
        metadata: Value,
        namespace: String,
        certainty: f64,
        domain: String,
        source: String,
        emotional_state: Option<String>,
        embedding: Option<Vec<f32>>,
    },
    RememberBatch {
        memories: Vec<RememberInput>,
    },
    Recall {
        query: String,
        top_k: usize,
        memory_type: Option<String>,
        include_consolidated: bool,
        expand_entities: bool,
        namespace: Option<String>,
        domain: Option<String>,
        source: Option<String>,
        query_embedding: Option<Vec<f32>>,
    },
    Forget {
        rid: String,
    },

    // ── Graph ─────────────────────────────────────────────
    Relate {
        entity: String,
        target: String,
        relationship: String,
        weight: f64,
    },
    Edges {
        entity: String,
    },

    // ── Session ───────────────────────────────────────────
    SessionStart {
        namespace: String,
        client_id: String,
        metadata: Value,
    },
    SessionEnd {
        session_id: String,
        summary: Option<String>,
    },

    // ── Cognition ─────────────────────────────────────────
    Think {
        run_consolidation: bool,
        run_conflict_scan: bool,
        run_pattern_mining: bool,
        run_personality: bool,
        consolidation_limit: usize,
    },

    // ── Conflicts ─────────────────────────────────────────
    Conflicts {
        status: Option<String>,
        conflict_type: Option<String>,
        entity: Option<String>,
        limit: usize,
    },
    Resolve {
        conflict_id: String,
        strategy: String,
        winner_rid: Option<String>,
        new_text: Option<String>,
        resolution_note: Option<String>,
    },

    // ── Info ──────────────────────────────────────────────
    Personality,
    Stats,

    // ── Database management ──────────────────────────────
    CreateDb {
        name: String,
    },
    ListDb,

    // ── Control ──────────────────────────────────────────
    Ping,
}

#[derive(Debug)]
pub struct RememberInput {
    pub text: String,
    pub memory_type: String,
    pub importance: f64,
    pub valence: f64,
    pub half_life: f64,
    pub metadata: Value,
    pub namespace: String,
    pub certainty: f64,
    pub domain: String,
    pub source: String,
    pub emotional_state: Option<String>,
    pub embedding: Option<Vec<f32>>,
}