mcp_runner/server/
mod.rs

1//! Server management module for MCP Runner.
2//!
3//! This module handles the lifecycle, monitoring, and process management of MCP servers.
4//! It provides functionality to start, stop, and monitor the health of MCP server processes.
5//! All public components are instrumented with `tracing` spans.
6//!
7//! # Components
8//!
9//! * `lifecycle` - Manages server lifecycle events and statuses
10//! * `monitor` - Health monitoring and automatic recovery of servers  
11//! * `process` - Core process management for server instances
12//!
13//! # Examples
14//!
15//! Managing server lifecycle:
16//!
17//! ```no_run
18//! use mcp_runner::server::{ServerLifecycleManager, ServerLifecycleEvent, ServerProcess};
19//! use mcp_runner::config::ServerConfig;
20//! use std::sync::Arc;
21//! use std::collections::HashMap;
22//!
23//! // Create a server process to get a valid ServerId
24//! let config = ServerConfig {
25//!     command: "sample".to_string(),
26//!     args: vec![],
27//!     env: HashMap::new(),
28//! };
29//! let server_process = ServerProcess::new("fetch-server".to_string(), config);
30//! let server_id = server_process.id();
31//! let server_name = "fetch-server".to_string();
32//!
33//! // Create lifecycle manager and record an event
34//! let manager = Arc::new(ServerLifecycleManager::new());
35//! manager.record_event(
36//!     server_id,
37//!     server_name,
38//!     ServerLifecycleEvent::Started,
39//!     Some("Server started successfully".to_string())
40//! ).unwrap();
41//! ```
42//!
43//! Monitoring server health:
44//!
45//! ```no_run
46//! use mcp_runner::server::{ServerMonitor, ServerMonitorConfig, ServerLifecycleManager};
47//! use std::sync::Arc;
48//! use std::time::Duration;
49//!
50//! let lifecycle_manager = Arc::new(ServerLifecycleManager::new());
51//! let config = ServerMonitorConfig {
52//!     check_interval: Duration::from_secs(30),
53//!     health_check_timeout: Duration::from_secs(5),
54//!     auto_restart: true,
55//!     max_consecutive_failures: 3,
56//! };
57//!
58//! // Create and start the monitor
59//! let mut monitor = ServerMonitor::new(lifecycle_manager, config);
60//! monitor.start().unwrap();
61//! ```
62pub mod lifecycle;
63pub mod monitor;
64mod process;
65
66pub use lifecycle::{ServerEvent, ServerLifecycleEvent, ServerLifecycleManager};
67pub use monitor::{ServerHealth, ServerMonitor, ServerMonitorConfig};
68pub use process::{ServerId, ServerProcess, ServerStatus};
mcp_runner/server/mod.rs

mcp_runner/server/
mod.rs
