e2eutil

Jul 27, 2017

Changes in this version

+ func AtomicUpdateClusterCR(crClient client.EtcdClusterCR, name, namespace string, maxRetries int, ...) (*spec.EtcdCluster, error)

+ func NameLabelSelector(name string) map[string]string

+ func WaitUntilOperatorReady(kubecli kubernetes.Interface, namespace, name string) error

Jul 11, 2017

Changes in this version

+ func DeleteSecrets(kubecli kubernetes.Interface, namespace string, secretNames ...string) error

+ func WaitPodsDeletedCompletely(kubecli kubernetes.Interface, namespace string, timeout time.Duration, ...) ([]*v1.Pod, error)

type StorageCheckerOptions

+ DeletedFromAPI bool

Jun 23, 2017

Changes in this version

+ func WaitUntilMembersWithNamesDeleted(t *testing.T, kubeClient kubernetes.Interface, timeout time.Duration, ...) ([]string, error)

+ func WaitUntilPodSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, ...) ([]string, error)

Jun 6, 2017

Changes in this version

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

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

May 17, 2017

Changes in this version

+ func CalculateRestoreWaitTime(needDataClone bool) time.Duration

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

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

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

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

+ func NewOperatorS3BackupPolicy() *spec.BackupPolicy

+ func PutDataToEtcd(url string) 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)

May 3, 2017

Changes in this version

+ 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 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 struct

+ S3Bucket string

+ S3Cli *s3.S3

Apr 24, 2017

Changes in this version

+ func PreparePeerTLSSecret(clusterName, ns, secretName string) error