Struct QueryPipeline 

pub struct QueryPipeline { /* private fields */ }

Transport-agnostic query pipeline.

Encapsulates the full query lifecycle: validate → intercept → compile → execute → intercept. Use PipelineBuilder to construct an instance.

Example

use type_bridge_server::{PipelineBuilder, QueryInput};

let pipeline = PipelineBuilder::new(my_executor)
    .with_schema_source(my_schema_source)
    .with_default_database("my_db")
    .build()?;

let output = pipeline.execute_query(QueryInput { ... }).await?;

Implementations

impl QueryPipeline

pub async fn execute_query( &self, input: QueryInput, ) -> Result<QueryOutput, PipelineError>

Execute a structured (AST-based) query through the full pipeline.

pub fn validate( &self, input: &ValidateInput, ) -> Result<ValidateOutput, PipelineError>

Validate clauses against the loaded schema without executing.

pub fn schema(&self) -> Option<&TypeSchema>

Get the loaded schema, if any.

pub fn is_connected(&self) -> bool

Check if the backend executor is connected.

pub fn default_database(&self) -> &str

Get the default database name.