Struct Server 

pub struct Server {

    pub openapi_spec: Value,
    pub tool_collection: ToolCollection,
    pub base_url: Url,
    pub default_headers: Option<HeaderMap>,
    pub filters: Option<Filters>,
    pub authorization_mode: AuthorizationMode,
    pub name: Option<String>,
    pub version: Option<String>,
    pub title: Option<String>,
    pub instructions: Option<String>,
    pub skip_tool_descriptions: bool,
    pub skip_parameter_descriptions: bool,
    pub response_transformer: Option<Arc<dyn ResponseTransformer>>,
}

Fields

openapi_spec: Value

tool_collection: ToolCollection

base_url: Url

default_headers: Option<HeaderMap>

filters: Option<Filters>

authorization_mode: AuthorizationMode

name: Option<String>

version: Option<String>

title: Option<String>

instructions: Option<String>

skip_tool_descriptions: bool

skip_parameter_descriptions: bool

response_transformer: Option<Arc<dyn ResponseTransformer>>

Global response transformer applied to all tools.

Uses dynamic dispatch (Arc<dyn>) because:

• Transformer runs once per HTTP call (10-1000ms latency)
• Vtable lookup overhead (~1ns) is unmeasurable
• Avoids viral generics throughout Server, Tool, ToolCollection

Implementations

impl Server

pub fn builder() -> ServerBuilder

Create an instance of Server using the builder syntax

impl Server

pub fn new( openapi_spec: Value, base_url: Url, default_headers: Option<HeaderMap>, filters: Option<Filters>, skip_tool_descriptions: bool, skip_parameter_descriptions: bool, ) -> Self

Create a new Server instance with required parameters

pub fn load_openapi_spec(&mut self) -> Result<(), Error>

Parse the OpenAPI specification and convert to OpenApiTool instances

Errors

Returns an error if the spec cannot be parsed or tools cannot be generated

pub fn set_tool_transformer( &mut self, tool_name: &str, transformer: Arc<dyn ResponseTransformer>, ) -> Result<(), Error>

Set a response transformer for a specific tool, overriding the global one.

The transformer’s transform_schema method is immediately applied to the tool’s output schema. The transform_response method will be applied to responses when the tool is called.

Errors

Returns an error if the tool is not found

pub fn tool_count(&self) -> usize

Get the number of loaded tools

pub fn get_tool_names(&self) -> Vec<String>

Get all tool names

pub fn has_tool(&self, name: &str) -> bool

Check if a specific tool exists

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

Get a tool by name

pub fn get_tool_metadata(&self, name: &str) -> Option<&ToolMetadata>

Get tool metadata by name

pub fn set_authorization_mode(&mut self, mode: AuthorizationMode)

Set the authorization mode for the server

pub fn authorization_mode(&self) -> AuthorizationMode

Get the current authorization mode

pub fn get_tool_stats(&self) -> String

Get basic tool statistics

pub fn validate_registry(&self) -> Result<(), Error>

Simple validation - check that tools are loaded

Errors

Returns an error if no tools are loaded

Trait Implementations

impl Clone for Server

fn clone(&self) -> Server

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for Server

fn get_info(&self) -> InitializeResult

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

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

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

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

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

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

fn get_prompt( &self, request: GetPromptRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResult, ErrorData>> + Send

fn list_prompts( &self, request: Option<PaginatedRequestParam>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + Send

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

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

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

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

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

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

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

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

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

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

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