Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.28.3

Sep 25, 2025

v0.28.2

Sep 25, 2025

v0.28.1

Aug 22, 2025

v0.28.0

Jul 25, 2025

Changes in this version

+ var ErrEmptyKubeConfig = fmt.Errorf("kubeconfig is empty")

+ func LoadKubeConfig(kubeconfigPath, contextName string) (clientcmd.ClientConfig, error)

+ func WaitLoadKubeConfig(ctx context.Context, kubeconfigPath, contextName string) (clientcmd.ClientConfig, error)

type Config

+ BindAddress string

+ func (c Config) BuildArgs(t TestingT) ([]string, error)

+ func (c Config) KubeconfigPath() string

+ type KcpRunner func(context.Context, TestingT, Config) (<-chan struct{}, error)

+ var ContextRunInProcessFunc KcpRunner = func(ctx context.Context, t TestingT, cfg Config) (<-chan struct{}, error) { ... }

type Option

+ func WithBindAddress(addr string) Option

+ func WithDefaultsFrom(t TestingT) Option

type RunningServer

+ Stop func()

+ Stopped func() bool

v0.27.1

Mar 27, 2025

v0.27.0

Mar 18, 2025

Changes in this version

+ var RunInProcessFunc func(t TestingT, dataDir string, args []string) (<-chan struct{}, error)

+ func Command(executableName, identity string) []string

+ func GetFreePort(t TestingT) (string, error)

+ func MonitorEndpoints(t TestingT, client *rest.Config, endpoints ...string)

+ func RunInProcess(o *runOptions)

+ func ScrapeMetrics(ctx context.Context, cfg *rest.Config, ...) error

+ func ScratchDirs(t TestingT) (string, string, error)

+ func StartKcpCommand(identity string) []string

+ func WaitForReady(ctx context.Context, cfg *rest.Config) error

+ func WithLogStreaming(o *runOptions)

+ type Config struct

+ Args []string

+ ArtifactDir string

+ ClientCADir string

+ DataDir string

+ LogToConsole bool

+ Name string

+ RunInProcess bool

+ type Fixture = map[string]RunningServer

+ func NewFixture(t TestingT, cfgs ...Config) Fixture

+ type Option func(*Config)

+ func WithClientCA(clientCADir string) Option

+ func WithCustomArguments(args ...string) Option

+ func WithLogToConsole() Option

+ func WithRunInProcess() Option

+ func WithScratchDirectories(artifactDir, dataDir string) Option

+ type RunOption func(o *runOptions)

+ type RunningServer interface

+ Artifact func(t TestingT, producer func() (runtime.Object, error))

+ BaseConfig func(t TestingT) *rest.Config

+ CADirectory func() string

+ ClientCAUserConfig func(t TestingT, config *rest.Config, name string, groups ...string) *rest.Config

+ KubeconfigPath func() string

+ Name func() string

+ RawConfig func() (clientcmdapi.Config, error)

+ RootShardSystemMasterBaseConfig func(t TestingT) *rest.Config

+ ShardNames func() []string

+ ShardSystemMasterBaseConfig func(t TestingT, shard string) *rest.Config

+ func NewExternalKCPServer(name, kubeconfigPath string, shardKubeconfigPaths map[string]string, ...) (RunningServer, error)

+ type TestingT interface

+ Cleanup func(func())

+ Error func(args ...any)

+ Errorf func(format string, args ...any)

+ FailNow func()

+ Failed func() bool

+ Fatal func(args ...any)

+ Fatalf func(format string, args ...any)

+ Helper func()

+ Log func(args ...any)

+ Logf func(format string, args ...any)

+ Name func() string

+ TempDir func() string