Struct WriteBatch 

pub struct WriteBatch<'s> { /* private fields */ }

A set of object writes that become durable and visible together. Created by ObjectStore::batch. See the module docs for the durability contract.

Implementations

impl<'s> WriteBatch<'s>

pub fn write(&self, bytes: &[u8]) -> StoreResult<Hash>

Hash bytes, dedup against staged and on-disk objects, and stage (policy Batch/None) or durably write (policy PerObject) the object. Returns the BLAKE3 hash either way.

pub fn write_parts(&self, parts: &[&[u8]]) -> StoreResult<Hash>

Self::write for an object whose bytes are the concatenation of parts, hashed and written streaming — no concatenated buffer is materialised.

Panics

Panics only if the internal hash-to-path mapping produces a path without a parent directory (impossible by construction) or if a previous write panicked while holding the batch mutex.

pub fn contains(&self, h: &Hash) -> bool

True when h is staged in this batch or already in the store.

Panics

Panics only if a previous write panicked while holding the batch mutex.

pub fn commit(self) -> StoreResult<()>

Make every staged object durable and visible: one full flush, then all renames, then deduplicated shard-directory flushes.

After commit() returns Ok, every hash returned by Self::write/Self::write_parts is durable AND visible. Callers MUST call this before reading any object written by this batch and before writing any ref/index that references one.

If commit() fails partway, already-renamed objects remain visible (content-addressing makes re-running the command idempotent) and not-yet-renamed temp files are unlinked on drop.

Panics

Panics only if a previous write panicked while holding the batch mutex.

Trait Implementations

impl<'s> Debug for WriteBatch<'s>

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

Formats the value using the given formatter.

impl ObjectSink for WriteBatch<'_>

fn put(&self, bytes: &[u8]) -> StoreResult<Hash>

Store bytes as one object, returning its BLAKE3 hash.

fn put_parts(&self, parts: &[&[u8]]) -> StoreResult<Hash>

Store the concatenation of parts as one object without the caller having to materialise the concatenated buffer.

fn has(&self, h: &Hash) -> bool

True when the object is already present (or staged) in this sink.