mcp-sse-proxy 0.2.9

SSE (Server-Sent Events) proxy implementation for MCP protocol using rmcp 0.10
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use arc_swap::{ArcSwap, ArcSwapOption};
pub use mcp_common::ToolFilter;
use rmcp::{
    ErrorData, RoleClient, RoleServer, ServerHandler, ServiceError,
    model::{
        CallToolRequestParam, CallToolResult, ClientInfo, Content, Implementation, ListToolsResult,
        PaginatedRequestParam, ProtocolVersion, ServerInfo,
    },
    service::{NotificationContext, Peer, RequestContext, RunningService},
};
use std::sync::Arc;
use std::sync::atomic::{AtomicU64, Ordering};
use std::time::{Instant, SystemTime};
use tracing::{debug, error, info, warn};

mod backend_session;
mod direct_core;
mod discovery;
mod dispatch;
mod forwarding;
mod lifecycle;

pub use backend_session::BackendSessionHandler;
pub use direct_core::SseHandler;
use discovery::DiscoveryCache;
pub use dispatch::SseServerHandler;
use forwarding::ForwardError;

static REQUEST_COUNTER: AtomicU64 = AtomicU64::new(1);