Struct McpServer 

pub struct McpServer<S> {
    registry: ToolRegistry<S>,
    config: ServerConfig,
}

The MCP server: answers each request with the tools of its registry, run against the state S.

Fields

registry: ToolRegistry<S>

config: ServerConfig

Implementations

impl<S: Send + Sync + 'static> McpServer<S>

pub(crate) fn new(registry: ToolRegistry<S>, config: ServerConfig) -> Self

A server answering with the tools of registry.

pub async fn handle( &self, state: &S, principal: &McpPrincipal, request: HttpRequest, progress_sink: Option<UnboundedSender<Value>>, ) -> HttpResponse

Handles one request. progress_sink, when given, receives progress notifications the transport may stream before the response.

async fn dispatch( &self, state: &S, principal: &McpPrincipal, headers: &RequestHeaders, method: &str, params: Option<Value>, progress_sink: Option<UnboundedSender<Value>>, ) -> Result<Value, RpcError>

fn unsupported_version(&self, requested: Value) -> RpcError

fn check_version( &self, client: &ClientContext, headers: &RequestHeaders, ) -> Result<(), RpcError>

fn server_info_meta(&self) -> MetaObject

fn discover(&self) -> Value

fn list_tools(&self, principal: &McpPrincipal) -> Value

async fn call_tool( &self, state: &S, principal: &McpPrincipal, client: ClientContext, tool: &Tool<S>, params: Map<String, Value>, progress: ProgressReporter, ) -> Result<Value, RpcError>

fn insufficient_scope( &self, principal: &McpPrincipal, required: McpScope, ) -> RpcError

The 403 for a missing scope. Its challenge asks for the scopes the token has as well, since a client stepping up requests exactly the challenged scopes and would lose the others.

fn tool_result(&self, result: ToolResult) -> Value

fn confirmation( &self, ctx: &RequestContext, request: ConfirmationRequest, binding: Option<&str>, skill_hint: Option<Hint>, ) -> Value

binding is None when the handler doesn’t declare that it asks for confirmation; the text fallback is then the only safe answer.

fn open_request_state( &self, sealed: &str, associated_data: &[u8], responses: Option<Value>, ) -> Result<RetryState, RpcError>