neptune-database 0.14.0

LevelDB-backed async storage layer (schema, vectors, maps) used by neptune-cash
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use super::super::super::neptune_leveldb::NeptuneLevelDb;
use super::traits::StorageReader;
use super::RustyKey;
use super::RustyValue;

// Note: RustyReader and SimpleRustyReader appear to be exactly
// the same.  Can we remove one of them?

/// A read-only database interface
#[derive(Debug, Clone)]
pub struct RustyReader {
    /// LevelDB Database
    pub db: NeptuneLevelDb<RustyKey, RustyValue>,
}

impl StorageReader for RustyReader {
    #[inline]
    async fn get(&self, key: RustyKey) -> Option<RustyValue> {
        self.db.get(key).await
    }

    #[inline]
    async fn get_many(&self, keys: impl IntoIterator<Item = RustyKey>) -> Vec<Option<RustyValue>> {
        futures::future::join_all(keys.into_iter().map(|key| self.db.get(key))).await
    }
}