framework

package
v0.0.0-...-4f82633 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 14, 2019 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Using the same interval as integration should be fine given the
	// minimal load that the apiserver is likely to be under.
	PollInterval = 50 * time.Millisecond
	// How long to try single API calls (like 'get' or 'list'). Used to prevent
	// transient failures from failing tests.
	DefaultSingleCallTimeout = 30 * time.Second
)

Variables

View Source
var RunId = uuid.NewUUID()

unique identifier of the e2e run

Functions

func DumpEventsInNamespace

func DumpEventsInNamespace(eventsLister EventsLister, namespace string)

func Errorf

func Errorf(format string, args ...interface{})

func ExpectNoError

func ExpectNoError(err error, explain ...interface{})

func ExpectNoErrorWithOffset

func ExpectNoErrorWithOffset(offset int, err error, explain ...interface{})

ExpectNoErrorWithOffset checks if "err" is set, and if so, fails assertion while logging the error at "offset" levels above its caller (for example, for call chain f -> g -> ExpectNoErrorWithOffset(1, ...) error would be logged for "f").

func Failf

func Failf(format string, args ...interface{})

func FailfWithOffset

func FailfWithOffset(offset int, format string, args ...interface{})

FailfWithOffset calls "Fail" and logs the error at "offset" levels above its caller (for example, for call chain f -> g -> FailfWithOffset(1, ...) error would be logged for "f").

func ListKubefedClusters

func ListKubefedClusters(tl common.TestLogger, client genericclient.Client, namespace string) *fedv1a1.KubefedClusterList

func LoadEnableTypeDirectives

func LoadEnableTypeDirectives(tl common.TestLogger) []*kfenable.EnableTypeDirective

func Logf

func Logf(format string, args ...interface{})

func NewE2ELogger

func NewE2ELogger() common.TestLogger

func ParseFlags

func ParseFlags()

func RemoveCleanupAction

func RemoveCleanupAction(p CleanupActionHandle)

RemoveCleanupAction removes a function that was installed by AddCleanupAction.

func RunCleanupActions

func RunCleanupActions()

RunCleanupActions runs all functions installed by AddCleanupAction. It does not remove them (see RemoveCleanupAction) but it does run unlocked, so they may remove themselves.

func SetUpUnmanagedFederation

func SetUpUnmanagedFederation()

func Skipf

func Skipf(format string, args ...interface{})

func TearDownUnmanagedFederation

func TearDownUnmanagedFederation()

func WaitForClusterReadiness

func WaitForClusterReadiness(tl common.TestLogger, client genericclient.Client,
	namespace string, interval, timeout time.Duration)

func WaitForUnmanagedClusterReadiness

func WaitForUnmanagedClusterReadiness()

Types

type CleanupActionHandle

type CleanupActionHandle *int

func AddCleanupAction

func AddCleanupAction(fn func()) CleanupActionHandle

AddCleanupAction installs a function that will be called in the event of the whole test being terminated. This allows arbitrary pieces of the overall test to hook into SynchronizedAfterSuite().

type ControllerFixture

type ControllerFixture struct {
	// contains filtered or unexported fields
}

ControllerFixture manages a kubefed controller for testing.

func NewClusterControllerFixture

func NewClusterControllerFixture(tl common.TestLogger, config *util.ControllerConfig) *ControllerFixture

NewClusterControllerFixture initializes a new cluster controller fixture.

func NewFederatedTypeConfigControllerFixture

func NewFederatedTypeConfigControllerFixture(tl common.TestLogger, config *util.ControllerConfig) *ControllerFixture

NewFederatedTypeConfigControllerFixure initializes a new federatedtypeconfig controller fixure.

func NewIngressDNSControllerFixture

func NewIngressDNSControllerFixture(tl common.TestLogger, config *util.ControllerConfig) *ControllerFixture

NewIngressDNSControllerFixture initializes a new ingress-dns controller fixture.

func NewServiceDNSControllerFixture

func NewServiceDNSControllerFixture(tl common.TestLogger, config *util.ControllerConfig) *ControllerFixture

NewServiceDNSControllerFixture initializes a new service-dns controller fixture.

func NewSyncControllerFixture

func NewSyncControllerFixture(tl common.TestLogger, controllerConfig *util.ControllerConfig, typeConfig typeconfig.Interface, namespacePlacement *metav1.APIResource) *ControllerFixture

NewSyncControllerFixture initializes a new sync controller fixture.

func (*ControllerFixture) TearDown

func (f *ControllerFixture) TearDown(tl common.TestLogger)

type EventsLister

type EventsLister func(opts metav1.ListOptions, ns string) (*corev1.EventList, error)

type FederationFramework

type FederationFramework interface {
	FederationFrameworkImpl

	// Registering a fixture ensures it will be torn down after the
	// current test has executed.
	RegisterFixture(fixture TestFixture)

	// Setup a sync controller if necessary and return the fixture.
	// This is implemented commonly to support running a sync
	// controller for tests that require it.
	SetUpSyncControllerFixture(typeConfig typeconfig.Interface) TestFixture

	// Ensure propagation of the test namespace to member clusters
	EnsureTestNamespacePropagation()

	// Ensure a federated namespace resource for the test namespace
	// exists so that the namespace will be propagated to either all
	// or no member clusters.
	EnsureTestFederatedNamespace(allClusters bool) *unstructured.Unstructured
}

FederationFramework provides an interface to a test federation so that the implementation can vary without affecting tests.

func NewFederationFramework

func NewFederationFramework(baseName string) FederationFramework

type FederationFrameworkImpl

type FederationFrameworkImpl interface {
	BeforeEach()
	AfterEach()

	ControllerConfig() *util.ControllerConfig

	Logger() common.TestLogger

	KubeConfig() *restclient.Config

	KubeClient(userAgent string) kubeclientset.Interface
	Client(userAgent string) genericclient.Client

	ClusterConfigs(userAgent string) map[string]common.TestClusterConfig
	ClusterDynamicClients(apiResource *metav1.APIResource, userAgent string) map[string]common.TestCluster
	ClusterKubeClients(userAgent string) map[string]kubeclientset.Interface
	ClusterNames(userAgent string) []string

	KubefedSystemNamespace() string

	// Name of the namespace for the current test to target
	TestNamespaceName() string
	// contains filtered or unexported methods
}

func NewUnmanagedFramework

func NewUnmanagedFramework(baseName string) FederationFrameworkImpl

type TestContextType

type TestContextType struct {
	InMemoryControllers             bool
	KubeConfig                      string
	KubeContext                     string
	KubefedSystemNamespace          string
	SingleCallTimeout               time.Duration
	LimitedScope                    bool
	LimitedScopeInMemoryControllers bool
	WaitForFinalization             bool
}
var TestContext *TestContextType = &TestContextType{}

func (*TestContextType) RunControllers

func (t *TestContextType) RunControllers() bool

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.

type UnmanagedFramework

type UnmanagedFramework struct {
	Config     *restclient.Config
	Kubeconfig *clientcmdapi.Config

	BaseName string
	// contains filtered or unexported fields
}

func (*UnmanagedFramework) AfterEach

func (f *UnmanagedFramework) AfterEach()

AfterEach deletes the namespace, after reading its events.

func (*UnmanagedFramework) BeforeEach

func (f *UnmanagedFramework) BeforeEach()

BeforeEach checks for federation apiserver is ready and makes a namespace.

func (*UnmanagedFramework) Client

func (f *UnmanagedFramework) Client(userAgent string) genericclient.Client

func (*UnmanagedFramework) ClusterConfigs

func (f *UnmanagedFramework) ClusterConfigs(userAgent string) map[string]common.TestClusterConfig

func (*UnmanagedFramework) ClusterDynamicClients

func (f *UnmanagedFramework) ClusterDynamicClients(apiResource *metav1.APIResource, userAgent string) map[string]common.TestCluster

func (*UnmanagedFramework) ClusterKubeClients

func (f *UnmanagedFramework) ClusterKubeClients(userAgent string) map[string]kubeclientset.Interface

func (*UnmanagedFramework) ClusterNames

func (f *UnmanagedFramework) ClusterNames(userAgent string) []string

func (*UnmanagedFramework) ControllerConfig

func (f *UnmanagedFramework) ControllerConfig() *util.ControllerConfig

func (*UnmanagedFramework) KubeClient

func (f *UnmanagedFramework) KubeClient(userAgent string) kubeclientset.Interface

func (*UnmanagedFramework) KubeConfig

func (f *UnmanagedFramework) KubeConfig() *restclient.Config

func (*UnmanagedFramework) KubefedSystemNamespace

func (f *UnmanagedFramework) KubefedSystemNamespace() string

func (*UnmanagedFramework) Logger

func (f *UnmanagedFramework) Logger() common.TestLogger

func (*UnmanagedFramework) TestNamespaceName

func (f *UnmanagedFramework) TestNamespaceName() string

Directories

Path Synopsis
Package ginkgowrapper wraps Ginkgo Fail and Skip functions to panic with structured data instead of a constant string.
Package ginkgowrapper wraps Ginkgo Fail and Skip functions to panic with structured data instead of a constant string.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL