e2eutil

package

v0.1.9 Latest Latest Go to latest Published: Jun 23, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pravega/bookkeeper-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CheckConfigMap(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, key string, ...) error
func CheckEvents(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, event string) (bool, error)
func CheckServiceExists(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, ...) error
func CreateBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)
func CreateBKClusterWithCM(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, cm string) (*bkapi.BookkeeperCluster, error)
func CreateConfigMap(t *testing.T, k8client client.Client, cm *corev1.ConfigMap) error
func DeleteBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error
func DeleteConfigMap(t *testing.T, k8client client.Client, cm *corev1.ConfigMap) error
func DeletePods(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, size int) error
func GetBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)
func NewClusterWithVersion(namespace, version string) *api.BookkeeperCluster
func NewConfigMap(namespace, name string, pravega string) *corev1.ConfigMap
func NewDefaultCluster(namespace string) *api.BookkeeperCluster
func UpdateBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error
func WaitForBKClusterToRollback(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, ...) error
func WaitForBKClusterToTerminate(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error
func WaitForBKClusterToUpgrade(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, ...) error
func WaitForBookkeeperClusterToBecomeReady(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error
func WaitForCMBKClusterToUpgrade(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	RetryInterval        = time.Second * 5
	Timeout              = time.Second * 60
	CleanupRetryInterval = time.Second * 1
	CleanupTimeout       = time.Second * 5
	ReadyTimeout         = time.Minute * 7
	UpgradeTimeout       = time.Minute * 10
	TerminateTimeout     = time.Minute * 2
	VerificationTimeout  = time.Minute * 5
)

Functions ¶

func CheckConfigMap ¶ added in v0.1.4

func CheckConfigMap(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, key string, value string) error

func CheckEvents ¶ added in v0.1.4

func CheckEvents(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, event string) (bool, error)

func CheckServiceExists ¶ added in v0.1.4

func CheckServiceExists(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, svcName string) error

func CreateBKCluster ¶

func CreateBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

CreateBKCluster creates a BookkeeperCluster CR with the desired spec

func CreateBKClusterWithCM ¶ added in v0.1.4

func CreateBKClusterWithCM(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, cm string) (*bkapi.BookkeeperCluster, error)

CreateBKCluster creates a BookkeeperCluster CR with the desired spec

func CreateConfigMap ¶ added in v0.1.4

func CreateConfigMap(t *testing.T, k8client client.Client, cm *corev1.ConfigMap) error

CreateConfigMap creates the configmap specified

func DeleteBKCluster ¶

func DeleteBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

DeleteBKCluster deletes the BookkeeperCluster CR specified by cluster spec

func DeleteConfigMap ¶ added in v0.1.4

func DeleteConfigMap(t *testing.T, k8client client.Client, cm *corev1.ConfigMap) error

DeleteConfigMap deletes the configmap specified

func DeletePods ¶ added in v0.1.4

func DeletePods(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, size int) error

func GetBKCluster ¶

func GetBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

GetBKCluster returns the latest BookkeeperCluster CR

func NewClusterWithVersion ¶

func NewClusterWithVersion(namespace, version string) *api.BookkeeperCluster

func NewConfigMap ¶ added in v0.1.4

func NewConfigMap(namespace, name string, pravega string) *corev1.ConfigMap

func NewDefaultCluster ¶

func NewDefaultCluster(namespace string) *api.BookkeeperCluster

NewDefaultCluster returns a cluster with an empty spec, which will be filled with default values

func UpdateBKCluster ¶

func UpdateBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

UpdateBkCluster updates the BookkeeperCluster CR

func WaitForBKClusterToRollback ¶ added in v0.1.4

func WaitForBKClusterToRollback(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, targetVersion string) error

WaitForBookkeeperClusterToRollback will wait until all pods are rolled back

func WaitForBKClusterToTerminate ¶

func WaitForBKClusterToTerminate(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

WaitForBKClusterToTerminate will wait until all Bookkeeper cluster pods are terminated

func WaitForBKClusterToUpgrade ¶

func WaitForBKClusterToUpgrade(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, targetVersion string) error

WaitForBookkeeperClusterToUpgrade will wait until all pods are upgraded

func WaitForBookkeeperClusterToBecomeReady ¶

func WaitForBookkeeperClusterToBecomeReady(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

WaitForBookkeeperClusterToBecomeReady will wait until all Bookkeeper cluster pods are ready

func WaitForCMBKClusterToUpgrade ¶ added in v0.1.4

func WaitForCMBKClusterToUpgrade(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

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