e2eutil

Documentation

Index

• Variables
• func CheckConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (bool, error)
• func CheckEvents(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (bool, error)
• func CreateBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*bkapi.BookkeeperCluster, error)
• func CreateBKClusterWithCM(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*bkapi.BookkeeperCluster, error)
• func CreateConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeleteBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeleteConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeletePods(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func GetBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*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, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBKClusterToRollback(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBKClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBKClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBookkeeperClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForCMBKClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error

Variables

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

Functions

func CheckConfigMap

func CheckConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) (bool, error)

func CheckEvents

func CheckEvents(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster, event string) (bool, error)

func CreateBKCluster

func CreateBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

CreateBKCluster creates a BookkeeperCluster CR with the desired spec

func CreateBKClusterWithCM

func CreateBKClusterWithCM(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster, cm string) (*bkapi.BookkeeperCluster, error)

CreateBKCluster creates a BookkeeperCluster CR with the desired spec

func CreateConfigMap

func CreateConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, cm *corev1.ConfigMap) error

CreateConfigMap creates the configmap specified

func DeleteBKCluster

func DeleteBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) error

DeleteBKCluster deletes the BookkeeperCluster CR specified by cluster spec

func DeleteConfigMap

func DeleteConfigMap(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, cm *corev1.ConfigMap) error

DeleteConfigMap deletes the configmap specified

func DeletePods

func DeletePods(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster, size int) error

func GetBKCluster

func GetBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

GetBKCluster returns the latest BookkeeperCluster CR

func NewClusterWithVersion

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

func NewConfigMap

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, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) error

UpdateBkCluster updates the BookkeeperCluster CR

func WaitForBKClusterToRollback

func WaitForBKClusterToRollback(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster, targetVersion string) error

WaitForBookkeeperClusterToRollback will wait until all pods are rolled back

func WaitForBKClusterToTerminate

func WaitForBKClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) error

WaitForBKClusterToTerminate will wait until all Bookkeeper cluster pods are terminated

func WaitForBKClusterToUpgrade

func WaitForBKClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster, targetVersion string) error

WaitForBookkeeperClusterToUpgrade will wait until all pods are upgraded

func WaitForBookkeeperClusterToBecomeReady

func WaitForBookkeeperClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) error

WaitForBookkeeperClusterToBecomeReady will wait until all Bookkeeper cluster pods are ready

func WaitForCMBKClusterToUpgrade

func WaitForCMBKClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, b *bkapi.BookkeeperCluster) error