Struct McpManager 

pub struct McpManager { /* private fields */ }

Manages connections to multiple MCP servers and their tools

Implementations

impl McpManager

pub fn new( event_sender: Sender<McpClientEvent>, oauth_handler: Option<Arc<dyn OAuthHandler>>, ) -> Self

pub async fn add_mcps(&mut self, configs: Vec<McpServerConfig>) -> Result<()>

pub async fn add_mcp_with_auth( &mut self, name: String, base_url: &str, auth_header: String, ) -> Result<()>

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

pub fn get_client_for_tool( &self, namespaced_tool_name: &str, arguments_json: &str, ) -> Result<(Arc<RunningService<RoleClient, McpClient>>, CallToolRequestParams)>

pub fn tool_definitions(&self) -> Vec<ToolDefinition>

pub fn server_instructions(&self) -> Vec<ServerInstructions>

pub fn server_statuses(&self) -> &[McpServerStatusEntry]

pub async fn authenticate_server(&mut self, name: &str) -> Result<()>

pub async fn list_prompts(&self) -> Result<Vec<Prompt>>

List all prompts from all connected MCP servers with namespacing

pub async fn get_prompt( &self, namespaced_prompt_name: &str, arguments: Option<Map<String, Value>>, ) -> Result<GetPromptResult>

Get a specific prompt by namespaced name

pub async fn shutdown(&mut self)

Shutdown all servers and wait for their tasks to complete

pub async fn shutdown_server(&mut self, server_name: &str) -> Result<()>

Shutdown a specific server by name

pub async fn set_roots(&mut self, new_roots: Vec<Root>) -> Result<()>

Set the roots advertised to MCP servers.

This updates the roots and sends notifications to all connected servers that support the roots/list_changed notification.

Trait Implementations

impl Drop for McpManager

fn drop(&mut self)

Executes the destructor for this type.