Struct McpServer 

pub struct McpServer { /* private fields */ }

A live connection to one MCP server (any transport).

Implementations

impl McpServer

pub async fn connect(config: McpServerConfig) -> Result<McpServer, Error>

Connect to the server, perform the initialize handshake, and fetch the tool list.

pub async fn tools(&self) -> Vec<McpToolDef>

Tools advertised by this server.

pub async fn name(&self) -> String

Server display name.

pub async fn capabilities(&self) -> McpServerCapabilities

Server-advertised capabilities captured at handshake.

pub fn health_check(&self) -> bool

Health-check the underlying transport without sending a real request. Returns true when the transport is alive, false otherwise.

Uses try_lock instead of blocking_lock because this method may be called from async contexts (e.g. health_check_all during heartbeat retries inside an async test or the tokio-based heartbeat worker).

pub fn ptr_eq(&self, other: &McpServer) -> bool

Identity comparison on the underlying transport handle. Two McpServer values share the same connection iff ptr_eq returns true — i.e. their inner Arc<Mutex<McpServerInner>> points to the same allocation. Cheap Arc-level comparison, no async, no lock.

Used by the daemon’s reconciliation layer to verify that a “preserved” healthy server’s live connection survives a recovery tick without being silently disconnected and respawned (the additive merge contract: a healthy handle covers its name and is reused verbatim via Arc::clone).

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

Call a tool on this server. Returns the raw JSON result.

pub async fn list_resources( &self, cursor: Option<String>, ) -> Result<McpResourcesListResult, Error>

resources/list — capability-gated.

pub async fn read_resource( &self, uri: &str, ) -> Result<McpResourceContents, Error>

resources/read — capability-gated.

pub async fn list_prompts( &self, cursor: Option<String>, ) -> Result<McpPromptsListResult, Error>

prompts/list — capability-gated.

pub async fn get_prompt( &self, name: &str, arguments: Value, ) -> Result<McpGetPromptResult, Error>

prompts/get — capability-gated.

Trait Implementations

impl Clone for McpServer

fn clone(&self) -> McpServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.