server

Nov 30, 2025

Changes in this version

+ const OAuthProviderDex

+ const OAuthProviderGoogle

type OAuthConfig

+ DexClientID string

+ DexClientSecret string

+ DexConnectorID string

+ DexIssuerURL string

+ Provider string

Nov 30, 2025

Changes in this version

+ const DefaultIPBurst

+ const DefaultIPRateLimit

+ const DefaultIdleTimeout

+ const DefaultMaxClientsPerIP

+ const DefaultOAuthScopes

+ const DefaultReadHeaderTimeout

+ const DefaultRefreshTokenTTL

+ const DefaultShutdownTimeout

+ const DefaultUserBurst

+ const DefaultUserRateLimit

+ const DefaultWriteTimeout

+ func CreateOAuthServer(config OAuthConfig) (*oauth.Server, storage.TokenStore, error)

+ type Metrics struct

+ BearerClientFailures int64

+ PerUserAuthFallback int64

+ PerUserAuthSuccess int64

+ func NewMetrics() *Metrics

+ func (m *Metrics) GetMetrics() (success, fallback, failures int64)

+ func (m *Metrics) IncrementBearerClientFailures()

+ func (m *Metrics) IncrementPerUserAuthFallback()

+ func (m *Metrics) IncrementPerUserAuthSuccess()

+ type OAuthConfig struct

+ AllowInsecureAuthWithoutState bool

+ AllowPublicClientRegistration bool

+ AllowedOrigins string

+ BaseURL string

+ DebugMode bool

+ DisableStreaming bool

+ EnableHSTS bool

+ EncryptionKey []byte

+ GoogleClientID string

+ GoogleClientSecret string

+ Interstitial *oauthserver.InterstitialConfig

+ MaxClientsPerIP int

+ RegistrationAccessToken string

+ type OAuthHTTPServer struct

+ func NewOAuthHTTPServer(mcpServer *mcpserver.MCPServer, serverType string, config OAuthConfig) (*OAuthHTTPServer, error)

+ func NewOAuthHTTPServerWithServer(mcpServer *mcpserver.MCPServer, serverType string, oauthServer *oauth.Server, ...) (*OAuthHTTPServer, error)

+ func (s *OAuthHTTPServer) GetOAuthHandler() *oauth.Handler

+ func (s *OAuthHTTPServer) GetOAuthServer() *oauth.Server

+ func (s *OAuthHTTPServer) GetTokenStore() storage.TokenStore

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

+ func (s *OAuthHTTPServer) Start(addr string, config OAuthConfig) error

type Option

+ func WithClientFactory(factory k8s.ClientFactory) Option

+ func WithDownstreamOAuth(enabled bool) Option

type ServerContext

+ func (sc *ServerContext) ClientFactory() k8s.ClientFactory

+ func (sc *ServerContext) DownstreamOAuthEnabled() bool

+ func (sc *ServerContext) K8sClientForContext(ctx context.Context) k8s.Client

+ func (sc *ServerContext) Metrics() *Metrics

Jun 13, 2025

Changes in this version

type ServerContext

+ func (sc *ServerContext) GetActiveSessionCount() int

+ func (sc *ServerContext) GetActiveSessions() map[string]*k8s.PortForwardSession

+ func (sc *ServerContext) RegisterPortForwardSession(sessionID string, session *k8s.PortForwardSession)

+ func (sc *ServerContext) StopAllPortForwardSessions() int

+ func (sc *ServerContext) StopPortForwardSession(sessionID string) error

+ func (sc *ServerContext) UnregisterPortForwardSession(sessionID string)

Jun 13, 2025

Changes in this version

+ var ErrMissingConfig = errors.New("configuration is required")

+ var ErrMissingK8sClient = errors.New("kubernetes client is required")

+ var ErrMissingLogger = errors.New("logger is required")

+ var ErrServerShutdown = errors.New("server context has been shutdown")

+ type Config struct

+ AllowedOperations []string

+ DefaultContext string

+ DefaultNamespace string

+ DryRun bool

+ EnableAuth bool

+ KubeConfigPath string

+ LogFormat string

+ LogLevel string

+ NonDestructiveMode bool

+ RestrictedNamespaces []string

+ ServerName string

+ Version string

+ func NewDefaultConfig() *Config

+ func (c *Config) Clone() *Config

+ type DefaultLogger struct

+ func (l *DefaultLogger) Debug(msg string, args ...interface{})

+ func (l *DefaultLogger) Error(msg string, args ...interface{})

+ func (l *DefaultLogger) Info(msg string, args ...interface{})

+ func (l *DefaultLogger) Warn(msg string, args ...interface{})

+ func (l *DefaultLogger) With(args ...interface{}) Logger

+ type Logger interface

+ Debug func(msg string, args ...interface{})

+ Error func(msg string, args ...interface{})

+ Info func(msg string, args ...interface{})

+ Warn func(msg string, args ...interface{})

+ With func(args ...interface{}) Logger

+ func NewDefaultLogger() Logger

+ type Option func(*ServerContext) error

+ func WithAuth(allowedOperations []string) Option

+ func WithConfig(config *Config) Option

+ func WithDefaultNamespace(namespace string) Option

+ func WithDryRun(enabled bool) Option

+ func WithK8sClient(client k8s.Client) Option

+ func WithLogLevel(level string) Option

+ func WithLogger(logger Logger) Option

+ func WithNonDestructiveMode(enabled bool) Option

+ func WithRestrictedNamespaces(namespaces []string) Option

+ func WithServerName(name string) Option

+ type ServerContext struct

+ func NewServerContext(ctx context.Context, opts ...Option) (*ServerContext, error)

+ func (sc *ServerContext) Config() *Config

+ func (sc *ServerContext) Context() context.Context

+ func (sc *ServerContext) IsShutdown() bool

+ func (sc *ServerContext) K8sClient() k8s.Client

+ func (sc *ServerContext) Logger() Logger

+ func (sc *ServerContext) Shutdown() error