diff options
| author | metamuffin <metamuffin@disroot.org> | 2025-12-11 03:25:56 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2025-12-11 03:25:56 +0100 |
| commit | 214b78c581319ee012383134107fa5c371febe09 (patch) | |
| tree | 6d775bbeb54a78c1acc32694dda4b7c21e94219e /cache/src/backends/rocksdb.rs | |
| parent | cd8a77b37fff75d7f2c3e96cf8a58598936b4e04 (diff) | |
| download | jellything-214b78c581319ee012383134107fa5c371febe09.tar jellything-214b78c581319ee012383134107fa5c371febe09.tar.bz2 jellything-214b78c581319ee012383134107fa5c371febe09.tar.zst | |
rocksdb cache backend
Diffstat (limited to 'cache/src/backends/rocksdb.rs')
| -rw-r--r-- | cache/src/backends/rocksdb.rs | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/cache/src/backends/rocksdb.rs b/cache/src/backends/rocksdb.rs new file mode 100644 index 0000000..183664f --- /dev/null +++ b/cache/src/backends/rocksdb.rs @@ -0,0 +1,26 @@ +/* + This file is part of jellything (https://codeberg.org/metamuffin/jellything) + which is licensed under the GNU Affero General Public License (version 3); see /COPYING. + Copyright (C) 2025 metamuffin <metamuffin.org> +*/ + +use crate::{Config, backends::CacheStorage}; +use anyhow::Result; +use rocksdb::DB; + +pub struct Rocksdb(DB); + +impl Rocksdb { + pub fn new(config: &Config) -> Result<Self> { + Ok(Self(rocksdb::DB::open_default(config.path.clone())?)) + } +} + +impl CacheStorage for Rocksdb { + fn store(&self, key: String, value: &[u8]) -> Result<()> { + Ok(self.0.put(key, value)?) + } + fn read(&self, key: &str) -> Result<Option<Vec<u8>>> { + Ok(self.0.get(key)?) + } +} |