e2eutil

Documentation

Index

• Variables
• func CheckAdminService(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func CreateCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.ZookeeperCluster, error)
• func DeleteCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeletePods(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func GetCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.ZookeeperCluster, error)
• func GetPods(t *testing.T, f *framework.Framework, 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(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error

Variables

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

Functions

func CheckAdminService

func CheckAdminService(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) error

func CreateCluster

func CreateCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)

CreateCluster creates a ZookeeperCluster CR with the desired spec

func DeleteCluster

func DeleteCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) error

DeleteCluster deletes the ZookeeperCluster CR specified by cluster spec

func DeletePods

func DeletePods(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster, size int) error

func GetCluster

func GetCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) (*api.ZookeeperCluster, error)

GetCluster returns the latest ZookeeperCluster CR

func GetPods

func GetPods(t *testing.T, f *framework.Framework, 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(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) error

UpdateCluster updates the ZookeeperCluster CR

func WaitForClusterToBecomeReady

func WaitForClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster, size int) error

WaitForClusterToBecomeReady will wait until all cluster pods are ready

func WaitForClusterToTerminate

func WaitForClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster) error

WaitForClusterToTerminate will wait until all cluster pods are terminated

func WaitForClusterToUpgrade

func WaitForClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, z *api.ZookeeperCluster, targetVersion string) error

WaitForClusterToUpgrade will wait until all pods are upgraded