e2eutil

Documentation

Index

• func ClusterWithBackup(cl *spec.Cluster, backupPolicy *spec.BackupPolicy) *spec.Cluster
• func ClusterWithRestore(cl *spec.Cluster, restorePolicy *spec.RestorePolicy) *spec.Cluster
• func ClusterWithSelfHosted(cl *spec.Cluster, sh *spec.SelfHostedPolicy) *spec.Cluster
• func ClusterWithVersion(cl *spec.Cluster, version string) *spec.Cluster
• func CreateCluster(t *testing.T, kubeClient kubernetes.Interface, namespace string, ...) (*spec.Cluster, error)
• func DeleteCluster(t *testing.T, kubeClient kubernetes.Interface, cl *spec.Cluster, ...) error
• func LogfWithTimestamp(t *testing.T, format string, args ...interface{})
• func NewCluster(genName string, size int) *spec.Cluster
• func NewPVBackupPolicy() *spec.BackupPolicy
• func NewS3BackupPolicy() *spec.BackupPolicy
• func PreparePeerTLSSecret(clusterName, ns, secretName string) error
• func UpdateCluster(kubeClient kubernetes.Interface, cl *spec.Cluster, maxRetries int, ...) (*spec.Cluster, error)
• func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, size int, ...) error
• func WaitUntilSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, ...) ([]string, error)
• type StorageCheckerOptions

Functions

func ClusterWithBackup

func ClusterWithBackup(cl *spec.Cluster, backupPolicy *spec.BackupPolicy) *spec.Cluster

func ClusterWithRestore

func ClusterWithRestore(cl *spec.Cluster, restorePolicy *spec.RestorePolicy) *spec.Cluster

func ClusterWithSelfHosted

func ClusterWithSelfHosted(cl *spec.Cluster, sh *spec.SelfHostedPolicy) *spec.Cluster

func ClusterWithVersion

func ClusterWithVersion(cl *spec.Cluster, version string) *spec.Cluster

func CreateCluster

func CreateCluster(t *testing.T, kubeClient kubernetes.Interface, namespace string, cl *spec.Cluster) (*spec.Cluster, error)

func DeleteCluster

func DeleteCluster(t *testing.T, kubeClient kubernetes.Interface, cl *spec.Cluster, storageCheckerOptions *StorageCheckerOptions) error

func LogfWithTimestamp

func LogfWithTimestamp(t *testing.T, format string, args ...interface{})

func NewCluster

func NewCluster(genName string, size int) *spec.Cluster

func NewPVBackupPolicy

func NewPVBackupPolicy() *spec.BackupPolicy

func NewS3BackupPolicy

func NewS3BackupPolicy() *spec.BackupPolicy

func PreparePeerTLSSecret

func PreparePeerTLSSecret(clusterName, ns, secretName string) error

func UpdateCluster

func UpdateCluster(kubeClient kubernetes.Interface, cl *spec.Cluster, maxRetries int, updateFunc k8sutil.ClusterTPRUpdateFunc) (*spec.Cluster, error)

func WaitSizeAndVersionReached

func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, size int, timeout time.Duration, cl *spec.Cluster) error

func WaitUntilSizeReached

func WaitUntilSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, cl *spec.Cluster) ([]string, error)

Types

type StorageCheckerOptions

type StorageCheckerOptions struct {
	S3Cli    *s3.S3
	S3Bucket string
}