Struct UltraFastServer 

pub struct UltraFastServer { /* private fields */ }

MCP Server implementation

Implementations

impl UltraFastServer

pub fn new(info: ServerInfo, capabilities: ServerCapabilities) -> Self

Create a new UltraFastServer with the given info and capabilities

pub async fn set_logging_config(&self, config: ServerLoggingConfig)

Configure server logging

pub async fn get_logging_config(&self) -> ServerLoggingConfig

Get current server logging configuration

pub fn with_timeout_config(self, config: TimeoutConfig) -> Self

Set timeout configuration

pub fn get_timeout_config(&self) -> TimeoutConfig

Get current timeout configuration

pub fn with_high_performance_timeouts(self) -> Self

Set timeout configuration for high-performance scenarios

pub fn with_long_running_timeouts(self) -> Self

Set timeout configuration for long-running operations

pub fn get_operation_timeout(&self, operation: &str) -> Duration

Get timeout for a specific operation

pub fn validate_timeout_config(&self) -> Result<(), String>

Validate timeout configuration

pub async fn set_log_level(&self, level: LogLevel) -> MCPResult<()>

Set the current log level

pub async fn get_log_level(&self) -> LogLevel

Get the current log level

pub fn with_monitoring_config(self, config: MonitoringConfig) -> Self

Enable monitoring with custom configuration

pub fn with_monitoring(self) -> Self

Enable monitoring with default configuration

pub fn with_health_checks(self) -> Self

Enable health checks with default configuration

pub fn with_metrics(self) -> Self

Enable metrics collection with default configuration

pub fn with_tracing(self) -> Self

Enable tracing with default configuration

pub fn with_full_monitoring(self) -> Self

Enable all monitoring features (health checks, metrics, tracing)

pub fn with_middleware(self) -> Self

Enable middleware support

pub fn with_recovery(self) -> Self

Enable recovery mechanisms

pub fn with_oauth(self) -> Self

Enable OAuth authentication

pub fn with_authentication( self, _token_validator: (), _required_scopes: Vec<String>, ) -> Self

Enable authentication with custom configuration (feature removed)

pub fn with_bearer_auth( self, _secret: String, _required_scopes: Vec<String>, ) -> Self

Enable Bearer token authentication (feature removed)

pub fn with_api_key_auth(self) -> Self

Enable API key authentication

pub fn with_basic_auth(self) -> Self

Enable Basic authentication

pub fn with_rate_limiting(self, requests_per_minute: u32) -> Self

Enable rate limiting

pub fn with_request_validation(self) -> Self

Enable request validation

pub fn with_response_caching(self) -> Self

Enable response caching

pub fn monitoring(&self) -> Option<Arc<MonitoringSystem>>

Get the monitoring system if available

pub async fn create_context(&self) -> Context

Create a context with the current server logging configuration

pub async fn create_context_with_ids( &self, request_id: String, session_id: Option<String>, ) -> Context

Create a context with custom request and session IDs

pub async fn register_tool( &self, tool: Tool, ) -> Result<(), ToolRegistrationError>

Register a tool with validation

pub async fn register_tools( &self, tools: Vec<Tool>, ) -> Result<(), ToolRegistrationError>

Register multiple tools

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

Unregister a tool by name

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

Get a tool by name

pub async fn list_tools(&self) -> Vec<Tool>

List all registered tools

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

Check if a tool exists

pub async fn tool_count(&self) -> usize

Get tool count

pub async fn clear_tools(&self)

Clear all tools

pub async fn validate_tool_call( &self, tool_name: &str, arguments: &Value, ) -> Result<(), MCPError>

Validate tool call arguments against tool schema

pub async fn execute_tool_call( &self, tool_name: &str, arguments: Value, ) -> Result<ToolResult, MCPError>

Execute a tool call with validation

pub fn with_tool_handler(self, handler: Arc<dyn ToolHandler>) -> Self

Add a tool handler to the server

pub fn with_resource_handler(self, handler: Arc<dyn ResourceHandler>) -> Self

Add a resource handler to the server

pub fn with_prompt_handler(self, handler: Arc<dyn PromptHandler>) -> Self

Add a prompt handler to the server

pub fn with_sampling_handler(self, handler: Arc<dyn SamplingHandler>) -> Self

Add a sampling handler to the server

pub fn with_completion_handler( self, handler: Arc<dyn CompletionHandler>, ) -> Self

Add a completion handler to the server

pub fn with_roots_handler(self, handler: Arc<dyn RootsHandler>) -> Self

Add a roots handler to the server

pub fn with_elicitation_handler( self, handler: Arc<dyn ElicitationHandler>, ) -> Self

Add an elicitation handler to the server

pub fn with_subscription_handler( self, handler: Arc<dyn ResourceSubscriptionHandler>, ) -> Self

Add a subscription handler to the server

pub fn with_logging_config(self, config: ServerLoggingConfig) -> Self

Configure logging with a custom configuration

pub async fn run_stdio(&self) -> MCPResult<()>

Run the server with stdio transport

pub async fn run_with_transport( &self, transport: Box<dyn Transport>, ) -> MCPResult<()>

Run the server with a custom transport

pub async fn run_streamable_http(&self, host: &str, port: u16) -> MCPResult<()>

Run the server with Streamable HTTP transport

pub async fn run_http(&self, config: HttpTransportConfig) -> MCPResult<()>

Run the server with HTTP transport

pub async fn run_streamable_http_with_config( &self, config: HttpTransportConfig, ) -> MCPResult<()>

Run the server with custom Streamable HTTP transport configuration This provides clearer naming for advanced Streamable HTTP configuration

pub fn info(&self) -> &ServerInfo

Get server info

pub fn cancellation_manager(&self) -> Arc<CancellationManager>

Get cancellation manager

pub fn ping_manager(&self) -> Arc<PingManager>

Get ping manager

pub async fn start_ping_monitoring( &self, ping_interval: Duration, ) -> MCPResult<()>

Start periodic ping monitoring (optional, for connection health) This method should be called after the server is running with a transport

pub async fn stop_ping_monitoring(&self) -> MCPResult<()>

Stop ping monitoring

pub async fn get_state(&self) -> ServerState

Get current server state

pub async fn can_operate(&self) -> bool

Check if server can accept operations

pub async fn notify_tools_changed( &self, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send tools list changed notification

pub async fn notify_resources_changed( &self, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send resources list changed notification

pub async fn notify_prompts_changed( &self, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send prompts list changed notification

pub async fn notify_resource_updated( &self, uri: String, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send resource updated notification

pub async fn notify_progress( &self, progress_token: Value, progress: f64, total: Option<f64>, message: Option<String>, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send progress notification

pub async fn notify_logging_message( &self, level: LogLevel, data: Value, logger: Option<String>, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send logging message notification

pub async fn notify_cancelled( &self, request_id: Value, reason: Option<String>, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send cancellation notification

pub async fn notify_roots_changed( &self, transport: &mut Box<dyn Transport>, ) -> MCPResult<()>

Send roots list changed notification

pub fn with_advanced_sampling_handler( self, handler: Arc<dyn AdvancedSamplingHandler>, ) -> Self

Set the advanced sampling handler for context collection and human-in-the-loop features

pub fn with_default_advanced_sampling(self) -> Self

Set the advanced sampling handler with default implementation

pub async fn handle_set_roots( &self, roots: Vec<Root>, transport: &mut Box<dyn Transport>, ) -> SetRootsResponse

Handle a roots/set request

Trait Implementations

impl Clone for UltraFastServer

fn clone(&self) -> UltraFastServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UltraFastServer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.