Struct Query 

pub struct Query { /* private fields */ }

Query manages the bidirectional control protocol over a Transport connection.

Routes incoming messages: control requests are handled internally, regular messages are forwarded to the consumer channel.

Implementations

impl Query

pub fn new( transport: Box<dyn Transport>, hooks: Vec<HookDefinition>, can_use_tool: Option<CanUseToolCallback>, mcp_handler: Option<McpMessageHandler>, control_timeout: Option<Duration>, ) -> Self

pub async fn connect(&mut self) -> Result<Receiver<Result<Message>>>

Connect to the CLI and perform the initialization handshake.

pub async fn send_message( &self, prompt: &str, session_id: Option<&str>, ) -> Result<()>

Send a user message to the CLI.

pub async fn send_control_command( &self, command: SDKControlCommand, ) -> Result<Value>

Send a control command and wait for the response.

pub async fn interrupt(&self) -> Result<Value>

pub async fn set_permission_mode(&self, mode: &str) -> Result<Value>

pub async fn set_model(&self, model: &str) -> Result<Value>

pub async fn rewind_files(&self, user_message_id: &str) -> Result<Value>

pub async fn get_mcp_status(&self) -> Result<Value>

pub async fn get_server_info(&self) -> Option<Value>

pub async fn end_input(&self) -> Result<()>

pub async fn close(&mut self) -> Result<()>

Trait Implementations

impl Drop for Query

fn drop(&mut self)

Executes the destructor for this type.