reifydb-core 0.4.11

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

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

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

/// Transaction conflict occurred due to concurrent modifications
pub fn transaction_conflict() -> Diagnostic {
	Diagnostic {
		code: "TXN_001".to_string(),
		rql: None,
		message: "Transaction conflict detected - another transaction modified the same data".to_string(),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Retry the transaction".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Transaction was discarded due to rollback or abort
pub fn transaction_rolled_back() -> Diagnostic {
	Diagnostic {
		code: "TXN_002".to_string(),
		rql: None,
		message: "Transaction rolled back and cannot be committed".to_string(),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Start a new transaction".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Transaction contains too many writes and exceeds size limits
pub fn transaction_too_large() -> Diagnostic {
	Diagnostic {
		code: "TXN_003".to_string(),
		rql: None,
		message: "Transaction contains too many writes and exceeds size limits".to_string(),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Split the transaction into smaller batches".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Transaction commit failed for a specific reason
pub fn commit_failed(reason: String) -> Diagnostic {
	Diagnostic {
		code: "TXN_004".to_string(),
		rql: None,
		message: format!("Transaction commit failed: {}", reason),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Check transaction state and retry if appropriate".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Transaction was already committed
pub fn transaction_already_committed() -> Diagnostic {
	Diagnostic {
		code: "TXN_008".to_string(),
		rql: None,
		message: "Transaction was already committed".to_string(),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Cannot use a transaction after it has been committed".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Transaction was already rolled back
pub fn transaction_already_rolled_back() -> Diagnostic {
	Diagnostic {
		code: "TXN_009".to_string(),
		rql: None,
		message: "Transaction was already rolled back".to_string(),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Cannot use a transaction after it has been rolled back".to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}

/// Attempted to access a key outside the transaction's declared key scope
pub fn key_out_of_scope(key: String) -> Diagnostic {
	Diagnostic {
		code: "TXN_010".to_string(),
		rql: None,
		message: format!("Key '{}' is not in the transaction's declared key scope", key),
		column: None,
		fragment: Fragment::None,
		label: None,
		help: Some("Declare the key when beginning the transaction or use a different transaction scope"
			.to_string()),
		notes: vec![],
		cause: None,
		operator_chain: None,
	}
}