Struct CalExecutor 

pub struct CalExecutor { /* private fields */ }

CAL query executor.

Stateless aside from configuration and a parse cache. Create once and call execute() for each query. Thread-safe.

Implementations

impl CalExecutor

pub fn new(config: CalExecutorConfig) -> Self

Create a new executor with the given configuration.

pub fn parse_cached(&self, input: &str) -> Result<CalQuery, CalError>

Parse input, reusing a cached AST for identical text.

Returns a clone: execute binds LET values into the query, so the cached entry must stay pristine. Cloning an AST is still far cheaper than lexing + parsing + validating one.

A poisoned lock degrades to a plain parse rather than failing the query — the cache is an optimization, and a caller’s statement should not fail because some other thread panicked.

pub fn plan_cache_len(&self) -> usize

How many statements the plan cache currently holds. Diagnostics and tests; not a stability guarantee.

pub fn with_governance(self, host: Arc<dyn GovernanceHost>) -> Self

Attach the governance host that backs RUN LOOP, APPROVE, REJECT, APPLY, ROLLBACK, and the loop DESCRIBE reads.

pub fn config(&self) -> &CalExecutorConfig

The effective configuration (read-only; for observability surfaces).

pub fn with_defaults() -> Self

Create an executor with all defaults.

pub fn execute( &self, input: &str, store: &dyn CalStoreFacade, ) -> Result<CalExecResult, CalError>

Parse and execute a CAL query string against store.

This is the primary entry point. Callers that have already parsed the query can call execute_query() instead.

Errors

Returns a CalError for parse failures or execution errors that map to a specific CAL error code. Store errors that do not map to a CAL code are wrapped in CalError::BudgetExceeded.

pub fn execute_parsed( &self, query: CalQuery, original_text: &str, store: &dyn CalStoreFacade, ) -> Result<CalExecResult, CalError>

Execute an already-parsed CalQuery AST against the store.

Used by the application/json+cal wire format path where the AST arrives as JSON rather than text. The original_text parameter is used for the query hash and the query field in the result; pass the JSON body or a synthetic representation.

pub fn execute_statement( &self, stmt: &CalStatement, store: &dyn CalStoreFacade, query: &CalQuery, exec_warnings: &mut Vec<String>, ) -> Result<CalResultPayload, CalError>