Struct McpProxyPlane 

pub struct McpProxyPlane { /* private fields */ }

ExecutionPlane that proxies tool calls to MCP servers over JSON-RPC 2.0 (stdio).

Credentials live in a CredentialVault and are injected into each server’s subprocess environment — the model never sees the credential values.

Usage:

let mut plane = McpProxyPlane::new(Arc::new(EnvCredentialVault));
plane.add_server("brave", McpServerConfig {
    command: "npx".into(),
    args: vec!["-y".into(), "@modelcontextprotocol/server-brave-search".into()],
    credential_keys: vec!["BRAVE_API_KEY".into()],
    env: Default::default(),
});
plane.connect().await?;
// ... use with RuntimeRunner ...
plane.disconnect().await;

Implementations

impl McpProxyPlane

pub fn new(vault: Arc<dyn CredentialVault>) -> Self

pub fn add_server( &mut self, name: impl Into<String>, config: McpServerConfig, ) -> &mut Self

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

Start all configured MCP server processes and discover their tool schemas.

pub async fn disconnect(&mut self)

Gracefully stop all MCP server processes.

pub fn register(&mut self, tool: RegisteredTool) -> &mut Self

Register an in-process tool. Local tools take priority over MCP tools of the same name.

pub fn unregister(&mut self, name: &str) -> &mut Self

Trait Implementations

impl ExecutionPlane for McpProxyPlane

fn schemas(&self) -> Vec<ToolSchema>

fn execute_all<'a>( &'a self, calls: &'a [ToolCall], ctx: RunContext<'a>, ) -> Pin<Box<dyn Stream<Item = Result<RunEvent>> + Send + 'a>>

Execute a batch of calls. Yields intermediate events; ends with one ToolResult per call.