Struct BuiltinPackageLoader 

pub struct BuiltinPackageLoader {
    client: Arc<dyn HttpClient + Send + Sync>,
    in_memory: Option<InMemoryCache>,
    cache: Option<FileSystemCache>,
    tokens: HashMap<String, String>,
    hash_validation: HashIntegrityValidationMode,
}

The builtin PackageLoader that is used by the wasmer CLI and respects $WASMER_DIR.

Fields

client: Arc<dyn HttpClient + Send + Sync>

in_memory: Option<InMemoryCache>

cache: Option<FileSystemCache>

tokens: HashMap<String, String>

A mapping from hostnames to tokens

hash_validation: HashIntegrityValidationMode

Implementations

impl BuiltinPackageLoader

pub fn new() -> Self

pub fn with_hash_validation_mode( self, mode: HashIntegrityValidationMode, ) -> Self

Set the validation mode to apply after downloading an image.

See HashIntegrityValidationMode for details.

pub fn with_cache_dir(self, cache_dir: impl Into<PathBuf>) -> Self

pub fn without_in_memory_cache(self) -> Self

Disable promotion of loaded containers into the in-memory cache.

pub fn cache(&self) -> Option<&FileSystemCache>

pub fn validate_cache( &self, mode: CacheValidationMode, ) -> Result<Vec<ImageHashMismatchError>, Error>

pub fn with_http_client( self, client: impl HttpClient + Send + Sync + 'static, ) -> Self

pub fn with_shared_http_client( self, client: Arc<dyn HttpClient + Send + Sync>, ) -> Self

pub fn with_tokens<I, K, V>(self, tokens: I) -> Self

where I: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<String>,

pub fn with_token( self, hostname: impl Into<String>, token: impl Into<String>, ) -> Self

Add an API token that will be used whenever sending requests to a particular hostname.

Note that this uses Url::authority() when looking up tokens, so it will match both plain hostnames (e.g. registry.wasmer.io) and hosts with a port number (e.g. localhost:8000).

pub fn insert_cached(&self, hash: WebcHash, container: &Container)

Insert a container into the in-memory hash.

pub fn evict_cached(&self, hash: &WebcHash) -> Option<Container>

Remove a container from the in-memory cache.

async fn get_cached(&self, hash: &WebcHash) -> Result<Option<Container>, Error>

async fn validate_hash( image: &Bytes, mode: HashIntegrityValidationMode, info: &DistributionInfo, ) -> Result<(), Error>

Validate image contents with the specified validation mode.

fn validate_hash_sync( image: &[u8], mode: HashIntegrityValidationMode, info: &DistributionInfo, ) -> Result<(), Error>

Validate image contents with the specified validation mode.

async fn download(&self, dist: &DistributionInfo) -> Result<Bytes, Error>

fn headers(&self, url: &Url) -> HeaderMap

fn decode_response_body( headers: &HeaderMap, body: Vec<u8>, ) -> Result<Vec<u8>, Error>

Decode the response body according to the Content-Encoding header.

• Supports gzip and zstd encodings
• Supports nested encodings (e.g. gzip, zstd)
• Passes through unencoded bodies or “identity” encoding unchanged

Trait Implementations

impl Debug for BuiltinPackageLoader

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

Formats the value using the given formatter.

impl Default for BuiltinPackageLoader

fn default() -> Self

Returns the “default value” for a type.

impl PackageLoader for BuiltinPackageLoader

fn load<'life0, 'life1, 'async_trait>( &'life0 self, summary: &'life1 PackageSummary, ) -> Pin<Box<dyn Future<Output = Result<Container, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn load_package_tree<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, root: &'life1 Container, resolution: &'life2 Resolution, root_is_local_dir: bool, ) -> Pin<Box<dyn Future<Output = Result<BinaryPackage, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Load a resolved package into memory so it can be executed.