Struct CacheManager

pub struct CacheManager { /* private fields */ }

Cache manager for handling Docker/OCI image caching operations

Implementations

impl CacheManager

pub fn new(cache: Cache, logger: Logger) -> Self

pub fn with_config( cache: Cache, logger: Logger, config: CacheManagerConfig, ) -> Self

pub async fn extract_and_cache_from_tar( &mut self, tar_file: &str, repository: &str, reference: &str, ) -> Result<()>

Extract from tar file and cache locally

pub async fn push_from_cache_with_source( &mut self, client: &RegistryClient, source_repository: &str, source_reference: &str, target_repository: &str, target_reference: &str, token: &Option<String>, ) -> Result<()>

Push from cache to registry with separate source and target coordinates

pub async fn push_from_cache( &mut self, client: &RegistryClient, repository: &str, reference: &str, token: &Option<String>, ) -> Result<()>

Push from cache to registry (same coordinates)

pub fn get_cache_stats(&self) -> Result<CacheStats>

Get cache statistics

pub fn list_cached_images(&self) -> Vec<(String, String)>

List all cached images

pub fn is_image_cached(&self, repository: &str, reference: &str) -> Result<bool>

Check if image is cached

pub fn validate_cache_completeness( &self, repository: &str, reference: &str, ) -> Result<()>

Validate cache completeness for an image

pub fn get_image_blobs( &self, repository: &str, reference: &str, ) -> Result<Vec<BlobInfo>>

Get image blobs from cache

pub fn get_cache(&self) -> &Cache

Get cache reference (for external operations)

pub fn get_cache_mut(&mut self) -> &mut Cache

Get mutable cache reference (for external operations)

Trait Implementations

impl Cacheable for CacheManager

type Key = (String, String)

type Value = bool

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Self::Key, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::Value>>> + Send + 'async_trait>>

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

Get from cache

fn put<'life0, 'async_trait>( &'life0 self, _key: Self::Key, _value: Self::Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Put into cache

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 Self::Key, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Check if exists in cache

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

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

Remove from cache

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

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

Clear all cache

impl Configurable<CacheManagerConfig> for CacheManager

fn configure(&mut self, config: CacheManagerConfig) -> Result<()>

Apply configuration

fn get_config(&self) -> &CacheManagerConfig

Get current configuration

fn validate_config(config: &CacheManagerConfig) -> Result<()>

Validate configuration