reifydb-core 0.4.12

Core database interfaces and data structures 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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

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

use reifydb_type::{error::Diagnostic, fragment::Fragment};

/// General frame processing error
pub fn frame_error(message: String) -> Diagnostic {
	Diagnostic {
		code: "ENG_001".to_string(),
		rql: None,
		message: format!("Frame processing error: {}", message),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Check frame data and operations".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Column policy saturation error - wraps an existing diagnostic
pub fn saturation_error(diagnostic: Diagnostic) -> Diagnostic {
	let rql = diagnostic.rql.clone();
	let message = diagnostic.message.clone();
	let column = diagnostic.column.clone();
	let fragment = diagnostic.fragment.clone();
	let label = diagnostic.label.clone();
	let notes = diagnostic.notes.clone();

	Diagnostic {
		code: "ENG_002".to_string(),
		rql,
		message: format!("Column policy saturation: {}", message),
		column,
		fragment,
		label,
		help: Some("Adjust column policy constraints".to_string()),
		notes,
		cause: Some(Box::new(diagnostic)),
		operator_chain: None,
	}
}

/// Frame missing required ROW_NUMBER column error
pub fn missing_row_number_column() -> Diagnostic {
	Diagnostic {
		code: "ENG_003".to_string(),
		rql: None,
		message: "Frame must have a __ROW__ID__ column for UPDATE operations".to_string(),
		column: None,
		fragment: Fragment::None,
		label: Some("missing required column".to_string()),
		help: Some("Ensure the query includes the encoded ID in the result set".to_string()),
		notes: vec!["UPDATE operations require encoded identifiers to locate existing rows".to_string()],
		cause: None,
		operator_chain: None,
	}
}

/// Invalid or undefined RowNumber values error
pub fn invalid_row_number_values() -> Diagnostic {
	Diagnostic {
		code: "ENG_004".to_string(),
		rql: None,
		message: "All RowNumber values must be defined for UPDATE operations".to_string(),
		column: None,
		fragment: Fragment::None,
		label: Some("invalid encoded identifiers".to_string()),
		help: Some("Check that the input data contains valid encoded IDs".to_string()),
		notes: vec!["RowNumber column must contain valid identifiers, not none values".to_string()],
		cause: None,
		operator_chain: None,
	}
}

/// Invalid parameter reference error
pub fn invalid_parameter_reference(fragment: Fragment) -> Diagnostic {
	let value = fragment.text();
	Diagnostic {
		code: "ENG_005".to_string(),
		rql: None,
		message: format!("Invalid parameter reference: {}", value),
		column: None,
		fragment,
		label: Some("invalid parameter syntax".to_string()),
		help: Some("Use $1, $2 for positional parameters or $name for named parameters".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Parameter not found error
pub fn parameter_not_found(fragment: Fragment) -> Diagnostic {
	let value = fragment.text();
	Diagnostic {
		code: "ENG_006".to_string(),
		rql: None,
		message: format!("Parameter not found: {}", value),
		column: None,
		fragment,
		label: Some("parameter not provided".to_string()),
		help: Some("Ensure all referenced parameters are provided in the query call".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Write operation rejected because the engine is in read-only (replica) mode.
pub fn read_only_rejection(fragment: Fragment) -> Diagnostic {
	Diagnostic {
		code: "ENG_007".to_string(),
		rql: None,
		message: "Cannot execute write operations on a read-only replica".to_string(),
		column: None,
		fragment,
		label: Some("write rejected".to_string()),
		help: Some("Send write operations (admin, command, subscription) to the primary node".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}