Struct LmdbStorage 

pub struct LmdbStorage { /* private fields */ }

Content-addressed LMDB storage.

Uses heed (LMDB wrapper) for memory-mapped, transactional chunk storage. Keys are 32-byte XorName addresses, values are raw chunk bytes.

Implementations

impl LmdbStorage

pub async fn new(config: LmdbStorageConfig) -> Result<Self>

Create a new LMDB storage instance.

Opens (or creates) an LMDB environment at {root_dir}/chunks.mdb/.

Errors

Returns an error if the LMDB environment cannot be opened.

pub async fn put(&self, address: &XorName, content: &[u8]) -> Result<bool>

Store a chunk.

Arguments

• address - Content address (should be BLAKE3 of content)
• content - Chunk data

Returns

Returns true if the chunk was newly stored, false if it already existed.

Errors

Returns an error if the write fails or content doesn’t match address.

pub async fn put_raw(&self, address: &XorName, data: &[u8]) -> Result<bool>

Store data at the given address without content-address verification.

Use this for data types where the address is not BLAKE3(content).

Errors

Returns an error if the write fails.

pub async fn put_overwrite(&self, address: &XorName, data: &[u8]) -> Result<()>

Overwrite a record at the given address without content-address verification.

Unlike put_raw, this does not check for existing records and will overwrite them. Used for mutable data types where the handler has already validated the update.

Errors

Returns an error if the write fails.

pub async fn get(&self, address: &XorName) -> Result<Option<Vec<u8>>>

Retrieve a chunk.

Arguments

• address - Content address to retrieve

Returns

Returns Some(content) if found, None if not found.

Errors

Returns an error if read fails or verification fails.

pub async fn get_raw(&self, address: &XorName) -> Result<Option<Vec<u8>>>

Retrieve raw data without content-address verification.

Use this for non-chunk data types where the stored bytes are serialized records, not raw content.

Errors

Returns an error if the read fails.

pub fn exists(&self, address: &XorName) -> Result<bool>

Check if a chunk exists.

Errors

Returns an error if the LMDB read transaction fails.

pub async fn delete(&self, address: &XorName) -> Result<bool>

Delete a chunk.

Errors

Returns an error if deletion fails.

pub fn stats(&self) -> StorageStats

Get storage statistics.

pub fn current_chunks(&self) -> Result<u64>

Return the number of chunks currently stored, queried from LMDB metadata.

This is an O(1) read of the B-tree page header — not a full scan.

Errors

Returns an error if the LMDB read transaction fails.

pub fn compute_address(content: &[u8]) -> XorName

Compute content address (BLAKE3 hash).

pub fn root_dir(&self) -> &Path

Get the root directory.