Struct ConcurrentCache 

pub struct ConcurrentCache { /* private fields */ }

Concurrent cache using DashMap for high-throughput scenarios

Implementations

impl ConcurrentCache

pub fn new(capacity: usize, metrics: Arc<DataMatchingMetrics>) -> Self

Create a new concurrent cache

pub fn with_ttl(self, ttl: Duration) -> Self

Set default TTL

pub fn with_negative_ttl(self, ttl: Duration) -> Self

Set negative cache TTL

pub fn get(&self, key: &str) -> CacheResult

Get from cache (checks negative cache too)

pub fn insert(&self, key: String, data: DataSource)

Insert into cache

pub fn insert_negative(&self, key: String)

Insert a negative cache entry

pub fn remove(&self, key: &str)

Remove from both caches

pub fn clear(&self)

Clear all caches

pub fn len(&self) -> usize

Get cache size

pub fn is_empty(&self) -> bool

Check if cache is empty

pub fn negative_len(&self) -> usize

Get negative cache size