Struct ManagedConnection 

pub struct ManagedConnection {
    pub config: McpServerConnectionConfig,
    pub transport: RwLock<Option<Arc<dyn McpTransport>>>,
    pub circuit_breaker: CircuitBreaker,
    pub restart_count: AtomicU32,
    pub shutdown_requested: AtomicBool,
    pub restart_notify: Notify,
    pub failure_tx: Sender<()>,
}

Connection state for a managed server.

Fields

config: McpServerConnectionConfig

Original configuration (used for restarts)

transport: RwLock<Option<Arc<dyn McpTransport>>>

Current transport (may be replaced on restart)

circuit_breaker: CircuitBreaker

Circuit breaker for resilient connections

restart_count: AtomicU32

Number of restart attempts

shutdown_requested: AtomicBool

Whether shutdown has been requested

restart_notify: Notify

Notifier for restart events

failure_tx: Sender<()>

Broadcast channel to notify pending requests of failure

Implementations

impl ManagedConnection

pub fn new(config: McpServerConnectionConfig) -> Self

Create a new managed connection.

pub async fn is_alive(&self) -> bool

Check if the connection is alive.

pub async fn get_transport(&self) -> Option<Arc<dyn McpTransport>>

Get the transport if available.

pub fn subscribe_failures(&self) -> Receiver<()>

Subscribe to failure notifications.

pub fn notify_failure(&self)

Notify pending requests of failure.