e2eutil

package
v0.9.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2019 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AtomicUpdateClusterCR added in v0.5.0

func AtomicUpdateClusterCR(crClient versioned.Interface, name, namespace string, maxRetries int, updateFunc k8sutil.EtcdClusterCRUpdateFunc) (*api.EtcdCluster, error)

func CalculateRestoreWaitTime added in v0.3.0

func CalculateRestoreWaitTime(needDataClone bool) int

func CheckEtcdData added in v0.3.0

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

func ClusterCRWithTLS added in v0.7.1

func ClusterCRWithTLS(cl *api.EtcdCluster, memberPeerTLSSecret, memberServerTLSSecret, operatorClientTLSSecret string)

ClusterCRWithTLS adds TLSPolicy to the passing in cluster CR.

func ClusterWithVersion added in v0.2.6

func ClusterWithVersion(cl *api.EtcdCluster, version string) *api.EtcdCluster

func CreateCluster added in v0.2.6

func CreateCluster(t *testing.T, crClient versioned.Interface, namespace string, cl *api.EtcdCluster) (*api.EtcdCluster, error)

func DeleteBackupFiles added in v0.9.4

func DeleteBackupFiles(wr writer.Writer, files []string) error

func DeleteCluster added in v0.2.6

func DeleteCluster(t *testing.T, crClient versioned.Interface, kubeClient kubernetes.Interface, cl *api.EtcdCluster) error

func DeleteSecrets added in v0.4.1

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

func KillMembers added in v0.3.0

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

func LogfWithTimestamp added in v0.2.6

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

func NameLabelSelector added in v0.5.0

func NameLabelSelector(name string) map[string]string

NameLabelSelector returns a label selector of the form name=<name>

func NewCluster added in v0.2.6

func NewCluster(genName string, size int) *api.EtcdCluster

func NewEtcdRestore added in v0.7.0

func NewEtcdRestore(clusterName string, size int, restoreSource api.RestoreSource, backupStorageType api.BackupStorageType) *api.EtcdRestore

NewEtcdRestore returns an EtcdRestore CR with the specified RestoreSource

func NewS3Backup added in v0.7.0

func NewS3Backup(endpoints []string, clusterName, path, secret, clientTLSSecret string) *api.EtcdBackup

NewS3Backup creates a EtcdBackup object using clusterName.

func NewS3RestoreSource added in v0.7.0

func NewS3RestoreSource(path, awsSecret string) *api.S3RestoreSource

NewS3RestoreSource returns an S3RestoreSource with the specified path and secret

func PrepareClientTLSSecret added in v0.3.1

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

func PreparePeerTLSSecret

func PreparePeerTLSSecret(clusterName, ns, secretName string) error

func PrepareTLS added in v0.7.1

func PrepareTLS(clusterName, namespace, memberPeerTLSSecret, memberClientTLSSecret, operatorClientTLSSecret string) error

PrepareTLS creates all the required tls certs for a given clusterName.

func PutDataToEtcd added in v0.3.0

func PutDataToEtcd(url string) error

func UpdateCluster added in v0.2.6

func UpdateCluster(crClient versioned.Interface, cl *api.EtcdCluster, maxRetries int, updateFunc k8sutil.EtcdClusterCRUpdateFunc) (*api.EtcdCluster, error)

func WaitPodsDeleted added in v0.3.0

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

func WaitPodsDeletedCompletely added in v0.4.1

func WaitPodsDeletedCompletely(kubecli kubernetes.Interface, namespace string, retries int, lo metav1.ListOptions) ([]*v1.Pod, error)

func WaitPodsWithImageDeleted added in v0.3.0

func WaitPodsWithImageDeleted(kubecli kubernetes.Interface, namespace, image string, retries int, lo metav1.ListOptions) ([]*v1.Pod, error)

func WaitSizeAndVersionReached added in v0.2.6

func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, size, retries int, cl *api.EtcdCluster) error

func WaitUntilMembersWithNamesDeleted added in v0.3.3

func WaitUntilMembersWithNamesDeleted(t *testing.T, crClient versioned.Interface, retries int, cl *api.EtcdCluster, targetNames ...string) ([]string, error)

func WaitUntilNoBackupFiles added in v0.9.4

func WaitUntilNoBackupFiles(wr writer.Writer, path string, timeout int) error

func WaitUntilOperatorReady added in v0.5.0

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

WaitUntilOperatorReady will wait until the first pod selected for the label name=etcd-operator is ready.

func WaitUntilPodSizeReached added in v0.3.3

func WaitUntilPodSizeReached(t *testing.T, kubeClient kubernetes.Interface, size, retries int, cl *api.EtcdCluster) ([]string, error)

func WaitUntilSizeReached added in v0.2.6

func WaitUntilSizeReached(t *testing.T, crClient versioned.Interface, size, retries int, cl *api.EtcdCluster) ([]string, error)

Types

type StorageCheckerOptions added in v0.2.6

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL