Struct MCPServerManager 

pub struct MCPServerManager { /* private fields */ }

MCP服务器管理器 / MCP server manager

Implementations

impl MCPServerManager

pub fn new() -> Self

创建新的管理器 / Create new manager

pub fn with_config( health_check_config: HealthCheckConfig, reconnect_policy: ReconnectPolicy, ) -> Self

使用自定义配置创建管理器 / Create manager with custom configuration

pub fn get_state_notifier(&self) -> Receiver<ManagerState>

获取状态通知器 / Get state notifier

pub async fn initialize( &self, servers: Vec<MCPServerConfig>, ) -> Result<(), ComputerError>

初始化管理器 / Initialize manager

pub async fn add_or_update_server( &self, config: MCPServerConfig, ) -> Result<(), ComputerError>

添加或更新服务器配置 / Add or update server configuration

pub async fn remove_server( &self, server_name: &str, ) -> Result<(), ComputerError>

移除服务器配置 / Remove server configuration

pub async fn start_all(&self) -> Result<(), ComputerError>

启动所有启用的服务器 / Start all enabled servers

pub async fn start_client(&self, server_name: &str) -> Result<(), ComputerError>

启动单个客户端 / Start single client

pub async fn stop_client(&self, server_name: &str) -> Result<(), ComputerError>

停止单个客户端 / Stop single client

pub async fn stop_all(&self) -> Result<(), ComputerError>

停止所有客户端 / Stop all clients

pub async fn close(&self) -> Result<(), ComputerError>

关闭管理器 / Close manager

pub async fn validate_tool_call( &self, tool_name: &str, _parameters: &Value, ) -> Result<(ServerName, ToolName), ComputerError>

验证工具调用 / Validate tool call

pub async fn call_tool( &self, server_name: &str, tool_name: &str, parameters: Value, timeout: Option<Duration>, ) -> Result<CallToolResult, ComputerError>

调用工具 / Call tool

pub async fn execute_tool( &self, tool_name: &str, parameters: Value, timeout: Option<Duration>, ) -> Result<CallToolResult, ComputerError>

执行工具（支持别名） / Execute tool (supports alias)

pub async fn get_server_status(&self) -> Vec<(String, bool, String)>

获取服务器状态列表 / Get server status list

pub async fn get_server_configs(&self) -> Value

获取所有服务器配置（用于 GetComputerConfigRet） Get all server configurations (for GetComputerConfigRet) 返回格式：{ server_name: { type, status, disabled, … } } Returns format: { server_name: { type, status, disabled, … } }

pub async fn list_available_tools(&self) -> Vec<Tool>

获取可用工具列表 / Get available tools list

pub async fn enable_auto_connect(&self)

启用自动连接 / Enable auto connect

pub async fn disable_auto_connect(&self)

禁用自动连接 / Disable auto connect

pub async fn enable_auto_reconnect(&self)

启用自动重连 / Enable auto reconnect

pub async fn disable_auto_reconnect(&self)

禁用自动重连 / Disable auto reconnect

pub async fn set_health_check_config(&self, config: HealthCheckConfig)

设置健康检查配置 / Set health check configuration

pub async fn get_health_check_config(&self) -> HealthCheckConfig

获取健康检查配置 / Get health check configuration

pub async fn set_reconnect_policy(&self, policy: ReconnectPolicy)

设置重连策略 / Set reconnect policy

pub async fn get_reconnect_policy(&self) -> ReconnectPolicy

获取重连策略 / Get reconnect policy

pub async fn start_health_monitor(&self)

启动健康监控 / Start health monitoring 定期检查所有活动客户端的健康状态，并在检测到故障时自动重连 Periodically checks health of all active clients and auto-reconnects on failure

pub async fn stop_health_monitor(&self)

停止健康监控 / Stop health monitoring

pub async fn check_server_health( &self, server_name: &str, ) -> Option<HealthCheckResult>

检查单个服务器的健康状态 / Check health of a single server

pub async fn check_all_health(&self) -> HashMap<String, HealthCheckResult>

检查所有服务器的健康状态 / Check health of all servers

pub async fn get_retry_counts(&self) -> HashMap<String, u32>

获取重试计数 / Get retry counts

pub async fn reset_retry_count(&self, server_name: &str)

重置特定服务器的重试计数 / Reset retry count for a specific server

pub async fn reset_all_retry_counts(&self)

重置所有重试计数 / Reset all retry counts

Trait Implementations

impl Default for MCPServerManager

fn default() -> Self

Returns the “default value” for a type.