summaryrefslogtreecommitdiff
path: root/src/database
diff options
context:
space:
mode:
authorTglman <tglman@tglman.com>2022-10-13 20:02:36 +0100
committerTglman <tglman@tglman.com>2022-10-13 20:02:36 +0100
commit842feabced55fb77060369c41a18c6ec27fcd70f (patch)
treebbc58b9154653726b26306b22b3474908cf8dbb5 /src/database
parentc948324cf25d46754a4d4c0877119eec3e4886a1 (diff)
downloadconduit-842feabced55fb77060369c41a18c6ec27fcd70f.zip
fix: update persy implementation after refactor
Diffstat (limited to 'src/database')
-rw-r--r--src/database/abstraction/persy.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/database/abstraction/persy.rs b/src/database/abstraction/persy.rs
index e78e731..1fa7a0d 100644
--- a/src/database/abstraction/persy.rs
+++ b/src/database/abstraction/persy.rs
@@ -1,6 +1,6 @@
use crate::{
database::{
- abstraction::{watchers::Watchers, DatabaseEngine, Tree},
+ abstraction::{watchers::Watchers, KeyValueDatabaseEngine, KvTree},
Config,
},
Result,
@@ -15,7 +15,7 @@ pub struct Engine {
persy: Persy,
}
-impl DatabaseEngine for Arc<Engine> {
+impl KeyValueDatabaseEngine for Arc<Engine> {
fn open(config: &Config) -> Result<Self> {
let mut cfg = persy::Config::new();
cfg.change_cache_size((config.db_cache_capacity_mb * 1024.0 * 1024.0) as u64);
@@ -27,7 +27,7 @@ impl DatabaseEngine for Arc<Engine> {
Ok(Arc::new(Engine { persy }))
}
- fn open_tree(&self, name: &'static str) -> Result<Arc<dyn Tree>> {
+ fn open_tree(&self, name: &'static str) -> Result<Arc<dyn KvTree>> {
// Create if it doesn't exist
if !self.persy.exists_index(name)? {
let mut tx = self.persy.begin()?;
@@ -61,7 +61,7 @@ impl PersyTree {
}
}
-impl Tree for PersyTree {
+impl KvTree for PersyTree {
fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>> {
let result = self
.persy