algeon-query-planning 0.1.2

Backend-neutral native query planning, proof, and admission contracts.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Entry point that assembles one [`CapabilityAnalysis`] from the node, edge,
//! and subgraph passes.

use super::{
    QueryPlan,
    edge::{analyze_input_edges, analyze_sink_edge, mark_shared_producer_edge_contracts},
    invariant::analyze_invariants,
    model::CapabilityAnalysis,
    node::analyze_node,
};
use crate::{backend::AnalysisContext, validation::PlanColumns};

impl QueryPlan {
    /// Runs bounded capability analysis for diagnostics, report projection, and
    /// native bounded-join admission.
    pub fn capability_analysis(&self, ctx: AnalysisContext<'_>) -> CapabilityAnalysis {
        analyze_query_capabilities(self, ctx)
    }
}

/// Runs bounded capability analysis for diagnostics, report projection, and
/// native bounded-join admission.
pub(crate) fn analyze_query_capabilities(plan: &QueryPlan, ctx: AnalysisContext<'_>) -> CapabilityAnalysis {
    let columns = PlanColumns::for_plan(plan);
    let nodes = plan.nodes().iter().map(|node| analyze_node(plan, node, &columns, ctx)).collect::<Vec<_>>();
    let mut edges =
        plan.nodes().iter().flat_map(|node| analyze_input_edges(plan, node.id, &node.kind)).collect::<Vec<_>>();
    edges.push(analyze_sink_edge(plan));
    mark_shared_producer_edge_contracts(plan, &mut edges);

    // Invariants read the edge contracts, including the shared-producer
    // marks, so both edge passes must finish before this call.
    let invariants = analyze_invariants(plan, &edges);
    CapabilityAnalysis { nodes, edges, invariants, policy: ctx.policy() }
}