Struct ImageStore 

pub struct ImageStore { /* private fields */ }

Disk-based image store with in-memory index and LRU eviction.

Implementations

impl ImageStore

pub fn new(store_dir: &Path, max_size_bytes: u64) -> Result<Self>

Create a new image store.

Creates the store directory if it doesn’t exist and loads any existing index from disk.

pub async fn get(&self, reference: &str) -> Option<StoredImage>

Get a stored image by reference.

pub async fn get_by_digest(&self, digest: &str) -> Option<StoredImage>

Get a stored image by digest.

pub async fn resolve(&self, image: &str) -> Option<StoredImage>

Resolve an image reference to a stored image.

CRI callers may address an image by an exact stored reference, by its image id (a bare sha256:... or a name@sha256:... digest pin), or by an unnormalized name (e.g. a tagless name that defaults to :latest).

pub async fn put( &self, reference: &str, digest: &str, source_dir: &Path, ) -> Result<StoredImage>

Store an image from a source directory.

Copies the OCI image layout from source_dir into the store under sha256/<digest>/.

pub async fn remove(&self, image: &str) -> Result<()>

Remove an image by reference or by image ID (digest).

The CRI RemoveImage may identify an image either by a repo reference/tag or by its image ID (sha256:<digest>, as returned in ImageStatus). When image does not match a stored reference key, fall back to removing every reference that points at the matching digest.

pub async fn list(&self) -> Vec<StoredImage>

List all stored images.

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

Evict least-recently-used images until total size is under the limit.

Returns the references of evicted images.

pub async fn total_size(&self) -> u64

Get total size of all stored images in bytes.

pub fn store_dir(&self) -> &Path

Get the store directory path.

Trait Implementations

impl ImageStoreBackend for ImageStore

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

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

Look up a stored image by reference. Returns None if not cached.

fn get_by_digest<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<StoredImage>> + Send + 'async_trait>>

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

Look up a stored image by content digest.

fn put<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, reference: &'life1 str, digest: &'life2 str, source_dir: &'life3 Path, ) -> Pin<Box<dyn Future<Output = Result<StoredImage>> + Send + 'async_trait>>

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

Store an image layout directory under the given reference and digest.

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

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

Remove an image by reference.

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

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

List all stored images.

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

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

Evict least-recently-used images to stay within the size cap.

fn total_size<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

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

Total disk usage across all stored images.