From 84ac3652415b662aae9580c008a5aa996d58c9f4 Mon Sep 17 00:00:00 2001 From: Jan Tuomi Date: Sat, 3 May 2025 00:15:02 +0300 Subject: Rename to AutereDB --- log_db/src/memtable_secondary.rs | 66 ---------------------------------------- 1 file changed, 66 deletions(-) delete mode 100644 log_db/src/memtable_secondary.rs (limited to 'log_db/src/memtable_secondary.rs') diff --git a/log_db/src/memtable_secondary.rs b/log_db/src/memtable_secondary.rs deleted file mode 100644 index e1ca835..0000000 --- a/log_db/src/memtable_secondary.rs +++ /dev/null @@ -1,66 +0,0 @@ -use once_cell::sync::Lazy; - -use super::*; -use std::collections::{btree_map::Values, BTreeMap}; - -pub struct SecondaryMemtable { - /// A 2-layer map of records indexed by SK => PK => LogKey. - /// The PK information is required to tell two records apart. - records: BTreeMap, -} - -static EMPTY_MAP: Lazy> = Lazy::new(|| BTreeMap::new()); - -impl SecondaryMemtable { - pub fn new() -> SecondaryMemtable { - SecondaryMemtable { - records: BTreeMap::new(), - } - } - - pub fn set(&mut self, pk: IndexableValue, sk: IndexableValue, value: LogKey) { - match self.records.get_mut(&sk) { - Some(map) => { - map.insert(pk, value); - } - None => { - self.records - .insert(sk, LogKeyMap::new_with_initial(pk, value)); - } - }; - } - - pub fn find_by(&self, key: &IndexableValue) -> Values { - match self.records.get(key) { - Some(set) => set.log_keys(), - None => EMPTY_MAP.values(), - } - } - - // Remove a single mapping associated with the given PK and SK. Returns `true` - // if the log key existed and was removed, `false` otherwise. - pub fn remove(&mut self, pk: &IndexableValue, sk: &IndexableValue) -> bool { - let map = match self.records.get_mut(sk) { - Some(set) => set, - None => return false, - }; - if map.len() == 1 && map.contains_pk(pk) { - self.records.remove(sk); - true - } else { - return match map.remove_pk(pk) { - Ok(_) => true, - Err(LogKeyMapError::NotFoundError) => false, - Err(e) => panic!("{:?}", e), - }; - } - } - - pub fn range>(&self, range: B) -> Vec<&LogKey> { - let mut keys = Vec::new(); - for (_, map) in self.records.range(range) { - keys.extend(map.log_keys()); - } - keys - } -} -- cgit v1.3