Versions in this module Expand all Collapse all v0 v0.9.4 Feb 28, 2019 Changes in this version + func AtomicUpdateClusterCR(crClient versioned.Interface, name, namespace string, maxRetries int, ...) (*api.EtcdCluster, error) + func CalculateRestoreWaitTime(needDataClone bool) int + func CheckEtcdData(t *testing.T, url string) + func ClusterCRWithTLS(cl *api.EtcdCluster, ...) + func ClusterWithVersion(cl *api.EtcdCluster, version string) *api.EtcdCluster + func CreateCluster(t *testing.T, crClient versioned.Interface, namespace string, ...) (*api.EtcdCluster, error) + func DeleteBackupFiles(wr writer.Writer, files []string) error + func DeleteCluster(t *testing.T, crClient versioned.Interface, kubeClient kubernetes.Interface, ...) error + func DeleteSecrets(kubecli kubernetes.Interface, namespace string, secretNames ...string) error + func KillMembers(kubecli kubernetes.Interface, namespace string, names ...string) error + func LogfWithTimestamp(t *testing.T, format string, args ...interface{}) + func NameLabelSelector(name string) map[string]string + func NewCluster(genName string, size int) *api.EtcdCluster + func NewEtcdRestore(clusterName string, size int, restoreSource api.RestoreSource, ...) *api.EtcdRestore + func NewS3Backup(endpoints []string, clusterName, path, secret, clientTLSSecret string) *api.EtcdBackup + func NewS3RestoreSource(path, awsSecret string) *api.S3RestoreSource + func PrepareClientTLSSecret(dir, clusterName, ns, mSecret, oSecret string) error + func PreparePeerTLSSecret(clusterName, ns, secretName string) error + func PrepareTLS(clusterName, namespace, memberPeerTLSSecret, memberClientTLSSecret, ... string) error + func PutDataToEtcd(url string) error + func UpdateCluster(crClient versioned.Interface, cl *api.EtcdCluster, maxRetries int, ...) (*api.EtcdCluster, error) + func WaitPodsDeleted(kubecli kubernetes.Interface, namespace string, retries int, ...) ([]*v1.Pod, error) + func WaitPodsDeletedCompletely(kubecli kubernetes.Interface, namespace string, retries int, ...) ([]*v1.Pod, error) + func WaitPodsWithImageDeleted(kubecli kubernetes.Interface, namespace, image string, retries int, ...) ([]*v1.Pod, error) + func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, ...) error + func WaitUntilMembersWithNamesDeleted(t *testing.T, crClient versioned.Interface, retries int, cl *api.EtcdCluster, ...) ([]string, error) + func WaitUntilNoBackupFiles(wr writer.Writer, path string, timeout int) error + func WaitUntilOperatorReady(kubecli kubernetes.Interface, namespace, name string) error + func WaitUntilPodSizeReached(t *testing.T, kubeClient kubernetes.Interface, size, retries int, ...) ([]string, error) + func WaitUntilSizeReached(t *testing.T, crClient versioned.Interface, size, retries int, ...) ([]string, error) + type StorageCheckerOptions struct + DeletedFromAPI bool + S3Bucket string + S3Cli *s3.S3