Struct McpLifecycleManager 

pub struct McpLifecycleManager { /* private fields */ }

Manages the lifecycle of multiple MCP server connections.

Implementations

impl McpLifecycleManager

pub fn new() -> Self

Create an empty lifecycle manager.

pub async fn register( &self, name: impl Into<String>, transport: impl McpTransport + 'static, reconnect_delay: Duration, )

Register an MCP server under the given name.

pub async fn start_all(&self) -> Result<(), AgentError>

Connect all registered, enabled servers.

pub async fn stop_all(&self) -> Result<(), AgentError>

Disconnect all servers cleanly.

pub async fn enable(&self, name: &str) -> Result<(), AgentError>

Enable a specific server (connects if not already connected).

pub async fn disable(&self, name: &str) -> Result<(), AgentError>

Disable a specific server (disconnects immediately).

pub async fn all_status(&self) -> Vec<McpServerStatus>

Return current status for all managed servers.

pub async fn list_tools( &self, server_name: &str, ) -> Result<Vec<McpToolDescriptor>, AgentError>

List tools available from a named server.

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

Invoke a tool on a named server, reconnecting if needed.

pub fn spawn_health_monitor(self: Arc<Self>, interval: Duration)

Spawn a background health-monitor task that reconnects servers that drop.

The task polls every interval and attempts reconnection with the server’s configured reconnect_delay.

Trait Implementations

impl Debug for McpLifecycleManager

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

Formats the value using the given formatter.

impl Default for McpLifecycleManager

fn default() -> McpLifecycleManager

Returns the “default value” for a type.