Struct CratesDocsHandler 

pub struct CratesDocsHandler { /* private fields */ }

MCP server handler

Implements standard MCP protocol handler interface, handles client requests.

Fields

• server: Server instance
• config: Handler configuration
• metrics: Optional metrics collector

Implementations

impl CratesDocsHandler

pub fn new(server: Arc<CratesDocsServer>) -> Self

Create new handler

Arguments

• server - Server instance

Example

use std::sync::Arc;
use crates_docs::server::{CratesDocsServer, CratesDocsHandler};
use crates_docs::AppConfig;

let config = AppConfig::default();
let server = Arc::new(CratesDocsServer::new(config).unwrap());
let handler = CratesDocsHandler::new(server);

pub fn with_config(server: Arc<CratesDocsServer>, config: HandlerConfig) -> Self

Create handler with configuration

pub fn with_merged_config( server: Arc<CratesDocsServer>, base_config: HandlerConfig, override_config: Option<HandlerConfig>, ) -> Self

Create handler with merged configuration

pub fn with_metrics(self, metrics: Arc<ServerMetrics>) -> Self

Set metrics

pub fn server(&self) -> &Arc<CratesDocsServer>

Get server reference

pub fn tool_registry(&self) -> &ToolRegistry

Get tool registry

pub fn config(&self) -> &HandlerConfig

Get configuration

pub fn metrics(&self) -> Option<&Arc<ServerMetrics>>

Get metrics (optional)

pub fn list_tools(&self) -> ListToolsResult

Get all tools list

pub fn list_resources(&self) -> ListResourcesResult

Get empty resources list

pub fn list_prompts(&self) -> ListPromptsResult

Get empty prompts list

pub async fn execute_tool( &self, params: CallToolRequestParams, ) -> ToolExecutionResult

Execute tool call (core logic)

This method encapsulates the complete tool execution flow:

• tracing tracking
• timing statistics
• metrics recording (if enabled)

Returns

Returns ToolExecutionResult, can be converted to different types to adapt to different traits

Trait Implementations

impl ServerHandler for CratesDocsHandler

fn handle_list_tools_request<'life0, 'async_trait>( &'life0 self, _request: Option<PaginatedRequestParams>, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ListToolsResult, RpcError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle list tools request

fn handle_call_tool_request<'life0, 'async_trait>( &'life0 self, params: CallToolRequestParams, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, CallToolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle call tool request

fn handle_list_resources_request<'life0, 'async_trait>( &'life0 self, _request: Option<PaginatedRequestParams>, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ListResourcesResult, RpcError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle list resources request

fn handle_read_resource_request<'life0, 'async_trait>( &'life0 self, _params: ReadResourceRequestParams, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ReadResourceResult, RpcError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle read resource request

fn handle_list_prompts_request<'life0, 'async_trait>( &'life0 self, _request: Option<PaginatedRequestParams>, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ListPromptsResult, RpcError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle list prompts request

fn handle_get_prompt_request<'life0, 'async_trait>( &'life0 self, _params: GetPromptRequestParams, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<GetPromptResult, RpcError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle get prompt request

fn on_initialized<'life0, 'async_trait>( &'life0 self, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Invoked when the server finishes initialization and receives an initialized_notification from the client.

fn handle_initialize_request<'life0, 'async_trait>( &'life0 self, params: InitializeRequestParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<InitializeResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles the InitializeRequest from a client.

fn handle_ping_request<'life0, 'async_trait>( &'life0 self, _params: Option<RequestParams>, _runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<Result, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles ping requests from clients.

fn handle_list_resource_templates_request<'life0, 'async_trait>( &'life0 self, params: Option<PaginatedRequestParams>, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ListResourceTemplatesResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles requests to list resource templates.

fn handle_subscribe_request<'life0, 'async_trait>( &'life0 self, params: SubscribeRequestParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<Result, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles subscription requests from clients.

fn handle_unsubscribe_request<'life0, 'async_trait>( &'life0 self, params: UnsubscribeRequestParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<Result, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles unsubscribe requests from clients.

fn handle_task_augmented_tool_call<'life0, 'async_trait>( &'life0 self, params: CallToolRequestParams, task_creator: TaskCreator<ClientJsonrpcRequest, ResultFromServer>, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<CreateTaskResult, CallToolError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles requests to call a task-augmented tool. you need to returns a CreateTaskResult containing task data. The actual operation result becomes available later through tasks/result after the task completes.

fn handle_set_level_request<'life0, 'async_trait>( &'life0 self, params: SetLevelRequestParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<Result, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles requests to enable or adjust logging level.

fn handle_complete_request<'life0, 'async_trait>( &'life0 self, params: CompleteRequestParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<CompleteResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles completion requests from clients.

fn handle_get_task_request<'life0, 'async_trait>( &'life0 self, params: GetTaskParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<GetTaskResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles a request to retrieve the state of a task.

fn handle_get_task_payload_request<'life0, 'async_trait>( &'life0 self, params: GetTaskPayloadParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<GetTaskPayloadResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles a request to retrieve the result of a completed task.

fn handle_cancel_task_request<'life0, 'async_trait>( &'life0 self, params: CancelTaskParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<CancelTaskResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles a request to cancel a task.

fn handle_list_task_request<'life0, 'async_trait>( &'life0 self, params: Option<PaginatedRequestParams>, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResult, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles a request to retrieve a list of tasks.

fn handle_custom_request<'life0, 'async_trait>( &'life0 self, request: CustomRequest, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<Result, RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles custom requests not defined in the standard protocol.

fn handle_initialized_notification<'life0, 'async_trait>( &'life0 self, params: Option<NotificationParams>, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles initialized notifications from clients. Customize this function in your specific handler to implement behavior tailored to your MCP server’s capabilities and requirements.

fn handle_cancelled_notification<'life0, 'async_trait>( &'life0 self, params: CancelledNotificationParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles cancelled operation notifications. Customize this function in your specific handler to implement behavior tailored to your MCP server’s capabilities and requirements.

fn handle_progress_notification<'life0, 'async_trait>( &'life0 self, params: ProgressNotificationParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles progress update notifications. Customize this function in your specific handler to implement behavior tailored to your MCP server’s capabilities and requirements.

fn handle_roots_list_changed_notification<'life0, 'async_trait>( &'life0 self, params: Option<NotificationParams>, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles notifications received from the client indicating that the list of roots has changed Customize this function in your specific handler to implement behavior tailored to your MCP server’s capabilities and requirements.

fn handle_task_status_notification<'life0, 'async_trait>( &'life0 self, params: TaskStatusNotificationParams, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

handles a notification from the receiver to the requestor, informing them that a task’s status has changed.

fn handle_custom_notification<'life0, 'async_trait>( &'life0 self, notification: CustomRequest, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handles custom notifications not defined in the standard protocol. Customize this function in your specific handler to implement behavior tailored to your MCP server’s capabilities and requirements.

fn handle_error<'life0, 'life1, 'async_trait>( &'life0 self, error: &'life1 RpcError, runtime: Arc<dyn McpServer>, ) -> Pin<Box<dyn Future<Output = Result<(), RpcError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Handles server errors that occur during operation.