e2eutil

Documentation

Index

• Variables
• func CreateBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*bkapi.BookkeeperCluster, error)
• func CreatePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.PravegaCluster, error)
• func CreateZKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*zkapi.ZookeeperCluster, error)
• func DeleteBKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeletePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func DeleteZKCluster(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 GetPravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.PravegaCluster, error)
• func GetZKCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*zkapi.ZookeeperCluster, error)
• func InitialSetup(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, namespace string) error
• func NewClusterWithVersion(namespace, version string) *api.PravegaCluster
• func NewDefaultCluster(namespace string) *api.PravegaCluster
• func NewTestWriteReadJob(namespace string, controllerUri string) *batchv1.Job
• func NewTier2(namespace string) *corev1.PersistentVolumeClaim
• func RestartTier2(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, namespace string) error
• func UpdatePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBKClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForBookkeeperClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForPravegaClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForPravegaClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForPravegaClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForZKClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WaitForZookeeperClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func WriteAndReadData(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 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 CreatePravegaCluster

func CreatePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) (*api.PravegaCluster, error)

CreatePravegaCluster creates a PravegaCluster CR with the desired spec

func CreateZKCluster

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

CreateZKCluster creates a ZookeeperCluster CR with the desired spec

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 DeletePravegaCluster

func DeletePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) error

DeletePravegaCluster deletes the PravegaCluster CR specified by cluster spec

func DeleteZKCluster

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

DeleteZKCluster deletes the ZookeeperCluster CR specified by cluster spec

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 GetPravegaCluster

func GetPravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) (*api.PravegaCluster, error)

GetPravegaCluster returns the latest PravegaCluster CR

func GetZKCluster

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

GetZKCluster returns the latest ZookeeperCluster CR

func InitialSetup

func InitialSetup(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, namespace string) error

func NewClusterWithVersion

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

func NewDefaultCluster

func NewDefaultCluster(namespace string) *api.PravegaCluster

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

func NewTestWriteReadJob

func NewTestWriteReadJob(namespace string, controllerUri string) *batchv1.Job

NewTestWriteReadJob returns a Job that can test pravega cluster by running a sample

func NewTier2

func NewTier2(namespace string) *corev1.PersistentVolumeClaim

func RestartTier2

func RestartTier2(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, namespace string) error

func UpdatePravegaCluster

func UpdatePravegaCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) error

UpdatePravegaCluster updates the PravegaCluster CR

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 WaitForBookkeeperClusterToBecomeReady

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

WaitForBooClusterToBecomeReady will wait until all Bookkeeper cluster pods are ready

func WaitForPravegaClusterToBecomeReady

func WaitForPravegaClusterToBecomeReady(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster, size int) error

WaitForPravegaClusterToBecomeReady will wait until all cluster pods are ready

func WaitForPravegaClusterToTerminate

func WaitForPravegaClusterToTerminate(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) error

WaitForPravegaClusterToTerminate will wait until all cluster pods are terminated

func WaitForPravegaClusterToUpgrade

func WaitForPravegaClusterToUpgrade(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster, targetVersion string) error

WaitForPravegaClusterToUpgrade will wait until all pods are upgraded

func WaitForZKClusterToTerminate

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

WaitForZKClusterToTerminate will wait until all zookeeper cluster pods are terminated

func WaitForZookeeperClusterToBecomeReady

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

WaitForZookeeperClusterToBecomeReady will wait until all zookeeper cluster pods are ready

func WriteAndReadData

func WriteAndReadData(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, p *api.PravegaCluster) error

WriteAndReadData writes sample data and reads it back from the given Pravega cluster