server

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