Method new

graphlite/src/cache/cache_manager.rs:122–214

Create new cache manager with configuration

(config: CacheConfig)

impl CacheManager {
    /// Create new cache manager with configuration
    pub fn new(config: CacheConfig) -> Result<Self, String> {
        config.validate()?;

        let result_cache = Arc::new(ResultCache::new(
            config.l1_config.max_entries,
            config.l1_config.max_memory_bytes,
            config.l2_config.max_entries,
            config.l2_config.max_memory_bytes,
            config.eviction_policy.clone(),
        ));

        let plan_cache = Arc::new(PlanCache::new(
            config.l3_config.max_entries,
            config.l3_config.max_memory_bytes,
            config
                .l3_config
                .default_ttl
                .unwrap_or(Duration::from_secs(3600)),
        ));

        let subquery_cache = Arc::new(SubqueryCache::new(
            config.l1_config.max_entries / 2, // Subqueries are smaller, allow more entries
            config.l1_config.max_memory_bytes / 4, // But use less memory
            config
                .l1_config
                .default_ttl
                .unwrap_or(Duration::from_secs(300)),
        ));

        let invalidation_strategy = match &config.invalidation_strategy {
            super::cache_config::InvalidationStrategy::Manual => {
                super::invalidation::InvalidationStrategy::Manual
            }
            super::cache_config::InvalidationStrategy::Ttl => {
                super::invalidation::InvalidationStrategy::Ttl {
                    default_ttl: Duration::from_secs(3600),
                    max_ttl: Duration::from_secs(7200),
                }
            }
            super::cache_config::InvalidationStrategy::TagBased => {
                super::invalidation::InvalidationStrategy::TagBased {
                    sensitive_tags: [
                        "nodes".to_string(),
                        "edges".to_string(),
                        "schema".to_string(),
                    ]
                    .into_iter()
                    .collect(),
                    propagation_delay: Duration::from_millis(100),
                }
            }
            super::cache_config::InvalidationStrategy::Versioned => {
                super::invalidation::InvalidationStrategy::Versioned {
                    track_data_version: true,
                    track_schema_version: true,
                }
            }
            super::cache_config::InvalidationStrategy::Hybrid {