server

Jul 4, 2025

Changes in this version

type InitializeResponse

+ Instructions string

Jun 21, 2025

Changes in this version

type Server

+ AsEmbedded func(transport *embedded.Transport) Server

Jun 21, 2025

Changes in this version

type ContentItem

+ func NewFileContent(mimeType string, data interface{}, filename string) ContentItem

+ func NewImageContent(imageURL, altText string) ContentItem

+ func NewLinkContent(url, title string) ContentItem

+ func NewTextContent(text string) ContentItem

+ type EmptyResponse struct

+ type InitializeResponse struct

+ Capabilities map[string]interface{}

+ ProtocolVersion string

+ ServerInfo ServerInfo

+ func NewInitializeResponse(protocolVersion string, serverInfo ServerInfo, ...) *InitializeResponse

+ type PromptGetResponse struct

+ Description string

+ Messages []PromptMessage

+ func NewPromptGetResponse(description string, messages []PromptMessage) *PromptGetResponse

+ type PromptInfo struct

+ Arguments []PromptArgument

+ Description string

+ Name string

+ type PromptListResponse struct

+ NextCursor string

+ Prompts []PromptInfo

+ func NewPromptListResponse(prompts []PromptInfo, nextCursor string) *PromptListResponse

+ type PromptMessage struct

+ Content PromptContent

+ Role string

+ type ResourceContent struct

+ Content []ContentItem

+ Text string

+ URI string

+ type ResourceInfo struct

+ Description string

+ MimeType string

+ Name string

+ URI string

+ type ResourceListResponse struct

+ NextCursor string

+ Resources []ResourceInfo

+ func NewResourceListResponse(resources []ResourceInfo, nextCursor string) *ResourceListResponse

+ type ResourceReadResponse struct

+ Contents []ResourceContent

+ func NewResourceReadResponse(contents []ResourceContent) *ResourceReadResponse

+ type ResourceTemplateInfo struct

+ Annotations map[string]interface{}

+ Description string

+ MimeType string

+ Name string

+ URITemplate string

+ type ResourceTemplatesListResponse struct

+ NextCursor string

+ ResourceTemplates []ResourceTemplateInfo

+ func NewResourceTemplatesListResponse(templates []ResourceTemplateInfo, nextCursor string) *ResourceTemplatesListResponse

+ type RootInfo struct

+ Name string

+ URI string

+ type RootsListResponse struct

+ Roots []RootInfo

+ func NewRootsListResponse(roots []RootInfo) *RootsListResponse

+ type ServerInfo struct

+ Name string

+ Version string

+ type ShutdownResponse struct

+ Success bool

+ func NewShutdownResponse(success bool) *ShutdownResponse

+ type ToolCallResponse struct

+ Content []ContentItem

+ IsError bool

+ func NewToolCallResponse(content []ContentItem, isError bool) *ToolCallResponse

+ type ToolInfo struct

+ Annotations map[string]interface{}

+ Description string

+ InputSchema interface{}

+ Name string

+ type ToolListResponse struct

+ NextCursor string

+ Tools []ToolInfo

+ func NewToolListResponse(tools []ToolInfo, nextCursor string) *ToolListResponse

Jun 7, 2025

Changes in this version

type ClientSession

+ ResourceSubscriptions []string

type Server

+ AsGRPC func(address string, options ...grpc.Option) Server

Jun 2, 2025

Changes in this version

type ClientInfo

+ Env map[string]string

+ Roots []string

type ClientSession

+ func (s *ClientSession) Capabilities() SamplingCapabilities

+ func (s *ClientSession) Env() map[string]string

+ func (s *ClientSession) Roots() []string

type Context

+ Session *ClientSession

+ type Session = ClientSession

Jun 1, 2025

Changes in this version

type Context

+ func (c *Context) GetPrimaryRoot() string

+ func (c *Context) GetRoots() []string

+ func (c *Context) InRoots(path string) bool

May 31, 2025

Changes in this version

+ type CapabilityCache struct

+ func NewCapabilityCache() *CapabilityCache

+ func (c *CapabilityCache) GetPendingNotifications() [][]byte

+ func (c *CapabilityCache) MarkPromptsChanged()

+ func (c *CapabilityCache) MarkResourcesChanged()

+ func (c *CapabilityCache) MarkToolsChanged()

+ func (c *CapabilityCache) QueueNotification(notification []byte)

+ func (c *CapabilityCache) ResetChangeFlags()

May 31, 2025

Changes in this version

+ func TestEnsureContentsArray(response map[string]interface{}, uri string) map[string]interface

+ func TestEnsureValidContentItems(items []interface{}) []interface

type Context

+ ProgressToken string

+ func (c *Context) CompleteProgress(finalMessage string) error

+ func (c *Context) CreateProgressReporter(total *float64, initialMessage string) *mcp.ProgressReporter

+ func (c *Context) CreateProgressToken() string

+ func (c *Context) CreateSimpleProgressReporter(total *float64) *mcp.ProgressReporter

+ func (c *Context) GetValidatedArgs(targetType reflect.Type) (interface{}, error)

+ func (c *Context) HasProgressToken() bool

+ func (c *Context) StartProgressOperation(total *float64, initialMessage string) *mcp.ProgressReporter

+ func (c *Context) ValidateToolArgs(toolName string) (interface{}, error)

type Option

+ func WithProtocolVersion(version string) Option

+ type OverflowStrategy int

+ const BlockUntilSpace

+ const CombineNotifications

+ const DropNewest

+ const DropOldest

+ type ProgressNotificationHandler struct

+ func NewProgressNotificationHandler(server *serverImpl) *ProgressNotificationHandler

+ func (pnh *ProgressNotificationHandler) CleanupRateLimiters()

+ func (pnh *ProgressNotificationHandler) GetAllStatistics() map[string]interface{}

+ func (pnh *ProgressNotificationHandler) GetConfiguration() *ProgressRateLimitConfig

+ func (pnh *ProgressNotificationHandler) GetOrCreateRateLimiter(progressToken string) *ProgressRateLimiter

+ func (pnh *ProgressNotificationHandler) GetProgressChannel() *mcp.ProgressChannel

+ func (pnh *ProgressNotificationHandler) SetConfiguration(config *ProgressRateLimitConfig)

+ type ProgressRateLimitConfig struct

+ BatchSize int

+ BatchTimeout time.Duration

+ BufferSize int

+ CombineThreshold time.Duration

+ EnableBatching bool

+ MaxNotificationsPerSecond int

+ OverflowStrategy OverflowStrategy

+ func NewDefaultProgressRateLimitConfig() *ProgressRateLimitConfig

+ type ProgressRateLimiter struct

+ func NewProgressRateLimiter(config *ProgressRateLimitConfig) *ProgressRateLimiter

+ func (prl *ProgressRateLimiter) BufferNotification(notification *mcp.ProgressNotification) error

+ func (prl *ProgressRateLimiter) CanSendNotification() bool

+ func (prl *ProgressRateLimiter) GetStatistics() map[string]interface{}

+ func (prl *ProgressRateLimiter) ProcessBuffer() []*mcp.ProgressNotification

type Resource

+ Annotations map[string]interface{}

type Server

+ Events func() *events.Subject

+ ListPrompts func() ([]mcp.Prompt, error)

+ ListResources func() ([]mcp.Resource, error)

+ ListTools func() ([]mcp.Tool, error)

+ Shutdown func() error

May 21, 2025

Changes in this version

+ type CancelledNotificationParams struct

+ Reason string

+ RequestID string

type Context

+ func (c *Context) CancelRequest(reason string) error

+ func (c *Context) CheckCancellation() error

+ func (c *Context) IsCancelled() bool

+ func (c *Context) RegisterForCancellation() <-chan struct{}

+ type RequestCanceller struct

+ func NewRequestCanceller() *RequestCanceller

+ func (rc *RequestCanceller) Cancel(requestID interface{}, reason string) bool

+ func (rc *RequestCanceller) Deregister(requestID interface{})

+ func (rc *RequestCanceller) IsCancelled(requestID interface{}) bool

+ func (rc *RequestCanceller) Register(requestID interface{}) <-chan struct{}

type Server

+ WithSchema func(toolName string, schema interface{}) Server

May 18, 2025

Changes in this version

+ func DefaultGRPCServerOptions() []grpc.Option

+ func WithGRPCKeepAlive(time, timeout time.Duration) grpc.Option

+ func WithGRPCMaxMessageSize(size int) grpc.Option

+ func WithGRPCTLS(certFile, keyFile, caFile string) grpc.Option

+ func WithGRPCTimeout(timeout time.Duration) grpc.Option

type Server

+ AsHTTPWithPaths func(address, pathPrefix, apiPath string) Server

+ AsMQTT func(brokerURL string, options ...mqtt.MQTTOption) Server

+ AsMQTTWithClientID func(brokerURL string, clientID string, options ...mqtt.MQTTOption) Server

+ AsMQTTWithTLS func(brokerURL string, tlsConfig mqtt.TLSConfig, options ...mqtt.MQTTOption) Server

+ AsNATS func(serverURL string, options ...nats.NATSOption) Server

+ AsNATSWithClientID func(serverURL string, clientID string, options ...nats.NATSOption) Server

+ AsNATSWithToken func(serverURL string, token string, options ...nats.NATSOption) Server

+ AsUDP func(address string, options ...udp.UDPOption) Server

+ AsUnixSocket func(socketPath string, options ...unix.UnixSocketOption) Server

+ AsWebsocketWithPaths func(address, pathPrefix, wsPath string) Server

May 18, 2025

Changes in this version

+ func ExtractProtocolVersion(params json.RawMessage) (string, error)

+ func FormatResourceResponse(uri string, result interface{}, version string) map[string]interface

+ func HandleMessage(s *serverImpl, message []byte) ([]byte, error)

+ func HandleMessageWithVersion(srv Server, message []byte, version string) ([]byte, error)

+ func SimpleJSONResponse(data interface{}) map[string]interface

+ func SimpleTextResponse(text string) map[string]interface

+ func SubstituteVariables(content string, variables map[string]interface{}) (string, error)

+ func ValidateContentForVersion(content SamplingContentHandler, version string) error

+ type AudioResource struct

+ AltText string

+ Data string

+ MimeType string

+ URL string

+ func (a AudioResource) ToResourceResponse() map[string]interface{}

+ type AudioSamplingContent struct

+ Data string

+ MimeType string

+ func (a *AudioSamplingContent) ToMessageContent() SamplingMessageContent

+ func (a *AudioSamplingContent) Validate() error

+ type ClientInfo struct

+ ProtocolVersion string

+ SamplingCaps SamplingCapabilities

+ SamplingSupported bool

type ClientSession

+ ClientInfo ClientInfo

+ Created time.Time

+ ID SessionID

+ LastActive time.Time

+ Metadata map[string]string

+ ProtocolVersion string

+ type ContentItem struct

+ AltText string

+ Blob string

+ Data interface{}

+ Filename string

+ ImageURL string

+ MimeType string

+ Text string

+ Title string

+ Type string

+ URL string

+ func BlobContent(blob string, mimeType string) ContentItem

+ func FileContent(fileURL string, filename string, mimeType string) ContentItem

+ func ImageContent(imageURL string, altText string, optMimeType ...string) ContentItem

+ func JSONContent(data interface{}) ContentItem

+ func LinkContent(url, title string) ContentItem

+ func TextContent(text string) ContentItem

+ type ContentType string

+ const ContentTypeAudio

+ const ContentTypeImage

+ const ContentTypeResource

+ const ContentTypeText

type Context

+ Logger *slog.Logger

+ Metadata map[string]interface{}

+ Request *Request

+ RequestBytes []byte

+ RequestID string

+ Response *Response

+ Version string

+ func (c *Context) Deadline() (deadline interface{}, ok bool)

+ func (c *Context) Err() error

+ func (c *Context) ExecuteResource(resourcePath string) (interface{}, error)

+ func (c *Context) ExecuteTool(toolName string, args map[string]interface{}) (interface{}, error)

+ func (c *Context) GetRegisteredResources() ([]*Resource, error)

+ func (c *Context) GetRegisteredTools() ([]*Tool, error)

+ func (c *Context) GetResourceDetails(resourcePath string) (*Resource, error)

+ func (c *Context) GetSamplingController() (*SamplingController, error)

+ func (c *Context) GetToolDetails(toolName string) (*Tool, error)

+ func (c *Context) RequestSampling(messages []SamplingMessage, preferences SamplingModelPreferences, ...) (*SamplingResponse, error)

+ func (c *Context) RequestSamplingWithPriority(messages []SamplingMessage, preferences SamplingModelPreferences, ...) (*SamplingResponse, error)

+ func (c *Context) ValidateSamplingRequest(messages []SamplingMessage, maxTokens int) error

+ func (c *Context) Value(key interface{}) interface{}

+ type FileResource struct

+ Filename string

+ MimeType string

+ URL string

+ func (fr FileResource) ToResourceResponse() map[string]interface{}

+ type ImageResource struct

+ AltText string

+ MimeType string

+ URL string

+ func (ir ImageResource) ToResourceResponse() map[string]interface{}

+ type ImageSamplingContent struct

+ Data string

+ MimeType string

+ func (i *ImageSamplingContent) ToMessageContent() SamplingMessageContent

+ func (i *ImageSamplingContent) Validate() error

+ type InvalidParametersError struct

+ Message string

+ func NewInvalidParametersError(message string) *InvalidParametersError

+ func (e *InvalidParametersError) Error() string

+ type JSONResource struct

+ Data interface{}

+ func (jr JSONResource) ToResourceResponse() map[string]interface{}

+ type LinkResource struct

+ Title string

+ URL string

+ func (lr LinkResource) ToResourceResponse() map[string]interface{}

+ type Option func(*serverImpl)

+ func WithSamplingConfig(config *SamplingConfig) Option

+ type Prompt struct

+ Arguments []PromptArgument

+ Description string

+ Name string

+ Templates []PromptTemplate

+ type PromptArgument struct

+ Description string

+ Name string

+ Required bool

+ type PromptContent struct

+ Data string

+ MimeType string

+ Resource map[string]interface{}

+ Text string

+ Type ContentType

+ type PromptTemplate struct

+ Content string

+ Role string

+ Variables []string

+ type ProtocolSamplingConfig struct

+ MaxTokens int

+ StreamingSupported bool

+ SupportedContentTypes map[string]bool

+ type RPCError struct

+ Code int

+ Data interface{}

+ Message string

+ func (e *RPCError) Error() string

+ type Request struct

+ ID interface{}

+ JSONRPC string

+ Method string

+ Params json.RawMessage

+ PromptArgs map[string]interface{}

+ PromptName string

+ ResourcePath string

+ ToolArgs map[string]interface{}

+ ToolName string

+ type RequestSamplingOptions struct

+ ForceSession bool

+ IgnoreCapability bool

+ MaxRetries int

+ RetryInterval time.Duration

+ Timeout time.Duration

+ func DefaultSamplingOptions() RequestSamplingOptions

+ type Resource struct

+ Description string

+ Handler ResourceHandler

+ IsTemplate bool

+ Path string

+ Schema interface{}

+ Template *wilduri.Template

+ type ResourceConverter interface

+ ToResourceResponse func() map[string]interface{}

+ type ResourceHandler func(ctx *Context, args interface{}) (interface{}, error)

+ func ConvertToResourceHandler(handler interface{}) (ResourceHandler, bool)

+ type ResourceResponse struct

+ Content []ContentItem

+ IsError bool

+ Metadata map[string]interface{}

+ func NewResourceResponse(items ...ContentItem) ResourceResponse

+ func (r ResourceResponse) AsError() ResourceResponse

+ func (r ResourceResponse) WithMetadata(metadata map[string]interface{}) ResourceResponse

+ type Response struct

+ Error *RPCError

+ ID interface{}

+ JSONRPC string

+ Result interface{}

+ type SamplingCapabilities struct

+ AudioSupport bool

+ ImageSupport bool

+ Supported bool

+ TextSupport bool

+ func DetectClientCapabilities(protocolVersion string) SamplingCapabilities

+ type SamplingConfig struct

+ DefaultMaxRetries int

+ DefaultPriority int

+ DefaultRetryInterval time.Duration

+ DefaultTimeout time.Duration

+ EnablePrioritization bool

+ GracefulDegradation bool

+ MaxConcurrentRequests int

+ MaxRequestsPerMinute int

+ MaxTimeout time.Duration

+ MaxTokensPerRequest int

+ PerClientRateLimit bool

+ ProtocolDefaults map[string]*ProtocolSamplingConfig

+ ResourceQuota map[string]int

+ func NewDefaultSamplingConfig() *SamplingConfig

+ type SamplingContentHandler interface

+ ToMessageContent func() SamplingMessageContent

+ Validate func() error

+ type SamplingController struct

+ func NewSamplingController(config *SamplingConfig, logger *slog.Logger) *SamplingController

+ func (sc *SamplingController) CanProcessRequest(sessionID SessionID) bool

+ func (sc *SamplingController) CompleteRequest(sessionID SessionID)

+ func (sc *SamplingController) GetConcurrentRequestCount() int

+ func (sc *SamplingController) GetRequestOptions(priority int) RequestSamplingOptions

+ func (sc *SamplingController) RecordRequest(sessionID SessionID)

+ func (sc *SamplingController) Stop()

+ func (sc *SamplingController) ValidateForProtocol(protocol string, messages []SamplingMessage, maxTokens int) error

+ type SamplingCreateMessageParams struct

+ MaxTokens int

+ Messages []SamplingMessage

+ ModelPreferences SamplingModelPreferences

+ SystemPrompt string

+ type SamplingMessage struct

+ Content SamplingMessageContent

+ Role string

+ func CreateAudioSamplingMessage(role, audioData, mimeType string) SamplingMessage

+ func CreateImageSamplingMessage(role, imageData, mimeType string) SamplingMessage

+ func CreateSamplingMessage(role string, content SamplingContentHandler) (SamplingMessage, error)

+ func CreateTextSamplingMessage(role, text string) SamplingMessage

+ type SamplingMessageContent struct

+ Data string

+ MimeType string

+ Text string

+ Type string

+ func (c *SamplingMessageContent) IsValidForVersion(version string) bool

+ type SamplingModelHint struct

+ Name string

+ type SamplingModelPreferences struct

+ CostPriority *float64

+ Hints []SamplingModelHint

+ IntelligencePriority *float64

+ SpeedPriority *float64

+ type SamplingResponse struct

+ Content SamplingMessageContent

+ Model string

+ Role string

+ StopReason string

type Server

+ AsHTTP func(address string) Server

+ GetRoots func() []string

+ GetServer func() *serverImpl

+ IsPathInRoots func(path string) bool

+ Logger func() *slog.Logger

+ WithAnnotations func(toolName string, annotations map[string]interface{}) Server

+ WithSamplingConfig func(config *SamplingConfig) Server

+ WithSamplingController func(controller *SamplingController) Server

+ type SessionID string

+ type SessionManager struct

+ func NewSessionManager() *SessionManager

+ func (sm *SessionManager) CloseSession(id SessionID) bool

+ func (sm *SessionManager) CreateSession(clientInfo ClientInfo, protocolVersion string) *ClientSession

+ func (sm *SessionManager) GetSession(id SessionID) (*ClientSession, bool)

+ func (sm *SessionManager) UpdateClientCapabilities(id SessionID, caps SamplingCapabilities) bool

+ func (sm *SessionManager) UpdateSession(id SessionID, update func(*ClientSession)) bool

+ type TextResource struct

+ Text string

+ func (tr TextResource) ToResourceResponse() map[string]interface{}

+ type TextSamplingContent struct

+ Text string

+ func (t *TextSamplingContent) ToMessageContent() SamplingMessageContent

+ func (t *TextSamplingContent) Validate() error

+ type Tool struct

+ Annotations map[string]interface{}

+ Description string

+ Handler ToolHandler

+ Name string

+ Schema interface{}

+ type ToolHandler func(ctx *Context, args interface{}) (interface{}, error)

May 12, 2025

Changes in this version

type Context

+ func (c *Context) AddResponseMetadata(key string, value interface{})

+ func (c *Context) Done() <-chan struct{}

+ func (c *Context) GenerateRequestID() string

+ func (c *Context) GetProgressToken() interface{}

+ func (c *Context) SendProgress(value interface{})

type LifecycleHandler

+ func (h *LifecycleHandler) SetLogger(logger logx.Logger)

type MessageHandler

+ func (h *MessageHandler) SetLogger(logger logx.Logger)

type Registry

+ func (r *Registry) SetLogger(logger logx.Logger)

type SubscriptionManager

+ func (sm *SubscriptionManager) SetLogger(logger logx.Logger)

type TransportManager

+ func (tm *TransportManager) SetLogger(logger logx.Logger)

May 12, 2025

Changes in this version

+ func AddPrompt[T any](srv *Server, name string, description string, handler PromptFunc[T]) error

+ func AddResource(srv *Server, uri string, kind string, description string, version string, ...) error

+ func AddTool[T any](srv *Server, name string, description string, handler ToolFunc[T]) error

+ func Message(role string, content string) protocol.PromptMessage

+ type PromptFunc func(T) (protocol.PromptMessage, error)

+ type ResourceFunc func() (protocol.ResourceContents, error)

+ type ToolFunc func(T) (protocol.Content, error)

+ type ToolMiddleware func(ToolFunc[T]) ToolFunc[T]

Apr 29, 2025

Changes in this version

type ServerOption

+ func WithAfterToolCallHook(hooks ...hooks.AfterToolCallHook) ServerOption

+ func WithAuth(validator auth.TokenValidator, checker auth.PermissionChecker) ServerOption

+ func WithBeforeHandleMessageHook(hooks ...hooks.BeforeHandleMessageHook) ServerOption

+ func WithBeforeSendResponseHook(hooks ...hooks.BeforeSendResponseHook) ServerOption

+ func WithBeforeSessionDestroyHook(hooks ...hooks.BeforeSessionDestroyHook) ServerOption

+ func WithBeforeToolCallHook(hooks ...hooks.BeforeToolCallHook) ServerOption

+ func WithBeforeUnmarshalHook(hooks ...hooks.BeforeUnmarshalHook) ServerOption

+ func WithJWTAuth(config auth.JWKSConfig, checker auth.PermissionChecker) ServerOption

+ func WithOnSessionCreateHook(hooks ...hooks.OnSessionCreateHook) ServerOption

+ func WithServerBeforeHandleNotificationHook(hooks ...hooks.ServerBeforeHandleNotificationHook) ServerOption

+ func WithServerBeforeHandleRequestHook(hooks ...hooks.ServerBeforeHandleRequestHook) ServerOption

+ func WithServerBeforeSendNotificationHook(hooks ...hooks.ServerBeforeSendNotificationHook) ServerOption

Apr 26, 2025

Changes in this version

type ServerOption

+ func WithPromptListChanged(listChanged bool) ServerOption

+ func WithResourceListChanged(listChanged bool) ServerOption

+ func WithResourceSubscription(subscribe bool) ServerOption

+ func WithToolListChanged(listChanged bool) ServerOption

Apr 26, 2025

Changes in this version

+ func ServeSSE(srv *Server, addr string, basePath string) error

+ func ServeStdio(srv *Server) error

+ func ServeWebSocket(srv *Server, addr string, path string) error

+ type ServerOption func(*Server)

+ func WithInstructions(instructions string) ServerOption

+ func WithLogger(logger types.Logger) ServerOption

+ func WithPromptCapabilities(listChanged bool) ServerOption

+ func WithResourceCapabilities(subscribe, listChanged bool) ServerOption

+ func WithServerCapabilities(caps protocol.ServerCapabilities) ServerOption

+ func WithToolCapabilities(listChanged bool) ServerOption

Apr 25, 2025

Changes in this version

type ClientSession

+ GetClientCapabilities func() protocol.ClientCapabilities

+ GetNegotiatedVersion func() string

+ SetNegotiatedVersion func(version string)

+ StoreClientCapabilities func(caps protocol.ClientCapabilities)

May 12, 2025

Changes in this version

+ const ServerVersion

+ func Assistant(msg string) protocol.PromptMessage

+ func NewStdioSession(connectionID string, writer io.Writer, logger types.Logger, ...) *stdioSession

+ func System(msg string) protocol.PromptMessage

+ func Text(msg string) protocol.Content

+ func User(msg string) protocol.PromptMessage

+ type Context struct

+ func NewContext(parentCtx context.Context, requestID string, session types.ClientSession, ...) *Context

+ func (c *Context) CallTool(toolName string, input interface{}) (json.RawMessage, *protocol.ToolError, error)

+ func (c *Context) CreateMessage(messages []protocol.SamplingMessage, opts *protocol.SamplingRequestParams) (*protocol.SamplingResult, error)

+ func (c *Context) Debug(message string)

+ func (c *Context) Error(message string)

+ func (c *Context) Info(message string)

+ func (c *Context) Log(level string, message string)

+ func (c *Context) ReadResource(uri string) (protocol.ResourceContents, error)

+ func (c *Context) ReportProgress(message string, current, total int)

+ func (c *Context) Warning(message string)

+ type DuplicateHandling int

+ const DuplicateError

+ const DuplicateIgnore

+ const DuplicateReplace

+ const DuplicateWarn

+ type Hooks struct

+ func NewHooks() *Hooks

+ type LifecycleHandler struct

+ func NewLifecycleHandler(srv *Server) *LifecycleHandler

+ func (h *LifecycleHandler) ExitHandler()

+ func (h *LifecycleHandler) InitializeHandler(params protocol.InitializeRequestParams) (protocol.InitializeResult, *protocol.ClientCapabilities, error)

+ func (h *LifecycleHandler) InitializedHandler()

+ func (h *LifecycleHandler) ShutdownHandler() error

+ type MessageHandler struct

+ func NewMessageHandler(srv *Server) *MessageHandler

+ func (mh *MessageHandler) AddCancelFuncForTest(requestID string, cancel context.CancelFunc)

+ func (mh *MessageHandler) GetCancelFuncForTest(requestID string) (context.CancelFunc, bool)

+ func (mh *MessageHandler) HandleMessage(session types.ClientSession, message []byte) error

+ func (mh *MessageHandler) RegisterNotificationHandler(method string, handler func(params json.RawMessage))

+ func (mh *MessageHandler) SendLoggingMessage(level protocol.LoggingLevel, message string, logger *string, data interface{})

+ func (mh *MessageHandler) SendNotificationToConnections(connectionIDs []string, notif *protocol.JSONRPCNotification)

+ func (mh *MessageHandler) SendProgress(connectionID string, token interface{}, value interface{})

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) AddPrompt(prompt protocol.Prompt) *Registry

+ func (r *Registry) AddResourceTemplate(uriPattern string, handlerFn any) error

+ func (r *Registry) AddRoot(root protocol.Root) *Registry

+ func (r *Registry) GetPrompt(uri string) (protocol.Prompt, bool)

+ func (r *Registry) GetPrompts() []protocol.Prompt

+ func (r *Registry) GetRegisteredResource(uri string) (*registeredResource, bool)

+ func (r *Registry) GetResource(uri string) (protocol.Resource, bool)

+ func (r *Registry) GetToolHandler(name string) (func(ctx *Context, rawArgs json.RawMessage) (interface{}, error), bool)

+ func (r *Registry) GetTools() []protocol.Tool

+ func (r *Registry) RegisterResource(resource protocol.Resource) *Registry

+ func (r *Registry) RegisterResourceTemplate(uriPattern string, config resourceConfig) error

+ func (r *Registry) RegisterStaticResource(uri string, config resourceConfig) error

+ func (r *Registry) RemovePrompt(name string) *Registry

+ func (r *Registry) RemoveRoot(root protocol.Root) *Registry

+ func (r *Registry) RemoveTool(name string) *Registry

+ func (r *Registry) ResourceRegistry() map[string]protocol.Resource

+ func (r *Registry) SetPromptChangedCallback(callback func())

+ func (r *Registry) SetResourceChangedCallback(callback func(uri string))

+ func (r *Registry) SetToolChangedCallback(callback func())

+ func (r *Registry) TemplateRegistry() map[string]*resourceTemplateInfo

+ func (r *Registry) Tool(name, desc string, fn any) *Registry

+ type ResourceDetails struct

+ Description string

+ Kind string

+ Name string

+ URI string

+ type ResourceOption func(*resourceConfig)

+ func WithAnnotations(annotations map[string]any) ResourceOption

+ func WithAsync(progressTemplate string) ResourceOption

+ func WithBinaryContent(data []byte) ResourceOption

+ func WithContentTypeInference(enabled bool) ResourceOption

+ func WithCustomKey(key string) ResourceOption

+ func WithDefaultParamValue(paramName string, defaultValue interface{}) ResourceOption

+ func WithDescription(description string) ResourceOption

+ func WithDirectoryListing(dirPath string) ResourceOption

+ func WithDuplicateHandling(handling DuplicateHandling) ResourceOption

+ func WithFileContent(filePath string) ResourceOption

+ func WithHandler(handlerFn any) ResourceOption

+ func WithMimeType(mimeType string) ResourceOption

+ func WithMultipleURIs(additionalURIs ...string) ResourceOption

+ func WithName(name string) ResourceOption

+ func WithReturnTypeConversion(converter func(interface{}) ([]protocol.ResourceContents, error)) ResourceOption

+ func WithTags(tags ...string) ResourceOption

+ func WithTextContent(text string) ResourceOption

+ func WithURLContent(url string) ResourceOption

+ func WithWildcardParam(paramName string) ResourceOption

+ type RootDetails struct

+ Description string

+ Kind string

+ Name string

+ URI string

type Server

+ ImplementsAuthorization bool

+ ImplementsCompletions bool

+ ImplementsLogging bool

+ ImplementsPromptListChanged bool

+ ImplementsResourceListChanged bool

+ ImplementsResourceSubscription bool

+ ImplementsSampling bool

+ ImplementsToolListChanged bool

+ MessageHandler *MessageHandler

+ Registry *Registry

+ SubscriptionManager *SubscriptionManager

+ TransportManager *TransportManager

+ func (s *Server) AsSSE(addr string, basePath string) *Server

+ func (s *Server) AsStdio() *Server

+ func (s *Server) AsWebsocket(addr string, path string) *Server

+ func (s *Server) Close() error

+ func (s *Server) Prompt(name, description string, messages ...protocol.PromptMessage) *Server

+ func (s *Server) Resource(uri string, options ...ResourceOption) *Server

+ func (s *Server) Root(root protocol.Root) *Server

+ func (s *Server) Run() error

+ func (s *Server) Tool(name, desc string, fn any) *Server

+ func (s *Server) WithLogger(logger logx.Logger) *Server

+ type SubscriptionManager struct

+ func NewSubscriptionManager() *SubscriptionManager

+ func (sm *SubscriptionManager) GetSubscribedConnectionIDs(uri string) []string

+ func (sm *SubscriptionManager) IsSubscribed(uri string, connectionID string) bool

+ func (sm *SubscriptionManager) Subscribe(uri, connectionID string)

+ func (sm *SubscriptionManager) Unsubscribe(uri, connectionID string)

+ func (sm *SubscriptionManager) UnsubscribeAll(connectionID string)

+ type TransportManager struct

+ Capabilities map[string]*protocol.ClientCapabilities

+ Sessions map[string]types.ClientSession

+ func NewTransportManager() *TransportManager

+ func (tm *TransportManager) AsSSE(s *Server, addr string, basePath string) *Server

+ func (tm *TransportManager) AsStdio(s *Server) *Server

+ func (tm *TransportManager) AsWebsocket(s *Server, addr string, path string) *Server

+ func (tm *TransportManager) GetAllSessionIDs() []string

+ func (tm *TransportManager) GetSession(sessionID string) (types.ClientSession, *protocol.ClientCapabilities, bool)

+ func (tm *TransportManager) RegisterSession(session types.ClientSession, caps *protocol.ClientCapabilities)

+ func (tm *TransportManager) RemoveSession(sessionID string)

+ func (tm *TransportManager) Run(s *Server) error

+ func (tm *TransportManager) SendMessage(sessionID string, message []byte) error

+ func (tm *TransportManager) Shutdown()

+ type TransportType int

+ const TransportNone

+ const TransportSSE

+ const TransportStdio

+ const TransportWebsocket

Mar 30, 2025

Changes in this version

+ type ClientSession interface

+ Close func() error

+ Initialize func()

+ Initialized func() bool

+ SendNotification func(notification protocol.JSONRPCNotification) error

+ SendResponse func(response protocol.JSONRPCResponse) error

+ SessionID func() string

+ type NotificationHandlerFunc func(ctx context.Context, params interface{}) error

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

+ type Server struct

+ func NewServer(serverName string, opts ServerOptions) *Server

+ func (s *Server) HandleMessage(ctx context.Context, sessionID string, rawMessage json.RawMessage) *protocol.JSONRPCResponse

+ func (s *Server) NotifyResourceUpdated(resource protocol.Resource)

+ func (s *Server) RegisterNotificationHandler(method string, handler NotificationHandlerFunc) error

+ func (s *Server) RegisterPrompt(prompt protocol.Prompt) error

+ func (s *Server) RegisterResource(resource protocol.Resource) error

+ func (s *Server) RegisterSession(session ClientSession) error

+ func (s *Server) RegisterTool(tool protocol.Tool, handler ToolHandlerFunc) error

+ func (s *Server) ResourceRegistry() map[string]protocol.Resource

+ func (s *Server) SendProgress(sessionID string, params protocol.ProgressParams) error

+ func (s *Server) SendPromptsListChanged() error

+ func (s *Server) SendResourcesListChanged() error

+ func (s *Server) SendToolsListChanged() error

+ func (s *Server) UnregisterPrompt(uri string) error

+ func (s *Server) UnregisterResource(uri string) error

+ func (s *Server) UnregisterSession(sessionID string)

+ type ServerOptions struct

+ Logger types.Logger

+ ServerCapabilities protocol.ServerCapabilities

+ type ToolHandlerFunc func(ctx context.Context, progressToken *protocol.ProgressToken, ...) (content []protocol.Content, isError bool)