e2eutil

Documentation

Index

• func CalculateRestoreWaitTime(needDataClone bool) time.Duration
• func CheckEtcdData(t *testing.T, url string)
• 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 DeleteClusterAndBackup(t *testing.T, kubecli kubernetes.Interface, cl *spec.Cluster, ...) error
• func KillMembers(kubecli kubernetes.Interface, namespace string, names ...string) error
• func LogfWithTimestamp(t *testing.T, format string, args ...interface{})
• func MakeBackup(kubecli kubernetes.Interface, ns, clusterName string) error
• func NewCluster(genName string, size int) *spec.Cluster
• func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy
• func NewPVBackupPolicy(cleanup bool) *spec.BackupPolicy
• func NewS3BackupPolicy(cleanup bool) *spec.BackupPolicy
• func PrepareClientTLSSecret(dir, clusterName, ns, mSecret, oSecret string) error
• func PreparePeerTLSSecret(clusterName, ns, secretName string) error
• func PutDataToEtcd(url string) error
• func UpdateCluster(kubeClient kubernetes.Interface, cl *spec.Cluster, maxRetries int, ...) (*spec.Cluster, error)
• func WaitBackupDeleted(kubeClient kubernetes.Interface, cl *spec.Cluster, ...) error
• func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, ...) error
• func WaitPodsDeleted(kubecli kubernetes.Interface, namespace string, timeout time.Duration, ...) ([]*v1.Pod, error)
• func WaitPodsWithImageDeleted(kubecli kubernetes.Interface, namespace, image string, timeout time.Duration, ...) ([]*v1.Pod, 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 CalculateRestoreWaitTime

func CalculateRestoreWaitTime(needDataClone bool) time.Duration

func CheckEtcdData

func CheckEtcdData(t *testing.T, url string)

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) error

func DeleteClusterAndBackup

func DeleteClusterAndBackup(t *testing.T, kubecli kubernetes.Interface, cl *spec.Cluster, checkerOpt StorageCheckerOptions) error

func KillMembers

func KillMembers(kubecli kubernetes.Interface, namespace string, names ...string) error

func LogfWithTimestamp

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

func MakeBackup

func MakeBackup(kubecli kubernetes.Interface, ns, clusterName string) error

func NewCluster

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

func NewOperatorS3BackupPolicy

func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy

func NewPVBackupPolicy

func NewPVBackupPolicy(cleanup bool) *spec.BackupPolicy

func NewS3BackupPolicy

func NewS3BackupPolicy(cleanup bool) *spec.BackupPolicy

func PrepareClientTLSSecret

func PrepareClientTLSSecret(dir, clusterName, ns, mSecret, oSecret string) error

func PreparePeerTLSSecret

func PreparePeerTLSSecret(clusterName, ns, secretName string) error

func PutDataToEtcd

func PutDataToEtcd(url string) error

func UpdateCluster

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

func WaitBackupDeleted

func WaitBackupDeleted(kubeClient kubernetes.Interface, cl *spec.Cluster, storageCheckerOptions StorageCheckerOptions) error

func WaitBackupPodUp

func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, timeout time.Duration) error

func WaitPodsDeleted

func WaitPodsDeleted(kubecli kubernetes.Interface, namespace string, timeout time.Duration, lo metav1.ListOptions) ([]*v1.Pod, error)

func WaitPodsWithImageDeleted

func WaitPodsWithImageDeleted(kubecli kubernetes.Interface, namespace, image string, timeout time.Duration, lo metav1.ListOptions) ([]*v1.Pod, 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
}