e2eutil

Documentation

Index

• func AtomicUpdateClusterCR(crClient client.EtcdClusterCR, name, namespace string, maxRetries int, ...) (*spec.EtcdCluster, error)
• func CalculateRestoreWaitTime(needDataClone bool) int
• func CheckEtcdData(t *testing.T, url string)
• func ClusterWithBackup(cl *spec.EtcdCluster, backupPolicy *spec.BackupPolicy) *spec.EtcdCluster
• func ClusterWithRestore(cl *spec.EtcdCluster, restorePolicy *spec.RestorePolicy) *spec.EtcdCluster
• func ClusterWithSelfHosted(cl *spec.EtcdCluster, sh *spec.SelfHostedPolicy) *spec.EtcdCluster
• func ClusterWithVersion(cl *spec.EtcdCluster, version string) *spec.EtcdCluster
• func CreateCluster(t *testing.T, crClient client.EtcdClusterCR, namespace string, ...) (*spec.EtcdCluster, error)
• func DeleteCluster(t *testing.T, crClient client.EtcdClusterCR, kubeClient kubernetes.Interface, ...) error
• func DeleteClusterAndBackup(t *testing.T, crClient client.EtcdClusterCR, kubecli 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 MakeBackup(kubecli kubernetes.Interface, ns, clusterName string) error
• func NameLabelSelector(name string) map[string]string
• func NewCluster(genName string, size int) *spec.EtcdCluster
• func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy
• func NewPVBackupPolicy(cleanup bool, storageClass string) *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(crClient client.EtcdClusterCR, cl *spec.EtcdCluster, maxRetries int, ...) (*spec.EtcdCluster, error)
• func WaitBackupDeleted(kubeClient kubernetes.Interface, cl *spec.EtcdCluster, ...) error
• func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, ...) 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 client.EtcdClusterCR, retries int, cl *spec.EtcdCluster, ...) ([]string, 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 client.EtcdClusterCR, size, retries int, ...) ([]string, error)
• type StorageCheckerOptions

Functions

func AtomicUpdateClusterCR

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

func CalculateRestoreWaitTime

func CalculateRestoreWaitTime(needDataClone bool) int

func CheckEtcdData

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

func ClusterWithBackup

func ClusterWithBackup(cl *spec.EtcdCluster, backupPolicy *spec.BackupPolicy) *spec.EtcdCluster

func ClusterWithRestore

func ClusterWithRestore(cl *spec.EtcdCluster, restorePolicy *spec.RestorePolicy) *spec.EtcdCluster

func ClusterWithSelfHosted

func ClusterWithSelfHosted(cl *spec.EtcdCluster, sh *spec.SelfHostedPolicy) *spec.EtcdCluster

func ClusterWithVersion

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

func CreateCluster

func CreateCluster(t *testing.T, crClient client.EtcdClusterCR, namespace string, cl *spec.EtcdCluster) (*spec.EtcdCluster, error)

func DeleteCluster

func DeleteCluster(t *testing.T, crClient client.EtcdClusterCR, kubeClient kubernetes.Interface, cl *spec.EtcdCluster) error

func DeleteClusterAndBackup

func DeleteClusterAndBackup(t *testing.T, crClient client.EtcdClusterCR, kubecli kubernetes.Interface, cl *spec.EtcdCluster, checkerOpt StorageCheckerOptions) error

func DeleteSecrets

func DeleteSecrets(kubecli kubernetes.Interface, namespace string, secretNames ...string) 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 NameLabelSelector

func NameLabelSelector(name string) map[string]string

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

func NewCluster

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

func NewOperatorS3BackupPolicy

func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy

func NewPVBackupPolicy

func NewPVBackupPolicy(cleanup bool, storageClass string) *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(crClient client.EtcdClusterCR, cl *spec.EtcdCluster, maxRetries int, updateFunc k8sutil.EtcdClusterCRUpdateFunc) (*spec.EtcdCluster, error)

func WaitBackupDeleted

func WaitBackupDeleted(kubeClient kubernetes.Interface, cl *spec.EtcdCluster, checkerOpt StorageCheckerOptions) error

func WaitBackupPodUp

func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, retries int) error

func WaitPodsDeleted

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

func WaitPodsDeletedCompletely

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

func WaitPodsWithImageDeleted

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

func WaitSizeAndVersionReached

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

func WaitUntilMembersWithNamesDeleted

func WaitUntilMembersWithNamesDeleted(t *testing.T, crClient client.EtcdClusterCR, retries int, cl *spec.EtcdCluster, targetNames ...string) ([]string, error)

func WaitUntilOperatorReady

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

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

func WaitUntilSizeReached

func WaitUntilSizeReached(t *testing.T, crClient client.EtcdClusterCR, size, retries int, cl *spec.EtcdCluster) ([]string, error)

Types

type StorageCheckerOptions

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