Struct McpProxy 

pub struct McpProxy { /* private fields */ }

The MCP security proxy (TCP transport).

Listens for incoming MCP connections, intercepts tool call requests, runs them through the policy engine, and forwards allowed requests to the upstream MCP server.

Implementations

impl McpProxy

pub fn new(engine: Engine, config: ProxyConfig) -> Self

Creates a new proxy with the given engine and configuration.

pub fn with_audit( engine: Engine, config: ProxyConfig, audit: AuditLogger, ) -> Self

Creates a new proxy with a custom audit logger.

pub fn engine(&self) -> &Arc<RwLock<Engine>>

Returns a reference to the shared engine.

pub fn config(&self) -> &ProxyConfig

Returns a reference to the proxy configuration.

pub fn stats(&self) -> &Arc<ProxyStats>

Returns a reference to the proxy stats.

pub async fn replace_engine(&self, new_engine: Engine)

Replaces the engine with a new one (for hot-reload).

pub async fn run(&self) -> Result<(), Box<dyn Error>>

Starts the proxy server with graceful shutdown.

Listens for incoming connections and handles them concurrently. On SIGTERM/SIGINT, stops accepting new connections and waits for active connections to drain (up to 30s timeout).