Struct QueryEngine 

pub struct QueryEngine { /* private fields */ }

The query engine orchestrates the agent loop.

Central coordinator that drives the LLM → tools → LLM cycle. Manages conversation history, context compaction, tool execution, error recovery, and hook dispatch. Create via QueryEngine::new.

Implementations

impl QueryEngine

pub fn new( llm: Arc<dyn Provider>, tools: ToolRegistry, permissions: PermissionChecker, state: AppState, config: QueryEngineConfig, ) -> Self

pub fn load_hooks(&mut self, hook_defs: &[HookDefinition])

Load hooks from configuration into the registry.

pub fn state(&self) -> &AppState

Get a reference to the app state.

pub fn state_mut(&mut self) -> &mut AppState

Get a mutable reference to the app state.

pub fn install_signal_handler(&self)

Install a Ctrl+C handler that triggers the cancellation token. Call this once at startup. Subsequent Ctrl+C signals during a turn will cancel the active operation instead of killing the process.

pub async fn run_turn(&mut self, user_input: &str) -> Result<()>

Run a single turn: process user input through the full agent loop.

pub async fn run_turn_with_sink( &mut self, user_input: &str, sink: &dyn StreamSink, ) -> Result<()>

Run a turn with a stream sink for real-time UI updates.

pub fn cancel(&self)

Cancel the current operation.

pub fn cancel_token(&self) -> CancellationToken

Get a cloneable cancel token for use in background tasks.