Struct BlobStore 

pub struct BlobStore { /* private fields */ }

A content-addressed blob store over a pluggable object backend.

Implementations

impl BlobStore

pub fn new(data_dir: &str) -> Result<Self>

Open the blob store on the local filesystem at <data_dir>/blobs, or at TAEL_BLOB_DIR when set (e.g. a separate fast mount). This is the default, single-binary path.

pub fn with_backend(backend: Arc<dyn ObjectBackend>) -> Result<Self>

Open the blob store on an arbitrary object backend (e.g. GCS). The path layout is identical, so the backend is a transparent swap.

pub fn put(&self, content: &[u8]) -> Result<String>

Hash content, write it snap-compressed if not already present, and return the hex sha256. Idempotent: re-putting identical content is a cheap no-op (the dedup property).

pub fn get(&self, hash: &str) -> Result<Option<Vec<u8>>>

Fetch and decompress a blob by hex sha256. Ok(None) if it doesn’t exist (e.g. GC’d under retention).

pub fn list_hashes(&self) -> Result<Vec<String>>

List every stored blob hash.

pub fn remove(&self, hash: &str) -> Result<()>

Delete a blob by hash. Missing blobs are a no-op.

pub fn gc(&self, live: &HashSet<String>) -> Result<usize>

Mark-and-sweep GC: delete every blob whose hash is not in live. Returns the number of blobs removed. (Blobs are written before their referencing row, so an orphan = a row that never landed, or a row that retention has since dropped — both safe to collect.)

Single-owner contract: on a shared object store this must run on exactly one node with a live set spanning all shards, or it will delete blobs other shards still reference. lib.rs enforces this by disabling per-node GC when the blob store is shared (GCS) unless this node is the designated coordinator.