Struct McpServerManager 

pub struct McpServerManager { /* private fields */ }

Manages MCP server connections and tool execution.

Implementations

impl McpServerManager

pub async fn reconcile_from_config(&self, config: &McpConfig)

Reconcile running MCP servers with the desired configuration.

This is best-effort and will:

• Stop servers that are running but removed/disabled in config.
• Start enabled servers that are not running.
• Restart servers whose effective runtime config changed.

Secrets are compared by their hydrated plaintext (env/header values), not by the encrypted-at-rest blobs (which can change on every save due to random nonces).

pub async fn initialize_from_config(&self, config: &McpConfig)

Initialize from configuration.

impl McpServerManager

pub async fn start_server(&self, config: McpServerConfig) -> Result<()>

Start a new MCP server connection.

pub async fn stop_server(&self, server_id: &str) -> Result<()>

Stop an MCP server connection.

pub async fn call_tool( &self, server_id: &str, tool_name: &str, args: Value, ) -> Result<McpCallResult>

Call a tool on a specific server.

pub fn get_tool_info(&self, server_id: &str, tool_name: &str) -> Option<McpTool>

Get tool info for a specific tool.

pub async fn refresh_tools(&self, server_id: &str) -> Result<()>

Refresh tools from a server.

impl McpServerManager

pub fn new() -> Self

pub fn new_with_config(config: Arc<RwLock<Config>>) -> Self

Create a manager that can respect global proxy settings when connecting SSE transports.

pub fn with_event_channel(self, tx: Sender<McpEvent>) -> Self

pub fn tool_index(&self) -> Arc<ToolIndex>

pub fn list_servers(&self) -> Vec<String>

Get all server IDs.

pub fn get_server_info(&self, server_id: &str) -> Option<RuntimeInfo>

Get runtime info for a server.

pub fn is_server_running(&self, server_id: &str) -> bool

Check if a server is running.

pub async fn shutdown_all(&self)

Shutdown all servers.

Trait Implementations

impl Clone for McpServerManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for McpServerManager

fn default() -> Self

Returns the “default value” for a type.