server

Documentation

Index

• func NewTestServer(server *MCPServer) *httptest.Server
• func ServeStdio(server *MCPServer) error
• type MCPServer
  • func NewMCPServer(name, version string, opts ...ServerOption) *MCPServer
  • func (s *MCPServer) AddNotificationHandler(handler NotificationHandlerFunc)
  • func (s *MCPServer) AddPrompt(name string, handler PromptHandlerFunc)
  • func (s *MCPServer) AddResource(uri string, handler ResourceHandlerFunc)
  • func (s *MCPServer) AddResourceTemplate(uriTemplate string, handler ResourceTemplateHandlerFunc)
  • func (s *MCPServer) AddTool(tool mcp.Tool, handler ToolHandlerFunc)
  • func (s *MCPServer) HandleMessage(ctx context.Context, message json.RawMessage) mcp.JSONRPCMessage
• type NotificationHandlerFunc
• type PromptHandlerFunc
• type ResourceHandlerFunc
• type ResourceTemplateHandlerFunc
• type SSEServer
  • func NewSSEServer(server *MCPServer, baseURL string) *SSEServer
  • func (s *SSEServer) SendEventToSession(sessionID string, event interface{}) error
  • func (s *SSEServer) Shutdown(ctx context.Context) error
  • func (s *SSEServer) Start(addr string) error
• type ServerOption
  • func WithLogging() ServerOption
  • func WithPromptCapabilities(listChanged bool) ServerOption
  • func WithResourceCapabilities(subscribe, listChanged bool) ServerOption
  • func WithToolCapabilities(listChanged bool) ServerOption
• type StdioServer
• type ToolHandlerFunc

Functions

func NewTestServer

func NewTestServer(server *MCPServer) *httptest.Server

NewTestServer creates a test server for testing purposes

func ServeStdio

func ServeStdio(server *MCPServer) error

ServeStdio creates a stdio server wrapper around an existing MCPServer

Types

type MCPServer

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

func NewMCPServer

func NewMCPServer(
	name, version string,
	opts ...ServerOption,
) *MCPServer

func (*MCPServer) AddNotificationHandler

func (s *MCPServer) AddNotificationHandler(
	handler NotificationHandlerFunc,
)

func (*MCPServer) AddPrompt

func (s *MCPServer) AddPrompt(name string, handler PromptHandlerFunc)

func (*MCPServer) AddResource

func (s *MCPServer) AddResource(uri string, handler ResourceHandlerFunc)

func (*MCPServer) AddResourceTemplate

func (s *MCPServer) AddResourceTemplate(
	uriTemplate string,
	handler ResourceTemplateHandlerFunc,
)

func (*MCPServer) AddTool

func (s *MCPServer) AddTool(tool mcp.Tool, handler ToolHandlerFunc)

func (*MCPServer) HandleMessage

func (s *MCPServer) HandleMessage(
	ctx context.Context,
	message json.RawMessage,
) mcp.JSONRPCMessage

type NotificationHandlerFunc

type NotificationHandlerFunc func(notification mcp.JSONRPCNotification)

type PromptHandlerFunc

type PromptHandlerFunc func(arguments map[string]string) (*mcp.GetPromptResult, error)

type ResourceHandlerFunc

type ResourceHandlerFunc func() ([]interface{}, error)

type ResourceTemplateHandlerFunc

type ResourceTemplateHandlerFunc func() (mcp.ResourceTemplate, error)

type SSEServer

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

func NewSSEServer

func NewSSEServer(server *MCPServer, baseURL string) *SSEServer

func (*SSEServer) SendEventToSession

func (s *SSEServer) SendEventToSession(
	sessionID string,
	event interface{},
) error

SendEventToSession sends an event to a specific session

func (*SSEServer) Shutdown

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

func (*SSEServer) Start

func (s *SSEServer) Start(addr string) error

type ServerOption

type ServerOption func(*MCPServer)

func WithLogging

func WithLogging() ServerOption

func WithPromptCapabilities

func WithPromptCapabilities(listChanged bool) ServerOption

func WithResourceCapabilities

func WithResourceCapabilities(subscribe, listChanged bool) ServerOption

func WithToolCapabilities

func WithToolCapabilities(listChanged bool) ServerOption

type StdioServer

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

StdioServer wraps a MCPServer and handles stdio communication

type ToolHandlerFunc

type ToolHandlerFunc func(arguments map[string]interface{}) (*mcp.CallToolResult, error)