refactor: implement rocks transaction

Signed-off-by: bsbds <[email protected]>
xline-kv · Apr 22, 2024 · 61de1a9 · 61de1a9
1 parent 668fcdb
commit 61de1a9
Show file tree

Hide file tree

Showing 2 changed files with 384 additions and 7 deletions.
diff --git a/crates/engine/src/rocksdb_engine/mod.rs b/crates/engine/src/rocksdb_engine/mod.rs
@@ -155,7 +155,7 @@ impl StorageEngine for RocksEngine {
 
     #[inline]
     fn transaction(&self) -> RocksTransaction {
-        RocksTransaction {}
+        RocksTransaction::new(Arc::clone(&self.inner), Arc::clone(&self.size))
     }
 
     #[inline]