Struct McpRegistry 

pub struct McpRegistry { /* private fields */ }

Implementations

impl McpRegistry

pub fn empty() -> Self

Create an empty registry with no MCP servers or tools.

pub async fn load_from_file(path: &str) -> Result<Self>

pub async fn from_config(cfg: &McpConfig) -> Result<Self>

pub fn new_empty() -> Self

Creates an empty registry for testing.

pub fn new_with_test_tool(name: &str, description: &str) -> Self

Creates a registry with a single test tool.

pub fn new_with_test_tool_annotations( name: &str, description: &str, annotations: ToolAnnotations, ) -> Result<Self, ToolAssemblyError>

Creates a registry with one annotated test tool.

Errors

Returns an assembly error if the static schema or generated descriptor is invalid.

pub fn new_with_test_tool_for_server( server: &str, name: &str, description: &str, annotations: ToolAnnotations, ) -> Result<Self, ToolAssemblyError>

Creates a registry with one annotated test tool under server.

Errors

Returns an assembly error if the static schema or generated descriptor is invalid.

pub fn tools(&self) -> Vec<(String, Tool)>

Return namespaced tools as (namespaced_name, Tool)

pub fn descriptors(&self) -> Vec<Arc<ToolDescriptor>>

Return compiled descriptors in provider-name order.

pub fn descriptor(&self, provider_name: &str) -> Option<Arc<ToolDescriptor>>

Look up one compiled descriptor by provider-visible name.

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

Return configured MCP server names.

pub async fn freeze_bindings(&self) -> Result<Self>

Freeze the selected descriptors and exact live transports for delegation. Re-list selected remote tools on those same transports to reject a configuration/catalog replacement racing snapshot capture. New tools are not added. This view cannot connect, reconnect, merge, or add tools.

Errors

Refuses missing/closed bindings, changed descriptors, or failed discovery.

pub fn has_frozen_bindings(&self) -> bool

Whether this registry is a captured connection view, not a catalog that may establish connections from configuration or environment variables.

pub fn require_bound_servers<'a>( &self, servers: impl IntoIterator<Item = &'a str>, ) -> Result<()>

Validate inherited dependencies without starting or reconfiguring them.

Errors

Refuses a non-frozen registry or any unavailable/replaced connection.

pub fn is_native_tool(&self, namespaced_name: &str) -> bool

Return whether the namespaced tool is backed by an in-process native tool.

pub fn resolve_mcp_tool( &self, namespaced_name: &str, ) -> Option<(String, String)>

Resolve the backing MCP server and raw tool name for a namespaced tool.

pub fn server_entries(&self) -> HashMap<String, McpServerEntry>

Return persisted runtime MCP definitions without exposing connected handles.

pub async fn upsert_server( &self, name: String, entry: McpServerEntry, ) -> Result<()>

Add or replace one MCP server and immediately refresh its advertised tools.

pub fn remove_server(&self, name: &str) -> bool

Remove one MCP server and every tool it contributed.

pub fn merge(&self, other: &McpRegistry) -> Result<Self, McpMergeError>

Merge another registry into this one, returning a deduplicated registry. This is used to combine global tools with skill-specific tools.

Errors

Returns a collision for incompatible descriptors, or rejects composition involving a frozen connection view. Delegation only supports filtering.

pub fn filtered( &self, allowed_servers: Option<&HashSet<String>>, allowed_tools: Option<&HashSet<String>>, ) -> Self

Return a registry narrowed to the server and tool sets allowed by the resolved run policy.

None means “all currently registered values” while Some(empty) means “none”. Native tools are governed by allowed_tools because they do not belong to an MCP server.

pub fn with_native_tool( self, tool: Arc<dyn NativeTool>, ) -> Result<Self, ToolAssemblyError>

Add an in-process runtime tool and its compiled descriptor.

Errors

Returns an assembly error for an invalid schema or a provider-name collision.

pub fn openai_tools_json(&self) -> Vec<Value>

pub async fn call_namespaced_tool( &self, namespaced_tool: &str, arguments: Value, ) -> Result<Value>

Execute a namespaced tool, e.g. “time__now” or “tavily__search”.

Trait Implementations

impl Clone for McpRegistry

fn clone(&self) -> McpRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for McpRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.