Struct LruParseCache 

pub struct LruParseCache { /* private fields */ }

LRU parse cache with configurable size limit.

Thread-safe implementation using RwLock for the main cache and atomics for statistics.

Implementations

impl LruParseCache

pub fn new(max_entries: usize) -> Self

Create a new cache with the specified maximum entries.

A good default is 10,000 entries, which at ~1KB per entry uses about 10MB of memory.

pub fn with_options(max_entries: usize, reader_eviction_enabled: bool) -> Self

Create a new cache with configurable options.

Arguments

• max_entries - Maximum number of entries to cache
• reader_eviction_enabled - If true, entries are evicted when all readers have passed them. If false, only LRU eviction is used.

pub fn get_stats(&self) -> CacheStats

Get current cache statistics.

pub fn reset_stats(&self)

Reset statistics counters (keeps cache contents).

pub fn clear(&self)

Clear all cached entries.

Trait Implementations

impl Debug for LruParseCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ParseCache for LruParseCache

fn get(&self, frame_number: u64) -> Option<Arc<CachedParse>>

Get cached parse result for a frame, if available.

fn put(&self, frame_number: u64, parsed: Arc<CachedParse>)

Store parse result for a frame.

fn reset_stats(&self)

Reset statistics counters. Default implementation does nothing.

fn reader_passed(&self, reader_id: usize, frame_number: u64)

Hint that a reader has finished with frames up to this number.

fn register_reader(&self) -> usize

Register a new reader and get its ID.

fn unregister_reader(&self, reader_id: usize)

Unregister a reader (e.g., when stream completes).

fn stats(&self) -> Option<CacheStats>

Get cache statistics (if available).

fn get_or_insert_with( &self, frame_number: u64, f: Box<dyn FnOnce() -> Arc<CachedParse> + '_>, ) -> (Arc<CachedParse>, bool)

Get cached result or compute and cache it. Returns (result, was_hit).