class McpProtocol<Transport>(sessions: Sessions<Transport>, initializer: Initializer, tools: Tools = tools(), resources: Resources = resources(), prompts: Prompts = prompts(), completions: Completions = completions(), logger: Logger = logger(), roots: Roots = roots(), cancellations: Cancellations = cancellations(), tasks: Tasks = tasks(), mcpFilter: McpFilter = McpFilter.NoOp, onError: (Throwable) -> Unit = { it.printStackTrace(System.err) }, random: Random = SecureRandom())

Models the MCP protocol in terms of message handling and session management.

McpRequest

data class McpRequest(val session: Session, val message: McpJsonRpcRequest, val http: Request)

McpResponse

sealed interface McpResponse

McpSessionState

sealed interface McpSessionState

Represents a session for a connection.

ObservableCapability

interface ObservableCapability<T>

Provides notification telling the client of changes to underlying capabilities lists.

ObservableResources

interface ObservableResources : Resources

Provides notification telling the client of changes to a particular resource

Prompts

interface Prompts : ObservableCapability<PromptCapability> , Function1<PromptName, PromptHandler> , Iterable<PromptCapability>

Handles protocol traffic for prompts features.

Resources

interface Resources : ObservableCapability<ResourceCapability> , Function1<ResourceRequest, ResourceResponse> , Iterable<ResourceCapability>

Handles protocol traffic for resources features and subscriptions.

Roots

interface Roots : Iterable<Root>

Handles protocol traffic for client provided roots.

Session

data class Session(val id: SessionId)

SessionBasedClient

class SessionBasedClient(sendToClient: (McpJsonRpcRequest) -> Unit, session: Session, logger: Logger, tasks: Tasks, roots: Roots, random: Random, clientTracking: () -> ClientTracking) : Client

Sessions

interface Sessions<Transport>

Responsible for managing the lifecycle of client sessions, including the assignment of transport to session, and the sending of messages to the client.

Tasks

interface Tasks

Handles protocol traffic for server task management. All operations are scoped by session.

TaskUpdateCallback

fun interface TaskUpdateCallback

Tools

interface Tools : ObservableCapability<ToolCapability> , Iterable<ToolCapability> , Function1<ToolName, ToolHandler>

Handles protocol traffic for server provided tools.

Properties

NoOp

val McpFilter.Companion.NoOp: McpFilter

Functions

RoutingMcpHandler

fun RoutingMcpHandler(initializer: Initializer, clientTracking: MutableMap<Session, ClientTracking>, completions: Completions, prompts: Prompts, resources: Resources, tools: Tools, logger: Logger, tasks: Tasks, cancellations: Cancellations, roots: Roots, random: Random, sessions: Sessions<*>): McpHandler

then

fun McpFilter.then(next: McpHandler): McpHandler

fun McpFilter.then(next: McpFilter): McpFilter

ValidateMcpMethodHeader

fun ValidateMcpMethodHeader(clientTracking: Map<Session, ClientTracking>): McpFilter