Struct SoloMcpServer 

pub struct SoloMcpServer { /* private fields */ }

The MCP server. Cheap to clone — every field is Arc-cloneable.

Implementations

impl SoloMcpServer

pub fn new( write: WriteHandle, pool: ReaderPool, embedder: Arc<dyn Embedder>, hnsw: Arc<dyn VectorIndex + Send + Sync>, ) -> Self

impl SoloMcpServer

pub async fn dispatch_tool( &self, name: &str, args_value: Value, ) -> Result<CallToolResult, McpError>

Direct tool-dispatch path used by both call_tool (the ServerHandler trait method, behind the rmcp protocol layer) and in-process tests that don’t want to spin up a full transport pair. Bypasses RequestContext (which requires a Peer not constructible outside rmcp internals).

pub fn dispatch_list_tools(&self) -> Vec<Tool>

List the tools this server exposes. Mirrors ServerHandler::list_tools without requiring a RequestContext.

Trait Implementations

impl Clone for SoloMcpServer

fn clone(&self) -> SoloMcpServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for SoloMcpServer

fn get_info(&self) -> ServerInfo

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

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

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<PaginatedRequestParamInner>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + Send

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

fn list_resource_templates( &self, request: Option<PaginatedRequestParamInner>, 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_cancelled( &self, notification: CancelledNotificationParam, ) -> impl Future<Output = ()> + Send

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

fn on_initialized(&self) -> impl Future<Output = ()> + Send

fn on_roots_list_changed(&self) -> impl Future<Output = ()> + Send

fn get_peer(&self) -> Option<Peer<RoleServer>>

fn set_peer(&mut self, peer: Peer<RoleServer>)