Struct McpServer 

pub struct McpServer {
    tools: ToolRegistry,
    resources: ResourceHandler,
    transport: Transport,
    port: u16,
    rate_limit: RateLimitConfig,
    jwt_authenticator: Option<JwtAuthenticator>,
    cors_config: CorsConfig,
}

MCP server for subcog.

Fields

tools: ToolRegistry

Tool registry.

resources: ResourceHandler

Resource handler.

transport: Transport

Transport type.

port: u16

HTTP port (if using HTTP transport).

rate_limit: RateLimitConfig

Rate limit configuration (ARCH-H1).

jwt_authenticator: Option<JwtAuthenticator>

JWT authenticator for HTTP transport (SEC-H1).

cors_config: CorsConfig

CORS configuration for HTTP transport (HIGH-SEC-006).

Implementations

impl McpServer

pub fn new() -> Self

Creates a new MCP server.

pub fn with_cors_config(self, config: CorsConfig) -> Self

Sets the CORS configuration for HTTP transport (HIGH-SEC-006).

By default, no origins are allowed (deny all CORS requests). Use this to explicitly allow specific origins.

pub fn with_jwt_authenticator(self, authenticator: JwtAuthenticator) -> Self

Sets the JWT authenticator for HTTP transport (SEC-H1).

Arguments

• authenticator - The JWT authenticator to use for validating bearer tokens.

pub fn with_jwt_from_env(self) -> SubcogResult<Self>

Initializes JWT authentication from environment variables.

Reads SUBCOG_MCP_JWT_SECRET, SUBCOG_MCP_JWT_ISSUER, and SUBCOG_MCP_JWT_AUDIENCE from the environment.

Errors

Returns an error if SUBCOG_MCP_JWT_SECRET is not set or too short.

pub const fn with_rate_limit(self, config: RateLimitConfig) -> Self

Sets the rate limit configuration (ARCH-H1).

Arguments

• config - The rate limit configuration.

fn try_init_resources() -> ResourceHandler

Tries to initialize ResourceHandler with services.

Uses domain-scoped index (user-level index with project facets).

pub const fn with_transport(self, transport: Transport) -> Self

Sets the transport type.

pub const fn with_port(self, port: u16) -> Self

Sets the HTTP port.

pub async fn start(&mut self) -> SubcogResult<()>

Starts the MCP server with graceful shutdown handling (RES-M4).

Sets up signal handlers for SIGINT/SIGTERM before starting the server. The server will gracefully shut down when a signal is received.

Errors

Returns an error if the server fails to start or signal handler cannot be installed.

fn build_handler(&mut self) -> McpHandler

async fn run_stdio(&mut self) -> SubcogResult<()>

Runs the server over stdio with graceful shutdown (RES-M4).

fn graceful_shutdown(&self)

Performs graceful shutdown cleanup (RES-M4).

async fn run_http(&mut self) -> SubcogResult<()>

Runs the server over HTTP with JWT authentication (SEC-H1).

Requires the http feature and SUBCOG_MCP_JWT_SECRET environment variable.

Trait Implementations

impl Default for McpServer

fn default() -> Self

Returns the “default value” for a type.