reifydb-cdc 0.4.13

Change Data Capture module for ReifyDB
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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

# Copyright (c) reifydb.com 2025
# This file is licensed under the Apache-2.0, see license.md file

# Setup: Create events across multiple versions
insert 1 a=1
commit
---
ok

insert 2 b=2
commit
---
ok

insert 3 c=3
update 3 a=10
commit
---
ok

insert 4 d=4
commit
---
ok

insert 5 e=5
delete 5 b
commit
---
ok

# Test inclusive range [2, 4]
cdc_range_included 2 4
---
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }
v4 Change { seq: 1, change: Insert { key: "d", post: "4" } }

# Test inclusive-exclusive range [2, 4)
cdc_range_included_excluded 2 4
---
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }

# Test exclusive-inclusive range (2, 4]
cdc_range_excluded_included 2 4
---
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }
v4 Change { seq: 1, change: Insert { key: "d", post: "4" } }

# Test exclusive-exclusive range (2, 4)
cdc_range_excluded_excluded 2 4
---
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }

# Test range from start [1, 3]
cdc_range_included 1 3
---
v1 Change { seq: 1, change: Insert { key: "a", post: "1" } }
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }

# Test unbounded start ..=3
cdc_range_to_included 3
---
v1 Change { seq: 1, change: Insert { key: "a", post: "1" } }
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }

# Test unbounded start ..<3
cdc_range_to_excluded 3
---
v1 Change { seq: 1, change: Insert { key: "a", post: "1" } }
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }

# Test unbounded end 3..
cdc_range_from_included 3
---
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }
v4 Change { seq: 1, change: Insert { key: "d", post: "4" } }
v5 Change { seq: 1, change: Insert { key: "e", post: "5" } }
v5 Change { seq: 2, change: Delete { key: "b", pre: "2" } }

# Test unbounded end 3>..
cdc_range_from_excluded 3
---
v4 Change { seq: 1, change: Insert { key: "d", post: "4" } }
v5 Change { seq: 1, change: Insert { key: "e", post: "5" } }
v5 Change { seq: 2, change: Delete { key: "b", pre: "2" } }

# Test fully unbounded range
cdc_range_unbounded
---
v1 Change { seq: 1, change: Insert { key: "a", post: "1" } }
v2 Change { seq: 1, change: Insert { key: "b", post: "2" } }
v3 Change { seq: 1, change: Insert { key: "c", post: "3" } }
v3 Change { seq: 2, change: Update { key: "a", pre: "1", post: "10" } }
v4 Change { seq: 1, change: Insert { key: "d", post: "4" } }
v5 Change { seq: 1, change: Insert { key: "e", post: "5" } }
v5 Change { seq: 2, change: Delete { key: "b", pre: "2" } }