aboutsummaryrefslogtreecommitdiff
path: root/database/src/transaction.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-12-18 18:45:53 +0100
committermetamuffin <metamuffin@disroot.org>2025-12-18 18:45:53 +0100
commitda985cc06e4caa7501222dbf54f212536fd42b0c (patch)
tree106ebacb66abb8fd97a7be4e802ac45d8ce9852d /database/src/transaction.rs
parentfc7f3ae8e39a0398ceba7b9c44f58679c01a98da (diff)
downloadjellything-da985cc06e4caa7501222dbf54f212536fd42b0c.tar
jellything-da985cc06e4caa7501222dbf54f212536fd42b0c.tar.bz2
jellything-da985cc06e4caa7501222dbf54f212536fd42b0c.tar.zst
transaction interface
Diffstat (limited to 'database/src/transaction.rs')
-rw-r--r--database/src/transaction.rs42
1 files changed, 0 insertions, 42 deletions
diff --git a/database/src/transaction.rs b/database/src/transaction.rs
deleted file mode 100644
index c0e89b7..0000000
--- a/database/src/transaction.rs
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- 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::backends::KV;
-use anyhow::Result;
-use std::sync::Arc;
-
-pub struct TransactionController {
- db: Arc<dyn KV>,
-}
-impl TransactionController {
- pub fn transact(&self, tx: impl Fn(&mut Transaction) -> Result<()>) -> Result<()> {
- tx(&mut Transaction {
- db: self.db.clone(),
- })?;
- Ok(())
- }
-}
-
-pub struct Transaction {
- db: Arc<dyn KV>,
-}
-impl KV for Transaction {
- fn set(&self, key: &[u8], value: &[u8]) -> Result<()> {
- self.db.set(key, value)
- }
- fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>> {
- self.db.get(key)
- }
- fn del(&self, key: &[u8]) -> Result<()> {
- self.db.del(key)
- }
- fn next(&self, key: &[u8]) -> Result<Option<Vec<u8>>> {
- self.db.next(key)
- }
- fn prev(&self, key: &[u8]) -> Result<Option<Vec<u8>>> {
- self.db.prev(key)
- }
-}