mcp

Documentation

Overview

Package mcp implements the HTTP Streamable MCP (Model Context Protocol) server over JSON-RPC 2.0 with SSE streaming, allowing any AI agent (Claude, GPT, Cursor, etc.) to discover and call Argus tools natively.

Index

• Constants
• type ClientInfo
• type ContentItem
• type InitializeParams
• type InitializeResult
• type InputSchema
• type JSONRPCRequest
• type JSONRPCResponse
• type Property
• type RPCError
• type Resource
• type SSEEvent
• type Server
  • func New(repo *storage.Repository, metrics *telemetry.Metrics, svcGraph *graph.Graph, ...) *Server
  • func (s *Server) Handler() http.Handler
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ServerInfo
• type Tool
• type ToolCallParams
• type ToolCallResult
• type ToolsListResult

Constants

const (
	ErrParseError     = -32700
	ErrInvalidRequest = -32600
	ErrMethodNotFound = -32601
	ErrInvalidParams  = -32602
	ErrInternalError  = -32603
)

Standard JSON-RPC error codes.

Types

type ClientInfo

type ClientInfo struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

type ContentItem

type ContentItem struct {
	Type     string    `json:"type"` // "text" | "resource"
	Text     string    `json:"text,omitempty"`
	Resource *Resource `json:"resource,omitempty"`
}

type InitializeParams

type InitializeParams struct {
	ProtocolVersion string         `json:"protocolVersion"`
	Capabilities    map[string]any `json:"capabilities"`
	ClientInfo      ClientInfo     `json:"clientInfo"`
}

type InitializeResult

type InitializeResult struct {
	ProtocolVersion string         `json:"protocolVersion"`
	Capabilities    map[string]any `json:"capabilities"`
	ServerInfo      ServerInfo     `json:"serverInfo"`
}

type InputSchema

type InputSchema struct {
	Type       string              `json:"type"`
	Properties map[string]Property `json:"properties,omitempty"`
	Required   []string            `json:"required,omitempty"`
}

type JSONRPCRequest

type JSONRPCRequest struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id"` // string | number | null
	Method  string      `json:"method"`
	Params  interface{} `json:"params,omitempty"`
}

type JSONRPCResponse

type JSONRPCResponse struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id"`
	Result  interface{} `json:"result,omitempty"`
	Error   *RPCError   `json:"error,omitempty"`
}

type Property

type Property struct {
	Type        string `json:"type"`
	Description string `json:"description,omitempty"`
}

type RPCError

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type Resource

type Resource struct {
	URI      string `json:"uri"`
	MimeType string `json:"mimeType"`
	Text     string `json:"text"`
}

type SSEEvent

type SSEEvent struct {
	Event string
	Data  string
}

SSE event envelope.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server is the HTTP Streamable MCP server. POST /mcp — JSON-RPC 2.0 request/response GET /mcp — SSE stream for real-time notifications OPTIONS /mcp — CORS preflight

func New

func New(
	repo *storage.Repository,
	metrics *telemetry.Metrics,
	svcGraph *graph.Graph,
	vectorIdx *vectordb.Index,
) *Server

New creates a new MCP server.

func (*Server) Handler

func (s *Server) Handler() http.Handler

Handler returns an http.Handler for the MCP server with CORS applied. Works correctly when mounted with http.StripPrefix.

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP dispatches by HTTP method — no path routing needed.

type ServerInfo

type ServerInfo struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

type Tool

type Tool struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	InputSchema InputSchema `json:"inputSchema"`
}

type ToolCallParams

type ToolCallParams struct {
	Name      string         `json:"name"`
	Arguments map[string]any `json:"arguments,omitempty"`
}

type ToolCallResult

type ToolCallResult struct {
	Content []ContentItem `json:"content"`
	IsError bool          `json:"isError,omitempty"`
}

type ToolsListResult

type ToolsListResult struct {
	Tools []Tool `json:"tools"`
}