Struct CteCacheManager 

pub struct CteCacheManager { /* private fields */ }

CTE Cache Manager

Managing caching of CTE (Common Table Expression) query results and ensuring thread-safe access.

Implementations

impl CteCacheManager

pub fn new() -> Self

Create a new cache manager.

pub fn with_config(config: CteCacheConfig) -> Self

Create using the configuration.

pub fn with_stats_manager(self, stats_manager: Arc<StatsManager>) -> Self

pub fn set_stats_manager(&self, stats_manager: Arc<StatsManager>)

Set the stats manager after creation

pub fn config(&self) -> CteCacheConfig

Obtain the configuration.

pub fn set_config(&self, config: CteCacheConfig)

Update the configuration.

pub fn is_enabled(&self) -> bool

Determine whether to enable caching.

pub fn should_cache( &self, cte_definition: &str, estimated_rows: u64, is_deterministic: bool, ) -> bool

Determine whether the results of the CTE (Common Table Expression) are cached.

Parameters

cte_definition: Text defining the Common Table Expression (CTE). estimated_rows: The estimated number of rows is_deterministic: Whether the CTE (Common Table Expression) is deterministic.

pub fn put( &self, cte_definition: &str, data: Vec<u8>, row_count: u64, ) -> Option<String>

Store the data in the cache.

pub fn put_with_cost( &self, cte_definition: &str, data: Vec<u8>, row_count: u64, compute_cost_ms: u64, ) -> Option<String>

Store the data in the cache with compute cost.

pub fn put_with_tables( &self, cte_definition: &str, data: Vec<u8>, row_count: u64, compute_cost_ms: u64, dependent_tables: Vec<String>, ) -> Option<String>

Store the data in the cache with dependent tables.

pub fn evict_low_priority(&self, target_bytes: usize) -> usize

Evict low priority entries

pub fn get(&self, cte_definition: &str) -> Option<Arc<Vec<u8>>>

Retrieve data from the cache.

pub fn contains(&self, cte_definition: &str) -> bool

Check whether it exists in the cache.

pub fn invalidate(&self, cte_definition: &str) -> bool

Invalidate the cache entry

pub fn invalidate_by_hash(&self, cte_hash: &str) -> bool

Invalidate cache entry by hash

pub fn invalidate_by_table(&self, table_name: &str) -> usize

Invalidate cache entries by table name

pub fn get_cache_entries(&self) -> Vec<(String, f64, usize)>

Get cache entries for eviction (internal use)

pub fn increment_evicted_count(&self, count: u64)

Increment eviction count (internal use)

pub fn clear(&self)

Clear all caches.

pub fn get_stats(&self) -> CteCacheStatsSnapshot

Obtain statistical information

pub fn reset_stats(&self)

Reset statistics

pub fn current_memory(&self) -> usize

Get the current memory usage

pub fn entry_count(&self) -> usize

Obtain the number of cached entries

pub fn cleanup_expired(&self) -> usize

Clearance of obsolete entries Note: moka handles TTL automatically, so this is a no-op

pub fn stats(&self) -> Arc<CteCacheStats>

Get the statistics object

Trait Implementations

impl Debug for CteCacheManager

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

Formats the value using the given formatter.

impl Default for CteCacheManager

fn default() -> Self

Returns the “default value” for a type.