2 unstable releases
0.2.0 | Jun 22, 2023 |
---|---|
0.1.0 | Apr 6, 2023 |
#40 in #lmdb
Used in datacake
350KB
7.5K
SLoC
Datacake LMDB
A pre-built implementation of the datacake-eventual-consistency Storage
trait, this allows you to set up
a persistent cluster immediately without any hassle of implementing a correct store.
For more info see https://github.com/lnx-search/datacake
Example
use std::env::temp_dir;
use anyhow::Result;
use uuid::Uuid;
use datacake_eventual_consistency::EventuallyConsistentStoreExtension;
use datacake_node::{
ConnectionConfig,
Consistency,
DCAwareSelector,
DatacakeNodeBuilder,
};
use datacake_lmdb::LmdbStorage;
static KEYSPACE: &str = "lmdb-store";
#[tokio::main]
async fn main() -> Result<()> {
tracing_subscriber::fmt::init();
let temp_dir = temp_dir().join(Uuid::new_v4().to_string());
std::fs::create_dir_all(&temp_dir)?;
let store = LmdbStorage::open(temp_dir).await?;
let addr = test_helper::get_unused_addr();
let connection_cfg = ConnectionConfig::new(addr, addr, Vec::<String>::new());
let node = DatacakeNodeBuilder::<DCAwareSelector>::new(1, connection_cfg)
.connect()
.await?;
let store = node
.add_extension(EventuallyConsistentStoreExtension::new(store))
.await?;
let handle = store.handle();
handle.put(KEYSPACE, 1, b"Hello, world".to_vec(), Consistency::All).await?;
let doc = handle
.get(KEYSPACE, 1)
.await?
.expect("Document should not be none");
assert_eq!(doc.id(), 1);
assert_eq!(doc.data(), b"Hello, world");
handle.del(KEYSPACE, 1, Consistency::All).await?;
let doc = handle.get(KEYSPACE, 1).await?;
assert!(doc.is_none(), "No document should not exist!");
handle.del(KEYSPACE, 2, Consistency::All).await?;
let doc = handle.get(KEYSPACE, 2).await?;
assert!(doc.is_none(), "No document should not exist!");
node.shutdown().await;
Ok(())
}
Dependencies
~9–19MB
~270K SLoC