Struct CdnCache

pub struct CdnCache { /* private fields */ }

Cache for CDN content following the standard CDN directory structure

Implementations

impl CdnCache

pub async fn new() -> Result<Self>

Create a new CDN cache

pub async fn for_product(product: &str) -> Result<Self>

Create a CDN cache for a specific product

pub async fn with_base_dir(base_dir: PathBuf) -> Result<Self>

Create a CDN cache with a custom base directory

pub async fn with_cdn_path(cdn_path: &str) -> Result<Self>

Create a CDN cache with a specific CDN path

pub fn set_cdn_path(&mut self, cdn_path: Option<String>)

Set the CDN path for this cache

pub fn config_dir(&self) -> PathBuf

Get the config cache directory

pub fn data_dir(&self) -> PathBuf

Get the data cache directory

pub fn patch_dir(&self) -> PathBuf

Get the patch cache directory

pub fn config_path(&self, hash: &str) -> PathBuf

Construct a config cache path from a hash

Follows CDN structure: config/{first2}/{next2}/{hash}

pub fn data_path(&self, hash: &str) -> PathBuf

Construct a data cache path from a hash

Follows CDN structure: data/{first2}/{next2}/{hash}

pub fn patch_path(&self, hash: &str) -> PathBuf

Construct a patch cache path from a hash

Follows CDN structure: patch/{first2}/{next2}/{hash}

pub fn index_path(&self, hash: &str) -> PathBuf

Construct an index cache path from a hash

Follows CDN structure: data/{first2}/{next2}/{hash}.index

pub async fn has_config(&self, hash: &str) -> bool

Check if a config exists in cache

pub async fn has_data(&self, hash: &str) -> bool

Check if data exists in cache

pub async fn has_patch(&self, hash: &str) -> bool

Check if a patch exists in cache

pub async fn has_index(&self, hash: &str) -> bool

Check if an index exists in cache

pub async fn write_config(&self, hash: &str, data: &[u8]) -> Result<()>

Write config data to cache

pub async fn write_data(&self, hash: &str, data: &[u8]) -> Result<()>

Write data to cache

pub async fn write_patch(&self, hash: &str, data: &[u8]) -> Result<()>

Write patch data to cache

pub async fn write_index(&self, hash: &str, data: &[u8]) -> Result<()>

Write index to cache

pub async fn read_config(&self, hash: &str) -> Result<Vec<u8>>

Read config from cache

pub async fn read_data(&self, hash: &str) -> Result<Vec<u8>>

Read data from cache

pub async fn read_patch(&self, hash: &str) -> Result<Vec<u8>>

Read patch from cache

pub async fn read_index(&self, hash: &str) -> Result<Vec<u8>>

Read index from cache

pub async fn open_data(&self, hash: &str) -> Result<File>

Stream read data from cache

Returns a file handle for efficient streaming

pub async fn data_size(&self, hash: &str) -> Result<u64>

Get data size without reading it

pub fn base_dir(&self) -> &PathBuf

Get the base directory of this cache

pub fn cdn_path(&self) -> Option<&str>

Get the CDN path if set

pub async fn write_configs_batch( &self, entries: &[(String, Vec<u8>)], ) -> Result<()>

Write multiple config files in parallel

pub async fn write_data_batch( &self, entries: &[(String, Vec<u8>)], ) -> Result<()>

Write multiple data files in parallel

pub async fn read_configs_batch( &self, hashes: &[String], ) -> Vec<Result<Vec<u8>>>

Read multiple config files in parallel

pub async fn read_data_batch(&self, hashes: &[String]) -> Vec<Result<Vec<u8>>>

Read multiple data files in parallel

pub async fn has_configs_batch(&self, hashes: &[String]) -> Vec<bool>

Check existence of multiple configs in parallel

pub async fn has_data_batch(&self, hashes: &[String]) -> Vec<bool>

Check existence of multiple data files in parallel

pub async fn data_sizes_batch(&self, hashes: &[String]) -> Vec<Result<u64>>

Get sizes of multiple data files in parallel