Struct McpServer 

pub struct McpServer { /* private fields */ }

MCP server backed by the rmcp framework.

The struct is cloned per request by rmcp’s handler dispatch; the expensive bits (provider closure) are behind an Arc so cloning is cheap.

Implementations

impl McpServer

pub fn new(options: ServerOptions) -> Self

pub fn builtins(&self) -> &BuiltinsConfig

Read the manifest-declared builtins: config. Downstream consumers (e.g. a graph_overview tool that wipes a temp/ directory when temp_cleanup: on_overview is set) call this to discover what flags the operator asked for. The framework itself does not act on this — that would force it to interpret graph-specific semantics it shouldn’t know about.

pub fn tool_router_mut(&mut self) -> &mut ToolRouter<McpServer>

Mutable access to the tool router for dynamic tool registration.

Use only at server-construction time (before serve). Once dispatching starts, the router is cloned per request and mutation would race.

pub fn prompt_router_mut(&mut self) -> &mut PromptRouter<McpServer>

Mutable access to the prompt router for dynamic skill / prompt registration. Same lifecycle contract as [tool_router_mut]: boot-time only. Most operators reach prompts via serve_prompts rather than touching the router directly.

pub fn register_typed_tool<T, F>( &mut self, name: &'static str, description: &'static str, handler: F, )

where T: for<'de> Deserialize<'de> + JsonSchema + Default + Send + Sync + 'static, F: Fn(T) -> String + Send + Sync + 'static,

Register a typed dynamic tool. Compresses the boilerplate of:

1. Generating a JSON Schema for the args type via schemars.
2. Building a rmcp::model::Tool attr from the schema + name + description.
3. Deserialising the per-call JSON arguments via serde.
4. Wrapping the handler in a rmcp::handler::server::router::tool::ToolRoute::new_dyn closure suitable for tool_router_mut.

The handler is Fn(T) -> String; it owns whatever state it needs through the closure environment (typically an Arc-clone of a domain-specific state handle). Returning a string means the tool reports a clean text body to the agent rather than exposing a tool-error envelope — matches the framework’s “errors as values” convention for source / GitHub tools.

pub fn ping_tool_attr() -> Tool

Generated tool metadata function for ping

pub fn read_source_tool_attr() -> Tool

Generated tool metadata function for read_source

pub fn grep_tool_attr() -> Tool

Generated tool metadata function for grep

pub fn list_source_tool_attr() -> Tool

Generated tool metadata function for list_source

pub fn repo_management_tool_attr() -> Tool

Generated tool metadata function for repo_management

Trait Implementations

impl Clone for McpServer

fn clone(&self) -> McpServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for McpServer

fn get_info(&self) -> ServerInfo

async fn list_prompts( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListPromptsResult, McpError>

async fn get_prompt( &self, request: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> Result<GetPromptResult, McpError>

async fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResult, ErrorData>

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

fn get_tool(&self, name: &str) -> Option<Tool>

Get a tool definition by name.

fn enqueue_task( &self, _request: CallToolRequestParams, _context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CreateTaskResult, ErrorData>> + MaybeSendFuture

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + MaybeSendFuture

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn list_resources( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + MaybeSendFuture

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture

fn read_resource( &self, request: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResult, ErrorData>> + MaybeSendFuture

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn list_tasks( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListTasksResult, ErrorData>> + MaybeSendFuture

fn get_task_info( &self, request: GetTaskInfoParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture

fn get_task_result( &self, request: GetTaskResultParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskPayloadResult, ErrorData>> + MaybeSendFuture

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CancelTaskResult, ErrorData>> + MaybeSendFuture