neug-protocol 0.2.1

Inter-process communication protocol for the NeuG graph database engine sidecar architecture.
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

use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
pub enum RequestPayload {
    OpenDb {
        path: String,
        mode: String,
        max_thread_num: usize,
        checkpoint_on_close: bool,
    },
    Connect {
        db_id: u64,
    },
    Execute {
        conn_id: u64,
        query: String,
    },
    CloseConn {
        conn_id: u64,
    },
    CloseDb {
        db_id: u64,
    },
}

#[derive(Serialize, Deserialize, Debug)]
pub struct Request {
    pub req_id: u64,
    pub payload: RequestPayload,
}

#[derive(Serialize, Deserialize, Debug)]
pub enum ResponsePayload {
    OkDb { db_id: u64 },
    OkConn { conn_id: u64 },
    OkResult { result_string: String },
    Error(String),
}

#[derive(Serialize, Deserialize, Debug)]
pub struct Response {
    pub req_id: u64,
    pub payload: ResponsePayload,
}