testutil

package
Version: v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jun 17, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

nolint: golint, errcheck

nolint: errcheck,golint

nolint: golint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BackupForCluster added in v0.2.2

func BackupForCluster(cluster *api.MysqlCluster) gomegatypes.GomegaMatcher

BackupForCluster is gomega matcher that matches a backup which is for given cluster

func BackupHaveCondition

func BackupHaveCondition(condType api.BackupConditionType, status core.ConditionStatus) gomegatypes.GomegaMatcher

BackupHaveCondition is a helper func that returns a matcher to check for an existing condition in condition list list

func BackupWithName added in v0.2.3

func BackupWithName(name string) gomegatypes.GomegaMatcher

BackupWithName is a gomega matcher that matchers a backup with the given name

func DrainChan

func DrainChan(requests <-chan reconcile.Request)

DrainChan drains the request chan time for drainTimeout

func HaveClusterStatusReadyNodes added in v0.2.4

func HaveClusterStatusReadyNodes(nodes int) gomegatypes.GomegaMatcher

HaveClusterStatusReadyNodes a matcher that checks cluster ready nodes to equal the given value

func ListAllBackupsFn added in v0.2.2

func ListAllBackupsFn(c client.Client, options *client.ListOptions) func() []api.MysqlBackup

ListAllBackupsFn returns a helper function that can be used with gomega Eventually and Consistently

func NewTestLogger

func NewTestLogger(w io.Writer) logr.Logger

NewTestLogger returns a logger good for tests

func NodeConditions added in v0.2.2

func NodeConditions(master, replicating, lagged, readOnly bool) []api.NodeCondition

NodeConditions returns a list of api.NodeConditions for a node

func PodHaveCondition added in v0.3.0

func PodHaveCondition(condType core.PodConditionType, status core.ConditionStatus) gomegatypes.GomegaMatcher

PodHaveCondition is a helper func that returns a matcher to check for an existing condition in condition list list

func RefreshFn added in v0.2.4

func RefreshFn(c client.Client, obj runtime.Object) func() runtime.Object

RefreshFn receives a client and a runtime.Objects and refreshes the object from k8s example: Eventually(RefreshFn(c, cluster.Unwrap())).Should(HaveClusterStatusReadyNodes(2))

func SetupTestReconcile added in v0.3.0

func SetupTestReconcile(inner reconcile.Reconciler) (reconcile.Reconciler, chan reconcile.Request)

SetupTestReconcile returns a reconcile.Reconcile implementation that delegates to inner and writes the request to requests after Reconcile is finished.

func StartTestManager added in v0.3.0

func StartTestManager(mgr manager.Manager) chan struct{}

StartTestManager adds recFn

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL