Method invalidate_by_graph_version

graphlite/src/cache/result_cache.rs:467–516

Invalidate entries by graph version

(&self, version: u64)

    /// Invalidate entries by graph version
    pub fn invalidate_by_graph_version(&self, version: u64) {
        let mut removed_keys = Vec::new();

        // Remove from L1
        {
            let mut l1_cache = self.l1_cache.write().unwrap();
            l1_cache.retain(|key, entry| {
                if key.graph_version < version {
                    removed_keys.push(key.clone());
                    let size = entry.size_bytes();
                    *self.l1_current_memory.write().unwrap() =
                        self.l1_current_memory.read().unwrap().saturating_sub(size);
                    false
                } else {
                    true
                }
            });
        }

        // Remove from L2
        {
            let mut l2_cache = self.l2_cache.write().unwrap();
            l2_cache.retain(|key, entry| {
                if key.graph_version < version {
                    if !removed_keys.contains(key) {
                        removed_keys.push(key.clone());
                    }
                    let size = entry.size_bytes();
                    *self.l2_current_memory.write().unwrap() =
                        self.l2_current_memory.read().unwrap().saturating_sub(size);
                    false
                } else {
                    true
                }
            });
        }

        // Update LRU trackers
        {
            let mut l1_lru = self.l1_lru.write().unwrap();
            let mut l2_lru = self.l2_lru.write().unwrap();

            for key in removed_keys {
                // Note: In a real implementation, we'd need to properly update LRU positions
                // This is a simplified version
                l1_lru.positions.remove(&key);
                l2_lru.positions.remove(&key);
            }
        }
    }

    /// Get cache statistics
    pub fn stats(&self) -> CacheStats {