Struct ProxyHandler 

pub struct ProxyHandler { /* private fields */ }

A proxy handler that forwards requests to a client based on the server’s capabilities

Implementations

impl ProxyHandler

pub fn new(client: RunningService<RoleClient, ClientInfo>) -> Self

pub fn with_mcp_id( client: RunningService<RoleClient, ClientInfo>, mcp_id: String, ) -> Self

pub async fn is_mcp_server_ready(&self) -> bool

pub fn is_terminated(&self) -> bool

检查子进程是否已经终止

pub async fn is_terminated_async(&self) -> bool

异步检查子进程是否已经终止

Trait Implementations

impl Clone for ProxyHandler

fn clone(&self) -> ProxyHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProxyHandler

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

Formats the value using the given formatter.

impl ServerHandler for ProxyHandler

fn get_info(&self) -> ServerInfo

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>

async fn list_resources( &self, request: Option<PaginatedRequestParam>, _context: RequestContext<RoleServer>, ) -> Result<ListResourcesResult, ErrorData>

async fn read_resource( &self, request: ReadResourceRequestParam, _context: RequestContext<RoleServer>, ) -> Result<ReadResourceResult, ErrorData>

async fn list_resource_templates( &self, request: Option<PaginatedRequestParam>, _context: RequestContext<RoleServer>, ) -> Result<ListResourceTemplatesResult, ErrorData>

async fn list_prompts( &self, request: Option<PaginatedRequestParam>, _context: RequestContext<RoleServer>, ) -> Result<ListPromptsResult, ErrorData>

async fn get_prompt( &self, request: GetPromptRequestParam, _context: RequestContext<RoleServer>, ) -> Result<GetPromptResult, ErrorData>

async fn complete( &self, request: CompleteRequestParam, _context: RequestContext<RoleServer>, ) -> Result<CompleteResult, ErrorData>

async fn on_progress( &self, notification: ProgressNotificationParam, _context: NotificationContext<RoleServer>, )

async fn on_cancelled( &self, notification: CancelledNotificationParam, _context: NotificationContext<RoleServer>, )

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 set_level( &self, request: SetLevelRequestParam, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), 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_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