Struct McpConnectionManager 

pub struct McpConnectionManager { /* private fields */ }

A thin wrapper around a set of running [RmcpClient] instances.

Implementations

impl McpConnectionManager

pub async fn validate_required_servers(&self) -> Result<()>

Waits for every required server and reports their startup failures together.

Callers must make the manager reachable to request handlers before awaiting this method, because server initialization may require client elicitation.

impl McpConnectionManager

pub async fn list_all_tools(&self) -> Vec<ToolInfo>

Returns all tools with model-visible names normalized.

pub async fn tool_info(&self, server: &str, tool: &str) -> Option<ToolInfo>

Returns one tool from the current live connection.

pub async fn capture_binding_with_metadata( self: &Arc<Self>, config: Arc<McpConfig>, plugins_available: bool, ) -> McpBinding

Captures the ready clients, their exact tools, and the supplied runtime metadata.

pub async fn hard_refresh_codex_apps_tools_cache(&self) -> Result<Vec<ToolInfo>>

Force-refresh codex apps tools by bypassing the in-process cache.

On success, the refreshed tools replace shared cache contents when the cache is enabled and the latest filtered tools are returned directly to the caller. On failure, existing shared cache contents remain unchanged.

impl McpConnectionManager

pub async fn new( mcp_servers: &HashMap<String, EffectiveMcpServer>, store_mode: OAuthCredentialsStoreMode, keyring_backend_kind: AuthKeyringBackendKind, approval_policy: &Constrained<AskForApproval>, submit_id: String, tx_event: Option<Sender<Event>>, startup_cancellation_token: CancellationToken, initial_permission_profile: PermissionProfile, runtime_context: McpRuntimeContext, codex_home: PathBuf, codex_apps_tools_cache: ConnectorRuntimeManager<ToolInfo>, tool_catalog_cache: McpToolCatalogCache, codex_apps_tools_cache_key: ConnectorRuntimeContextKey, prefix_mcp_tool_names: bool, client_elicitation_capability: ElicitationCapability, supports_openai_form_elicitation: bool, tool_plugin_provenance: ToolPluginProvenance, auth: Option<&CodexAuth>, codex_apps_auth_manager: Option<Arc<AuthManager>>, elicitation_reviewer: Option<ElicitationReviewerHandle>, elicitation_lifecycle: Option<ElicitationLifecycle>, elicitation_router: ElicitationRequestRouter, ) -> Self

Creates an MCP connection manager. Threadless callers can pass no tx_event; startup notifications are then skipped and interactive elicitations are declined.

pub fn new_uninitialized_with_permission_profile( approval_policy: &Constrained<AskForApproval>, permission_profile: &PermissionProfile, prefix_mcp_tool_names: bool, ) -> Self

pub fn empty(prefix_mcp_tool_names: bool) -> Self

pub fn has_servers(&self) -> bool

pub async fn shutdown(&self)

Stop all MCP clients owned by this manager and terminate stdio server processes.

pub fn server_origin(&self, server_name: &str) -> Option<&str>

pub fn server_environment_id(&self, server_name: &str) -> Option<&str>

pub fn server_pollutes_memory(&self, server_name: &str) -> bool

pub fn plugin_id_for_mcp_server_name(&self, server_name: &str) -> Option<&str>

pub fn is_selected_plugin_mcp_server(&self, server_name: &str) -> bool

pub fn tool_approval_mode( &self, server_name: &str, tool_name: &str, ) -> AppToolApproval

pub fn is_host_owned_codex_apps_server(&self, server_name: &str) -> bool

pub fn set_approval_policy(&self, approval_policy: &Constrained<AskForApproval>)

pub fn set_permission_profile(&self, permission_profile: PermissionProfile)

pub fn elicitations_auto_deny(&self) -> bool

pub fn set_elicitations_auto_deny(&self, auto_deny: bool)

pub fn elicitation_router(&self) -> ElicitationRequestRouter

pub async fn resolve_elicitation( &self, server_name: String, id: RequestId, response: ElicitationResponse, ) -> Result<()>

pub async fn wait_for_server_ready( &self, server_name: &str, timeout: Duration, ) -> bool

pub async fn list_all_resources( &self, include_server: impl Fn(&str) -> bool, ) -> HashMap<String, Vec<Resource>>

Returns resources from servers selected by include_server. Each key is the server name and the value is a vector of resources.

pub async fn list_all_resource_templates( &self, include_server: impl Fn(&str) -> bool, ) -> HashMap<String, Vec<ResourceTemplate>>

Returns resource templates from servers selected by include_server. Each key is the server name and the value is a vector of templates.

pub async fn call_tool( &self, server: &str, tool: &str, arguments: Option<Value>, meta: Option<Value>, ) -> Result<CallToolResult>

Invoke the tool indicated by the (server, tool) pair.

pub async fn server_supports_sandbox_state_meta_capability( &self, server: &str, ) -> Result<bool>

pub async fn list_resources( &self, server: &str, params: Option<PaginatedRequestParams>, ) -> Result<ListResourcesResult>

List resources from the specified server.

pub async fn list_resource_templates( &self, server: &str, params: Option<PaginatedRequestParams>, ) -> Result<ListResourceTemplatesResult>

List resource templates from the specified server.

pub async fn read_resource( &self, server: &str, params: ReadResourceRequestParams, ) -> Result<ReadResourceResult>

Read a resource from the specified server.

Trait Implementations

impl Drop for McpConnectionManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.