aboutsummaryrefslogtreecommitdiffstats
path: root/log_db/src/row.rs
diff options
context:
space:
mode:
authorJan Tuomi <jan@jantuomi.fi>2025-05-03 00:15:02 +0300
committerJan Tuomi <jan@jantuomi.fi>2025-05-03 00:20:36 +0300
commit84ac3652415b662aae9580c008a5aa996d58c9f4 (patch)
tree3d39fe6ce5da76a1102458c120480e4190a70fcf /log_db/src/row.rs
parente17048eddfe2df86abd2d498da2a33b9c3dd8a72 (diff)
Rename to AutereDB
Diffstat (limited to 'log_db/src/row.rs')
-rw-r--r--log_db/src/row.rs70
1 files changed, 0 insertions, 70 deletions
diff --git a/log_db/src/row.rs b/log_db/src/row.rs
deleted file mode 100644
index d8140d2..0000000
--- a/log_db/src/row.rs
+++ /dev/null
@@ -1,70 +0,0 @@
-use super::*;
-
-#[derive(Debug, Clone)]
-pub struct Row {
- pub values: Vec<Value>,
- pub tombstone: bool,
-}
-
-impl Row {
- pub fn serialize(&self) -> Vec<u8> {
- let mut bytes = Vec::new();
-
- if self.tombstone {
- bytes.extend(&[B_TOMBSTONE]);
- } else {
- bytes.extend(&[B_LIVE]);
- }
-
- for value in &self.values {
- bytes.extend(value.serialize());
- }
- bytes
- }
-
- pub fn deserialize(bytes: &[u8]) -> Row {
- assert!(bytes.len() > 0);
-
- let mut values = Vec::new();
-
- let tombstone = bytes[0] == B_TOMBSTONE;
-
- let mut start = 1;
- while start < bytes.len() {
- let (rv, consumed) = Value::deserialize(&bytes[start..]);
- values.push(rv);
- start += consumed;
- }
- Row { values, tombstone }
- }
-}
-
-#[cfg(test)]
-mod tests {
- use super::*;
-
- #[test]
- fn test_record_serialize_deserialize() {
- let record = Row {
- values: vec![
- Value::Int(1),
- Value::String("hello".to_string()),
- Value::Bytes(vec![0, 1, 2, 3]),
- ],
- tombstone: true,
- };
-
- let serialized = record.serialize();
- let deserialized = Row::deserialize(&serialized);
- let reserialized = deserialized.serialize();
-
- assert_eq!(serialized.len(), reserialized.len());
- assert_eq!(record.values, deserialized.values);
- }
-}
-
-#[derive(Clone, Debug)]
-pub enum TxEntry {
- Upsert { row: Row },
- Delete { row: Row },
-}