server

package

Go to main page

Versions in this module

v0

v0.0.34

Jul 25, 2026

Changes in this version

type StreamableHTTPOption

+ func WithStateless(stateless bool) StreamableHTTPOption

v0.0.33

Jul 23, 2026

v0.0.32

Jul 19, 2026

Changes in this version

+ var ErrSamplingNotSupported = errors.New("session does not support sampling")

+ var ErrUnsupportedNotification = errors.New("unsupported notification method")

+ type CompletionHandlerFunc func(ctx context.Context, request mcp.CompleteRequest) (*mcp.CompleteResult, error)

type MCPServer

+ func (*MCPServer) RequestSampling(ctx context.Context, request mcp.CreateMessageRequest) (*mcp.CreateMessageResult, error)

+ func (*MCPServer) SendNotificationToClient(ctx context.Context, method string, params map[string]any) error

type ServerOption

+ func WithCompletionHandler(h CompletionHandlerFunc) ServerOption

+ func WithSubscribeHandlers(subscribe, unsubscribe SubscribeHandlerFunc) ServerOption

+ type SessionWithResourceTemplates interface

+ GetSessionResourceTemplates func() map[string]ServerResourceTemplate

+ SetSessionResourceTemplates func(templates map[string]ServerResourceTemplate)

+ type SessionWithSampling interface

+ RequestSampling func(ctx context.Context, request mcp.CreateMessageRequest) (*mcp.CreateMessageResult, error)

+ type SubscribeHandlerFunc func(ctx context.Context, uri string) error

v0.0.30

Jul 17, 2026

Changes in this version

+ type SessionWithPrompts interface

+ GetSessionPrompts func() map[string]ServerPrompt

+ SetSessionPrompts func(prompts map[string]ServerPrompt)

v0.0.29

Jul 16, 2026

Changes in this version

+ type CallGate func(ctx context.Context, r *http.Request) *Denial

+ type Denial struct

+ Code int

+ HTTPStatus int

+ Message string

type StreamableHTTPOption

+ func WithCallGate(gate CallGate) StreamableHTTPOption

v0.0.28

Jul 13, 2026

Changes in this version

+ var ErrElicitationNotSupported = errors.New("session does not support elicitation")

+ var ErrNoActiveSession = errors.New("no active session")

type ServerOption

+ func WithPageSize(n int) ServerOption

+ type SessionWithElicitation interface

+ RequestElicitation func(ctx context.Context, request mcp.ElicitationRequest) (*mcp.ElicitationResult, error)

type StreamableHTTPOption

+ func WithDisableLocalhostProtection(disable bool) StreamableHTTPOption

v0.0.27

Jul 7, 2026

Changes in this version

+ func ServeStdio(server *MCPServer, _ ...StdioOption) error

+ type ClientSession interface

+ Initialize func()

+ Initialized func() bool

+ NotificationChannel func() chan<- mcp.JSONRPCNotification

+ SessionID func() string

+ func ClientSessionFromContext(ctx context.Context) ClientSession

+ type HTTPContextFunc func(ctx context.Context, r *http.Request) context.Context

+ type Hooks struct

+ func (c *Hooks) AddBeforeCallTool(hook OnBeforeCallToolFunc)

+ func (c *Hooks) AddBeforeListTools(hook OnBeforeListToolsFunc)

+ func (c *Hooks) AddOnRegisterSession(hook OnRegisterSessionHookFunc)

+ type MCPServer struct

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

+ func (*MCPServer) RequestElicitation(ctx context.Context, request mcp.ElicitationRequest) (*mcp.ElicitationResult, error)

+ func (*MCPServer) WithContext(ctx context.Context, session ClientSession) context.Context

+ func (s *MCPServer) AddPrompt(prompt mcp.Prompt, handler PromptHandlerFunc)

+ func (s *MCPServer) AddResource(resource mcp.Resource, handler ResourceHandlerFunc)

+ func (s *MCPServer) AddResourceTemplate(template mcp.ResourceTemplate, handler ResourceTemplateHandlerFunc)

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

+ func (s *MCPServer) AddTools(tools ...ServerTool)

+ func (s *MCPServer) DeleteTools(names ...string)

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

+ func (s *MCPServer) SendNotificationToAllClients(method string, params map[string]any)

+ func (s *MCPServer) SetTools(tools ...ServerTool)

+ type NotificationHandlerFunc func(ctx context.Context, notification mcp.JSONRPCNotification)

+ type OnBeforeCallToolFunc func(ctx context.Context, id any, message *mcp.CallToolRequest)

+ type OnBeforeListToolsFunc func(ctx context.Context, id any, message *mcp.ListToolsRequest)

+ type OnRegisterSessionHookFunc func(ctx context.Context, session ClientSession)

+ type PromptHandlerFunc func(ctx context.Context, request mcp.GetPromptRequest) (*mcp.GetPromptResult, error)

+ type ResourceHandlerFunc func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error)

+ type ResourceTemplateHandlerFunc func(ctx context.Context, request mcp.ReadResourceRequest) ([]mcp.ResourceContents, error)

+ type SSEOption func(*SSEServer)

+ func WithMessageEndpoint(endpoint string) SSEOption

+ func WithSSEEndpoint(endpoint string) SSEOption

+ type SSEServer struct

+ func NewSSEServer(server *MCPServer, opts ...SSEOption) *SSEServer

+ func (s *SSEServer) MessageHandler() http.Handler

+ func (s *SSEServer) SSEHandler() http.Handler

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

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

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

+ type ServerOption func(*MCPServer)

+ func WithHooks(hooks *Hooks) ServerOption

+ func WithLogger(logger *slog.Logger) ServerOption

+ func WithLogging() ServerOption

+ func WithPromptCapabilities(listChanged bool) ServerOption

+ func WithResourceCapabilities(subscribe, listChanged bool) ServerOption

+ func WithToolCapabilities(listChanged bool) ServerOption

+ type ServerPrompt struct

+ Handler PromptHandlerFunc

+ Prompt mcp.Prompt

+ type ServerResource struct

+ Handler ResourceHandlerFunc

+ Resource mcp.Resource

+ type ServerResourceTemplate struct

+ Handler ResourceTemplateHandlerFunc

+ Template mcp.ResourceTemplate

+ type ServerTool struct

+ Handler ToolHandlerFunc

+ Tool mcp.Tool

+ type SessionIdManager interface

+ Generate func() string

+ Terminate func(sessionID string) (isNotAllowed bool, err error)

+ Validate func(sessionID string) (isTerminated bool, err error)

+ type SessionWithResources interface

+ GetSessionResources func() map[string]ServerResource

+ SetSessionResources func(resources map[string]ServerResource)

+ type SessionWithTools interface

+ GetSessionTools func() map[string]ServerTool

+ SetSessionTools func(tools map[string]ServerTool)

+ type StdioOption func(*stdioConfig)

+ type StreamableHTTPOption func(*StreamableHTTPServer)

+ func WithEndpointPath(endpointPath string) StreamableHTTPOption

+ func WithHTTPContextFunc(fn HTTPContextFunc) StreamableHTTPOption

+ func WithHeartbeatInterval(interval time.Duration) StreamableHTTPOption

+ func WithSessionIdManager(manager SessionIdManager) StreamableHTTPOption

+ type StreamableHTTPServer struct

+ func NewStreamableHTTPServer(server *MCPServer, opts ...StreamableHTTPOption) *StreamableHTTPServer

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

+ func (s *StreamableHTTPServer) Shutdown(ctx context.Context) error

+ func (s *StreamableHTTPServer) Start(addr string) error

+ type ToolHandlerFunc func(ctx context.Context, request mcp.CallToolRequest) (*mcp.CallToolResult, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL