e2eutil

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 * 3
)

Functions

func CheckPvcSanity

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

func CreateCluster

CreateCluster creates a PravegaCluster CR with the desired spec

func DeleteCluster

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

DeleteCluster deletes the PravegaCluster CR specified by cluster spec

func GetCluster

GetCluster returns the latest PravegaCluster CR

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 UpdateCluster

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

UpdateCluster updates the PravegaCluster CR

func WaitForClusterToBecomeReady

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

WaitForClusterToTerminate will wait until all cluster pods are terminated

func WaitForClusterToUpgrade

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

WaitForClusterToUpgrade will wait until all pods are upgraded

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL