Struct McpServiceRegistry 

pub struct McpServiceRegistry { /* private fields */ }

Manages MCP services offered to successor proxies and agents.

Use the Self::add_mcp_server method to register MCP servers. For rmcp-based servers, use the sacp-rmcp crate which provides convenient extension methods.

This struct is a handle to the underlying registry. Cloning the struct produces a second handle to the same registry.

Handling requests

You must add the registry (or a clone of it) to the JrHandlerChain so that it can intercept MCP requests. Typically you do this by providing it as an argument to the handler chain methods.

Implementations

impl McpServiceRegistry

pub fn new() -> Self

Creates a new empty MCP service registry

pub fn add_mcp_server<C: Component>( &self, name: impl ToString, new_fn: impl Fn() -> C + Send + Sync + 'static, ) -> Result<(), Error>

Add an MCP server to the registry using a custom spawner.

This is the base method for adding MCP servers. Use this if you have a custom way to create Component instances for your MCP server.

For rmcp-based servers, use the sacp-rmcp crate which provides convenient extension methods.

Parameters

• name: The name of the server.
• spawner: A trait object that can create Component instances.

Trait Implementations

impl AsRef<McpServiceRegistry> for McpServiceRegistry

fn as_ref(&self) -> &McpServiceRegistry

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for McpServiceRegistry

fn clone(&self) -> McpServiceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for McpServiceRegistry

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

Formats the value using the given formatter.

impl Default for McpServiceRegistry

fn default() -> McpServiceRegistry

Returns the “default value” for a type.

impl JrMessageHandler for McpServiceRegistry

fn describe_chain(&self) -> impl Debug

Returns a debug description of the handler chain for diagnostics

async fn handle_message( &mut self, message: MessageAndCx, ) -> Result<Handled<MessageAndCx>, Error>

Attempt to claim an incoming message (request or notification).