Method invalidate_by_graph_version

graphlite/src/cache/subquery_cache.rs:516–547

Invalidate entries by graph version

(&self, version: u64)

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

        entries.retain(|key, entry| {
            if key.graph_version < version {
                removed_keys.push(key.clone());
                removed_size += entry.size_bytes();
                false
            } else {
                true
            }
        });

        // Update indices
        for key in removed_keys {
            self.update_indices(&key, false);
        }

        {
            let mut current_memory = self.current_memory.write().unwrap();
            *current_memory = current_memory.saturating_sub(removed_size);
        }

        {
            let mut stats = self.stats.write().unwrap();
            stats.invalidations += 1;
            stats.current_entries = entries.len();
            stats.memory_bytes = *self.current_memory.read().unwrap();
        }
    }

    /// Invalidate entries by schema version
    pub fn invalidate_by_schema_version(&self, version: u64) {