server

package

Go to main page

Versions in this module

v1

v1.6.1

Aug 24, 2026

v1.6.0

Aug 23, 2026

Changes in this version

type ServerOptionFunc

+ func WithStaticDir(dir string) ServerOptionFunc

v1.5.0

Aug 23, 2026

Changes in this version

type Server

+ func (srv *Server) HandleStaticChecked(pattern string) error

+ func (srv *Server) RunContext(ctx context.Context) error

type ServerOptionFunc

+ func WithConfigFile(path string) ServerOptionFunc

+ func WithEnvironment() ServerOptionFunc

+ func WithOptions(options ServerOptions) ServerOptionFunc

+ func WithServerHeader(value string) ServerOptionFunc

+ func WithStartupBanner() ServerOptionFunc

type ServerOptions

+ ServerHeader string

+ func DefaultServerOptions() ServerOptions

v1.4.0

Aug 23, 2026

Changes in this version

type ServerOptionFunc

+ func WithMCPLegacyRoutedSSE(enabled bool) ServerOptionFunc

+ func WithMCPOriginValidator(validator func(*http.Request) bool) ServerOptionFunc

type ServerOptions

+ MCPLegacyRoutedSSE bool

+ MCPOriginValidator func(r *http.Request) bool

v1.3.1

Aug 23, 2026

v1.3.0

Aug 23, 2026

v1.2.0

May 24, 2026

Changes in this version

type Server

+ func (srv *Server) RegisterMCPResourceTemplate(template mcp.ResourceTemplate) error

type ServerOptionFunc

+ func WithMCPProtocolVersion(version string) ServerOptionFunc

type ServerOptions

+ MCPProtocolVersion string

v1.1.0

May 24, 2026

Changes in this version

type Server

+ func (srv *Server) RegisteredRoutes() []string

type ServerOptionFunc

+ func WithHealthAddr(addr string) ServerOptionFunc

+ func WithLogLevel(level string) ServerOptionFunc

v0

v0.34.2

May 19, 2026

v0.34.1

May 19, 2026

v0.34.0

May 19, 2026

v0.33.1

May 18, 2026

v0.33.0

May 18, 2026

Changes in this version

+ func VersionInfo() string

v0.32.0

May 18, 2026

v0.31.0

May 18, 2026

v0.30.0

May 18, 2026

Changes in this version

+ func JSONEcho[T any]() http.HandlerFunc

v0.29.0

May 18, 2026

Changes in this version

+ func JSONHandler[In, Out any](fn func(context.Context, In) (Out, error)) http.HandlerFunc

type Server

+ func (srv *Server) DELETE(pattern string, handler http.HandlerFunc)

+ func (srv *Server) GET(pattern string, handler http.HandlerFunc)

+ func (srv *Server) HEAD(pattern string, handler http.HandlerFunc)

+ func (srv *Server) OPTIONS(pattern string, handler http.HandlerFunc)

+ func (srv *Server) PATCH(pattern string, handler http.HandlerFunc)

+ func (srv *Server) POST(pattern string, handler http.HandlerFunc)

+ func (srv *Server) PUT(pattern string, handler http.HandlerFunc)

+ type StatusError struct

+ Code int

+ Err error

+ Message string

+ func NewStatusError(code int, message string) *StatusError

+ func (e *StatusError) Error() string

+ func (e *StatusError) HTTPStatus() int

+ func (e *StatusError) Unwrap() error

v0.27.1

May 18, 2026

v0.27.0

May 18, 2026

Changes in this version

+ func Bind(r *http.Request, dst any) error

+ func BindForm(r *http.Request, dst any) error

+ func BindJSON(r *http.Request, dst any) error

+ func BindQuery(r *http.Request, dst any) error

+ func Validate(dst any) error

+ type FieldError struct

+ Field string

+ Message string

+ Param string

+ Tag string

+ Value any

+ func (f *FieldError) Error() string

type ServerOptionFunc

+ func WithMCPToolCallTimeout(d time.Duration) ServerOptionFunc

type ServerOptions

+ MCPToolCallTimeout time.Duration

+ type ValidationError struct

+ Fields []*FieldError

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) HasField(field string) bool

v0.26.1

May 18, 2026

v0.26.0

May 18, 2026

v0.25.1

May 17, 2026

Changes in this version

+ func SetBuiltinPresetHooks(tools, standardResources, observability, developer func(*Server))

type Server

+ func (srv *Server) AddMetrics(deltaRequests uint64, deltaResponseTime int64)

+ func (srv *Server) ClientLimiterCount() int

+ func (srv *Server) IsReady() bool

+ func (srv *Server) IsRunning() bool

+ func (srv *Server) MCPHandler() *mcp.Handler

+ func (srv *Server) MiddlewareRoutes() map[string]MiddlewareStack

+ func (srv *Server) Mux() *http.ServeMux

+ func (srv *Server) ServerStart() time.Time

+ func (srv *Server) SetMetrics(totalRequests uint64, totalResponseTime int64)

+ func (srv *Server) TotalRequests() uint64

+ func (srv *Server) TotalResponseTime() int64

v0.24.0

Oct 19, 2025

Changes in this version

type Server

+ func (srv *Server) CompleteDeferredInit(ctx context.Context, err error) error

v0.23.0

Oct 19, 2025

Changes in this version

type ServerOptionFunc

+ func WithBannerColor(enabled bool) ServerOptionFunc

+ func WithDeferredInit(fn func(context.Context, *Server) error) ServerOptionFunc

+ func WithDeferredInitStopOnFailure(stop bool) ServerOptionFunc

+ func WithOnReady(hook func(context.Context, *Server) error) ServerOptionFunc

type ServerOptions

+ BannerColor bool

+ DeferredInit func(context.Context, *Server) error

+ OnReadyHooks []func(context.Context, *Server) error

+ StopOnDeferredInitFailure bool

v0.22.0

Sep 29, 2025

v0.21.0

Sep 29, 2025

Changes in this version

+ const BinaryMessage

+ const CloseAbnormalClosure

+ const CloseGoingAway

+ const CloseInternalServerError

+ const CloseInvalidFramePayloadData

+ const CloseMandatoryExtension

+ const CloseMessage

+ const CloseMessageTooBig

+ const CloseNoStatusReceived

+ const CloseNormalClosure

+ const ClosePolicyViolation

+ const CloseProtocolError

+ const CloseServiceRestart

+ const CloseTLSHandshake

+ const CloseTryAgainLater

+ const CloseUnsupportedData

+ const ErrorCodeInternalError

+ const ErrorCodeInvalidParams

+ const ErrorCodeInvalidRequest

+ const ErrorCodeMethodNotFound

+ const ErrorCodeParseError

+ const GlobalMiddlewareRoute

+ const JSONRPCVersion

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelWarn

+ const MCPVersion

+ const PingMessage

+ const PongMessage

+ const TextMessage

+ var BuildHash = "unknown"

+ var BuildTime = "unknown"

+ var ErrBadHandshake = pkgwebsocket.ErrBadHandshake

+ var ErrNotWebSocket = pkgwebsocket.ErrNotWebSocket

+ var Version = "dev"

+ func CheckOriginWithAllowedList(allowedOrigins []string) func(r *http.Request) bool

+ func DefaultCheckOrigin(r *http.Request) bool

+ func DefaultLogger() *slog.Logger

+ func EnsureTrailingSlash(dir string) string

+ func GetVersionInfo() string

+ func HealthCheckHandler(w http.ResponseWriter, r *http.Request)

+ func IsCloseError(err error, codes ...int) bool

+ func IsUnexpectedCloseError(err error, expectedCodes ...int) bool

+ func NewStdioTransport(logger *slog.Logger) *stdioTransport

+ func NewStdioTransportWithIO(r io.Reader, w io.Writer, logger *slog.Logger) *stdioTransport

+ func PanicHandler(w http.ResponseWriter, r *http.Request)

+ func RecoveryMiddleware(next http.Handler) http.HandlerFunc

+ func RequestLoggerMiddleware(next http.Handler) http.HandlerFunc

+ func ResponseTimeMiddleware(next http.Handler) http.HandlerFunc

+ func SetDefaultLogger(l *slog.Logger)

+ func TraceMiddleware(next http.Handler) http.HandlerFunc

+ type AuthTokenInjector struct

+ func NewAuthTokenInjector(provider func(context.Context) (string, error)) *AuthTokenInjector

+ func (ati *AuthTokenInjector) InterceptRequest(ctx context.Context, req *InterceptableRequest) (*InterceptorResponse, error)

+ func (ati *AuthTokenInjector) InterceptResponse(ctx context.Context, req *InterceptableRequest, resp *InterceptableResponse) error

+ func (ati *AuthTokenInjector) Name() string

+ type CORSOptions struct

+ AllowCredentials bool

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ ExposeHeaders []string

+ MaxAgeSeconds int

+ type CalculatorTool struct

+ func NewCalculatorTool() *CalculatorTool

+ func (t *CalculatorTool) Description() string

+ func (t *CalculatorTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *CalculatorTool) Name() string

+ func (t *CalculatorTool) Schema() map[string]interface{}

+ type CapturedRequest struct

+ Body string

+ Headers map[string][]string

+ ID string

+ Method string

+ Path string

+ Response *CapturedResponse

+ Timestamp time.Time

+ type CapturedResponse struct

+ Body string

+ Headers map[string][]string

+ Status int

+ type ConfigResource struct

+ func NewConfigResource(options *ServerOptions) *ConfigResource

+ func (r *ConfigResource) Description() string

+ func (r *ConfigResource) List() ([]string, error)

+ func (r *ConfigResource) MimeType() string

+ func (r *ConfigResource) Name() string

+ func (r *ConfigResource) Read() (interface{}, error)

+ func (r *ConfigResource) URI() string

+ type Conn = pkgwebsocket.Conn

+ type DataFunc func(r *http.Request) interface

+ type DevGuideTool struct

+ func (t *DevGuideTool) Description() string

+ func (t *DevGuideTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *DevGuideTool) Name() string

+ func (t *DevGuideTool) Schema() map[string]interface{}

+ type DiscoveryPolicy int

+ const DiscoveryAuthenticated

+ const DiscoveryCount

+ const DiscoveryNone

+ const DiscoveryPublic

+ type FileReadTool struct

+ func NewFileReadTool(rootDir string) (*FileReadTool, error)

+ func (t *FileReadTool) Description() string

+ func (t *FileReadTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *FileReadTool) Name() string

+ func (t *FileReadTool) Schema() map[string]interface{}

+ type HTTPRequestTool struct

+ func NewHTTPRequestTool() *HTTPRequestTool

+ func (t *HTTPRequestTool) Description() string

+ func (t *HTTPRequestTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *HTTPRequestTool) Name() string

+ func (t *HTTPRequestTool) Schema() map[string]interface{}

+ type Header struct

+ type InterceptableRequest struct

+ Metadata map[string]interface{}

+ func (ir *InterceptableRequest) GetBody() ([]byte, error)

+ func (ir *InterceptableRequest) SetBody(body []byte)

+ type InterceptableResponse struct

+ Body *bytes.Buffer

+ Headers http.Header

+ Metadata map[string]interface{}

+ StatusCode int

+ type Interceptor interface

+ InterceptRequest func(ctx context.Context, req *InterceptableRequest) (*InterceptorResponse, error)

+ InterceptResponse func(ctx context.Context, req *InterceptableRequest, resp *InterceptableResponse) error

+ Name func() string

+ type InterceptorChain struct

+ func NewInterceptorChain() *InterceptorChain

+ func (ic *InterceptorChain) Add(interceptor Interceptor)

+ func (ic *InterceptorChain) Remove(name string) bool

+ func (ic *InterceptorChain) WrapHandler(next http.Handler) http.Handler

+ type InterceptorResponse struct

+ Body []byte

+ Headers http.Header

+ StatusCode int

+ type JSONRPCEngine = pkgjsonrpc.Engine

+ func NewJSONRPCEngine() *JSONRPCEngine

+ type JSONRPCError = pkgjsonrpc.ErrorDetails

+ type JSONRPCMethodHandler = pkgjsonrpc.MethodHandler

+ type JSONRPCRequest = pkgjsonrpc.Request

+ type JSONRPCResponse = pkgjsonrpc.Response

+ type ListDirectoryTool struct

+ func NewListDirectoryTool(rootDir string) (*ListDirectoryTool, error)

+ func (t *ListDirectoryTool) Description() string

+ func (t *ListDirectoryTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *ListDirectoryTool) Name() string

+ func (t *ListDirectoryTool) Schema() map[string]interface{}

+ type LogResource struct

+ func NewLogResource(maxSize int) *LogResource

+ func (r *LogResource) AddLogEntry(entry string)

+ func (r *LogResource) Description() string

+ func (r *LogResource) List() ([]string, error)

+ func (r *LogResource) MimeType() string

+ func (r *LogResource) Name() string

+ func (r *LogResource) Read() (interface{}, error)

+ func (r *LogResource) URI() string

+ type LoggingCapability struct

+ type MCPCapabilities struct

+ Experimental map[string]interface{}

+ Logging *LoggingCapability

+ Prompts *PromptsCapability

+ Resources *ResourcesCapability

+ SSE *SSECapability

+ Sampling *SamplingCapability

+ Tools *ToolsCapability

+ type MCPClientInfo struct

+ Name string

+ Version string

+ type MCPDiscoveryInfo struct

+ Capabilities map[string]interface{}

+ Endpoints map[string]string

+ Transports []MCPTransportInfo

+ Version string

+ type MCPExtension interface

+ Configure func(srv *Server) error

+ Description func() string

+ Name func() string

+ Resources func() []MCPResource

+ Tools func() []MCPTool

+ func ExampleECommerceExtension() MCPExtension

+ type MCPExtensionBuilder struct

+ func NewMCPExtension(name string) *MCPExtensionBuilder

+ func (b *MCPExtensionBuilder) Build() MCPExtension

+ func (b *MCPExtensionBuilder) WithConfiguration(fn func(*Server) error) *MCPExtensionBuilder

+ func (b *MCPExtensionBuilder) WithDescription(desc string) *MCPExtensionBuilder

+ func (b *MCPExtensionBuilder) WithResource(resource MCPResource) *MCPExtensionBuilder

+ func (b *MCPExtensionBuilder) WithTool(tool MCPTool) *MCPExtensionBuilder

+ type MCPHandler struct

+ func NewMCPHandler(serverInfo MCPServerInfo) *MCPHandler

+ func (h *MCPHandler) GetMetrics() map[string]interface{}

+ func (h *MCPHandler) GetRegisteredResources() []string

+ func (h *MCPHandler) GetRegisteredTools() []string

+ func (h *MCPHandler) GetToolByName(name string) (MCPTool, bool)

+ func (h *MCPHandler) ProcessRequest(requestData []byte) []byte

+ func (h *MCPHandler) ProcessRequestWithTransport(transport MCPTransport) error

+ func (h *MCPHandler) RegisterNamespace(name string, configs ...MCPNamespaceConfig) error

+ func (h *MCPHandler) RegisterResource(resource MCPResource)

+ func (h *MCPHandler) RegisterResourceInNamespace(resource MCPResource, namespace string)

+ func (h *MCPHandler) RegisterSSEClient(clientID string) chan *JSONRPCRequest

+ func (h *MCPHandler) RegisterTool(tool MCPTool)

+ func (h *MCPHandler) RegisterToolInNamespace(tool MCPTool, namespace string)

+ func (h *MCPHandler) RunStdioLoop() error

+ func (h *MCPHandler) SendSSENotification(clientID string, method string, params interface{}) error

+ func (h *MCPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *MCPHandler) UnregisterSSEClient(clientID string)

+ type MCPInitializeParams struct

+ Capabilities interface{}

+ ClientInfo MCPClientInfo

+ ProtocolVersion string

+ type MCPInitializeResult struct

+ Capabilities MCPCapabilities

+ ProtocolVersion string

+ ServerInfo MCPServerInfo

+ type MCPMetrics struct

+ func (m *MCPMetrics) GetMetricsSummary() map[string]interface{}

+ type MCPNamespace struct

+ Name string

+ Resources []MCPResource

+ Tools []MCPTool

+ type MCPNamespaceConfig func(*MCPNamespace)

+ func WithNamespaceResources(resources ...MCPResource) MCPNamespaceConfig

+ func WithNamespaceTools(tools ...MCPTool) MCPNamespaceConfig

+ type MCPResource interface

+ Description func() string

+ List func() ([]string, error)

+ MimeType func() string

+ Name func() string

+ Read func() (interface{}, error)

+ URI func() string

+ type MCPResourceContent struct

+ MimeType string

+ Text interface{}

+ URI string

+ type MCPResourceInfo struct

+ Description string

+ MimeType string

+ Name string

+ URI string

+ type MCPResourceReadParams struct

+ URI string

+ type MCPServerInfo struct

+ Name string

+ Version string

+ type MCPTool interface

+ Description func() string

+ Execute func(params map[string]interface{}) (interface{}, error)

+ Name func() string

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

+ type MCPToolCallParams struct

+ Arguments map[string]interface{}

+ Name string

+ type MCPToolInfo struct

+ Description string

+ InputSchema map[string]interface{}

+ Name string

+ type MCPToolResult struct

+ Content []map[string]interface{}

+ type MCPToolWithContext interface

+ ExecuteWithContext func(ctx context.Context, params map[string]interface{}) (interface{}, error)

+ type MCPTransport interface

+ Close func() error

+ Receive func() (*JSONRPCRequest, error)

+ Send func(response *JSONRPCResponse) error

+ type MCPTransportConfig func(*mcpTransportOptions)

+ func MCPDev() MCPTransportConfig

+ func MCPObservability() MCPTransportConfig

+ func MCPOverHTTP(endpoint string) MCPTransportConfig

+ func MCPOverSSE(endpoint string) MCPTransportConfig

+ func MCPOverStdio() MCPTransportConfig

+ type MCPTransportInfo struct

+ Description string

+ Endpoint string

+ Headers map[string]string

+ Type string

+ type MCPTransportType int

+ const HTTPTransport

+ const StdioTransport

+ type MetricsResource struct

+ func NewMetricsResource(server *Server) *MetricsResource

+ func (r *MetricsResource) Description() string

+ func (r *MetricsResource) List() ([]string, error)

+ func (r *MetricsResource) MimeType() string

+ func (r *MetricsResource) Name() string

+ func (r *MetricsResource) Read() (interface{}, error)

+ func (r *MetricsResource) URI() string

+ type MiddlewareFunc func(http.Handler) http.HandlerFunc

+ func AuthMiddleware(options *ServerOptions) MiddlewareFunc

+ func ChaosMiddleware(options *ServerOptions) MiddlewareFunc

+ func HeadersMiddleware(options *ServerOptions) MiddlewareFunc

+ func MetricsMiddleware(srv *Server) MiddlewareFunc

+ func RateLimitMiddleware(srv *Server) MiddlewareFunc

+ func RequestCaptureMiddleware(debuggerTool *RequestDebuggerTool) MiddlewareFunc

+ type MiddlewareRegistry struct

+ func NewMiddlewareRegistry(globalMiddleware MiddlewareStack) *MiddlewareRegistry

+ func (mwr *MiddlewareRegistry) Add(route string, middleware MiddlewareStack)

+ func (mwr *MiddlewareRegistry) Get(route string) MiddlewareStack

+ func (mwr *MiddlewareRegistry) RemoveStack(route string)

+ type MiddlewareStack []MiddlewareFunc

+ func DefaultMiddleware(server *Server) MiddlewareStack

+ func FileServer(options *ServerOptions) MiddlewareStack

+ func SecureAPI(srv *Server) MiddlewareStack

+ func SecureWeb(options *ServerOptions) MiddlewareStack

+ type PromptsCapability struct

+ type RateLimit = rate.Limit

+ type RateLimitInterceptor struct

+ func NewRateLimitInterceptor(limiter RateLimiter) *RateLimitInterceptor

+ func (rli *RateLimitInterceptor) InterceptRequest(ctx context.Context, req *InterceptableRequest) (*InterceptorResponse, error)

+ func (rli *RateLimitInterceptor) InterceptResponse(ctx context.Context, req *InterceptableRequest, resp *InterceptableResponse) error

+ func (rli *RateLimitInterceptor) Name() string

+ type RateLimiter interface

+ Allow func(key string) bool

+ type RequestDebuggerTool struct

+ func (t *RequestDebuggerTool) CaptureRequest(r *http.Request, responseHeaders map[string][]string, statusCode int, ...)

+ func (t *RequestDebuggerTool) Description() string

+ func (t *RequestDebuggerTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *RequestDebuggerTool) Name() string

+ func (t *RequestDebuggerTool) Schema() map[string]interface{}

+ type RequestLogger struct

+ func NewRequestLogger(logger func(format string, args ...interface{})) *RequestLogger

+ func (rl *RequestLogger) InterceptRequest(ctx context.Context, req *InterceptableRequest) (*InterceptorResponse, error)

+ func (rl *RequestLogger) InterceptResponse(ctx context.Context, req *InterceptableRequest, resp *InterceptableResponse) error

+ func (rl *RequestLogger) Name() string

+ type ResourceBuilder struct

+ func NewResource(uri string) *ResourceBuilder

+ func (b *ResourceBuilder) Build() MCPResource

+ func (b *ResourceBuilder) WithDescription(desc string) *ResourceBuilder

+ func (b *ResourceBuilder) WithMimeType(mimeType string) *ResourceBuilder

+ func (b *ResourceBuilder) WithName(name string) *ResourceBuilder

+ func (b *ResourceBuilder) WithRead(fn func() (interface{}, error)) *ResourceBuilder

+ type ResourcesCapability struct

+ ListChanged bool

+ Subscribe bool

+ type ResponseTransformer struct

+ func NewResponseTransformer(transformer func([]byte, string) ([]byte, error)) *ResponseTransformer

+ func (rt *ResponseTransformer) InterceptRequest(ctx context.Context, req *InterceptableRequest) (*InterceptorResponse, error)

+ func (rt *ResponseTransformer) InterceptResponse(ctx context.Context, req *InterceptableRequest, resp *InterceptableResponse) error

+ func (rt *ResponseTransformer) Name() string

+ type RouteInspectorTool struct

+ func (t *RouteInspectorTool) Description() string

+ func (t *RouteInspectorTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *RouteInspectorTool) Name() string

+ func (t *RouteInspectorTool) Schema() map[string]interface{}

+ type RouteListResource struct

+ func (r *RouteListResource) Description() string

+ func (r *RouteListResource) List() ([]string, error)

+ func (r *RouteListResource) MimeType() string

+ func (r *RouteListResource) Name() string

+ func (r *RouteListResource) Read() (interface{}, error)

+ func (r *RouteListResource) URI() string

+ type SSECapability struct

+ Enabled bool

+ Endpoint string

+ HeaderRouting bool

+ type SSEClient struct

+ func (c *SSEClient) Close()

+ func (c *SSEClient) IsReady() bool

+ func (c *SSEClient) Send(response *JSONRPCResponse) (err error)

+ func (c *SSEClient) SetInitialized()

+ func (c *SSEClient) SetReady()

+ type SSEManager struct

+ func NewSSEManager() *SSEManager

+ func (m *SSEManager) BroadcastToAll(response *JSONRPCResponse)

+ func (m *SSEManager) GetClientCount() int

+ func (m *SSEManager) HandleSSE(w http.ResponseWriter, r *http.Request, mcpHandler *MCPHandler)

+ func (m *SSEManager) SendToClient(clientID string, response *JSONRPCResponse) error

+ type SSEMessage struct

+ Data any

+ Event string

+ func NewSSEMessage(data any) *SSEMessage

+ func (sse *SSEMessage) String() string

+ type SamplingCapability struct

+ type Server struct

+ Options *ServerOptions

+ func NewServer(opts ...ServerOptionFunc) (*Server, error)

+ func (srv *Server) AddMiddleware(route string, mw MiddlewareFunc)

+ func (srv *Server) AddMiddlewareStack(route string, mw MiddlewareStack)

+ func (srv *Server) Handle(pattern string, handlerFunc http.HandlerFunc)

+ func (srv *Server) HandleFunc(pattern string, handler http.HandlerFunc)

+ func (srv *Server) HandleFuncDynamic(pattern, tmplName string, dataFunc DataFunc) error

+ func (srv *Server) HandleStatic(pattern string)

+ func (srv *Server) HandleTemplate(pattern, t string, data interface{}) error

+ func (srv *Server) Handler() http.Handler

+ func (srv *Server) MCPEnabled() bool

+ func (srv *Server) RegisterDeveloperMCPTools()

+ func (srv *Server) RegisterMCPExtension(ext MCPExtension) error

+ func (srv *Server) RegisterMCPNamespace(name string, configs ...MCPNamespaceConfig) error

+ func (srv *Server) RegisterMCPResource(resource MCPResource) error

+ func (srv *Server) RegisterMCPResourceInNamespace(resource MCPResource, namespace string) error

+ func (srv *Server) RegisterMCPTool(tool MCPTool) error

+ func (srv *Server) RegisterMCPToolInNamespace(tool MCPTool, namespace string) error

+ func (srv *Server) RegisterObservabilityMCPResources()

+ func (srv *Server) Run() error

+ func (srv *Server) Stop() error

+ func (srv *Server) WebSocketUpgrader() *Upgrader

+ func (srv *Server) WithOutStack(stack MiddlewareStack) error

+ type ServerConfigResource struct

+ func NewServerConfigResource(srv *Server) *ServerConfigResource

+ func (r *ServerConfigResource) Description() string

+ func (r *ServerConfigResource) List() ([]string, error)

+ func (r *ServerConfigResource) MimeType() string

+ func (r *ServerConfigResource) Name() string

+ func (r *ServerConfigResource) Read() (interface{}, error)

+ func (r *ServerConfigResource) URI() string

+ type ServerControlTool struct

+ func (t *ServerControlTool) Description() string

+ func (t *ServerControlTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *ServerControlTool) Name() string

+ func (t *ServerControlTool) Schema() map[string]interface{}

+ type ServerHealthResource struct

+ func NewServerHealthResource(srv *Server) *ServerHealthResource

+ func (r *ServerHealthResource) Description() string

+ func (r *ServerHealthResource) List() ([]string, error)

+ func (r *ServerHealthResource) MimeType() string

+ func (r *ServerHealthResource) Name() string

+ func (r *ServerHealthResource) Read() (interface{}, error)

+ func (r *ServerHealthResource) URI() string

+ type ServerLogResource struct

+ func NewServerLogResource(maxSize int) *ServerLogResource

+ func (r *ServerLogResource) Description() string

+ func (r *ServerLogResource) Enabled(ctx context.Context, level slog.Level) bool

+ func (r *ServerLogResource) Handle(ctx context.Context, record slog.Record) error

+ func (r *ServerLogResource) List() ([]string, error)

+ func (r *ServerLogResource) MimeType() string

+ func (r *ServerLogResource) Name() string

+ func (r *ServerLogResource) Read() (interface{}, error)

+ func (r *ServerLogResource) URI() string

+ func (r *ServerLogResource) WithAttrs(attrs []slog.Attr) slog.Handler

+ func (r *ServerLogResource) WithGroup(name string) slog.Handler

+ type ServerOptionFunc func(srv *Server) error

+ func WithAddr(addr string) ServerOptionFunc

+ func WithAuthTokenValidator(validator func(token string) (bool, error)) ServerOptionFunc

+ func WithCORS(opts *CORSOptions) ServerOptionFunc

+ func WithCSPWebWorkerSupport() ServerOptionFunc

+ func WithDebugMode() ServerOptionFunc

+ func WithEncryptedClientHello(echKeys ...[]byte) ServerOptionFunc

+ func WithFIPSMode() ServerOptionFunc

+ func WithHardenedMode() ServerOptionFunc

+ func WithHealthServer() ServerOptionFunc

+ func WithIdleTimeout(timeout time.Duration) ServerOptionFunc

+ func WithLogger(l *slog.Logger) ServerOptionFunc

+ func WithLoglevel(level slog.Level) ServerOptionFunc

+ func WithMCPBuiltinResources(enabled bool) ServerOptionFunc

+ func WithMCPBuiltinTools(enabled bool) ServerOptionFunc

+ func WithMCPDiscoveryFilter(filter func(toolName string, r *http.Request) bool) ServerOptionFunc

+ func WithMCPDiscoveryPolicy(policy DiscoveryPolicy) ServerOptionFunc

+ func WithMCPEndpoint(endpoint string) ServerOptionFunc

+ func WithMCPFileToolRoot(rootDir string) ServerOptionFunc

+ func WithMCPNamespace(name string, configs ...MCPNamespaceConfig) ServerOptionFunc

+ func WithMCPResourcesDisabled() ServerOptionFunc

+ func WithMCPServerInfo(name, version string) ServerOptionFunc

+ func WithMCPSupport(name, version string, configs ...MCPTransportConfig) ServerOptionFunc

+ func WithMCPToolsDisabled() ServerOptionFunc

+ func WithOnShutdown(hook func(context.Context) error) ServerOptionFunc

+ func WithRateLimit(limit RateLimit, burst int) ServerOptionFunc

+ func WithReadHeaderTimeout(timeout time.Duration) ServerOptionFunc

+ func WithReadTimeout(timeout time.Duration) ServerOptionFunc

+ func WithSuppressBanner(suppress bool) ServerOptionFunc

+ func WithTLS(certFile, keyFile string) ServerOptionFunc

+ func WithTemplateDir(dir string) ServerOptionFunc

+ func WithTimeouts(readTimeout, writeTimeout, idleTimeout time.Duration) ServerOptionFunc

+ func WithWriteTimeout(timeout time.Duration) ServerOptionFunc

+ type ServerOptions struct

+ Addr string

+ AuthTokenValidatorFunc func(token string) (bool, error)

+ Burst int

+ CORS *CORSOptions

+ CSPWebWorkerSupport bool

+ CertFile string

+ ChaosErrorRate float64

+ ChaosMaxLatency time.Duration

+ ChaosMinLatency time.Duration

+ ChaosMode bool

+ ChaosPanicRate float64

+ ChaosThrottleRate float64

+ DebugMode bool

+ ECHKeys [][]byte

+ EnableECH bool

+ EnableTLS bool

+ FIPSMode bool

+ HardenedMode bool

+ HealthAddr string

+ IdleTimeout time.Duration

+ KeyFile string

+ LogLevel string

+ MCPDev bool

+ MCPDiscoveryFilter func(toolName string, r *http.Request) bool

+ MCPDiscoveryPolicy DiscoveryPolicy

+ MCPEnabled bool

+ MCPEndpoint string

+ MCPFileToolRoot string

+ MCPLogResourceSize int

+ MCPObservability bool

+ MCPResourcesEnabled bool

+ MCPServerName string

+ MCPServerVersion string

+ MCPToolsEnabled bool

+ MCPTransport MCPTransportType

+ OnShutdownHooks []func(context.Context) error

+ RateLimit RateLimit

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ RunHealthServer bool

+ StaticDir string

+ SuppressBanner bool

+ TLSAddr string

+ TLSHealthAddr string

+ TemplateDir string

+ WriteTimeout time.Duration

+ func NewServerOptions() *ServerOptions

+ type SimpleResource struct

+ DescriptionFunc func() string

+ ListFunc func() ([]string, error)

+ MimeTypeFunc func() string

+ NameFunc func() string

+ ReadFunc func() (interface{}, error)

+ URIFunc func() string

+ func (r *SimpleResource) Description() string

+ func (r *SimpleResource) List() ([]string, error)

+ func (r *SimpleResource) MimeType() string

+ func (r *SimpleResource) Name() string

+ func (r *SimpleResource) Read() (interface{}, error)

+ func (r *SimpleResource) URI() string

+ type SimpleTool struct

+ DescriptionFunc func() string

+ ExecuteFunc func(map[string]interface{}) (interface{}, error)

+ NameFunc func() string

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

+ func (t *SimpleTool) Description() string

+ func (t *SimpleTool) Execute(params map[string]interface{}) (interface{}, error)

+ func (t *SimpleTool) Name() string

+ func (t *SimpleTool) Schema() map[string]interface{}

+ type StreamingLogResource struct

+ func (r *StreamingLogResource) Description() string

+ func (r *StreamingLogResource) Name() string

+ func (r *StreamingLogResource) URI() string

+ type SystemResource struct

+ func NewSystemResource() *SystemResource

+ func (r *SystemResource) Description() string

+ func (r *SystemResource) List() ([]string, error)

+ func (r *SystemResource) MimeType() string

+ func (r *SystemResource) Name() string

+ func (r *SystemResource) Read() (interface{}, error)

+ func (r *SystemResource) URI() string

+ type ToolBuilder struct

+ func NewTool(name string) *ToolBuilder

+ func (b *ToolBuilder) Build() MCPTool

+ func (b *ToolBuilder) WithDescription(desc string) *ToolBuilder

+ func (b *ToolBuilder) WithExecute(fn func(map[string]interface{}) (interface{}, error)) *ToolBuilder

+ func (b *ToolBuilder) WithParameter(name, paramType, description string, required bool) *ToolBuilder

+ type ToolsCapability struct

+ ListChanged bool

+ type Upgrader = pkgwebsocket.Upgrader

Other modules containing this package

github.com/osauer/hyperserve/v2

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