e2eutil

Documentation

Index

• Variables
• func CreateCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.PravegaCluster, error)
• func DeleteCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) error
• func GetCluster(t *testing.T, f *framework.Framework, ctx *framework.TestCtx, ...) (*api.PravegaCluster, 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 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
• 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 * 3
)

Functions

func CreateCluster

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

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

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

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