Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

framework

package

Go to main page

Versions in this module

v0

v0.20.0

Jul 30, 2023

Changes in this version

+ var TestConfig *testConfig

+ func AdmitWorkspaceAccess(ctx context.Context, t *testing.T, ...)

+ func ClientCAUserConfig(t *testing.T, cfg *rest.Config, clientCAConfigDirectory, username string, ...) *rest.Config

+ func ConfigWithToken(token string, cfg *rest.Config) *rest.Config

+ func CreateClientCA(t *testing.T) (string, string)

+ func CreateResources(ctx context.Context, fs embed.FS, upstreamConfig *rest.Config, ...) error

+ func CreateTempDirForTest(t *testing.T, dirName string) (string, error)

+ func DirectOrGoRunCommand(executableName string) []string

+ func Eventually(t *testing.T, condition func() (success bool, reason string), ...)

+ func EventuallyCondition(t *testing.T, getter func() (conditions.Getter, error), ...)

+ func EventuallyReady(t *testing.T, getter func() (conditions.Getter, error), ...)

+ func ExportVirtualWorkspaceURLs(export *apisv1alpha1.APIExport) []string

+ func GatherMetrics(ctx context.Context, t *testing.T, server RunningServer, directory string)

+ func GetFreePort(t *testing.T) (string, error)

+ func InProcessEnvSet() bool

+ func Kubectl(t *testing.T, kubeconfigPath string, args ...string) []byte

+ func KubectlApply(t *testing.T, kubeconfigPath string, input []byte) []byte

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

+ func LogToConsoleEnvSet() bool

+ func LogicalClusterRawConfig(rawConfig clientcmdapi.Config, logicalClusterName logicalcluster.Path, ...) clientcmdapi.Config

+ func NewBindCompute(t *testing.T, path logicalcluster.Path, server RunningServer, ...) *bindCompute

+ func NewOrganizationFixture(t *testing.T, server RunningServer, options ...UnprivilegedWorkspaceOption) (logicalcluster.Path, *tenancyv1alpha1.Workspace)

+ func NewPrivilegedOrganizationFixture(t *testing.T, server RunningServer, options ...O) (logicalcluster.Path, *tenancyv1alpha1.Workspace)

+ func NewSyncerFixture(t *testing.T, server RunningServer, path logicalcluster.Path, ...) *syncerFixture

+ func NewWorkspaceFixture(t *testing.T, server RunningServer, parent logicalcluster.Path, ...) (logicalcluster.Path, *tenancyv1alpha1.Workspace)

+ func NoGoRunEnvSet() bool

+ func RepositoryBinDir() string

+ func RepositoryDir() string

+ func RunInProcess(o *runOptions)

+ func RunTMCCliPlugin(t *testing.T, kubeconfigPath string, subcommand []string) []byte

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

+ func ScrapeMetricsForServer(t *testing.T, srv RunningServer)

+ func ScratchDirs(t *testing.T) (string, string, error)

+ func StartKcpCommand() []string

+ func StaticTokenUserConfig(username string, cfg *rest.Config) *rest.Config

+ func Suite(t *testing.T, suite string)

+ func TestServerArgs() []string

+ func TestServerArgsWithTokenAuthFile(tokenAuthFile string) []string

+ func TestServerWithAuditPolicyFile(auditPolicyFile string) []string

+ func TestServerWithClientCAFile(clientCAFile string) []string

+ func TmcCliPluginCommand() []string

+ func UniqueGroup(suffix string) string

+ func VirtualWorkspaceURL(ctx context.Context, kcpClusterClient kcpclientset.ClusterInterface, ...) (string, bool, error)

+ func VirtualWorkspaceURLOrDie(t *testing.T, kcpClusterClient kcpclientset.ClusterInterface, ...) string

+ func WaitForReady(ctx context.Context, t *testing.T, cfg *rest.Config, keepMonitoring bool) error

+ func WithLogStreaming(o *runOptions)

+ func WorkspaceShard(ctx context.Context, kcpClient kcpclientset.ClusterInterface, ...) (*corev1alpha1.Shard, error)

+ func WorkspaceShardOrDie(t *testing.T, kcpClient kcpclientset.ClusterInterface, ...) *corev1alpha1.Shard

+ func WriteEmbedFile(t *testing.T, source string) string

+ func WriteLogicalClusterConfig(t *testing.T, rawConfig clientcmdapi.Config, contextName string, ...) (clientcmd.ClientConfig, string)

+ func WriteTokenAuthFile(t *testing.T) string

+ type Accessory struct

+ func NewAccessory(t *testing.T, artifactDir string, name string, cmd ...string) *Accessory

+ func (a *Accessory) Run(t *testing.T, opts ...RunOption) error

+ type ArtifactFunc func(*testing.T, func() (runtime.Object, error))

+ type BindComputeOption func(t *testing.T, w *bindCompute)

+ func WithAPIExportsWorkloadBindOption(apiexports ...string) BindComputeOption

+ func WithLocationSelectorWorkloadBindOption(selectors ...metav1.LabelSelector) BindComputeOption

+ func WithLocationWorkspaceWorkloadBindOption(clusterName logicalcluster.Path) BindComputeOption

+ func WithNSSelectorWorkloadBindOption(selector metav1.LabelSelector) BindComputeOption

+ func WithPlacementNameBindOption(placementName string) BindComputeOption

+ type ConditionEvaluator struct

+ func Is(conditionType conditionsv1alpha1.ConditionType) *ConditionEvaluator

+ func IsNot(conditionType conditionsv1alpha1.ConditionType) *ConditionEvaluator

+ func (c *ConditionEvaluator) WithReason(reason string) *ConditionEvaluator

+ type Expectation func(ctx context.Context) (done bool, err error)

+ type ExpectationController struct

+ func NewExpecter(informer cache.SharedIndexInformer) *ExpectationController

+ func (c *ExpectationController) ExpectBefore(ctx context.Context, expectation Expectation, duration time.Duration) error

+ type Expecter interface

+ ExpectBefore func(context.Context, Expectation, time.Duration) error

+ type PrivilegedWorkspaceOption func(ws *tenancyv1alpha1.Workspace)

+ func WithRequiredGroups(groups ...string) PrivilegedWorkspaceOption

+ type RegisterWorkspaceExpectation func(seed *tenancyv1alpha1.Workspace, expectation WorkspaceExpectation) error

+ func ExpectWorkspaces(ctx context.Context, t *testing.T, client kcpclient.Interface) (RegisterWorkspaceExpectation, error)

+ type RegisterWorkspaceShardExpectation func(seed *corev1alpha1.Shard, expectation WorkspaceShardExpectation) error

+ func ExpectWorkspaceShards(ctx context.Context, t *testing.T, client kcpclient.Interface) (RegisterWorkspaceShardExpectation, error)

+ type RunOption func(o *runOptions)

+ type RunningServer interface

+ Artifact func(t *testing.T, producer func() (runtime.Object, error))

+ BaseConfig func(t *testing.T) *rest.Config

+ CADirectory func() string

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

+ KubeconfigPath func() string

+ Name func() string

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

+ RootShardSystemMasterBaseConfig func(t *testing.T) *rest.Config

+ ShardNames func() []string

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

+ func NewFakeWorkloadServer(t *testing.T, server RunningServer, org logicalcluster.Path, ...) RunningServer

+ func PrivateKcpServer(t *testing.T, options ...TmcConfigOption) RunningServer

+ func SharedKcpServer(t *testing.T) RunningServer

+ type StartedSyncerFixture struct

+ func (sf *StartedSyncerFixture) DownstreamNamespaceFor(t *testing.T, upstreamWorkspace logicalcluster.Name, upstreamNamespace string) string

+ func (sf *StartedSyncerFixture) StopHeartBeat(t *testing.T)

+ func (sf *StartedSyncerFixture) StopSyncerTunnel(t *testing.T)

+ func (sf *StartedSyncerFixture) ToSyncTargetKey() string

+ func (sf *StartedSyncerFixture) WaitForSyncTargetReady(ctx context.Context, t *testing.T)

+ func (sf StartedSyncerFixture) StartAPIImporter(t *testing.T) *appliedSyncerFixture

+ func (sf StartedSyncerFixture) StartHeartBeat(t *testing.T) *StartedSyncerFixture

+ func (sf StartedSyncerFixture) StartSyncer(t *testing.T) *StartedSyncerFixture

+ func (sf StartedSyncerFixture) StartSyncerTunnel(t *testing.T) *StartedSyncerFixture

+ type SyncTargetOption func(cluster *workloadv1alpha1.SyncTarget)

+ type SyncerOption func(t *testing.T, fs *syncerFixture)

+ func WithAPIExports(exports ...string) SyncerOption

+ func WithDownstreamPreparation(prepare func(config *rest.Config, isFakePCluster bool)) SyncerOption

+ func WithExtraResources(resources ...string) SyncerOption

+ func WithSyncTargetLabels(labels map[string]string) SyncerOption

+ func WithSyncTargetName(name string) SyncerOption

+ func WithSyncedUserWorkspaces(syncedUserWorkspaces ...*tenancyv1alpha1.Workspace) SyncerOption

+ type TmcConfigOption func(*tmcConfig) *tmcConfig

+ func WithCustomArguments(args ...string) TmcConfigOption

+ func WithScratchDirectories(artifactDir, dataDir string) TmcConfigOption

+ type UnprivilegedWorkspaceOption func(ws *tenancyv1alpha1.Workspace)

+ func TODO_WithoutMultiShardSupport() UnprivilegedWorkspaceOption

+ func WithLocation(w tenancyv1alpha1.WorkspaceLocation) UnprivilegedWorkspaceOption

+ func WithName(s string, formatArgs ...interface{}) UnprivilegedWorkspaceOption

+ func WithNameSuffix(suffix string) UnprivilegedWorkspaceOption

+ func WithRootShard() UnprivilegedWorkspaceOption

+ func WithShard(name string) UnprivilegedWorkspaceOption

+ func WithType(path logicalcluster.Path, name tenancyv1alpha1.WorkspaceTypeName) UnprivilegedWorkspaceOption

+ type WorkspaceExpectation func(*tenancyv1alpha1.Workspace) error

+ type WorkspaceOption interface

+ type WorkspaceShardExpectation func(*corev1alpha1.Shard) error

v0.20.0-rc5

Jul 30, 2023

v0.20.0-rc4

Jul 30, 2023

v0.20.0-rc3

Jul 30, 2023

v0.20.0-rc2

Jul 30, 2023

v0.20.0-rc1

Jul 30, 2023