Documentation ¶
Index ¶
- Constants
- func CreateKubeConfig(clientCfg *rest.Config) *clientcmdapi.Config
- func CreateTestNamespace(tl common.TestLogger, client kubeclientset.Interface, baseName string) string
- func FindFreeLocalPort() (int, error)
- func NewIntegrationLogger(t *testing.T) common.TestLogger
- func SetUpEtcd(tl common.TestLogger) *url.URL
- func TearDownEtcd(tl common.TestLogger)
- func TearDownOnPanic(tl common.TestLogger, f TestFixture)
- type ControllerFixture
- func NewClusterControllerFixture(config *restclient.Config) *ControllerFixture
- func NewRSPControllerFixture(tl common.TestLogger, config *restclient.Config) *ControllerFixture
- func NewServiceDNSControllerFixture(tl common.TestLogger, config *restclient.Config) *ControllerFixture
- func NewSyncControllerFixture(tl common.TestLogger, typeConfig typeconfig.Interface, ...) *ControllerFixture
- type FederationFixture
- func (f *FederationFixture) AddMemberCluster(tl common.TestLogger) string
- func (f *FederationFixture) ClusterDynamicClients(tl common.TestLogger, apiResource *metav1.APIResource, userAgent string) map[string]common.TestCluster
- func (f *FederationFixture) ClusterKubeClients(tl common.TestLogger, userAgent string) map[string]kubeclientset.Interface
- func (f *FederationFixture) ClusterNames() []string
- func (f *FederationFixture) NewCrClient(tl common.TestLogger, userAgent string) crclientset.Interface
- func (f *FederationFixture) NewFedClient(tl common.TestLogger, userAgent string) fedclientset.Interface
- func (f *FederationFixture) TearDown(tl common.TestLogger)
- type InstallStrategy
- type KubernetesApiFixture
- type SecureConfigFixture
- type TestFixture
Constants ¶
const (
DefaultWaitInterval = 50 * time.Millisecond
)
Variables ¶
This section is empty.
Functions ¶
func CreateKubeConfig ¶
func CreateKubeConfig(clientCfg *rest.Config) *clientcmdapi.Config
CreateKubeConfig transforms a rest config to a cli config.
func CreateTestNamespace ¶
func CreateTestNamespace(tl common.TestLogger, client kubeclientset.Interface, baseName string) string
func FindFreeLocalPort ¶
FindFreeLocalPort returns the number of an available port number on the loopback interface. Useful for determining the port to launch a server on. Error handling required - there is a non-zero chance that the returned port number will be bound by another process after this function returns.
func NewIntegrationLogger ¶
func NewIntegrationLogger(t *testing.T) common.TestLogger
func TearDownEtcd ¶
func TearDownEtcd(tl common.TestLogger)
func TearDownOnPanic ¶
func TearDownOnPanic(tl common.TestLogger, f TestFixture)
TearDownOnPanic can be used to ensure cleanup on setup failure.
Types ¶
type ControllerFixture ¶
type ControllerFixture struct {
// contains filtered or unexported fields
}
ControllerFixture manages a federation controller for testing.
func NewClusterControllerFixture ¶
func NewClusterControllerFixture(config *restclient.Config) *ControllerFixture
NewClusterControllerFixture initializes a new cluster controller fixture.
func NewRSPControllerFixture ¶
func NewRSPControllerFixture(tl common.TestLogger, config *restclient.Config) *ControllerFixture
NewRSPControllerFixture initializes a new RSP controller fixture.
func NewServiceDNSControllerFixture ¶
func NewServiceDNSControllerFixture(tl common.TestLogger, config *restclient.Config) *ControllerFixture
NewServiceDNSControllerFixture initializes a new service-dns controller fixture.
func NewSyncControllerFixture ¶
func NewSyncControllerFixture(tl common.TestLogger, typeConfig typeconfig.Interface, kubeConfig *restclient.Config) *ControllerFixture
NewSyncControllerFixture initializes a new sync controller fixture.
func (*ControllerFixture) TearDown ¶
func (f *ControllerFixture) TearDown(tl common.TestLogger)
type FederationFixture ¶
type FederationFixture struct { KubeApi *KubernetesApiFixture Clusters map[string]*KubernetesApiFixture ClusterController *ControllerFixture }
FederationFixture manages servers for kube, cluster registry and federation along with a set of member clusters.
func SetUpFederationFixture ¶
func SetUpFederationFixture(tl common.TestLogger, clusterCount int) *FederationFixture
func (*FederationFixture) AddMemberCluster ¶
func (f *FederationFixture) AddMemberCluster(tl common.TestLogger) string
AddCluster adds a new member cluster to the federation.
func (*FederationFixture) ClusterDynamicClients ¶
func (f *FederationFixture) ClusterDynamicClients(tl common.TestLogger, apiResource *metav1.APIResource, userAgent string) map[string]common.TestCluster
func (*FederationFixture) ClusterKubeClients ¶
func (f *FederationFixture) ClusterKubeClients(tl common.TestLogger, userAgent string) map[string]kubeclientset.Interface
func (*FederationFixture) ClusterNames ¶
func (f *FederationFixture) ClusterNames() []string
func (*FederationFixture) NewCrClient ¶
func (f *FederationFixture) NewCrClient(tl common.TestLogger, userAgent string) crclientset.Interface
func (*FederationFixture) NewFedClient ¶
func (f *FederationFixture) NewFedClient(tl common.TestLogger, userAgent string) fedclientset.Interface
func (*FederationFixture) TearDown ¶
func (f *FederationFixture) TearDown(tl common.TestLogger)
type InstallStrategy ¶
type InstallStrategy struct { install.EmptyInstallStrategy // contains filtered or unexported fields }
func (*InstallStrategy) GetCRDs ¶
func (s *InstallStrategy) GetCRDs() []*extensionsv1beta1.CustomResourceDefinition
type KubernetesApiFixture ¶
type KubernetesApiFixture struct { EtcdUrl *url.URL Host string ApiServer *integration.APIServer IsPrimary bool }
KubernetesApiFixture manages a kubernetes api server
func SetUpKubernetesApiFixture ¶
func SetUpKubernetesApiFixture(tl common.TestLogger) *KubernetesApiFixture
func (*KubernetesApiFixture) NewClient ¶
func (f *KubernetesApiFixture) NewClient(tl common.TestLogger, userAgent string) clientset.Interface
func (*KubernetesApiFixture) NewConfig ¶
func (f *KubernetesApiFixture) NewConfig(tl common.TestLogger) *rest.Config
func (*KubernetesApiFixture) TearDown ¶
func (f *KubernetesApiFixture) TearDown(tl common.TestLogger)
type SecureConfigFixture ¶
type SecureConfigFixture struct { CertDir string ServerCAFile string Key *rsa.PrivateKey CACert *x509.Certificate CACertFile string }
func SetUpSecureConfigFixture ¶
func SetUpSecureConfigFixture(tl common.TestLogger) *SecureConfigFixture
func (*SecureConfigFixture) NewClientConfig ¶
func (f *SecureConfigFixture) NewClientConfig(tl common.TestLogger, host string) *rest.Config
func (*SecureConfigFixture) TearDown ¶
func (f *SecureConfigFixture) TearDown(tl common.TestLogger)
type TestFixture ¶
type TestFixture interface {
TearDown(tl common.TestLogger)
}
SetUp is likely to be fixture-specific, but TearDown needs to be consistent to enable TearDownOnPanic.