Struct PartUploadSession 

pub struct PartUploadSession<'p, B: MultipartBlobStore, N, H> { /* private fields */ }

One part stream. The store owns its bounded hasher and staged bytes; this handle keeps the byte count, authenticated commitment and at most 256 KiB of private buffering before an authority-checked storage write.

Implementations

impl<B: MultipartBlobStore, N: NamespaceStore, H: HookSet> PartUploadSession<'_, B, N, H>

pub async fn push(&mut self, chunk: Bytes) -> Result<(), ServerError>

Write one nonempty chunk, rejecting an overrun before storing it.

Errors

invalid_argument for an empty or overlong chunk; storage errors retain the fixed redacted message.

pub async fn finish(self) -> Result<Vec<u8>, ServerError>

Verify and commit the part, returning its authenticated receipt.

Errors

invalid_argument for a short part or mismatched subtree.

pub async fn abort(self)

Discard an incomplete part. An older committed copy of this index is untouched.

pub async fn abort_with(self, err: &ServerError)

Discard an incomplete stream and record the error returned to the client.

Trait Implementations

impl<B: MultipartBlobStore, N, H> Debug for PartUploadSession<'_, B, N, H>

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

Formats the value using the given formatter.