Struct FsPackSink 

pub struct FsPackSink { /* private fields */ }

The upload handle of FsBlobStore: a temp file and a running hash. Memory is one chunk, never the blob.

Trait Implementations

impl Debug for FsPackSink

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

Formats the value using the given formatter.

impl Drop for FsPackSink

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl PackSink for FsPackSink

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.