Struct FragmentCache 

pub struct FragmentCache { /* private fields */ }

Two-tier fragment cache (memory + disk)

Implementations

impl FragmentCache

pub async fn open(config: CacheConfig) -> Result<Self>

Create or open a cache

pub async fn get(&self, fragment_id: &FragmentId) -> Option<Bytes>

Get a fragment from cache

pub async fn put( &self, fragment_id: FragmentId, data: Bytes, entry: CacheEntry, ) -> Result<()>

Put a fragment into cache

pub fn contains(&self, fragment_id: &FragmentId) -> bool

Check if fragment exists in cache

pub fn get_entry(&self, fragment_id: &FragmentId) -> Option<CacheEntry>

Get cache entry metadata

pub fn needs_revalidation( &self, fragment_id: &FragmentId, etag: Option<&str>, ) -> bool

Validate cache entry against remote

pub fn stats(&self) -> CacheStats

Get cache statistics

pub async fn clear(&self) -> Result<()>

Clear all cached data

pub async fn sync(&self) -> Result<()>

Persist cache state

Trait Implementations

impl Drop for FragmentCache

fn drop(&mut self)

Executes the destructor for this type.