reddb-io-server 1.1.1

RedDB server-side engine: storage, runtime, replication, MCP, AI, and the gRPC/HTTP/RedWire/PG-wire dispatchers. Re-exported by the umbrella `reddb` crate.
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
68
69
70
71
72
73

use std::sync::Arc;

use crate::storage::engine::GraphStore;

pub(crate) fn add_node_or_panic(graph: &GraphStore, id: &str, label: &str, category: &str) {
    graph
        .add_node_with_label(id, label, category)
        .unwrap_or_else(|err| panic!("failed to add test graph node {id}: {err}"));
}

pub(crate) fn add_edge_or_panic(
    graph: &GraphStore,
    from: &str,
    to: &str,
    edge_label: &str,
    weight: f32,
) {
    graph
        .add_edge_with_label(from, to, edge_label, weight)
        .unwrap_or_else(|err| panic!("failed to add test graph edge {from}->{to}: {err}"));
}

pub(crate) fn service_graph() -> Arc<GraphStore> {
    let graph = GraphStore::new();

    add_node_or_panic(&graph, "host:10.0.0.1", "webserver", "host");
    add_node_or_panic(&graph, "host:10.0.0.2", "database", "host");
    add_node_or_panic(&graph, "svc:ssh", "SSH", "service");
    add_node_or_panic(&graph, "svc:http", "HTTP", "service");

    add_edge_or_panic(&graph, "host:10.0.0.1", "svc:ssh", "has_service", 1.0);
    add_edge_or_panic(&graph, "host:10.0.0.1", "svc:http", "has_service", 1.0);
    add_edge_or_panic(&graph, "host:10.0.0.1", "host:10.0.0.2", "connects_to", 1.0);
    add_edge_or_panic(&graph, "host:10.0.0.2", "svc:ssh", "has_service", 1.0);

    Arc::new(graph)
}

pub(crate) fn service_graph_with_user() -> Arc<GraphStore> {
    let graph = service_graph();

    add_node_or_panic(&graph, "user:admin", "admin", "user");
    add_edge_or_panic(&graph, "host:10.0.0.1", "user:admin", "has_user", 1.0);

    graph
}

pub(crate) fn unified_query_graph() -> Arc<GraphStore> {
    let graph = GraphStore::new();

    add_node_or_panic(&graph, "host:192.168.1.1", "192.168.1.1", "host");
    add_node_or_panic(&graph, "host:192.168.1.2", "192.168.1.2", "host");
    add_node_or_panic(&graph, "svc:ssh:22", "SSH", "service");
    add_node_or_panic(&graph, "svc:http:80", "HTTP", "service");

    add_edge_or_panic(&graph, "host:192.168.1.1", "svc:ssh:22", "has_service", 1.0);
    add_edge_or_panic(
        &graph,
        "host:192.168.1.1",
        "svc:http:80",
        "has_service",
        1.0,
    );
    add_edge_or_panic(
        &graph,
        "host:192.168.1.1",
        "host:192.168.1.2",
        "connects_to",
        1.0,
    );

    Arc::new(graph)
}