trine-kv 0.6.0

Embedded LSM MVCC key-value database.
Documentation 
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
27
28
29
30
31
32
33

use std::future::Future;
use std::path::Path;

use crate::{
    db::{DatabaseStorageRef, Db},
    error::{Error, Result},
};

impl Db {
    pub(crate) fn block_on_sync_api<T>(
        &self,
        future: impl Future<Output = Result<T>>,
    ) -> Result<T> {
        if self.inner.options.storage_mode.is_object_store_persistent()
            || self.inner.options.storage_mode.is_browser_persistent()
        {
            return Err(Error::unsupported_backend(
                "selected storage backend requires the async API",
            ));
        }
        futures::executor::block_on(future)
    }

    pub(in crate::db) fn storage_read_path(&self) -> Option<&Path> {
        match self.inner.storage.resources() {
            DatabaseStorageRef::Memory(_) => None,
            DatabaseStorageRef::Filesystem(resources) => Some(resources.root),
            DatabaseStorageRef::ObjectStore(resources) => Some(resources.prefix),
            #[cfg(all(target_arch = "wasm32", target_os = "unknown"))]
            DatabaseStorageRef::Browser(resources) => Some(resources.root),
        }
    }
}