utils

Documentation

Index

• func ConfigMap(name, namespace string, labels, data map[string]string) *corev1.ConfigMap
• func GenerateUUID() string
• func GetFileContents(filePath string) []byte
• func Secret(secretName string, namespace string, data map[string][]byte) *corev1.Secret
• func WaitForClusterStatusCondition(t *testing.T, f client.Client, namespace, name string, ...) error
• func WaitForDeployment(t *testing.T, f client.Client, namespace, name string, replicas int, ...) error
• func WaitForIndexReplicas(t *testing.T, kubeclient kubernetes.Interface, namespace, clusterName string, ...) error
• func WaitForIndexTemplateReplicas(t *testing.T, kubeclient kubernetes.Interface, namespace, clusterName string, ...) error
• func WaitForNodeStatusCondition(t *testing.T, f client.Client, namespace, name string, ...) error
• func WaitForPods(t *testing.T, f client.Client, namespace string, labels map[string]string, ...) (*corev1.PodList, error)
• func WaitForReadyDeployment(t *testing.T, kubeclient client.Client, namespace, name string, replicas int, ...) error
• func WaitForRolloutComplete(t *testing.T, f client.Client, namespace string, labels map[string]string, ...) (*corev1.PodList, error)
• func WaitForStatefulset(t *testing.T, kubeclient client.Client, namespace, name string, replicas int, ...) error

Functions

func ConfigMap

func ConfigMap(name, namespace string, labels, data map[string]string) *corev1.ConfigMap

func GenerateUUID

func GenerateUUID() string

func GetFileContents

func GetFileContents(filePath string) []byte

func Secret

func Secret(secretName string, namespace string, data map[string][]byte) *corev1.Secret

func WaitForClusterStatusCondition

func WaitForClusterStatusCondition(t *testing.T, f client.Client, namespace, name string, condition loggingv1.ClusterCondition, retryInterval, timeout time.Duration) error

func WaitForDeployment

func WaitForDeployment(t *testing.T, f client.Client, namespace, name string, replicas int,
	retryInterval, timeout time.Duration) error

func WaitForIndexReplicas

func WaitForIndexReplicas(t *testing.T, kubeclient kubernetes.Interface, namespace, clusterName string, replicas int32, retryInterval, timeout time.Duration) error

func WaitForIndexTemplateReplicas

func WaitForIndexTemplateReplicas(t *testing.T, kubeclient kubernetes.Interface, namespace, clusterName string, replicas int32, retryInterval, timeout time.Duration) error

func WaitForNodeStatusCondition

func WaitForNodeStatusCondition(t *testing.T, f client.Client, namespace, name string, condition loggingv1.ElasticsearchNodeUpgradeStatus, retryInterval, timeout time.Duration) error

func WaitForPods

func WaitForPods(t *testing.T, f client.Client, namespace string, labels map[string]string, retryInterval, timeout time.Duration) (*corev1.PodList, error)

func WaitForReadyDeployment

func WaitForReadyDeployment(t *testing.T, kubeclient client.Client, namespace, name string, replicas int,
	retryInterval, timeout time.Duration) error

func WaitForRolloutComplete

func WaitForRolloutComplete(t *testing.T, f client.Client, namespace string, labels map[string]string, excludePods []string, expectedPodCount int, retryInterval, timeout time.Duration) (*corev1.PodList, error)

func WaitForStatefulset

func WaitForStatefulset(t *testing.T, kubeclient client.Client, namespace, name string, replicas int, retryInterval, timeout time.Duration) error