Struct MemoryPackSink 

pub struct MemoryPackSink { /* private fields */ }

The upload handle of MemoryBlobStore. It hashes incrementally and buffers the blob: the one exception to PackSink’s one-part memory bound, since this backend holds every blob in memory anyway.

Trait Implementations

impl Debug for MemoryPackSink

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

Formats the value using the given formatter.

impl PackSink for MemoryPackSink

async fn write(&mut self, chunk: Bytes) -> Result<(), StoreError>

Append a chunk. Writing past the declared length is StoreError::Invalid.

async fn commit(self) -> Result<CommitOutcome, StoreError>

Make the blob visible, only if BLAKE3(bytes) == key and the total equals the declared length; otherwise StoreError::Invalid and nothing is visible (a streaming backend withholds its final part until the hash verifies).

async fn commit_with_root( self, content_root: Hash, ) -> Result<CommitOutcome, StoreError>

Make an object blob visible, only if the total equals the declared length and BLAKE3(bytes) == content_root (the key is the object id, so it cannot be the hash of the bytes). Verification and visibility are as for Self::commit: a streaming backend withholds its final byte until the root verifies. A pack or marker key is StoreError::Invalid. A backend that cannot verify a root is StoreError::Unsupported, which is the default.

async fn abort(self)

Discard the upload; nothing becomes visible.