Struct ProxyAwareSessionManager 

pub struct ProxyAwareSessionManager { /* private fields */ }

感知代理状态的 SessionManager

职责：

1. 委托 LocalSessionManager 处理核心 session 逻辑
2. 维护 session → backend_version 映射
3. 在 resume 时检查版本一致性
4. 版本不匹配时使 session 失效

Implementations

impl ProxyAwareSessionManager

pub fn new(handler: Arc<ProxyHandler>) -> Self

Trait Implementations

impl SessionManager for ProxyAwareSessionManager

type Error = LocalSessionManagerError

type Transport = WorkerTransport<LocalSessionWorker>

async fn create_session( &self, ) -> Result<(SessionId, Self::Transport), Self::Error>

Create a new session and return its ID together with the transport that will be used to exchange MCP messages within this session.

async fn initialize_session( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<ServerJsonRpcMessage, Self::Error>

Forward the first message (the initialize request) to the session.

async fn has_session(&self, id: &SessionId) -> Result<bool, Self::Error>

Return true if a session with the given ID exists and is active.

async fn close_session(&self, id: &SessionId) -> Result<(), Self::Error>

Close and remove the session. Corresponds to an HTTP DELETE request with Mcp-Session-Id.

async fn create_stream( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

Route a client request into the session and return an SSE stream carrying the server’s response(s).

async fn accept_message( &self, id: &SessionId, message: ClientJsonRpcMessage, ) -> Result<(), Self::Error>

Accept a notification, response, or error message from the client without producing a response stream.

async fn create_standalone_stream( &self, id: &SessionId, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

Create an SSE stream not tied to a specific client request (HTTP GET).

async fn resume( &self, id: &SessionId, last_event_id: String, ) -> Result<impl Stream<Item = ServerSseMessage> + Send + 'static, Self::Error>

Resume an SSE stream from the given Last-Event-ID, replaying any events the client missed.