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/.

When config.max_map_size is 0 (the default) the map size is derived from the available disk space on the partition that hosts the database, minus config.disk_reserve. This allows a node to use all available storage without a fixed cap. If the operator adds more storage later the map is resized on demand (see Self::put).

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.

Before writing, verifies that available disk space exceeds the configured reserve. If the LMDB map is full but more disk space exists (e.g. the operator added storage), the map is resized automatically and the write is retried.

Returns

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

Errors

Returns an error if the write fails, content doesn’t match address, or the disk is too full to accept new chunks.

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

Retrieve a chunk.

Returns

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

Errors

Returns an error if read fails or verification 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.

pub async fn all_keys(&self) -> Result<Vec<XorName>>

Return all stored record keys.

Iterates the LMDB database in a read transaction. Used by the replication subsystem for hint construction and audit sampling.

Errors

Returns an error if the LMDB read transaction fails.

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

Retrieve raw chunk bytes without content-address verification.

Used by the audit subsystem to compute digests over stored bytes. Unlike Self::get, this does not verify hash(content) == address.

Errors

Returns an error if the LMDB read transaction fails.