Struct BlobStore 

pub struct BlobStore { /* private fields */ }

One SQLite-backed immutable payload plane for one repository family.

Implementations

impl BlobStore

pub fn open( storage: &Path, artifact_key: impl Into<String>, plane: BlobPlane, ) -> Result<Self, BlobStoreError>

Opens <storage>/blobs/<artifact_key>/<plane>.sqlite and creates its schema under BEGIN IMMEDIATE. Existing corrupt SQLite headers are preserved beside the database before a clean empty store is created.

pub fn open_with_breaker( storage: &Path, artifact_key: impl Into<String>, plane: BlobPlane, breaker: &dyn BlobStoreBreaker, ) -> Result<Self, BlobStoreError>

Like Self::open, but invokes the supplied breaker exactly once after corruption recovery has completed successfully.

pub fn artifact_key(&self) -> &str

pub const fn plane(&self) -> BlobPlane

pub fn path(&self) -> &Path

pub fn pragmas(&self) -> &BlobStorePragmas

pub fn usage(&self) -> Result<BlobUsage, BlobStoreError>

Returns current payload rows plus the SQLite file allocation. Quota admission uses this before an insert so a rejected payload never enters the immutable store.

pub fn put( &mut self, full_key: &FullKey, payload: &[u8], ) -> Result<PutReport, BlobStoreError>

Inserts a payload once. An existing row is never updated, even if its bytes fail a later integrity check; callers must use a new producer key.

pub fn get(&self, full_key: &FullKey) -> Result<Option<Vec<u8>>, BlobStoreError>

Reads a payload only after verifying its stored digest and schema. A malformed row is indistinguishable from a miss to consumers, but remains on disk for quarantine/forensics rather than being rewritten in place.

pub fn quarantine(&mut self, full_key: &FullKey) -> Result<(), BlobStoreError>

Records a deterministic failure without modifying the immutable payload table. Subsequent puts report quarantined until a changed key is used.

Trait Implementations

impl Debug for BlobStore

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

Formats the value using the given formatter.