Struct ContentAddressedArchive 

pub struct ContentAddressedArchive {
    pub config: ArchiveConfig,
    pub index: ArchiveIndex,
    pub data: Vec<u8>,
}

An append-only, content-addressed archive for storing immutable data blobs.

Data is kept in a flat in-memory byte array (data). Each entry records the offset and length of its blob so that slices can be returned without copying. Removed entries are tombstoned in their metadata; their bytes remain in the flat array but are excluded from all live-entry computations.

Fields

config: ArchiveConfig

Archive capacity and behaviour settings.

index: ArchiveIndex

CID → entry index.

data: Vec<u8>

Flat byte array holding all blob data (including tombstoned blobs).

Implementations

impl ContentAddressedArchive

pub fn new(config: ArchiveConfig) -> Self

Create a new, empty archive with the given configuration.

pub fn is_full(&self) -> bool

Returns true when the archive has reached either of its capacity limits.

pub fn put( &mut self, data: Vec<u8>, metadata: HashMap<String, String>, now: u64, ) -> Result<String, ArchiveError>

Insert a blob into the archive.

Computes the CID from data, checks for duplicates, enforces capacity limits, appends the bytes to the flat array, and records the entry.

Returns the computed CID on success.

pub fn get(&self, cid: &str) -> Result<&[u8], ArchiveError>

Retrieve the raw bytes of the blob identified by cid.

pub fn get_entry(&self, cid: &str) -> Result<&ArchiveEntry, ArchiveError>

Retrieve the metadata entry for the blob identified by cid.

pub fn contains(&self, cid: &str) -> bool

Returns true if a live entry with cid exists.

pub fn remove(&mut self, cid: &str) -> Result<Vec<u8>, ArchiveError>

Logically remove the entry for cid, returning the original blob bytes.

The entry is kept in the index with "_tombstone" = "true" in its metadata; the raw bytes remain in the flat data array.

pub fn list_cids(&self) -> Vec<&str>

Return the sorted list of all live CID strings (alphabetical order).

pub fn list_entries(&self) -> Vec<&ArchiveEntry>

Return live entries sorted by CID.

pub fn total_data_bytes(&self) -> u64

Total bytes occupied by live entries.

pub fn entry_count(&self) -> usize

Number of live entries.

pub fn verify_integrity(&self) -> Vec<String>

Verify every live entry by recomputing its CID from stored bytes.

Returns the CIDs of entries where the recomputed CID differs from the recorded CID (indicating data corruption).

pub fn export_entries(&self) -> Vec<ArchiveBlock>

Export all live entries as ArchiveBlock values.

pub fn merge( &mut self, other: &ContentAddressedArchive, now: u64, ) -> Result<usize, ArchiveError>

Import all live entries from other that are not already present in self. Returns the number of entries added.

Entries that already exist (even as tombstones) in self are skipped.

pub fn stats(&self) -> ArchiveStats

Compute aggregate statistics for the archive.

Trait Implementations

impl Clone for ContentAddressedArchive

fn clone(&self) -> ContentAddressedArchive

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContentAddressedArchive

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

Formats the value using the given formatter.