test

Documentation

Index

• Constants
• func AddToFrameworkScheme(addToScheme addToSchemeFunc, obj runtime.Object) error
• func MainEntry(m *testing.M)
• type CleanupOptions
• type Framework
• type FrameworkClient
• type TestCtx
  • func NewTestCtx(t *testing.T) *TestCtx
  • func (ctx *TestCtx) AddCleanupFn(fn cleanupFn)
  • func (ctx *TestCtx) Cleanup()
  • func (ctx *TestCtx) GetID() string
  • func (ctx *TestCtx) GetNamespace() (string, error)
  • func (ctx *TestCtx) InitializeClusterResources(cleanupOptions *CleanupOptions) error

Constants

const (
	ProjRootFlag          = "root"
	KubeConfigFlag        = "kubeconfig"
	NamespacedManPathFlag = "namespacedMan"
	GlobalManPathFlag     = "globalMan"
	SingleNamespaceFlag   = "singleNamespace"
	TestNamespaceEnv      = "TEST_NAMESPACE"
	LocalOperatorFlag     = "localOperator"
)

Functions

func AddToFrameworkScheme

func AddToFrameworkScheme(addToScheme addToSchemeFunc, obj runtime.Object) error

AddToFrameworkScheme allows users to add the scheme for their custom resources to the framework's scheme for use with the dynamic client. The user provides the addToScheme function (located in the register.go file of their operator project) and the List struct for their custom resource. For example, for a memcached operator, the list stuct may look like:

&MemcachedList{
	TypeMeta: metav1.TypeMeta{
		Kind: "Memcached",
		APIVersion: "cache.example.com/v1alpha1",
		},
	}

The List object is needed because the CRD has not always been fully registered by the time this function is called. If the CRD takes more than 5 seconds to become ready, this function throws an error

func MainEntry

func MainEntry(m *testing.M)

Types

type CleanupOptions

type CleanupOptions struct {
	TestContext   *TestCtx
	Timeout       time.Duration
	RetryInterval time.Duration
}

type Framework

type Framework struct {
	Client            *frameworkClient
	KubeConfig        *rest.Config
	KubeClient        kubernetes.Interface
	Scheme            *runtime.Scheme
	NamespacedManPath *string
	Namespace         string
	LocalOperator     bool
}

var (
	// Global framework struct
	Global *Framework
)

type FrameworkClient

type FrameworkClient interface {
	Get(gCtx goctx.Context, key dynclient.ObjectKey, obj runtime.Object) error
	List(gCtx goctx.Context, opts *dynclient.ListOptions, list runtime.Object) error
	Create(gCtx goctx.Context, obj runtime.Object, cleanupOptions *CleanupOptions) error
	Delete(gCtx goctx.Context, obj runtime.Object, opts ...dynclient.DeleteOptionFunc) error
	Update(gCtx goctx.Context, obj runtime.Object) error
}

type TestCtx

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

func NewTestCtx

func NewTestCtx(t *testing.T) *TestCtx

func (*TestCtx) AddCleanupFn

func (ctx *TestCtx) AddCleanupFn(fn cleanupFn)

func (*TestCtx) Cleanup

func (ctx *TestCtx) Cleanup()

func (*TestCtx) GetID

func (ctx *TestCtx) GetID() string

func (*TestCtx) GetNamespace

func (ctx *TestCtx) GetNamespace() (string, error)

func (*TestCtx) InitializeClusterResources

func (ctx *TestCtx) InitializeClusterResources(cleanupOptions *CleanupOptions) error