Struct ChunkCache 

pub struct ChunkCache { /* private fields */ }

Chunk cache manager.

Manages multiple chunked entries, providing efficient lookup and storage of large files split into chunks.

Implementations

impl ChunkCache

pub fn new(default_chunk_size: usize) -> Self

Creates a new chunk cache with the given default chunk size.

Arguments

• default_chunk_size - Default size of each chunk in bytes

Examples

use tower_http_cache::chunks::ChunkCache;

// Create cache with 1MB chunks
let cache = ChunkCache::new(1024 * 1024);

pub fn get_or_create( &self, key: String, metadata: ChunkMetadata, ) -> Arc<ChunkedEntry>

Gets or creates a chunked entry.

If an entry exists for the key, returns it. Otherwise, creates a new entry with the given metadata.

Arguments

• key - Cache key
• metadata - File metadata (used only if creating new entry)

Examples

let cache = ChunkCache::new(1024 * 1024);

let metadata = ChunkMetadata {
    total_size: 10_000_000,
    content_type: "video/mp4".to_string(),
    etag: None,
    last_modified: None,
    status: StatusCode::OK,
    version: http::Version::HTTP_11,
    headers: vec![],
};

let entry = cache.get_or_create("video.mp4".to_string(), metadata);

pub fn get(&self, key: &str) -> Option<Arc<ChunkedEntry>>

Gets an entry if it exists.

Arguments

• key - Cache key

Examples

let cache = ChunkCache::new(1024 * 1024);

assert!(cache.get("nonexistent").is_none());

cache.get_or_create("exists".to_string(), metadata);
assert!(cache.get("exists").is_some());

pub fn remove(&self, key: &str) -> Option<Arc<ChunkedEntry>>

Removes an entry from the cache.

Arguments

• key - Cache key

Examples

let cache = ChunkCache::new(1024 * 1024);

cache.get_or_create("temp".to_string(), metadata);
assert!(cache.get("temp").is_some());

cache.remove("temp");
assert!(cache.get("temp").is_none());

pub fn stats(&self) -> ChunkCacheStats

Gets cache statistics.

Examples

let cache = ChunkCache::new(1024);

let entry = cache.get_or_create("file1".to_string(), metadata);
entry.add_chunk(0, Bytes::from(vec![0u8; 1024]));

let stats = cache.stats();
assert_eq!(stats.total_entries, 1);
assert_eq!(stats.total_chunks, 1);
assert_eq!(stats.total_bytes, 1024);