Struct Blob 

pub struct Blob<S> { /* private fields */ }

A blob in the process of being written.

Implementations

impl Blob<NeedsTruncate>

pub async fn truncate( self, size: u64, ) -> Result<TruncateBlobSuccess, TruncateBlobError>

Truncates the blob to the given size. On success, the blob enters the writable state.

pub fn deconstruct( self, ) -> (NeededBlobsProxy, BlobId, ClientEnd<BlobWriterMarker>)

Return the fields for manual handling of the protocol.

The returned BlobWriter client end is in the initial state of the protocol (GetVmo has not been called).

Once the blob has been written through the BlobWriter, BlobWritten should be called on the returned NeededBlobs proxy. The returned NeededBlobs proxy should not otherwise be used.

impl Blob<NeedsData>

pub fn write( self, buf: &[u8], ) -> impl Future<Output = Result<BlobWriteSuccess, WriteBlobError>> + '_

Writes all of the given buffer to the blob.

Panics

Panics if a write is attempted with a buf larger than the remaining blob size.

pub async fn write_with_trace_callbacks( self, buf: &[u8], after_write: &(dyn Fn(u64) + Send + Sync), after_write_ack: &(dyn Fn() + Send + Sync), ) -> Result<BlobWriteSuccess, WriteBlobError>

Writes all of the given buffer to the blob.

after_write and after_write_ack are called before and after, respectively, waiting for the server to acknowledge writes. They may be called multiple times if the write of buf is chunked. after_write is given the size of each write in bytes. Useful for creating trace spans.

Panics

Panics if a write is attempted with a buf larger than the remaining blob size.

impl Blob<NeedsBlobWritten>

pub async fn blob_written(self) -> Result<(), BlobWrittenError>

Tells pkg-cache that the blob has been successfully written and can now be read.

Trait Implementations

impl<S: Debug> Debug for Blob<S>

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

Formats the value using the given formatter.