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.

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.