Struct ChunkCache 

pub struct ChunkCache { /* private fields */ }

A per-dataset chunk cache with hash-based index and LRU eviction.

Usage

let cache = ChunkCache::new();
// Pass &cache to read_chunked_data — it will populate the index lazily.

The cache is wrapped in Mutex internally so it can be mutated through shared references (thread-safe).

Implementations

impl ChunkCache

pub fn new() -> Self

Create a new chunk cache with default limits (1 MiB, 16 slots).

pub fn with_capacity(max_bytes: usize, max_slots: usize) -> Self

Create a new chunk cache with custom byte budget and slot count.

pub fn has_index(&self) -> bool

Returns true if the chunk index has been built.

pub fn populate_index(&self, chunks: &[ChunkInfo], rank: usize)

Build the chunk index from a pre-collected list of ChunkInfo.

The rank parameter is used to truncate offsets to spatial dims only (B-tree v1 stores rank+1 offsets).

pub fn lookup_index(&self, coord: &[u64]) -> Option<ChunkInfo>

Look up a chunk by its spatial coordinate in the index.

pub fn all_indexed_chunks(&self) -> Option<Vec<ChunkInfo>>

Return all indexed chunks as a Vec<ChunkInfo> (order unspecified).

pub fn get_decompressed(&self, coord: &[u64]) -> Option<Vec<u8>>

Try to get cached decompressed data for a chunk coordinate.

Returns a clone of the cache-line-aligned buffer.

pub fn get_decompressed_aligned( &self, coord: &[u64], ) -> Option<CacheAlignedBuffer>

Try to get a reference-counted clone of the aligned buffer for a chunk.

pub fn put_decompressed(&self, coord: ChunkCoord, data: Vec<u8>)

Insert decompressed chunk data into the LRU cache.

The data is stored in a CacheAlignedBuffer so subsequent reads return cache-line-aligned memory.

pub fn put_decompressed_aligned( &self, coord: ChunkCoord, data: CacheAlignedBuffer, )

Insert an already-aligned buffer into the LRU cache.

pub fn clear(&self)

Clear the entire cache (index + decompressed data).

pub fn prefetch_hint(&self, next_coords: &[ChunkCoord])

Hint that the given chunk coordinates will be accessed soon.

Pre-populates the chunk index for these coordinates so that subsequent lookups are O(1). This does NOT pre-decompress the chunks — it only ensures the index entries exist.

pub fn access_stats(&self) -> AccessStats

Return the current access pattern statistics.

pub fn set_sweep_direction(&self, direction: &'static str)

Update the sweep direction label in the access stats.

pub fn cached_chunk_count(&self) -> usize

Number of decompressed chunks currently cached.

pub fn cached_bytes(&self) -> usize

Total bytes of decompressed data currently cached.

Trait Implementations

impl Default for ChunkCache

fn default() -> Self

Returns the “default value” for a type.