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

pub fn with_keep_alive(handler: Arc<ProxyHandler>, keep_alive: Duration) -> Self

pub fn with_max_sessions(self, max_sessions: Option<usize>) -> Self

Limit the number of concurrent sessions (None = unlimited).

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.

fn restore_session( &self, _id: Arc<str>, ) -> impl Future<Output = Result<RestoreOutcome<Self::Transport>, Self::Error>> + Send

Attempt to restore a previously-known session from external state, creating a fresh in-memory session worker with the given id.

fn event_store(&self) -> Option<Arc<dyn EventStore>>

Return the shared event store used for resumable SSE streams.