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() *spec.BackupPolicy
• func NewPVBackupPolicy() *spec.BackupPolicy
• func NewS3BackupPolicy() *spec.BackupPolicy
• 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 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() *spec.BackupPolicy

func NewPVBackupPolicy

func NewPVBackupPolicy() *spec.BackupPolicy

func NewS3BackupPolicy

func NewS3BackupPolicy() *spec.BackupPolicy

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 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
}