reifydb-sdk 0.5.6

SDK for building ReifyDB operators, procedures, transforms and more
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

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

/// Which diff kinds the chaos generator may emit.
///
/// Default is `all()`. The default is independent of the operator's
/// `CAPABILITIES` advertisement on purpose: an operator that advertises
/// Insert-only but silently processes Updates is exactly the bug class this
/// harness is designed to catch.
#[derive(Debug, Clone, Copy)]
pub struct SupportedOps {
	pub insert: bool,
	pub update: bool,
	pub remove: bool,
}

impl Default for SupportedOps {
	fn default() -> Self {
		Self::all()
	}
}

impl SupportedOps {
	pub const fn all() -> Self {
		Self {
			insert: true,
			update: true,
			remove: true,
		}
	}

	pub const fn insert_only() -> Self {
		Self {
			insert: true,
			update: false,
			remove: false,
		}
	}

	pub const fn no_remove() -> Self {
		Self {
			insert: true,
			update: true,
			remove: false,
		}
	}

	pub const fn no_update() -> Self {
		Self {
			insert: true,
			update: false,
			remove: true,
		}
	}
}

#[derive(Debug, Clone, Copy)]
pub enum BatchSizeDist {
	Constant(usize),

	Uniform {
		min: usize,
		max: usize,
	},

	Geometric(f64),
}

impl Default for BatchSizeDist {
	fn default() -> Self {
		Self::Geometric(0.4)
	}
}

#[derive(Debug, Clone, Copy)]
pub struct ChaosConfig {
	pub num_ops: usize,
	pub max_live_rows: usize,
	pub duplicate_update_burst: f64,
	pub update_as_remove_insert: f64,
	pub batch_size: BatchSizeDist,
	pub supported_ops: SupportedOps,
}

impl Default for ChaosConfig {
	fn default() -> Self {
		Self {
			num_ops: 200,
			max_live_rows: 50,
			duplicate_update_burst: 0.3,
			update_as_remove_insert: 0.1,
			batch_size: BatchSizeDist::default(),
			supported_ops: SupportedOps::default(),
		}
	}
}