Struct BlobStore 

pub struct BlobStore { /* private fields */ }

The Content Addressable Storage blob store.

Stores blobs indexed by BLAKE3 hash on the local filesystem. Provides deduplication, optional compression, and integrity verification.

Thread Safety

BlobStore is Send + Sync and can be shared across threads via Arc. The pack index cache uses Mutex for interior mutability.

Implementations

impl BlobStore

pub fn new(root: impl Into<PathBuf>) -> Result<Self, CasError>

Create a new BlobStore rooted at the given directory.

Creates the objects/ subdirectory if it doesn’t exist.

pub fn open_in_memory() -> Result<Self, CasError>

Create a BlobStore backed by a temporary directory.

Useful for testing and in-memory repository usage. The temporary directory is cleaned up when the BlobStore is dropped.

pub fn new_uncompressed(root: impl Into<PathBuf>) -> Result<Self, CasError>

Create a BlobStore with compression disabled (for testing).

pub fn set_verify_on_read(&mut self, verify: bool)

Set whether to verify blob hashes on read.

When disabled, get_blob() skips the BLAKE3 hash verification step, saving O(n) computation per read. The content-addressed storage scheme already provides correctness by construction (the filename is the hash), so this is safe for performance-critical paths like snapshot_head() which may read many blobs in sequence.

pub fn verify_on_read(&self) -> bool

Check whether hash verification is enabled on read.

pub fn put_blob(&self, data: &[u8]) -> Result<Hash, CasError>

Store a blob, returning its BLAKE3 hash.

If a blob with the same hash already exists, this is a no-op (deduplication). Returns the hash either way.

pub fn put_blob_new(&self, data: &[u8]) -> Result<Hash, CasError>

Store a blob, returning an error if it already exists.

pub fn put_blob_with_hash( &self, data: &[u8], expected_hash: &Hash, ) -> Result<(), CasError>

Store a blob with an explicit hash (used when receiving blobs from a remote).

Verifies the data matches the expected hash before storing.

pub fn get_blob(&self, hash: &Hash) -> Result<Vec<u8>, CasError>

Retrieve a blob by its BLAKE3 hash.

Tries loose objects first, then pack files. Decompresses if necessary and verifies the hash of the result (unless verification was disabled via set_verify_on_read(false)).

pub fn has_blob(&self, hash: &Hash) -> bool

Check if a blob exists in the store.

Checks loose objects first, then pack files. This does NOT verify the blob’s integrity — it only checks for existence.

pub fn delete_blob(&self, hash: &Hash) -> Result<(), CasError>

Delete a blob from the store.

The caller is responsible for ensuring no patches reference this blob.

pub fn blob_count(&self) -> Result<u64, CasError>

Get the total number of blobs in the store.

pub fn total_size(&self) -> Result<u64, CasError>

Get the total size of all blobs in the store (compressed).

pub fn list_blobs(&self) -> Result<Vec<Hash>, CasError>

List all blob hashes in the store.

pub fn objects_dir(&self) -> PathBuf

Get the path to the objects directory.

pub fn pack_dir(&self) -> PathBuf

Get the path to the pack directory.

pub fn invalidate_pack_cache(&self)

Invalidate the pack cache (call after repack or external pack changes).

pub fn get_blob_packed(&self, hash: &Hash) -> Result<Vec<u8>, CasError>

Retrieve a blob from pack files only (not loose objects).

pub fn has_blob_packed(&self, hash: &Hash) -> bool

Check if a blob exists in any pack file.

pub fn list_blobs_packed(&self) -> Result<Vec<Hash>, CasError>

List all blob hashes stored in pack files.

pub fn repack(&self, threshold: usize) -> Result<usize, CasError>

Repack loose blobs into a pack file if the count exceeds the threshold.

Returns the number of blobs that were packed. If the loose blob count is at or below the threshold, no packing occurs and 0 is returned. After successful packing, the loose blobs are removed.