From da985cc06e4caa7501222dbf54f212536fd42b0c Mon Sep 17 00:00:00 2001 From: metamuffin Date: Thu, 18 Dec 2025 18:45:53 +0100 Subject: transaction interface --- database/src/transaction.rs | 42 ------------------------------------------ 1 file changed, 42 deletions(-) delete mode 100644 database/src/transaction.rs (limited to 'database/src/transaction.rs') 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 -*/ - -use crate::backends::KV; -use anyhow::Result; -use std::sync::Arc; - -pub struct TransactionController { - db: Arc, -} -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, -} -impl KV for Transaction { - fn set(&self, key: &[u8], value: &[u8]) -> Result<()> { - self.db.set(key, value) - } - fn get(&self, key: &[u8]) -> Result>> { - self.db.get(key) - } - fn del(&self, key: &[u8]) -> Result<()> { - self.db.del(key) - } - fn next(&self, key: &[u8]) -> Result>> { - self.db.next(key) - } - fn prev(&self, key: &[u8]) -> Result>> { - self.db.prev(key) - } -} -- cgit v1.3