mcp

May 6, 2026

Changes in this version

+ func NewPlugin() plugin.Plugin

May 1, 2026

Changes in this version

+ const CodeConnectionTimeout

+ const CodeForbidden

+ const CodeInternalError

+ const CodeInvalidParams

+ const CodeInvalidRequest

+ const CodeMaxConnectionsExceeded

+ const CodeMethodNotFound

+ const CodeOperationDisabled

+ const CodeParseError

+ const CodeRateLimitExceeded

+ const CodeResourceNotFound

+ const CodeUnauthorized

+ const Version

+ const VersionMajor

+ const VersionMinor

+ const VersionPatch

+ var ErrConnectionTimeout = errors.New("connection timeout")

+ var ErrForbidden = errors.New("forbidden: insufficient permissions")

+ var ErrInvalidRequest = errors.New("invalid request")

+ var ErrMaxConnectionsExceeded = errors.New("maximum connections exceeded")

+ var ErrOperationDisabled = errors.New("operation disabled")

+ var ErrRateLimitExceeded = errors.New("rate limit exceeded")

+ var ErrResourceNotFound = errors.New("resource not found")

+ var ErrUnauthorized = errors.New("unauthorized: invalid or missing JWT token")

+ func Contains(slice []string, value string) bool

+ func FromJSON(data string, v interface{}) error

+ func GetUserEmailFromContext(ctx context.Context) (string, error)

+ func GetUserIDFromContext(ctx context.Context) (string, error)

+ func GetUserRolesFromContext(ctx context.Context) ([]string, error)

+ func GetVersion() string

+ func HandleSSE(c *fiber.Ctx, mcpServer *MCPServer, config *Config, log *slog.Logger) error

+ func Ptr[T any](v T) *T

+ func ToJSON(v interface{}) (string, error)

+ type Config struct

+ Enabled bool

+ EnabledOperations []string

+ LogLevel string

+ LogRequests bool

+ RateLimit RateLimitConfig

+ SSE SSEConfig

+ func DefaultConfig() *Config

+ func ParseConfig(cfg interface{}) (*Config, error)

+ func (c *Config) GetConnectionTimeout() time.Duration

+ func (c *Config) GetHeartbeatInterval() time.Duration

+ func (c *Config) IsOperationEnabled(operation string) bool

+ func (c *Config) Validate() error

+ type ConnectionPool struct

+ func (cp *ConnectionPool) AddConnection(userID string) error

+ func (cp *ConnectionPool) RemoveConnection(userID string)

+ type ContextKey string

+ const ContextKeyUserEmail

+ const ContextKeyUserID

+ const ContextKeyUserRoles

+ type MCPError struct

+ Code int

+ Data any

+ Err error

+ Message string

+ func NewMCPError(code int, message string, err error) *MCPError

+ func WrapError(err error) *MCPError

+ func (e *MCPError) Error() string

+ func (e *MCPError) Unwrap() error

+ type MCPServer struct

+ func NewMCPServer(config *Config, db database.Database, log *slog.Logger) (*MCPServer, error)

+ func (s *MCPServer) GetServer() *server.MCPServer

+ func (s *MCPServer) HandleRequest(ctx context.Context, request interface{}) (interface{}, error)

+ type Plugin struct

+ func (p *Plugin) Handler() fiber.Handler

+ func (p *Plugin) Initialize(cfg map[string]any) error

+ func (p *Plugin) Name() string

+ func (p *Plugin) SetupEndpoints(router fiber.Router) error

+ type RateLimitConfig struct

+ Burst int

+ Enabled bool

+ RequestsPerMinute int

+ type SSEConfig struct

+ ConnectionTimeout int

+ HeartbeatInterval int

+ MaxConnectionsPerUser int