hyperserve

Sep 29, 2025

Changes in this version

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

+ func DefaultCheckOrigin(r *http.Request) bool

+ func DefaultLogger() *slog.Logger

+ func SetDefaultLogger(l *slog.Logger)

type JSONRPCEngine

+ func NewJSONRPCEngineWithLogger(log *slog.Logger) *JSONRPCEngine

+ type RateLimit = pkgserver.RateLimit

type Upgrader

+ func WebSocketUpgrader(srv *Server) *Upgrader

Sep 27, 2025

Changes in this version

+ 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 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 PoolConfig struct

+ ConnectionTimeout time.Duration

+ EnableCompression bool

+ HealthCheckInterval time.Duration

+ IdleTimeout time.Duration

+ MaxConnectionsPerEndpoint int

+ MaxIdleConnections int

+ OnConnectionClosed func(endpoint string, conn *Conn, reason error)

+ OnConnectionCreated func(endpoint string, conn *Conn)

+ func DefaultPoolConfig() PoolConfig

+ type PoolStats struct

+ ActiveConnections atomic.Int64

+ ConnectionsCreated atomic.Int64

+ ConnectionsReused atomic.Int64

+ FailedConnections atomic.Int64

+ HealthChecksFailed atomic.Int64

+ IdleConnections atomic.Int64

+ TotalConnections atomic.Int64

+ 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 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 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 ServerOptionFunc

+ func WithCORS(opts *CORSOptions) ServerOptionFunc

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

+ func WithSuppressBanner(suppress bool) ServerOptionFunc

type ServerOptions

+ CORS *CORSOptions

+ OnShutdownHooks []func(context.Context) error

+ SuppressBanner bool

+ type WebSocketPool struct

+ func NewWebSocketPool(config PoolConfig) *WebSocketPool

+ func (p *WebSocketPool) Close(conn *Conn, reason error) error

+ func (p *WebSocketPool) Get(ctx context.Context, endpoint string, upgrader *Upgrader, ...) (*Conn, error)

+ func (p *WebSocketPool) GetStats() PoolStats

+ func (p *WebSocketPool) Put(conn *Conn) error

+ func (p *WebSocketPool) Shutdown(ctx context.Context) error

Jul 20, 2025

Changes in this version

+ type DiscoveryPolicy int

+ const DiscoveryAuthenticated

+ const DiscoveryCount

+ const DiscoveryNone

+ const DiscoveryPublic

type MCPHandler

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

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

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

type ServerOptionFunc

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

+ func WithMCPDiscoveryPolicy(policy DiscoveryPolicy) ServerOptionFunc

type ServerOptions

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

+ MCPDiscoveryPolicy DiscoveryPolicy

Jul 20, 2025

Changes in this version

+ type MCPDiscoveryInfo struct

+ Capabilities map[string]interface{}

+ Endpoints map[string]string

+ Transports []MCPTransportInfo

+ Version string

+ type MCPTransportInfo struct

+ Description string

+ Endpoint string

+ Headers map[string]string

+ Type string

Jul 20, 2025

Changes in this version

type MCPCapabilities

+ SSE *SSECapability

+ type SSECapability struct

+ Enabled bool

+ Endpoint string

+ HeaderRouting bool

Jul 19, 2025

Changes in this version

type MCPHandler

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

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

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

+ type MCPNamespace struct

+ Name string

+ Resources []MCPResource

+ Tools []MCPTool

+ type MCPNamespaceConfig func(*MCPNamespace)

+ func WithNamespaceResources(resources ...MCPResource) MCPNamespaceConfig

+ func WithNamespaceTools(tools ...MCPTool) MCPNamespaceConfig

type Server

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

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

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

type ServerOptionFunc

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

Jul 14, 2025

Changes in this version

type MCPHandler

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

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

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

type MCPTransportConfig

+ func MCPOverSSE(endpoint string) MCPTransportConfig

+ 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

Jul 13, 2025

Changes in this version

type MiddlewareFunc

+ func RequestCaptureMiddleware(debuggerTool *RequestDebuggerTool) MiddlewareFunc

type RequestDebuggerTool

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

Jul 13, 2025

Changes in this version

type MiddlewareStack

+ func SecureWebWithRateLimit(srv *Server) MiddlewareStack

type Server

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

Jul 13, 2025

Changes in this version

type ServerOptionFunc

+ func WithIdleTimeout(timeout time.Duration) ServerOptionFunc

+ func WithReadHeaderTimeout(timeout time.Duration) ServerOptionFunc

+ func WithReadTimeout(timeout time.Duration) ServerOptionFunc

+ func WithWriteTimeout(timeout time.Duration) ServerOptionFunc

type ServerOptions

+ ReadHeaderTimeout time.Duration

Jul 13, 2025

Changes in this version

+ 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{}

Jul 13, 2025

Changes in this version

type ServerOptions

+ MCPDev bool

+ MCPObservability bool

Jul 13, 2025

Changes in this version

+ 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 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 MCPTransportConfig

+ func MCPDev() MCPTransportConfig

+ func MCPObservability() MCPTransportConfig

+ type RequestDebuggerTool struct

+ 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 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 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 Server

+ func (srv *Server) RegisterDeveloperMCPTools()

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

+ func (srv *Server) RegisterObservabilityMCPResources()

+ 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 WithDebugMode() ServerOptionFunc

type ServerOptions

+ DebugMode bool

+ LogLevel string

+ 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 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

Jul 12, 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 PingMessage

+ const PongMessage

+ const TextMessage

+ var ErrBadHandshake = ws.ErrBadHandshake

+ var ErrNotWebSocket = ws.ErrNotWebSocket

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

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

+ type Conn struct

+ func (c *Conn) Close() error

+ func (c *Conn) CloseHandler() func(code int, text string) error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) PingHandler() func(appData string) error

+ func (c *Conn) PongHandler() func(appData string) error

+ func (c *Conn) ReadJSON(v interface{}) error

+ func (c *Conn) ReadMessage() (messageType int, p []byte, err error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetCloseHandler(h func(code int, text string) error)

+ func (c *Conn) SetPingHandler(h func(appData string) error)

+ func (c *Conn) SetPongHandler(h func(appData string) error)

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) WriteControl(messageType int, data []byte, deadline time.Time) error

+ func (c *Conn) WriteJSON(v interface{}) error

+ func (c *Conn) WriteMessage(messageType int, data []byte) error

+ type Upgrader struct

+ AllowedOrigins []string

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

+ CheckOrigin func(r *http.Request) bool

+ EnableCompression bool

+ Error func(w http.ResponseWriter, r *http.Request, status int, reason error)

+ HandshakeTimeout time.Duration

+ MaxMessageSize int64

+ ReadBufferSize int

+ RequireProtocol bool

+ Subprotocols []string

+ WriteBufferSize int

+ func (u *Upgrader) Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (*Conn, error)

Jul 12, 2025

Changes in this version

+ var BuildHash = "unknown"

+ var BuildTime = "unknown"

+ func GetVersionInfo() string

type ServerOptionFunc

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

Jul 12, 2025

Changes in this version

type ServerOptionFunc

+ func WithCSPWebWorkerSupport() ServerOptionFunc

type ServerOptions

+ CSPWebWorkerSupport bool

Jul 11, 2025

Changes in this version

+ const Version

Jul 11, 2025

Changes in this version

type ServerOptionFunc

+ func WithMCPBuiltinResources(enabled bool) ServerOptionFunc

+ func WithMCPBuiltinTools(enabled bool) ServerOptionFunc

Jul 11, 2025

Changes in this version

type MCPHandler

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

+ type MCPMetrics struct

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

+ type MCPResourceWithCache struct

+ func EnableResourceCaching(resource MCPResource, ttl time.Duration, cacheSize int) *MCPResourceWithCache

+ func (r *MCPResourceWithCache) ClearCache()

+ func (r *MCPResourceWithCache) Description() string

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

+ func (r *MCPResourceWithCache) MimeType() string

+ func (r *MCPResourceWithCache) Name() string

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

+ func (r *MCPResourceWithCache) URI() string

+ type MCPToolWithContext interface

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

Jul 10, 2025

Changes in this version

+ const ErrorCodeInternalError

+ const ErrorCodeInvalidParams

+ const ErrorCodeInvalidRequest

+ const ErrorCodeMethodNotFound

+ const ErrorCodeParseError

+ const GlobalMiddlewareRoute

+ const JSONRPCVersion

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelWarn

+ const MCPVersion

+ func EnsureTrailingSlash(dir string) string

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

+ 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 TraceMiddleware(next http.Handler) http.HandlerFunc

+ 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 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 DataFunc func(r *http.Request) interface

+ 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 JSONRPCEngine struct

+ func NewJSONRPCEngine() *JSONRPCEngine

+ func (engine *JSONRPCEngine) GetRegisteredMethods() []string

+ func (engine *JSONRPCEngine) ProcessRequest(requestData []byte) []byte

+ func (engine *JSONRPCEngine) ProcessRequestDirect(request *JSONRPCRequest) *JSONRPCResponse

+ func (engine *JSONRPCEngine) RegisterMethod(name string, handler JSONRPCMethodHandler)

+ type JSONRPCError struct

+ Code int

+ Data interface{}

+ Message string

+ type JSONRPCMethodHandler func(params interface{}) (interface{}, error)

+ type JSONRPCRequest struct

+ ID interface{}

+ JSONRPC string

+ Method string

+ Params interface{}

+ type JSONRPCResponse struct

+ Error *JSONRPCError

+ ID interface{}

+ JSONRPC string

+ Result interface{}

+ 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

+ Sampling *SamplingCapability

+ Tools *ToolsCapability

+ type MCPClientInfo struct

+ Name string

+ Version string

+ type MCPHandler struct

+ func NewMCPHandler(serverInfo MCPServerInfo) *MCPHandler

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

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

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

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

+ func (h *MCPHandler) RunStdioLoop() error

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

+ type MCPInitializeParams struct

+ Capabilities interface{}

+ ClientInfo MCPClientInfo

+ ProtocolVersion string

+ type MCPInitializeResult struct

+ Capabilities MCPCapabilities

+ ProtocolVersion string

+ ServerInfo MCPServerInfo

+ 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 MCPTransport interface

+ Close func() error

+ Receive func() (*JSONRPCRequest, error)

+ Send func(response *JSONRPCResponse) error

+ type MCPTransportConfig func(*mcpTransportOptions)

+ func MCPOverHTTP(endpoint string) MCPTransportConfig

+ func MCPOverStdio() MCPTransportConfig

+ 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

+ 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 ResourcesCapability struct

+ ListChanged bool

+ Subscribe bool

+ 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) MCPEnabled() bool

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

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

+ func (srv *Server) Run() error

+ func (srv *Server) Stop() error

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

+ type ServerOptionFunc func(srv *Server) error

+ func WithAddr(addr string) ServerOptionFunc

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

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

+ func WithFIPSMode() ServerOptionFunc

+ func WithHardenedMode() ServerOptionFunc

+ func WithHealthServer() ServerOptionFunc

+ func WithLogger(l *slog.Logger) ServerOptionFunc

+ func WithLoglevel(level slog.Level) ServerOptionFunc

+ func WithMCPEndpoint(endpoint string) ServerOptionFunc

+ func WithMCPFileToolRoot(rootDir string) ServerOptionFunc

+ func WithMCPResourcesDisabled() ServerOptionFunc

+ func WithMCPServerInfo(name, version string) ServerOptionFunc

+ func WithMCPSupport(configs ...MCPTransportConfig) ServerOptionFunc

+ func WithMCPToolsDisabled() ServerOptionFunc

+ func WithRateLimit(limit rateLimit, burst int) ServerOptionFunc

+ func WithTLS(certFile, keyFile string) ServerOptionFunc

+ func WithTemplateDir(dir string) ServerOptionFunc

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

+ type ServerOptions struct

+ Addr string

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

+ Burst int

+ CertFile string

+ ChaosErrorRate float64

+ ChaosMaxLatency time.Duration

+ ChaosMinLatency time.Duration

+ ChaosMode bool

+ ChaosPanicRate float64

+ ChaosThrottleRate float64

+ ECHKeys [][]byte

+ EnableECH bool

+ EnableTLS bool

+ FIPSMode bool

+ HardenedMode bool

+ HealthAddr string

+ IdleTimeout time.Duration

+ KeyFile string

+ MCPEnabled bool

+ MCPEndpoint string

+ MCPFileToolRoot string

+ MCPLogResourceSize int

+ MCPResourcesEnabled bool

+ MCPServerName string

+ MCPServerVersion string

+ MCPToolsEnabled bool

+ MCPTransport MCPTransportType

+ RateLimit rateLimit

+ ReadTimeout time.Duration

+ RunHealthServer bool

+ StaticDir string

+ TLSAddr string

+ TLSHealthAddr string

+ TemplateDir string

+ WriteTimeout time.Duration

+ func NewServerOptions() *ServerOptions

+ 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 ToolsCapability struct

+ ListChanged bool