Struct AgentClient 

pub struct AgentClient { /* private fields */ }

Implementations

impl AgentClient

pub async fn connect(addr: &str) -> Result<Self, GrpcError>

pub async fn from_channel(channel: Channel) -> Result<Self, GrpcError>

pub async fn local(default_model: ModelId) -> Result<Self, GrpcError>

pub async fn create_session( &self, params: CreateSessionParams, ) -> Result<String, GrpcError>

pub async fn resume_session( &self, session_id: &str, ) -> Result<(Vec<Message>, Vec<String>), GrpcError>

pub async fn subscribe_session_events(&self) -> Result<(), GrpcError>

pub async fn send_message( &self, message: String, model: ModelId, ) -> Result<(), GrpcError>

pub async fn send_content_message( &self, content: Vec<UserContent>, model: ModelId, ) -> Result<(), GrpcError>

pub async fn edit_message( &self, message_id: String, content: Vec<UserContent>, model: ModelId, ) -> Result<(), GrpcError>

pub async fn approve_tool( &self, tool_call_id: String, decision: ApprovalDecision, ) -> Result<(), GrpcError>

pub async fn switch_primary_agent( &self, primary_agent_id: String, ) -> Result<(), GrpcError>

pub async fn cancel_operation(&self) -> Result<(), GrpcError>

pub async fn compact_session(&self, model: ModelId) -> Result<(), GrpcError>

pub async fn execute_bash_command( &self, command: String, ) -> Result<(), GrpcError>

pub async fn dequeue_queued_item(&self) -> Result<(), GrpcError>

pub async fn subscribe_client_events( &self, ) -> Result<Receiver<ClientEvent>, GrpcError>

pub async fn session_id(&self) -> Option<String>

pub async fn list_sessions(&self) -> Result<Vec<SessionInfo>, GrpcError>

pub async fn get_session( &self, session_id: &str, ) -> Result<Option<SessionState>, GrpcError>

pub async fn delete_session(&self, session_id: &str) -> Result<bool, GrpcError>

pub async fn get_conversation( &self, session_id: &str, ) -> Result<(Vec<Message>, Vec<String>), GrpcError>

pub async fn shutdown(self)

pub async fn get_mcp_servers(&self) -> Result<Vec<McpServerInfo>, GrpcError>

pub async fn resolve_model(&self, input: &str) -> Result<ModelId, GrpcError>

pub async fn get_default_model(&self) -> Result<ModelId, GrpcError>

pub async fn list_providers(&self) -> Result<Vec<ProviderInfo>, GrpcError>

pub async fn get_provider_auth_status( &self, provider_id: Option<String>, ) -> Result<Vec<ProviderAuthStatus>, GrpcError>

pub async fn start_auth( &self, provider_id: String, ) -> Result<StartAuthResponse, GrpcError>

pub async fn send_auth_input( &self, flow_id: String, input: String, ) -> Result<AuthProgress, GrpcError>

pub async fn get_auth_progress( &self, flow_id: String, ) -> Result<AuthProgress, GrpcError>

pub async fn cancel_auth(&self, flow_id: String) -> Result<(), GrpcError>

pub async fn list_models( &self, provider_id: Option<String>, ) -> Result<Vec<ProviderModel>, GrpcError>

pub async fn list_workspace_files(&self) -> Result<Vec<String>, GrpcError>

pub async fn list_workspaces( &self, environment_id: Option<String>, ) -> Result<Vec<WorkspaceInfo>, GrpcError>

pub async fn list_repos( &self, environment_id: Option<String>, ) -> Result<Vec<RepoInfo>, GrpcError>

pub async fn resolve_repo( &self, environment_id: Option<String>, path: String, ) -> Result<RepoInfo, GrpcError>

pub async fn get_workspace_status( &self, workspace_id: &str, ) -> Result<WorkspaceStatus, GrpcError>