worktable 0.9.0-alpha9

WorkTable is in-memory storage
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
83
84
85

use indexset::cdc::change::ChangeEvent;
use indexset::core::pair::Pair;

pub fn convert_change_event<T, L1, L2>(ev: ChangeEvent<Pair<T, L1>>) -> ChangeEvent<Pair<T, L2>>
where
    L1: Into<L2>,
{
    match ev {
        ChangeEvent::InsertAt {
            event_id,
            max_value,
            value,
            index,
        } => ChangeEvent::InsertAt {
            event_id,
            max_value: Pair {
                key: max_value.key,
                value: max_value.value.into(),
            },
            value: Pair {
                key: value.key,
                value: value.value.into(),
            },
            index,
        },
        ChangeEvent::RemoveAt {
            event_id,
            max_value,
            value,
            index,
        } => ChangeEvent::RemoveAt {
            event_id,
            max_value: Pair {
                key: max_value.key,
                value: max_value.value.into(),
            },
            value: Pair {
                key: value.key,
                value: value.value.into(),
            },
            index,
        },
        ChangeEvent::CreateNode {
            event_id,
            max_value,
        } => ChangeEvent::CreateNode {
            event_id,
            max_value: Pair {
                key: max_value.key,
                value: max_value.value.into(),
            },
        },
        ChangeEvent::RemoveNode {
            event_id,
            max_value,
        } => ChangeEvent::RemoveNode {
            event_id,
            max_value: Pair {
                key: max_value.key,
                value: max_value.value.into(),
            },
        },
        ChangeEvent::SplitNode {
            event_id,
            max_value,
            split_index,
        } => ChangeEvent::SplitNode {
            event_id,
            max_value: Pair {
                key: max_value.key,
                value: max_value.value.into(),
            },
            split_index,
        },
    }
}

pub fn convert_change_events<T, L1, L2>(
    evs: Vec<ChangeEvent<Pair<T, L1>>>,
) -> Vec<ChangeEvent<Pair<T, L2>>>
where
    L1: Into<L2>,
{
    evs.into_iter().map(convert_change_event).collect()
}