Struct QueryPipelineManager 

pub struct QueryPipelineManager<S: QueryStorage + 'static> {
    pub macro_manager: Arc<MacroManager>,
    pub type_alias_manager: Arc<TypeAliasManager>,
    pub sequence_manager: Arc<SequenceManager>,
    pub last_dml_plan_hits: AtomicU64,
    /* private fields */
}

Fields

macro_manager: Arc<MacroManager>

Shared macro catalog (user-defined macros), engine-wide.

Created once with the pipeline manager and shared with every query through the binder (expansion), parser-adjacent planning and the execution runtime (DDL). Persistence/WAL backends can be attached by replacing this instance before serving queries.

type_alias_manager: Arc<TypeAliasManager>

Shared type-alias catalog (user-defined types), engine-wide.

Threaded the same way as Self::macro_manager.

sequence_manager: Arc<SequenceManager>

Shared sequence catalog (named sequences for curr_val/next_val), engine-wide.

Threaded the same way as Self::macro_manager.

last_dml_plan_hits: AtomicU64

Implementations

impl<S: QueryStorage + 'static> QueryPipelineManager<S>

pub fn execute_explain( &mut self, explain_stmt: &ExplainStmt, qctx: Arc<QueryContext>, ) -> DBResult<ExecutionResult>

pub fn execute_explain_analyze( &mut self, explain_stmt: &ExplainStmt, qctx: Arc<QueryContext>, transaction_scope: TransactionScope, ) -> DBResult<ExecutionResult>

pub fn execute_profile( &mut self, profile_stmt: &ProfileStmt, qctx: Arc<QueryContext>, transaction_scope: TransactionScope, ) -> DBResult<ExecutionResult>

impl<S: QueryStorage + 'static> QueryPipelineManager<S>

pub fn execute_query(&mut self, query_text: &str) -> DBResult<ExecutionResult>

pub fn execute_query_with_space( &mut self, query_text: &str, space_info: Option<SpaceInfo>, ) -> DBResult<ExecutionResult>

Convenience entry: parse, bind auto-commit storage for DML, compile, execute, and finalize in one call. Used by tests and the embedded API.

Finalization of the auto-bound operation storage is performed by [execute_prepared_materialized].

pub fn execute_query_stream_with_request( &mut self, query_text: &str, rctx: Arc<QueryRequestContext>, space_info: Option<SpaceInfo>, ) -> DBResult<StreamingQueryResult>

pub fn execute_query_stream_with_request_scope( &mut self, query_text: &str, rctx: Arc<QueryRequestContext>, space_info: Option<SpaceInfo>, transaction_id: Option<TransactionId>, ) -> DBResult<StreamingQueryResult>

pub fn execute_query_with_request( &mut self, query_text: &str, rctx: Arc<QueryRequestContext>, space_info: Option<SpaceInfo>, ) -> DBResult<ExecutionResult>

pub fn execute_query_with_request_scope( &mut self, query_text: &str, rctx: Arc<QueryRequestContext>, space_info: Option<SpaceInfo>, transaction_id: Option<TransactionId>, ) -> DBResult<ExecutionResult>

pub fn execute_query_with_profile( &mut self, query_text: &str, session_id: i64, space_info: Option<SpaceInfo>, ) -> DBResult<(ExecutionResult, QueryMetrics, QueryProfile)>

Execute a statement end to end and report its stage profile.

The only entry that produces a QueryProfile: stage timings and the metric counters are recorded here so embedded and API callers get the same picture the transport layer shows, with no second profile assembly anywhere else. space_info selects the target space and is None for statements that do not need one.

impl<S: QueryStorage + 'static> QueryPipelineManager<S>

pub const DEFAULT_STATISTICS_SAMPLE_LIMIT: usize = 10_000

Fallback sampling window used when the server assembly did not pass an explicit statistics_sample_limit (mirrors the config default).

pub const DEFAULT_STATISTICS_MIN_EPOCH_DELTA: u64 = 100

Fallback epoch delta used when the server assembly did not pass an explicit statistics_min_epoch_delta (mirrors the config default).

pub fn with_optimizer( storage: Arc<RwLock<S>>, stats_manager: Arc<StatsManager>, optimizer_engine: Arc<OptimizerEngine>, ) -> Self

pub fn with_statistics_sample_limit(self, sample_limit: usize) -> Self

pub fn with_statistics_min_epoch_delta(self, delta: u64) -> Self

pub fn with_password_history_depth(self, depth: usize) -> Self

Set the retained password-history depth for user-management operations (assembly-time only).

pub fn set_optimizer_engine(&mut self, optimizer_engine: Arc<OptimizerEngine>)

Replace the optimizer engine (assembly-time only).

Re-runs the post-construction injection so the replacement behaves like an engine passed to Self::with_optimizer. Callers must swap before the first query; execution-time replacement is unsupported.

pub fn statistics_sample_limit(&self) -> usize

Effective sampling window currently in force for statistics collection (server config value or the fallback default).

pub fn statistics_min_epoch_delta(&self) -> u64

Effective epoch delta currently in force for automatic refresh.

pub fn statistics_settings_summary(&self) -> String

One-line summary of the effective statistics settings, surfaced in EXPLAIN diagnostics so operators can verify which sampling window and refresh threshold produced the statistics behind a plan.

pub fn set_space_cost_configs( &mut self, configs: HashMap<String, CostModelConfig>, labels: HashMap<String, String>, )

Install per-space cost model overrides on the engine, with display labels for EXPLAIN observability (assembly-time only).

pub fn set_default_cost_profile_label(&mut self, label: String)

Display label of the global cost profile (assembly-time only).

pub fn cost_profile_label_for(&self, space: Option<&str>) -> Option<String>

Effective cost profile label for a space, if the assembly provided one: the space override when present, else the global label. Empty global label means unassembled: no label at all.

pub fn collect_statistics( &self, space: &str, force: bool, ) -> Result<CollectedSummary, String>

Collect (or serve cached) statistics for a space into the optimizer’s StatisticsManager.

force bypasses the version gate so an explicit ANALYZE always refreshes the statistics. Collection is serialized internally.

pub fn with_query_registry(self, registry: Arc<QueryRegistry>) -> Self

pub fn with_shared_scheduler(self, scheduler: Arc<SharedScheduler>) -> Self

pub fn set_shared_scheduler(&mut self, scheduler: Option<Arc<SharedScheduler>>)

Set the shared scheduler (used when the pipeline is built before the scheduler is created, e.g. the vector-enabled server path).

pub fn set_query_registry(&mut self, registry: Option<Arc<QueryRegistry>>)

Set the query registry (used when the pipeline is built before the registry is created, e.g. the vector-enabled server path).

pub fn shared_scheduler(&self) -> Option<Arc<SharedScheduler>>

Access the shared scheduler instance, if any.

pub fn query_registry(&self) -> Option<Arc<QueryRegistry>>

Access the query registry instance, if any.

pub fn set_query_manager(&mut self, manager: Option<Arc<QueryManager>>)

Set the global QueryManager (used when the pipeline is built before the manager is created, e.g. the server startup path).

pub fn query_manager(&self) -> Option<Arc<QueryManager>>

Access the global QueryManager instance, if installed.

pub fn with_optimizer_and_cache( storage: Arc<RwLock<S>>, stats_manager: Arc<StatsManager>, optimizer_engine: Arc<OptimizerEngine>, plan_cache_config: PlanCacheConfig, ) -> Self

pub fn with_extensions(self, extensions: Arc<ExtensionRegistry>) -> Self

Attach a shared pipeline-extension registry (experimental).

pub fn set_extensions(&mut self, extensions: Arc<ExtensionRegistry>)

Replace the pipeline-extension registry on an existing manager (experimental). Used when the manager was built by another constructor and the caller only has &mut access.

pub fn extensions(&self) -> Arc<ExtensionRegistry>

Pipeline-extension registry backing this manager.

pub fn optimizer_engine(&self) -> &OptimizerEngine

pub fn with_schema_manager(self, schema_manager: Arc<SchemaManager>) -> Self

pub fn with_index_manager( self, index_manager: Arc<dyn IndexMetadataManager>, ) -> Self

pub fn plan_cache(&self) -> &QueryPlanCache

pub fn plan_cache_metrics(&self) -> Arc<PlanCacheStats>

pub fn clear_plan_cache(&self)

pub fn with_sync_manager(self, sync_manager: Arc<SyncManager>) -> Self

pub fn with_dml_shape_cache(self, enabled: bool) -> Self

Toggle DML shape plan caching (independent switch / rollback path).

pub fn dml_shape_cache_enabled(&self) -> bool

Whether DML shape plan caching is enabled.

pub fn dml_template_ast_parse_count(&self) -> u64

pub fn dml_template_ast_hit_count(&self) -> u64

pub fn dml_bind_skipped_count(&self) -> u64

pub fn storage(&self) -> Option<Arc<RwLock<S>>>

The underlying storage binding, if any.