Struct ClaudeAgentClient 

pub struct ClaudeAgentClient { /* private fields */ }

Implementations

impl ClaudeAgentClient

pub fn spawn_stream_message( options: ClaudeAgentOptions, content: impl Into<String>, ) -> UnboundedReceiver<StreamEvent>

pub fn new(options: ClaudeAgentOptions) -> Result<Self>

pub fn with_transport( options: ClaudeAgentOptions, transport: Box<dyn Transport>, ) -> Result<Self>

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

pub async fn connect_with_prompt( &mut self, content: impl Into<String>, ) -> Result<()>

pub async fn connect_with_stream<S>(&mut self, stream: S) -> Result<()>

where S: Stream<Item = Value> + Unpin,

pub async fn send_message( &mut self, content: impl Into<String>, ) -> Result<MessageResponse>

pub async fn query(&mut self, content: impl Into<String>) -> Result<()>

pub async fn query_with_session_id( &mut self, content: impl Into<String>, session_id: impl Into<String>, ) -> Result<()>

pub async fn query_stream<S>(&mut self, stream: S) -> Result<()>

where S: Stream<Item = Value> + Unpin,

pub async fn query_stream_with_session_id<S>( &mut self, stream: S, session_id: impl Into<String>, ) -> Result<()>

where S: Stream<Item = Value> + Unpin,

pub async fn receive_response(&mut self) -> Result<Vec<Message>>

pub async fn receive_messages(&mut self) -> Result<Vec<Message>>

pub async fn stream_message( &mut self, content: impl Into<String>, ) -> Result<UnboundedReceiver<StreamEvent>>

pub async fn get_conversation_history(&self) -> Result<Vec<Message>>

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

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

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

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

pub async fn set_permission_mode(&mut self, mode: PermissionMode) -> Result<()>

pub async fn set_model(&mut self, model: Option<String>) -> Result<()>

pub async fn rewind_files( &mut self, user_message_id: impl Into<String>, ) -> Result<()>

pub async fn reconnect_mcp_server( &mut self, server_name: impl Into<String>, ) -> Result<()>

pub async fn toggle_mcp_server( &mut self, server_name: impl Into<String>, enabled: bool, ) -> Result<()>

pub async fn stop_task(&mut self, task_id: impl Into<String>) -> Result<()>

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

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

pub fn get_server_info(&self) -> Option<&Map<String, Value>>

Trait Implementations

impl Debug for ClaudeAgentClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.