e2eutil

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

Variables

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

Functions

func CheckAdminService

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

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

func NewClusterWithEmptyDir

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