Struct SSEProxy

pub struct SSEProxy { /* private fields */ }

SSE Proxy server for MCP servers

Provides an HTTP and SSE proxy that allows web clients to interact with MCP servers using Actix Web. The proxy supports authentication, server listing, tool calls, and resource retrieval.

Implementations

impl SSEProxy

pub async fn start_proxy( runner_access: SSEProxyRunnerAccess, config: SSEProxyConfig, ) -> Result<SSEProxyHandle>

Start the SSE proxy server

Creates a proxy handle and starts the server in a background task. Returns a handle that can be used to control and communicate with the proxy.

Arguments

• runner_access - Functions to access McpRunner operations
• config - Configuration for the SSE proxy

Returns

A Result containing a SSEProxyHandle or an error

pub async fn process_tool_call( &self, server_name: &str, tool_name: &str, args: Value, request_id: &str, ) -> Result<()>

Process a tool call request from a client

Arguments

• server_name - Name of the server to call the tool on
• tool_name - Name of the tool to call
• args - Arguments to pass to the tool
• request_id - Request ID for correlation

Returns

A Result<()> indicating success or failure

pub fn get_server_info(&self) -> &Arc<Mutex<HashMap<String, ServerInfo>>>

Get the server information cache

pub fn get_runner_access(&self) -> &SSEProxyRunnerAccess

Get the runner access functions

pub fn event_manager(&self) -> &Arc<EventManager>

Get the event manager

pub fn config(&self) -> &SSEProxyConfig

Get the configuration

Trait Implementations

impl Clone for SSEProxy

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.