Struct AgentNetworkClient 

pub struct AgentNetworkClient { /* private fields */ }

MCP relay client that communicates with a subprocess over stdio.

Implementations

impl AgentNetworkClient

pub async fn spawn_agent( &mut self, description: &str, working_dir: &str, config: AgentConfig, ) -> Result<String, AgentNetworkClientError>

Spawn a new agent with the given description and config.

pub async fn await_agent( &mut self, agent_id: &str, timeout_secs: Option<u64>, ) -> Result<AgentResult, AgentNetworkClientError>

Wait for an agent to complete, with optional timeout.

pub async fn list_agents( &mut self, ) -> Result<Vec<AgentInfo>, AgentNetworkClientError>

List all agents.

pub async fn stop_agent( &mut self, agent_id: &str, ) -> Result<(), AgentNetworkClientError>

Stop a running agent by ID.

pub async fn get_agent_status( &mut self, agent_id: &str, ) -> Result<AgentInfo, AgentNetworkClientError>

Get the current status of an agent by ID.

impl AgentNetworkClient

pub async fn connect( binary_path: &str, ) -> Result<AgentNetworkClient, AgentNetworkClientError>

Connect to a relay process using default MCP server arguments.

pub async fn connect_with_args( binary_path: &str, args: &[&str], ) -> Result<AgentNetworkClient, AgentNetworkClientError>

Connect to a relay process with custom arguments.

pub async fn send_request( &mut self, method: &str, params: Option<Value>, ) -> Result<Value, AgentNetworkClientError>

Send a JSON-RPC request and read the response.

pub async fn initialize(&mut self) -> Result<Value, AgentNetworkClientError>

Perform the MCP initialize handshake with the relay process.

pub async fn call_tool( &mut self, name: &str, args: Value, ) -> Result<Value, AgentNetworkClientError>

Call a tool on the relay server by name with the given arguments.

pub async fn list_tools(&mut self) -> Result<Value, AgentNetworkClientError>

List all tools available on the relay server.

pub async fn shutdown(self) -> Result<(), AgentNetworkClientError>

Shut down the relay client and terminate the child process.

pub fn is_initialized(&self) -> bool

Check whether the client has completed initialization.