Struct oci_wasm::WasmClient

pub struct WasmClient { /* private fields */ }

A light wrapper around the oci-distribution client to add support for the application/wasm type

Implementations

impl WasmClient

pub fn new(client: Client) -> Self

Create a new client

pub async fn pull( &self, image: &Reference, auth: &RegistryAuth ) -> Result<ImageData>

A convenience wrapper around Client::pull that pulls a wasm component and errors if there are layers that aren’t wasm

pub async fn pull_manifest_and_config( &self, image: &Reference, auth: &RegistryAuth ) -> Result<(OciImageManifest, WasmConfig, String)>

A convenience wrapper around Client::pull_manifest_and_config that parses the config as a WasmConfig type

pub async fn push( &self, image: &Reference, auth: &RegistryAuth, component_layer: ImageLayer, config: impl ToConfig, annotations: Option<HashMap<String, String>> ) -> Result<PushResponse>

A convenience wrapper around Client::push that pushes a wasm component or module with the given config and optional annotations for the manifest

Methods from Deref<Target = Client>

pub async fn list_tags( &self, image: &Reference, auth: &RegistryAuth, n: Option<usize>, last: Option<&str> ) -> Result<TagResponse, OciDistributionError>

Fetches the available Tags for the given Reference

The client will check if it’s already been authenticated and if not will attempt to do.

pub async fn pull( &self, image: &Reference, auth: &RegistryAuth, accepted_media_types: Vec<&str> ) -> Result<ImageData, OciDistributionError>

Pull an image and return the bytes

The client will check if it’s already been authenticated and if not will attempt to do.

pub async fn push( &self, image_ref: &Reference, layers: &[ImageLayer], config: Config, auth: &RegistryAuth, manifest: Option<OciImageManifest> ) -> Result<PushResponse, OciDistributionError>

Push an image and return the uploaded URL of the image

The client will check if it’s already been authenticated and if not will attempt to do.

If a manifest is not provided, the client will attempt to generate it from the provided image and config data.

Returns pullable URL for the image

pub async fn push_blob( &self, image_ref: &Reference, data: &[u8], digest: &str ) -> Result<String, OciDistributionError>

Pushes a blob to the registry

pub async fn auth( &self, image: &Reference, authentication: &RegistryAuth, operation: RegistryOperation ) -> Result<Option<String>, OciDistributionError>

Perform an OAuth v2 auth request if necessary.

This performs authorization and then stores the token internally to be used on other requests.

pub async fn fetch_manifest_digest( &self, image: &Reference, auth: &RegistryAuth ) -> Result<String, OciDistributionError>

Fetch a manifest’s digest from the remote OCI Distribution service.

If the connection has already gone through authentication, this will use the bearer token. Otherwise, this will attempt an anonymous pull.

Will first attempt to read the Docker-Content-Digest header using a HEAD request. If this header is not present, will make a second GET request and return the SHA256 of the response body.

pub async fn pull_image_manifest( &self, image: &Reference, auth: &RegistryAuth ) -> Result<(OciImageManifest, String), OciDistributionError>

Pull a manifest from the remote OCI Distribution service.

The client will check if it’s already been authenticated and if not will attempt to do.

A Tuple is returned containing the OciImageManifest and the manifest content digest hash.

If a multi-platform Image Index manifest is encountered, a platform-specific Image manifest will be selected using the client’s default platform resolution.

pub async fn pull_manifest_raw( &self, image: &Reference, auth: &RegistryAuth, accepted_media_types: &[&str] ) -> Result<(Vec<u8>, String), OciDistributionError>

Pull a manifest from the remote OCI Distribution service without parsing it.

The client will check if it’s already been authenticated and if not will attempt to do.

A Tuple is returned containing raw byte representation of the manifest and the manifest content digest.

pub async fn pull_manifest( &self, image: &Reference, auth: &RegistryAuth ) -> Result<(OciManifest, String), OciDistributionError>

Pull a manifest from the remote OCI Distribution service.

The client will check if it’s already been authenticated and if not will attempt to do.

A Tuple is returned containing the Manifest and the manifest content digest hash.

pub async fn pull_manifest_and_config( &self, image: &Reference, auth: &RegistryAuth ) -> Result<(OciImageManifest, String, String), OciDistributionError>

Pull a manifest and its config from the remote OCI Distribution service.

The client will check if it’s already been authenticated and if not will attempt to do.

A Tuple is returned containing the OciImageManifest, the manifest content digest hash and the contents of the manifests config layer as a String.

pub async fn push_manifest_list( &self, reference: &Reference, auth: &RegistryAuth, manifest: OciImageIndex ) -> Result<String, OciDistributionError>

Push a manifest list to an OCI registry.

This pushes a manifest list to an OCI registry.

pub async fn pull_blob<T>( &self, image: &Reference, layer: &OciDescriptor, out: T ) -> Result<(), OciDistributionError>

where T: AsyncWrite + Unpin,

Pull a single layer from an OCI registry.

This pulls the layer for a particular image that is identified by the given layer descriptor. The image reference is used to find the repository and the registry, but it is not used to verify that the digest is a layer inside of the image. (The manifest is used for that.)

pub async fn pull_blob_stream( &self, image: &Reference, layer: &OciDescriptor ) -> Result<impl Stream<Item = Result<Bytes, Error>>, OciDistributionError>

Stream a single layer from an OCI registry.

This is a streaming version of Client::pull_blob. Returns Stream.

pub async fn mount_blob( &self, image: &Reference, source: &Reference, digest: &str ) -> Result<(), OciDistributionError>

Mounts a blob to the provided reference, from the given source

pub async fn push_manifest( &self, image: &Reference, manifest: &OciManifest ) -> Result<String, OciDistributionError>

Pushes the manifest for a specified image

Returns pullable manifest URL

pub async fn push_manifest_raw( &self, image: &Reference, body: Vec<u8>, content_type: HeaderValue ) -> Result<String, OciDistributionError>

Pushes the manifest, provided as raw bytes, for a specified image

Returns pullable manifest url

Trait Implementations

impl AsRef<Client> for WasmClient

fn as_ref(&self) -> &Client

Converts this type into a shared reference of the (usually inferred) input type.

impl Deref for WasmClient

type Target = Client

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<Client> for WasmClient

fn from(value: Client) -> Self

Converts to this type from the input type.

impl From<WasmClient> for Client

fn from(value: WasmClient) -> Self

Converts to this type from the input type.