Struct Get

pub struct Get { /* private fields */ }

A pending fuchsia.pkg/PackageCache.Get() request. Clients must, in order:

1. open/write the meta blob, if Some(NeededBlob) is provided by that API
2. enumerate all missing content blobs
3. open/write all missing content blobs, if Some(NeededBlob) is provided by that API
4. finish() to complete the Get() request.

Implementations

impl Get

pub fn make_open_meta_blob(&mut self) -> DeferredOpenBlob

Returns an independent object that can be used to open the meta blob for write. See Self::open_meta_blob.

pub async fn open_meta_blob( &mut self, ) -> Result<Option<NeededBlob>, OpenBlobError>

Opens the meta blob for write, if it is still needed. The blob’s data can be provided using the returned NeededBlob.

pub fn get_missing_blobs( &mut self, ) -> impl Stream<Item = Result<Vec<BlobInfo>, ListMissingBlobsError>> + Unpin

Determines the set of blobs that the caller must open/write to complete this Get() operation. The returned stream will never yield an empty Vec. Callers should process the missing blobs (via make_open_blob or open_blob) concurrently with reading the stream to guarantee stream termination.

pub fn make_open_blob(&mut self, content_blob: BlobId) -> DeferredOpenBlob

Returns an independent object that can be used to open the content_blob for write. See Self::open_blob.

pub async fn open_blob( &mut self, content_blob: BlobId, ) -> Result<Option<NeededBlob>, OpenBlobError>

Opens content_blob for write, if it is still needed. The blob’s data can be provided using the returned NeededBlob.

pub async fn finish(self) -> Result<PackageDirectory, GetError>

Notifies the endpoint that all blobs have been written and wait for the response to the pending Get() request, returning the cached [PackageDirectory].

pub async fn abort(self)

Aborts this caching operation for the package.

Trait Implementations

impl Debug for Get

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

Formats the value using the given formatter.