testutil

package
v1.0.0-beta.15 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2024 License: AGPL-3.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DefaultStorageClassName = "default-sc-for-testing"
)

Functions

func CreateMockStorageClass

func CreateMockStorageClass(testCtx *testutil.TestContext, storageClassName string) *storagev1.StorageClass

func CreateVolumeSnapshotClass

func CreateVolumeSnapshotClass(testCtx *testutil.TestContext, storageProvisioner string) *snapshotv1.VolumeSnapshotClass

func ListAndCheckInstanceSet added in v0.9.0

func ListAndCheckInstanceSet(testCtx *testutil.TestContext, key types.NamespacedName) *workloads.InstanceSetList

func ListAndCheckInstanceSetItemsCount added in v0.9.0

func ListAndCheckInstanceSetItemsCount(testCtx *testutil.TestContext, key types.NamespacedName, cnt int) *workloads.InstanceSetList

func ListAndCheckInstanceSetWithComponent added in v0.9.0

func ListAndCheckInstanceSetWithComponent(testCtx *testutil.TestContext, key types.NamespacedName, componentName string) *workloads.InstanceSetList

func MockInstanceSetReady added in v0.9.0

func MockInstanceSetReady(its *workloads.InstanceSet, pods ...*corev1.Pod)

MockInstanceSetReady mocks the ITS workload to ready state.

func MockPodAvailable

func MockPodAvailable(pod *corev1.Pod, lastTransitionTime metav1.Time)

MockPodAvailable mocks pod is available

func MockPodIsFailed added in v0.9.0

func MockPodIsFailed(ctx context.Context, testCtx testutil.TestContext, pod *corev1.Pod)

func MockPodIsRunning

func MockPodIsRunning(ctx context.Context, testCtx testutil.TestContext, pod *corev1.Pod)

func MockPodIsTerminating

func MockPodIsTerminating(ctx context.Context, testCtx testutil.TestContext, pod *corev1.Pod)

MockPodIsTerminating mocks pod is terminating.

func NewFakePod added in v0.9.0

func NewFakePod(parentName string, ordinal int) *corev1.Pod

NewFakePod creates a fake pod of the StatefulSet workload for testing.

func RemovePodFinalizer

func RemovePodFinalizer(ctx context.Context, testCtx testutil.TestContext, pod *corev1.Pod)

RemovePodFinalizer removes the pod finalizer to delete the pod finally.

func SetGetReturnedObject

func SetGetReturnedObject(out client.Object, expectedObj client.Object)

func SetListReturnedObjects

func SetListReturnedObjects(list client.ObjectList, objects []runtime.Object) error

func SetupK8sMock

func SetupK8sMock() (*gomock.Controller, *mock_client.MockClient)

Types

type CallMockGetReturnedOptions

type CallMockGetReturnedOptions = func(callHelper *callHelper, call *gomock.Call, _ HandleGetReturnedObject) error

type CallMockListReturnedOptions

type CallMockListReturnedOptions = func(callHelper *callHelper, call *gomock.Call, _ HandleListReturnedObject) error

type CallMockOptions

type CallMockOptions = func(call *gomock.Call)

func WithAnyTimes

func WithAnyTimes() CallMockOptions

func WithFailed

func WithFailed(err error, times ...CallMockOptions) CallMockOptions

func WithMaxTimes

func WithMaxTimes(n int) CallMockOptions

func WithMinTimes

func WithMinTimes(n int) CallMockOptions

func WithSucceed

func WithSucceed(times ...CallMockOptions) CallMockOptions

func WithTimes

func WithTimes(n int) CallMockOptions

type CallMockPatchReturnedOptions

type CallMockPatchReturnedOptions = func(callHelper *callHelper, call *gomock.Call, _ HandlePatchReturnedObject) error

type CallMockReturnedOptions

type CallMockReturnedOptions = func(callHelper *callHelper, call *gomock.Call)

type CallbackFn

type CallbackFn = func(sequence int, r []runtime.Object)

type CallerFunction

type CallerFunction = func() *gomock.Call

type DoReturnedFunction

type DoReturnedFunction = any

type Getter

type Getter = func(key client.ObjectKey, obj client.Object) (bool, error)

type HandleCreateReturnedObject

type HandleCreateReturnedObject = func(obj client.Object) error

func WithCreatedFailedResult

func WithCreatedFailedResult() HandleCreateReturnedObject

func WithCreatedSucceedResult

func WithCreatedSucceedResult() HandleCreateReturnedObject

type HandleGetReturnedObject

type HandleGetReturnedObject = func(key client.ObjectKey, obj client.Object) error

func WithConstructGetResult

func WithConstructGetResult(mockObj client.Object) HandleGetReturnedObject

func WithConstructSequenceResult

func WithConstructSequenceResult(mockObjs map[client.ObjectKey][]MockGetReturned) HandleGetReturnedObject

func WithConstructSimpleGetResult

func WithConstructSimpleGetResult(mockObjs []client.Object, get ...Getter) HandleGetReturnedObject

type HandleListReturnedObject

type HandleListReturnedObject = func(list client.ObjectList) error

func WithConstructListReturnedResult

func WithConstructListReturnedResult(r []runtime.Object) HandleListReturnedObject

func WithConstructListSequenceResult

func WithConstructListSequenceResult(mockObjsList [][]runtime.Object, fns ...CallbackFn) HandleListReturnedObject

type HandlePatchReturnedObject

type HandlePatchReturnedObject = func(obj client.Object, patch client.Patch) error

type K8sClientMockHelper

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

func NewK8sMockClient

func NewK8sMockClient() *K8sClientMockHelper

func (*K8sClientMockHelper) Client

func (helper *K8sClientMockHelper) Client() client.Client

func (*K8sClientMockHelper) Controller

func (helper *K8sClientMockHelper) Controller() *gomock.Controller

func (*K8sClientMockHelper) Finish

func (helper *K8sClientMockHelper) Finish()

func (*K8sClientMockHelper) MockCreateMethod

func (helper *K8sClientMockHelper) MockCreateMethod(options ...any)

func (*K8sClientMockHelper) MockDeleteMethod

func (helper *K8sClientMockHelper) MockDeleteMethod(options ...any)

func (*K8sClientMockHelper) MockGetMethod

func (helper *K8sClientMockHelper) MockGetMethod(options ...any)

func (*K8sClientMockHelper) MockListMethod

func (helper *K8sClientMockHelper) MockListMethod(options ...any)

func (*K8sClientMockHelper) MockPatchMethod

func (helper *K8sClientMockHelper) MockPatchMethod(options ...any)

func (*K8sClientMockHelper) MockStatusMethod

func (helper *K8sClientMockHelper) MockStatusMethod() *mock_client.MockStatusWriter

func (*K8sClientMockHelper) MockUpdateMethod

func (helper *K8sClientMockHelper) MockUpdateMethod(options ...any)

func (*K8sClientMockHelper) StatusWriter

func (helper *K8sClientMockHelper) StatusWriter() *mock_client.MockStatusWriter

type MockGetReturned

type MockGetReturned struct {
	Object client.Object
	Err    error
}

type Mysql

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

Mysql represents MySQL output bindings.

func (*Mysql) Close

func (m *Mysql) Close() error

Close closes the DB.

func (*Mysql) GetRole

func (m *Mysql) GetRole(ctx context.Context) (string, error)

func (*Mysql) Init

func (m *Mysql) Init(metadata map[string]string) error

Init initializes the MySQL binding.

type Tunnel

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

func OpenTunnel

func OpenTunnel(svc *corev1.Service) (*Tunnel, error)

func (*Tunnel) Close

func (t *Tunnel) Close() error

func (*Tunnel) GetMySQLConn

func (t *Tunnel) GetMySQLConn() (*Mysql, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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