Method get

nodedb/src/control/server/pgwire/handler/prepared/plan_cache.rs:99–116

Look up cached physical tasks for the given SQL. On a hit returns both the cached tasks and the `DescriptorVersionSet` they were built against — the caller feeds the set into `SharedState::acquire_plan_lease_scope` so cache hits and fresh plans share the same lease-acquisition path. Returns `None` if not cached or if any recorded descriptor version has bumped / been dropped. Stale entries are ev

(
        &mut self,
        sql: &str,
        current_version: F,
    )

    /// descriptor version has bumped / been dropped. Stale
    /// entries are evicted automatically.
    pub fn get<F>(
        &mut self,
        sql: &str,
        current_version: F,
    ) -> Option<(Vec<PhysicalTask>, DescriptorVersionSet)>
    where
        F: Fn(&DescriptorId) -> Option<u64>,
    {
        let key = hash_sql(sql);
        let entry = self.entries.get(&key)?;
        if entry.versions.all_fresh(&current_version) {
            return Some((entry.tasks.clone(), entry.versions.clone()));
        }
        // Stale — evict.
        self.entries.remove(&key);
        self.order.retain(|k| *k != key);
        None
    }

    /// Store compiled physical tasks in the cache along with
    /// the descriptor version set they were built against.