Struct datacake_lmdb::StorageHandle

pub struct StorageHandle { /* private fields */ }

A asynchronous wrapper around a LMDB database.

These operations will be ran in a background thread preventing any IO operations from blocking the async context.

Implementations

impl StorageHandle

pub async fn open(path: impl AsRef<Path>) -> Result<Self>

Connects to the LMDB database.

This spawns 1 background threads with actions being executed within that thread.

This approach reduces the affect of writes blocking reads and vice-versa.

If the database does not already exist it will be created.

use datacake_lmdb::StorageHandle;

let storage = StorageHandle::open("./my-lmdb-data").await.expect("Create database");

pub fn env(&self) -> &Env

Get the current heed environment.

Trait Implementations

impl Clone for StorageHandle

fn clone(&self) -> StorageHandle

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StorageHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.