e2eutil

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2017 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CalculateRestoreWaitTime added in v0.3.0

func CalculateRestoreWaitTime(needDataClone bool) time.Duration

func CheckEtcdData added in v0.3.0

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

func ClusterWithBackup added in v0.2.6

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

func ClusterWithRestore added in v0.2.6

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

func ClusterWithSelfHosted added in v0.2.6

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

func ClusterWithVersion added in v0.2.6

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

func CreateCluster added in v0.2.6

func CreateCluster(t *testing.T, kubeClient kubernetes.Interface, namespace string, cl *spec.Cluster) (*spec.Cluster, error)

func DeleteCluster added in v0.2.6

func DeleteCluster(t *testing.T, kubeClient kubernetes.Interface, cl *spec.Cluster) error

func DeleteClusterAndBackup added in v0.3.0

func DeleteClusterAndBackup(t *testing.T, kubecli kubernetes.Interface, cl *spec.Cluster, checkerOpt StorageCheckerOptions) 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 MakeBackup added in v0.3.0

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

func NewCluster added in v0.2.6

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

func NewOperatorS3BackupPolicy added in v0.3.0

func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy

func NewPVBackupPolicy added in v0.2.6

func NewPVBackupPolicy(cleanup bool) *spec.BackupPolicy

func NewS3BackupPolicy added in v0.2.6

func NewS3BackupPolicy(cleanup bool) *spec.BackupPolicy

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 PutDataToEtcd added in v0.3.0

func PutDataToEtcd(url string) error

func UpdateCluster added in v0.2.6

func UpdateCluster(kubeClient kubernetes.Interface, cl *spec.Cluster, maxRetries int, updateFunc k8sutil.ClusterTPRUpdateFunc) (*spec.Cluster, error)

func WaitBackupDeleted added in v0.3.1

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

func WaitBackupPodUp added in v0.3.0

func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, timeout time.Duration) error

func WaitPodsDeleted added in v0.3.0

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

func WaitPodsWithImageDeleted added in v0.3.0

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

func WaitSizeAndVersionReached added in v0.2.6

func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, size int, timeout time.Duration, cl *spec.Cluster) error

func WaitUntilSizeReached added in v0.2.6

func WaitUntilSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, cl *spec.Cluster) ([]string, error)

Types

type StorageCheckerOptions added in v0.2.6

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

Jump to

Keyboard shortcuts

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