server

Documentation

Overview

Package server implements the MCP server with HTTP Streamable and stdio transports.

Index

• type Config
• type JSONRPCError
• type JSONRPCRequest
• type JSONRPCResponse
• type Server
  • func New(cfg Config) *Server
  • func (s *Server) SendEvent(sessionID string, event interface{}) error
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start() error
• type Session
• type Tool
• type ToolHandler

Types

type Config

type Config struct {
	Addr         string
	Orchestrator *orchestrator.Orchestrator
	Version      string
	Commit       string
	UseStdio     bool
	AppConfig    *config.Config
}

Config holds server configuration.

type JSONRPCError

type JSONRPCError struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

JSONRPCError represents a JSON-RPC 2.0 error.

type JSONRPCRequest

type JSONRPCRequest struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      interface{}     `json:"id,omitempty"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params,omitempty"`
}

JSONRPCRequest represents a JSON-RPC 2.0 request.

type JSONRPCResponse

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

JSONRPCResponse represents a JSON-RPC 2.0 response.

type Server

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

Server is the MCP HTTP Streamable and stdio server.

func New

func New(cfg Config) *Server

New creates a new MCP server.

func (*Server) SendEvent

func (s *Server) SendEvent(sessionID string, event interface{}) error

SendEvent sends an event to a session.

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

Shutdown gracefully shuts down the server.

func (*Server) Start

func (s *Server) Start() error

Start starts the HTTP server or stdio loop.

type Session

type Session struct {
	ID        string
	CreatedAt time.Time
	// contains filtered or unexported fields
}

Session represents an MCP session.

type Tool

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

Tool represents an MCP tool definition.

type ToolHandler

type ToolHandler func(ctx context.Context, params json.RawMessage) (interface{}, error)

ToolHandler handles a tool call.