diff options
author | Alex Auvolat <alex@adnab.me> | 2022-06-03 16:40:38 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-06-03 16:40:38 +0200 |
commit | 2d5541b0e7ed0939e99710f40d3859c05bc31175 (patch) | |
tree | bed4653c7073f927275c8f6aa0f870ea9d227f54 /src/db/lmdb_adapter.rs | |
parent | f7a1c70089bf453554f5ae787da4865caf0ee5c4 (diff) | |
download | garage-2d5541b0e7ed0939e99710f40d3859c05bc31175.tar.gz garage-2d5541b0e7ed0939e99710f40d3859c05bc31175.zip |
Integrate LMDB with rest
Diffstat (limited to 'src/db/lmdb_adapter.rs')
-rw-r--r-- | src/db/lmdb_adapter.rs | 26 |
1 files changed, 25 insertions, 1 deletions
diff --git a/src/db/lmdb_adapter.rs b/src/db/lmdb_adapter.rs index d568b5c5..095f512b 100644 --- a/src/db/lmdb_adapter.rs +++ b/src/db/lmdb_adapter.rs @@ -72,7 +72,31 @@ impl IDb for LmdbDb { } fn list_trees(&self) -> Result<Vec<String>> { - unimplemented!() + let tree0 = match self.db.open_database::<heed::types::Str, ByteSlice>(None)? { + Some(x) => x, + None => return Ok(vec![]), + }; + + let mut ret = vec![]; + let tx = self.db.read_txn()?; + for item in tree0.iter(&tx)? { + let (tree_name, _) = item?; + ret.push(tree_name.to_string()); + } + drop(tx); + + let mut ret2 = vec![]; + for tree_name in ret { + if self + .db + .open_database::<ByteSlice, ByteSlice>(Some(&tree_name))? + .is_some() + { + ret2.push(tree_name); + } + } + + Ok(ret2) } // ---- |