Struct ServerRunner

pub struct ServerRunner { /* private fields */ }

Server runner that manages the complete lifecycle

Implementations

impl ServerRunner

pub fn new(server: McpServer) -> Self

Create a new server runner

pub async fn add_listener<L>(&self, listener: L)

where L: LifecycleListener + 'static,

Add a lifecycle listener

pub fn lifecycle(&self) -> &LifecycleManager

Get the lifecycle manager

pub async fn start<T>(&self, transport: T) -> McpResult<()>

where T: ServerTransport + 'static,

Start the server with a transport

pub async fn stop(&self) -> McpResult<()>

Stop the server gracefully

pub async fn stop_with_timeout( &self, shutdown_timeout: Duration, ) -> McpResult<()>

Stop the server with a timeout

pub async fn run_until_shutdown<T>(&self, transport: T) -> McpResult<()>

where T: ServerTransport + 'static,

Run the server until shutdown signal

pub async fn run_with_signals<T>(&self, transport: T) -> McpResult<()>

where T: ServerTransport + 'static,

Run the server with graceful shutdown on CTRL+C

pub fn server(&self) -> Arc<Mutex<McpServer>>

Get the server instance (for advanced usage)

pub async fn is_running(&self) -> bool

Check if the server is running

pub async fn uptime(&self) -> Option<Duration>

Get server uptime

pub async fn restart<T>(&self, transport: T) -> McpResult<()>

where T: ServerTransport + 'static,

Restart the server

pub async fn wait_for_state( &self, target_state: LifecycleState, timeout_duration: Option<Duration>, ) -> McpResult<()>

Wait for the server to reach a specific state

pub async fn notify_listeners<F>(&self, f: F)

where F: Fn(&dyn LifecycleListener) + Send + Sync,

Notify all listeners with a closure

impl ServerRunner

pub async fn health_status(&self) -> HealthStatus

Get health status