Struct Router 

pub struct Router { /* private fields */ }

Routes MCP requests to the appropriate handlers.

Implementations

impl Router

pub fn new() -> Self

Creates a new empty router.

pub fn set_list_page_size(&mut self, page_size: Option<usize>)

Sets the list pagination page size.

When set, list methods (tools/list, resources/list, resources/templates/list, prompts/list, tasks/list) will page results using opaque base64 cursors.

pub fn set_strict_input_validation(&mut self, strict: bool)

Sets whether to use strict input validation.

When enabled, tool input validation will reject any properties not explicitly defined in the tool’s input schema (enforces additionalProperties: false).

When disabled (default), extra properties are allowed unless the schema explicitly sets additionalProperties: false.

pub fn strict_input_validation(&self) -> bool

Returns whether strict input validation is enabled.

pub fn add_tool<H: ToolHandler + 'static>(&mut self, handler: H)

Adds a tool handler.

If a tool with the same name already exists, it will be replaced. Use add_tool_with_behavior for finer control over duplicate handling.

pub fn add_tool_with_behavior<H: ToolHandler + 'static>( &mut self, handler: H, behavior: DuplicateBehavior, ) -> Result<(), McpError>

Adds a tool handler with specified duplicate behavior.

Returns Err if behavior is [DuplicateBehavior::Error] and the tool name already exists.

pub fn add_resource<H: ResourceHandler + 'static>(&mut self, handler: H)

Adds a resource handler.

If a resource with the same URI already exists, it will be replaced. Use add_resource_with_behavior for finer control over duplicate handling.

pub fn add_resource_with_behavior<H: ResourceHandler + 'static>( &mut self, handler: H, behavior: DuplicateBehavior, ) -> Result<(), McpError>

Adds a resource handler with specified duplicate behavior.

Returns Err if behavior is [DuplicateBehavior::Error] and the resource URI already exists.

pub fn add_resource_template(&mut self, template: ResourceTemplate)

Adds a resource template definition.

pub fn add_prompt<H: PromptHandler + 'static>(&mut self, handler: H)

Adds a prompt handler.

If a prompt with the same name already exists, it will be replaced. Use add_prompt_with_behavior for finer control over duplicate handling.

pub fn add_prompt_with_behavior<H: PromptHandler + 'static>( &mut self, handler: H, behavior: DuplicateBehavior, ) -> Result<(), McpError>

Adds a prompt handler with specified duplicate behavior.

Returns Err if behavior is [DuplicateBehavior::Error] and the prompt name already exists.

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

Returns all tool definitions.

pub fn tools_filtered( &self, session_state: Option<&SessionState>, tag_filters: Option<&TagFilters<'_>>, ) -> Vec<Tool>

Returns tool definitions filtered by session state and tags.

Tools that have been disabled in the session state will not be included. If tag filters are provided, tools must match the include/exclude criteria.

pub fn resources(&self) -> Vec<Resource>

Returns all resource definitions.

pub fn resources_filtered( &self, session_state: Option<&SessionState>, tag_filters: Option<&TagFilters<'_>>, ) -> Vec<Resource>

Returns resource definitions filtered by session state and tags.

Resources that have been disabled in the session state will not be included. If tag filters are provided, resources must match the include/exclude criteria.

pub fn resource_templates(&self) -> Vec<ResourceTemplate>

Returns all resource templates.

pub fn resource_templates_filtered( &self, session_state: Option<&SessionState>, tag_filters: Option<&TagFilters<'_>>, ) -> Vec<ResourceTemplate>

Returns resource templates filtered by session state and tags.

Templates that have been disabled in the session state will not be included. If tag filters are provided, templates must match the include/exclude criteria.

pub fn prompts(&self) -> Vec<Prompt>

Returns all prompt definitions.

pub fn prompts_filtered( &self, session_state: Option<&SessionState>, tag_filters: Option<&TagFilters<'_>>, ) -> Vec<Prompt>

Returns prompt definitions filtered by session state and tags.

Prompts that have been disabled in the session state will not be included. If tag filters are provided, prompts must match the include/exclude criteria.

pub fn tools_count(&self) -> usize

Returns the number of registered tools.

pub fn resources_count(&self) -> usize

Returns the number of registered resources.

pub fn resource_templates_count(&self) -> usize

Returns the number of registered resource templates.

pub fn prompts_count(&self) -> usize

Returns the number of registered prompts.

pub fn get_tool(&self, name: &str) -> Option<&Box<dyn ToolHandler>>

Gets a tool handler by name.

pub fn get_resource(&self, uri: &str) -> Option<&Box<dyn ResourceHandler>>

Gets a resource handler by URI.

pub fn get_resource_template( &self, uri_template: &str, ) -> Option<&ResourceTemplate>

Gets a resource template by URI template.

pub fn resource_exists(&self, uri: &str) -> bool

Returns true if a resource exists for the given URI (static or template match).

pub fn get_prompt(&self, name: &str) -> Option<&Box<dyn PromptHandler>>

Gets a prompt handler by name.

pub fn handle_initialize( &self, _cx: &Cx, session: &mut Session, params: InitializeParams, instructions: Option<&str>, ) -> McpResult<InitializeResult>

Handles the initialize request.

pub fn handle_tools_list( &self, _cx: &Cx, params: ListToolsParams, session_state: Option<&SessionState>, ) -> McpResult<ListToolsResult>

Handles the tools/list request.

If session_state is provided, disabled tools will be filtered out. If include_tags/exclude_tags are provided, tools are filtered by tags.

pub fn handle_tools_call( &self, cx: &Cx, request_id: u64, params: CallToolParams, budget: &Budget, session_state: SessionState, notification_sender: Option<&NotificationSender>, bidirectional_senders: Option<&BidirectionalSenders>, ) -> McpResult<CallToolResult>

Handles the tools/call request.

Arguments

• cx - The asupersync context for cancellation and tracing
• request_id - Internal request ID for tracking
• params - The tool call parameters including tool name and arguments
• budget - Request budget for timeout enforcement
• session_state - Session state for per-session storage
• notification_sender - Optional callback for sending progress notifications
• bidirectional_senders - Optional senders for sampling/elicitation

pub fn handle_resources_list( &self, _cx: &Cx, params: ListResourcesParams, session_state: Option<&SessionState>, ) -> McpResult<ListResourcesResult>

Handles the resources/list request.

If session_state is provided, disabled resources will be filtered out. If include_tags/exclude_tags are provided, resources are filtered by tags.

pub fn handle_resource_templates_list( &self, _cx: &Cx, params: ListResourceTemplatesParams, session_state: Option<&SessionState>, ) -> McpResult<ListResourceTemplatesResult>

Handles the resources/templates/list request.

If session_state is provided, disabled resource templates will be filtered out. If include_tags/exclude_tags are provided, templates are filtered by tags.

pub fn handle_resources_read( &self, cx: &Cx, request_id: u64, params: &ReadResourceParams, budget: &Budget, session_state: SessionState, notification_sender: Option<&NotificationSender>, bidirectional_senders: Option<&BidirectionalSenders>, ) -> McpResult<ReadResourceResult>

Handles the resources/read request.

Arguments

• cx - The asupersync context for cancellation and tracing
• request_id - Internal request ID for tracking
• params - The resource read parameters including URI
• budget - Request budget for timeout enforcement
• session_state - Session state for per-session storage
• notification_sender - Optional callback for sending progress notifications
• bidirectional_senders - Optional senders for sampling/elicitation

pub fn handle_prompts_list( &self, _cx: &Cx, params: ListPromptsParams, session_state: Option<&SessionState>, ) -> McpResult<ListPromptsResult>

Handles the prompts/list request.

If session_state is provided, disabled prompts will be filtered out. If include_tags/exclude_tags are provided, prompts are filtered by tags.

pub fn handle_prompts_get( &self, cx: &Cx, request_id: u64, params: GetPromptParams, budget: &Budget, session_state: SessionState, notification_sender: Option<&NotificationSender>, bidirectional_senders: Option<&BidirectionalSenders>, ) -> McpResult<GetPromptResult>

Handles the prompts/get request.

Arguments

• cx - The asupersync context for cancellation and tracing
• request_id - Internal request ID for tracking
• params - The prompt get parameters including name and arguments
• budget - Request budget for timeout enforcement
• session_state - Session state for per-session storage
• notification_sender - Optional callback for sending progress notifications
• bidirectional_senders - Optional senders for sampling/elicitation

pub fn handle_tasks_list( &self, _cx: &Cx, params: ListTasksParams, task_manager: Option<&SharedTaskManager>, ) -> McpResult<ListTasksResult>

Handles the tasks/list request.

Lists all background tasks, optionally filtered by status.

pub fn handle_tasks_get( &self, _cx: &Cx, params: GetTaskParams, task_manager: Option<&SharedTaskManager>, ) -> McpResult<GetTaskResult>

Handles the tasks/get request.

Gets information about a specific task, including its result if completed.

pub fn handle_tasks_cancel( &self, _cx: &Cx, params: CancelTaskParams, task_manager: Option<&SharedTaskManager>, ) -> McpResult<CancelTaskResult>

Handles the tasks/cancel request.

Requests cancellation of a running or pending task.

pub fn handle_tasks_submit( &self, cx: &Cx, params: SubmitTaskParams, task_manager: Option<&SharedTaskManager>, ) -> McpResult<SubmitTaskResult>

Handles the tasks/submit request.

Submits a new background task for execution.

impl Router

pub fn mount(&mut self, other: Router, prefix: Option<&str>) -> MountResult

Mounts all handlers from another router with an optional prefix.

This consumes the source router and moves its handlers into this router. Names/URIs are prefixed with prefix/ if a prefix is provided.

Example

let mut main_router = Router::new();
let db_router = Router::new();
// ... add handlers to db_router ...

main_router.mount(db_router, Some("db"));
// Tool "query" becomes "db/query"

pub fn mount_tools( &mut self, other: Router, prefix: Option<&str>, ) -> MountResult

Mounts only tools from a router.

pub fn mount_resources( &mut self, other: Router, prefix: Option<&str>, ) -> MountResult

Mounts only resources from a router.

pub fn mount_prompts( &mut self, other: Router, prefix: Option<&str>, ) -> MountResult

Mounts only prompts from a router.

Trait Implementations

impl Default for Router

fn default() -> Self

Returns the “default value” for a type.