Struct McpRegistry 

pub struct McpRegistry { /* private fields */ }

Registry of connected MCP servers.

Implementations

impl McpRegistry

pub fn new() -> Self

Create a new empty registry.

pub fn with_telemetry(self, tel: Arc<Telemetry>) -> Self

Set the telemetry handle for emitting McpConnect events.

pub fn with_event_channel() -> (Self, UnboundedReceiver<McpConnectEvent>)

Create a registry with a channel for connection events.

pub fn event_sender(&self) -> Option<UnboundedSender<McpConnectEvent>>

Get a clone of the event sender, if configured.

pub fn from_config_background(project_dir: &Path) -> Self

Load MCP configuration and start connecting to servers in the background. Returns immediately with an empty registry; servers are added as they connect. Connection status events are sent through the internal channel if configured.

pub fn from_config_background_with_events( project_dir: &Path, event_tx: Option<UnboundedSender<McpConnectEvent>>, ) -> Self

Load MCP configuration and start connecting to servers in the background, with an external event channel for TUI status display.

pub async fn from_config(project_dir: &Path) -> Self

Load MCP configuration and connect to all servers (blocking). Prefer from_config_background for non-blocking startup.

pub async fn add_server(&self, config: McpServerConfig) -> Result<()>

Add a server to the registry.

pub async fn list_tools_timeout(&self, server_name: &str) -> Duration

Timeout budget for a slow tools/list operation on a connected server.

The transport already has its own request timeout. This outer budget adds a small grace period so TUI background tasks do not cancel a request right before the transport timeout/error can surface.

pub async fn list_all_tools(&self) -> Vec<McpToolInfo>

Get all available tools from all connected servers.

pub async fn list_tools_for_server(&self, server_name: &str) -> Vec<McpToolInfo>

Get tools from a single connected server.

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

Call a tool on a specific server.

pub async fn server_statuses(&self) -> Vec<(String, ServerStatus)>

Get the status of all servers.

pub async fn wait_for_initial_connections(&self, timeout: Duration)

Wait for initial background connections to complete (or timeout). Returns immediately if no background connections are pending.

pub fn share(&self) -> Arc<Self>

Get an Arc clone for sharing across threads.

Trait Implementations

impl Default for McpRegistry

fn default() -> Self

Returns the “default value” for a type.