Struct McpServiceRegistry 

pub struct McpServiceRegistry { /* private fields */ }

Manages MCP services offered to successor proxies and agents.

Use the Self::add_rmcp_server method to register MCP servers implemented using the rmcp crate.

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 registery (or a clone of it) to the JsonRpcConnection so that it can intercept MCP requests. Typically you do this by providing it as an argument to the [`]

Implementations

impl McpServiceRegistry

pub fn new() -> Self

pub fn with_rmcp_server<S>( self, name: impl ToString, make_service: impl Fn() -> S + 'static + Send + Sync, ) -> Result<Self, Error>

where S: Service<RoleServer>,

Add the MCP server to the registry and return self. Useful for chaining. Equivalent to Self::add_rmcp_server.

Parameters

• name: The name of the server.
• make_service: A function that creates the service (e.g., YourService::new).

pub fn add_rmcp_server<S>( &self, name: impl ToString, make_service: impl Fn() -> S + 'static + Send + Sync, ) -> Result<(), Error>

where S: Service<RoleServer>,

Add an MCP server implemented using the rmcp crate.

Parameters

• name: The name of the server.
• make_service: A function that creates the service (e.g., YourService::new).

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 JsonRpcHandler for McpServiceRegistry

fn describe_chain(&self) -> impl Debug

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

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