rxqlite 0.1.11

A secured distributed sqlite database built upon `openraft`, `sqlx` and `sqlite`.
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

use std::sync::Arc;

use openraft::raft::AppendEntriesRequest;
use openraft::raft::AppendEntriesResponse;
use openraft::raft::InstallSnapshotRequest;
use openraft::raft::InstallSnapshotResponse;
use openraft::raft::VoteRequest;
use openraft::raft::VoteResponse;
use toy_rpc_ha421::macros::export_impl;

use crate::app::App;
use crate::TypeConfig;

/// Raft protocol service.
pub struct Raft {
    app: Arc<App>,
}

#[export_impl]
impl Raft {
    pub fn new(app: Arc<App>) -> Self {
        Self { app }
    }

    #[export_method]
    pub async fn vote(
        &self,
        vote: VoteRequest<u64>,
    ) -> Result<VoteResponse<u64>, toy_rpc_ha421::Error> {
        self.app
            .raft
            .vote(vote)
            .await
            .map_err(|e| toy_rpc_ha421::Error::Internal(Box::new(e)))
    }

    #[export_method]
    pub async fn append(
        &self,
        req: AppendEntriesRequest<TypeConfig>,
    ) -> Result<AppendEntriesResponse<u64>, toy_rpc_ha421::Error> {
        tracing::debug!("handle append");
        self.app
            .raft
            .append_entries(req)
            .await
            .map_err(|e| toy_rpc_ha421::Error::Internal(Box::new(e)))
    }

    #[export_method]
    pub async fn snapshot(
        &self,
        req: InstallSnapshotRequest<TypeConfig>,
    ) -> Result<InstallSnapshotResponse<u64>, toy_rpc_ha421::Error> {
        self.app
            .raft
            .install_snapshot(req)
            .await
            .map_err(|e| toy_rpc_ha421::Error::Internal(Box::new(e)))
    }
}