v0.3.0 Latest Latest

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

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




This section is empty.


This section is empty.


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() *spec.BackupPolicy

func NewPVBackupPolicy added in v0.2.6

func NewPVBackupPolicy() *spec.BackupPolicy

func NewS3BackupPolicy added in v0.2.6

func NewS3BackupPolicy() *spec.BackupPolicy

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 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)


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