e2eutil

package

v0.5.0 Latest Latest Go to latest Published: Jul 27, 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/kraman/etcd-operator

Links

Open Source Insights

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) *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, kubeClient kubernetes.Interface, retries int, ...) ([]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, kubeClient kubernetes.Interface, size, retries int, ...) ([]string, error)
type StorageCheckerOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AtomicUpdateClusterCR ¶ added in v0.5.0

func AtomicUpdateClusterCR(crClient client.EtcdClusterCR, name, namespace string, maxRetries int, updateFunc k8sutil.EtcdClusterCRUpdateFunc) (*spec.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 ClusterWithBackup ¶ added in v0.2.6

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

func ClusterWithRestore ¶ added in v0.2.6

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

func ClusterWithSelfHosted ¶ added in v0.2.6

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

func ClusterWithVersion ¶ added in v0.2.6

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

func CreateCluster ¶ added in v0.2.6

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

func DeleteCluster ¶ added in v0.2.6

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

func DeleteClusterAndBackup ¶ added in v0.3.0

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

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

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

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

func WaitBackupDeleted ¶ added in v0.3.1

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

func WaitBackupPodUp ¶ added in v0.3.0

func WaitBackupPodUp(t *testing.T, kubecli kubernetes.Interface, ns, clusterName string, retries int) 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 *spec.EtcdCluster) error

func WaitUntilMembersWithNamesDeleted ¶ added in v0.3.3

func WaitUntilMembersWithNamesDeleted(t *testing.T, kubeClient kubernetes.Interface, retries int, cl *spec.EtcdCluster, targetNames ...string) ([]string, 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 *spec.EtcdCluster) ([]string, error)

func WaitUntilSizeReached ¶ added in v0.2.6

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

Types ¶

type StorageCheckerOptions ¶ added in v0.2.6

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

Source Files ¶

View all Source files

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