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

use super::*;

#[test]
fn init_cluster() {
    let rt = Runtime::new().unwrap();
    let _ = rt.block_on(async {
        let tm = TestManager::new("init_cluster", 3, None);

        tm.wait_for_cluster_established(1, 60).await.unwrap();
    });
}

#[test]
fn start_cluster() {
    let rt = Runtime::new().unwrap();

    let _ = rt.block_on(async {
        let mut tm = TestManager::new("start_cluster", 3, None);
        tm.wait_for_cluster_established(1, 60).await.unwrap();
        tm.kill_all().unwrap();
        tm.start().unwrap();
        tm.wait_for_cluster_established(1, 60).await.unwrap();
    });
}

#[test]
fn init_cluster_insecures_ssl() {
    let rt = Runtime::new().unwrap();
    let _ = rt.block_on(async {
        let tm = TestManager::new(
            "init_cluster_insecures_ssl",
            3,
            Some(TestTlsConfig::default().accept_invalid_certificates(true)),
        );

        tm.wait_for_cluster_established(1, 60).await.unwrap();
    });
}

#[test]
fn start_cluster_insecure_ssl() {
    let rt = Runtime::new().unwrap();

    let _ = rt.block_on(async {
        let mut tm = TestManager::new(
            "start_cluster_insecure_ssl",
            3,
            Some(TestTlsConfig::default().accept_invalid_certificates(true)),
        );
        //tm.keep_temp_directories=true;
        tm.wait_for_cluster_established(1, 60).await.unwrap();
        tm.kill_all().unwrap();
        tm.start().unwrap();
        tm.wait_for_cluster_established(1, 60).await.unwrap();
    });
}