noatun 0.1.3

Noatun is an in-process, distributed database with materialized view support.
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
74
75
76
77
78
79
80
81
82

use crate::database::{DatabaseSettings, OpenMode};
use crate::MessageFrame;
use crate::SavefileMessageSerializer;
use crate::{Database, Message, MessageId};
use savefile_derive::Savefile;
use std::pin::Pin;

noatun_object!(
    struct Doc {
        opod counter: u32,
    }
);

#[derive(Savefile, Debug)]
pub struct DocMessage {
    val: u32,
    reset: bool,
}

impl Message for DocMessage {
    type Root = Doc;
    type Serializer = SavefileMessageSerializer<Self>;

    fn apply(&self, _time: MessageId, root: Pin<&mut Self::Root>) {
        let mut root = root.pin_project();
        if self.reset {
            root.counter.set(0);
        } else {
            root.counter += self.val;
        }
    }
}

#[test]
fn test_subsume_nonlocal() {
    super::setup_tracing();
    let msg0_time = MessageId::new_debug2(0).timestamp();
    let mut db: Database<DocMessage> = Database::create_new(
        "test/test_subsumption_nonlocal1",
        OpenMode::Overwrite,
        DatabaseSettings {
            mock_time: Some(msg0_time),
            ..DatabaseSettings::default()
        },
    )
    .unwrap();
    let mut db = db.begin_session_mut().unwrap();
    db.disable_filesystem_sync().unwrap();

    println!("Cur cutoff time: {:?}", db.current_cutoff_time());

    for i in 0..3 {
        db.append_single(
            &MessageFrame::new(
                MessageId::new_debug2(i),
                vec![],
                DocMessage {
                    val: 1,
                    reset: false,
                },
            ),
            false,
        )
        .unwrap();
    }
    assert_eq!(db.count_messages(), 3);

    db.append_single(
        &MessageFrame::new(
            MessageId::new_debug2(10),
            vec![],
            DocMessage {
                val: 0,
                reset: true,
            },
        ),
        false,
    )
    .unwrap();

    assert_eq!(db.count_messages(), 1);
}