rxqlite 0.1.15

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
62
63
64
65
66
67
68
69
70
71

use super::*;
/*
#[cfg(target_os = "linux")]
use super::consts::DELAY_BETWEEN_KILL_AND_START;
*/
#[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();
        /*
        #[cfg(target_os = "linux")]
        {
           tokio::time::sleep(DELAY_BETWEEN_KILL_AND_START).await;
        }
        */
        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();
        /*
        #[cfg(target_os = "linux")]
        {
           tokio::time::sleep(DELAY_BETWEEN_KILL_AND_START).await;
        }
        */
        tm.start().unwrap();
        tm.wait_for_cluster_established(1, 60).await.unwrap();
    });
}