e2eutil

package

v0.2.15 Latest Latest Go to latest Published: Mar 15, 2023 License: Apache-2.0 Imports: 11 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/zookeeper-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CheckAdminService(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error
func CreateCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)
func DeleteCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error
func DeletePods(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, size int) error
func GetCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)
func GetPods(k8client client.Client, z *api.ZookeeperCluster) (*corev1.PodList, error)
func NewClusterWithEmptyDir(namespace string) *api.ZookeeperCluster
func NewClusterWithVersion(namespace, version string) *api.ZookeeperCluster
func NewDefaultCluster(namespace string) *api.ZookeeperCluster
func UpdateCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error
func WaitForClusterToBecomeReady(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, size int) error
func WaitForClusterToTerminate(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error
func WaitForClusterToUpgrade(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, ...) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	RetryInterval    = time.Second * 15
	ReadyTimeout     = time.Minute * 15
	UpgradeTimeout   = time.Minute * 25
	TerminateTimeout = time.Minute * 15
)

Functions ¶

func CheckAdminService ¶ added in v0.2.10

func CheckAdminService(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error

func CreateCluster ¶

func CreateCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)

CreateCluster creates a ZookeeperCluster CR with the desired spec

func DeleteCluster ¶

func DeleteCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error

DeleteCluster deletes the ZookeeperCluster CR specified by cluster spec

func DeletePods ¶

func DeletePods(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, size int) error

func GetCluster ¶

func GetCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)

GetCluster returns the latest ZookeeperCluster CR

func GetPods ¶ added in v0.2.13

func GetPods(k8client client.Client, z *api.ZookeeperCluster) (*corev1.PodList, error)

func NewClusterWithEmptyDir ¶ added in v0.2.9

func NewClusterWithEmptyDir(namespace string) *api.ZookeeperCluster

func NewClusterWithVersion ¶

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

func NewDefaultCluster ¶

func NewDefaultCluster(namespace string) *api.ZookeeperCluster

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

func UpdateCluster ¶

func UpdateCluster(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error

UpdateCluster updates the ZookeeperCluster CR

func WaitForClusterToBecomeReady ¶

func WaitForClusterToBecomeReady(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, size int) error

WaitForClusterToBecomeReady will wait until all cluster pods are ready

func WaitForClusterToTerminate ¶

func WaitForClusterToTerminate(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster) error

WaitForClusterToTerminate will wait until all cluster pods are terminated

func WaitForClusterToUpgrade ¶

func WaitForClusterToUpgrade(logger logr.Logger, k8client client.Client, z *api.ZookeeperCluster, targetVersion string) error

WaitForClusterToUpgrade will wait until all pods are upgraded

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