Struct ImagePuller 

pub struct ImagePuller { /* private fields */ }

High-level image puller with caching.

Implementations

impl ImagePuller

pub fn new(store: Arc<ImageStore>, auth: RegistryAuth) -> Self

Create a new image puller.

pub fn with_platform( store: Arc<ImageStore>, auth: RegistryAuth, platform: Option<String>, ) -> Self

Create an image puller that resolves multi-arch images to an explicit platform (e.g. “linux/arm64”) instead of the host architecture. None keeps the host-architecture default.

pub fn set_metrics(self, metrics: RuntimeMetrics) -> Self

Attach Prometheus metrics to this puller.

pub fn with_signature_policy(self, policy: SignaturePolicy) -> Self

Set the signature verification policy for image pulls.

pub fn with_progress_fn( self, f: Arc<dyn Fn(usize, usize, &str, i64) + Send + Sync>, ) -> Self

Set a layer progress callback: (current, total, digest, size_bytes).

pub async fn pull(&self, reference: &str) -> Result<OciImage>

Pull an image, using the local cache if available.

Returns the loaded OCI image from the store.

pub async fn force_pull(&self, reference: &str) -> Result<OciImage>

Pull an image, bypassing the local cache.

pub async fn is_cached(&self, reference: &str) -> bool

Check if an image is already cached.

pub async fn remove_cached(&self, reference: &str) -> Result<bool>

Remove a cached image by reference.

pub async fn list_cached(&self) -> Result<Vec<String>>

List all cached image references.

Trait Implementations

impl ImageRegistry for ImagePuller

fn pull<'life0, 'life1, 'async_trait>( &'life0 self, reference: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<PulledImage>> + Send + 'async_trait>>

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

Pull an image by reference, using local cache when available.

fn force_pull<'life0, 'life1, 'async_trait>( &'life0 self, reference: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<PulledImage>> + Send + 'async_trait>>

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

Pull an image, bypassing any local cache.

fn is_cached<'life0, 'life1, 'async_trait>( &'life0 self, reference: &'life1 str, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check whether an image is already available locally.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, reference: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Remove a locally cached image by reference.

fn list_cached<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

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

List all locally cached image references.