Struct QueryPipeline 

pub struct QueryPipeline { /* private fields */ }

Builder and runner for AQL queries.

Wraps all registries and state needed to run queries. Create once, call query or select many times.

Example

use amql_engine::{QueryPipeline, ProjectRoot};

let root = ProjectRoot::from(std::path::Path::new("."));
let mut pipeline = QueryPipeline::builder(&root).build();
let results = pipeline.query("route[method=\"GET\"]", "src/").unwrap();

Implementations

impl QueryPipeline

pub fn builder(root: &ProjectRoot) -> QueryPipelineBuilder

Create a builder pre-loaded with all default resolvers and extractors.

pub fn query( &mut self, selector: &str, scope: &str, ) -> Result<Vec<QueryResult>, AqlError>

Run a unified query (code + annotations) and apply middleware.

pub fn select( &self, selector: &str, scope: Option<&str>, ) -> Result<Vec<Annotation>, AqlError>

Select annotations by selector (no code parsing).

pub fn reload(&mut self)

Reload all annotations from disk (call after external writes).

pub fn extractors(&self) -> &ExtractorRegistry

Return the extractor registry for this pipeline.

pub fn root(&self) -> &ProjectRoot

Return the project root for this pipeline.