e2eutil

package

v0.3.3 Latest Latest Go to latest Published: Jun 23, 2017 License: Apache-2.0 Imports: 35 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/DataDog/etcd-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func CalculateRestoreWaitTime(needDataClone bool) time.Duration
func CheckEtcdData(t *testing.T, url string)
func ClusterWithBackup(cl *spec.Cluster, backupPolicy *spec.BackupPolicy) *spec.Cluster
func ClusterWithRestore(cl *spec.Cluster, restorePolicy *spec.RestorePolicy) *spec.Cluster
func ClusterWithSelfHosted(cl *spec.Cluster, sh *spec.SelfHostedPolicy) *spec.Cluster
func ClusterWithVersion(cl *spec.Cluster, version string) *spec.Cluster
func CreateCluster(t *testing.T, kubeClient kubernetes.Interface, namespace string, ...) (*spec.Cluster, error)
func DeleteCluster(t *testing.T, kubeClient kubernetes.Interface, cl *spec.Cluster) error
func DeleteClusterAndBackup(t *testing.T, kubecli kubernetes.Interface, cl *spec.Cluster, ...) 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 NewCluster(genName string, size int) *spec.Cluster
func NewOperatorS3BackupPolicy(cleanup bool) *spec.BackupPolicy
func NewPVBackupPolicy(cleanup bool) *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(kubeClient kubernetes.Interface, cl *spec.Cluster, maxRetries int, ...) (*spec.Cluster, error)
func WaitBackupDeleted(kubeClient kubernetes.Interface, cl *spec.Cluster, ...) error
func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, ...) error
func WaitPodsDeleted(kubecli kubernetes.Interface, namespace string, timeout time.Duration, ...) ([]*v1.Pod, error)
func WaitPodsWithImageDeleted(kubecli kubernetes.Interface, namespace, image string, timeout time.Duration, ...) ([]*v1.Pod, error)
func WaitSizeAndVersionReached(t *testing.T, kubeClient kubernetes.Interface, version string, size int, ...) error
func WaitUntilMembersWithNamesDeleted(t *testing.T, kubeClient kubernetes.Interface, timeout time.Duration, ...) ([]string, error)
func WaitUntilPodSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, ...) ([]string, error)
func WaitUntilSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, ...) ([]string, error)
type StorageCheckerOptions

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 WaitUntilMembersWithNamesDeleted ¶ added in v0.3.3

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

func WaitUntilPodSizeReached ¶ added in v0.3.3

func WaitUntilPodSizeReached(t *testing.T, kubeClient kubernetes.Interface, size int, timeout time.Duration, cl *spec.Cluster) ([]string, 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
}

Source Files ¶

View all Source files

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