diff options
| author | metamuffin <metamuffin@disroot.org> | 2025-12-15 15:09:37 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2025-12-15 15:09:37 +0100 |
| commit | 0e48299889c3c2b81bf351ffe5da71e0bcd4c22a (patch) | |
| tree | 8a7ff2bd2330c206070b2062723ba471b2d62544 /database/src/backends/memory.rs | |
| parent | 7552a4ff0e027334398d28d5687a339ad77c0871 (diff) | |
| download | jellything-0e48299889c3c2b81bf351ffe5da71e0bcd4c22a.tar jellything-0e48299889c3c2b81bf351ffe5da71e0bcd4c22a.tar.bz2 jellything-0e48299889c3c2b81bf351ffe5da71e0bcd4c22a.tar.zst | |
db
Diffstat (limited to 'database/src/backends/memory.rs')
| -rw-r--r-- | database/src/backends/memory.rs | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/database/src/backends/memory.rs b/database/src/backends/memory.rs index 97c8c2c..2f19ce6 100644 --- a/database/src/backends/memory.rs +++ b/database/src/backends/memory.rs @@ -4,13 +4,18 @@ Copyright (C) 2025 metamuffin <metamuffin.org> */ -use crate::backends::DatabaseStorage; +use crate::backends::KV; use anyhow::Result; use std::{collections::BTreeMap, sync::RwLock}; pub struct Memory(RwLock<BTreeMap<Vec<u8>, Vec<u8>>>); -impl DatabaseStorage for Memory { +impl Memory { + pub fn new() -> Self { + Self(RwLock::new(BTreeMap::new())) + } +} +impl KV for Memory { fn set(&self, key: &[u8], value: &[u8]) -> Result<()> { self.0.write().unwrap().insert(key.to_vec(), value.to_vec()); Ok(()) @@ -18,6 +23,10 @@ impl DatabaseStorage for Memory { fn get<'a>(&'a self, key: &[u8]) -> Result<Option<Vec<u8>>> { Ok(self.0.read().unwrap().get(key).cloned()) } + fn del(&self, key: &[u8]) -> Result<()> { + self.0.write().unwrap().remove(key); + Ok(()) + } fn next(&self, key: &[u8]) -> Result<Option<Vec<u8>>> { let r = self.0.read().unwrap(); Ok(r.range(key.to_vec()..).next().map(|(k, _)| k.to_owned())) |