e2eutil

package
v0.5.7 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2023 License: Apache-2.0 Imports: 20 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 * 10
	UpgradeTimeout       = time.Minute * 10
	TerminateTimeout     = time.Minute * 2
	VerificationTimeout  = time.Minute * 5
)

Functions

func CheckConfigMapUpdated added in v0.5.3 

func CheckConfigMapUpdated(t *testing.T, k8client client.Client, pravega *api.PravegaCluster, cmName string, key string, values []string) error

func CheckExternalAccesss added in v0.5.3 

func CheckExternalAccesss(t *testing.T, k8client client.Client, pravega *api.PravegaCluster) error

CheckExternalAccesss Checks if External Access is enabled or not

func CheckServiceExists added in v0.5.3 

func CheckServiceExists(t *testing.T, k8client client.Client, pravega *api.PravegaCluster, svcName string) error

func CheckStsExists added in v0.5.3 

func CheckStsExists(t *testing.T, k8client client.Client, pravega *api.PravegaCluster, stsName string) error

func CreateBKCluster added in v0.5.2 

func CreateBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

CreateBKCluster creates a BookkeeperCluster CR with the desired spec

func CreatePravegaCluster added in v0.5.2 

func CreatePravegaCluster(t *testing.T, k8client client.Client, p *api.PravegaCluster) (*api.PravegaCluster, error)

CreatePravegaCluster creates a PravegaCluster CR with the desired spec

func CreatePravegaClusterForExternalAccess added in v0.5.3 

func CreatePravegaClusterForExternalAccess(t *testing.T, k8client client.Client, p *api.PravegaCluster) (*api.PravegaCluster, error)

CreatePravegaClusterForExternalAccess creates a PravegaCluster CR with the desired spec for ExternalAccess

func CreatePravegaClusterWithTls added in v0.5.3 

func CreatePravegaClusterWithTls(t *testing.T, k8client client.Client, p *api.PravegaCluster) (*api.PravegaCluster, error)

CreatePravegaClusterWithTls creates a PravegaCluster CR with the desired spec for tls

func CreatePravegaClusterWithTlsAuth added in v0.5.3 

func CreatePravegaClusterWithTlsAuth(t *testing.T, k8client client.Client, p *api.PravegaCluster) (*api.PravegaCluster, error)

CreatePravegaClusterWithTlsAuth creates a PravegaCluster CR with the desired spec for both Auth and Tls

func CreateZKCluster added in v0.5.2 

func CreateZKCluster(t *testing.T, k8client client.Client, z *zkapi.ZookeeperCluster) (*zkapi.ZookeeperCluster, error)

CreateZKCluster creates a ZookeeperCluster CR with the desired spec

func DeleteBKCluster added in v0.5.2 

func DeleteBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

DeleteBKCluster deletes the BookkeeperCluster CR specified by cluster spec

func DeletePods added in v0.5.3 

func DeletePods(t *testing.T, k8client client.Client, p *api.PravegaCluster, size int) error

func DeletePravegaCluster added in v0.5.2 

func DeletePravegaCluster(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

DeletePravegaCluster deletes the PravegaCluster CR specified by cluster spec

func DeleteZKCluster added in v0.5.2 

func DeleteZKCluster(t *testing.T, k8client client.Client, z *zkapi.ZookeeperCluster) error

DeleteZKCluster deletes the ZookeeperCluster CR specified by cluster spec

func GetBKCluster added in v0.5.2 

func GetBKCluster(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) (*bkapi.BookkeeperCluster, error)

GetBKCluster returns the latest BookkeeperCluster CR

func GetDeployment added in v0.5.4 

func GetDeployment(t *testing.T, k8client client.Client, deployName string) (*appsv1.Deployment, error)

GetDeployment returns the deployment

func GetPravegaCluster added in v0.5.2 

func GetPravegaCluster(t *testing.T, k8client client.Client, p *api.PravegaCluster) (*api.PravegaCluster, error)

GetPravegaCluster returns the latest PravegaCluster CR

func GetSts added in v0.5.4 

func GetSts(t *testing.T, k8client client.Client, stsName string) (*appsv1.StatefulSet, error)

GetSts returns the sts

func GetZKCluster added in v0.5.2 

func GetZKCluster(t *testing.T, k8client client.Client, z *zkapi.ZookeeperCluster) (*zkapi.ZookeeperCluster, error)

GetZKCluster returns the latest ZookeeperCluster CR

func InitialSetup added in v0.5.2 

func InitialSetup(t *testing.T, k8client client.Client, namespace string) error

func NewClusterWithNoSegmentStoreCpuLimits added in v0.5.6 

func NewClusterWithNoSegmentStoreCpuLimits(namespace string) *api.PravegaCluster

func NewClusterWithNoSegmentStoreMemoryLimits added in v0.5.6 

func NewClusterWithNoSegmentStoreMemoryLimits(namespace string) *api.PravegaCluster

func NewClusterWithVersion 

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

func NewDefaultCluster 

func NewDefaultCluster(namespace string) *api.PravegaCluster

NewDefaultCluster returns a cluster with some of the fields already filled in spec and the remaining fields 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, k8client client.Client, namespace string) error

func UpdatePravegaCluster added in v0.5.2 

func UpdatePravegaCluster(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

UpdatePravegaCluster updates the PravegaCluster CR

func UpdatePravegaClusterRollback added in v0.5.3 

func UpdatePravegaClusterRollback(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

UpdatePravegaClusterRollback updates the PravegaCluster CR for Rollback

func WaitForBKClusterToTerminate added in v0.5.2 

func WaitForBKClusterToTerminate(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster) error

WaitForBKClusterToTerminate will wait until all Bookkeeper cluster pods are terminated

func WaitForBookkeeperClusterToBecomeReady added in v0.5.2 

func WaitForBookkeeperClusterToBecomeReady(t *testing.T, k8client client.Client, b *bkapi.BookkeeperCluster, size int) error

WaitForBooClusterToBecomeReady will wait until all Bookkeeper cluster pods are ready

func WaitForCMPravegaClusterToUpgrade added in v0.5.2 

func WaitForCMPravegaClusterToUpgrade(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

func WaitForPravegaClusterToBecomeReady added in v0.5.2 

func WaitForPravegaClusterToBecomeReady(t *testing.T, k8client client.Client, p *api.PravegaCluster, size int) error

WaitForPravegaClusterToBecomeReady will wait until all cluster pods are ready

func WaitForPravegaClusterToFailUpgrade added in v0.5.3 

func WaitForPravegaClusterToFailUpgrade(t *testing.T, k8client client.Client, p *api.PravegaCluster, targetVersion string) error

WaitForPravegaClusterToFailUpgrade will wait till Upgrade Fails

func WaitForPravegaClusterToRollback added in v0.5.3 

func WaitForPravegaClusterToRollback(t *testing.T, k8client client.Client, p *api.PravegaCluster, targetVersion string) error

WaitForPravegaClusterToRollback will wait until all pods have completed Rollback

func WaitForPravegaClusterToTerminate added in v0.5.2 

func WaitForPravegaClusterToTerminate(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

WaitForPravegaClusterToTerminate will wait until all cluster pods are terminated

func WaitForPravegaClusterToUpgrade added in v0.5.2 

func WaitForPravegaClusterToUpgrade(t *testing.T, k8client client.Client, p *api.PravegaCluster, targetVersion string) error

WaitForPravegaClusterToUpgrade will wait until all pods are upgraded

func WaitForZKClusterToTerminate added in v0.5.2 

func WaitForZKClusterToTerminate(t *testing.T, k8client client.Client, z *zkapi.ZookeeperCluster) error

WaitForZKClusterToTerminate will wait until all zookeeper cluster pods are terminated

func WaitForZookeeperClusterToBecomeReady added in v0.5.2 

func WaitForZookeeperClusterToBecomeReady(t *testing.T, k8client client.Client, z *zkapi.ZookeeperCluster, size int) error

WaitForZookeeperClusterToBecomeReady will wait until all zookeeper cluster pods are ready

func WriteAndReadData 

func WriteAndReadData(t *testing.T, k8client client.Client, p *api.PravegaCluster) error

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

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.