e2eutil

Documentation

Index

• func AtomicUpdateClusterCR(crClient client.NatsClusterCR, name, namespace string, maxRetries int, ...) (*spec.NatsCluster, error)
• func ClusterWithSize(cl *spec.NatsCluster, size int) *spec.NatsCluster
• func ClusterWithVersion(cl *spec.NatsCluster, version string) *spec.NatsCluster
• func CreateCluster(t *testing.T, crClient client.NatsClusterCR, namespace string, ...) (*spec.NatsCluster, error)
• func DeleteCluster(t *testing.T, crClient client.NatsClusterCR, kubeClient corev1.CoreV1Interface, ...) error
• func DeleteSecrets(kubecli corev1.CoreV1Interface, namespace string, secretNames ...string) error
• func KillMembers(kubecli corev1.CoreV1Interface, namespace string, names ...string) error
• func LogfWithTimestamp(t *testing.T, format string, args ...interface{})
• func NameLabelSelector(name string) map[string]string
• func NewCluster(genName string, size int) *spec.NatsCluster
• func UpdateCluster(crClient client.NatsClusterCR, cl *spec.NatsCluster, maxRetries int, ...) (*spec.NatsCluster, error)
• func WaitPodsDeleted(kubecli corev1.CoreV1Interface, namespace string, retries int, ...) ([]*v1.Pod, error)
• func WaitUntilOperatorReady(kubecli corev1.CoreV1Interface, namespace, name string) error
• func WaitUntilPodSizeAndRoutesReached(t *testing.T, kubeClient corev1.CoreV1Interface, size, retries int, ...) ([]string, error)
• func WaitUntilPodSizeAndVersionAndRoutesReached(t *testing.T, kubeClient corev1.CoreV1Interface, version string, ...) error
• func WaitUntilPodSizeReached(t *testing.T, kubeClient corev1.CoreV1Interface, size, retries int, ...) ([]string, error)

Functions

func AtomicUpdateClusterCR

func AtomicUpdateClusterCR(crClient client.NatsClusterCR, name, namespace string, maxRetries int, updateFunc kubernetesutil.NatsClusterCRUpdateFunc) (*spec.NatsCluster, error)

func ClusterWithSize

func ClusterWithSize(cl *spec.NatsCluster, size int) *spec.NatsCluster

func ClusterWithVersion

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

func CreateCluster

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

func DeleteCluster

func DeleteCluster(t *testing.T, crClient client.NatsClusterCR, kubeClient corev1.CoreV1Interface, cl *spec.NatsCluster) error

func DeleteSecrets

func DeleteSecrets(kubecli corev1.CoreV1Interface, namespace string, secretNames ...string) error

func KillMembers

func KillMembers(kubecli corev1.CoreV1Interface, namespace string, names ...string) error

func LogfWithTimestamp

func LogfWithTimestamp(t *testing.T, format string, args ...interface{})

func NameLabelSelector

func NameLabelSelector(name string) map[string]string

NameLabelSelector returns a label selector of the form name=<name>

func NewCluster

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

func UpdateCluster

func UpdateCluster(crClient client.NatsClusterCR, cl *spec.NatsCluster, maxRetries int, updateFunc kubernetesutil.NatsClusterCRUpdateFunc) (*spec.NatsCluster, error)

func WaitPodsDeleted

func WaitPodsDeleted(kubecli corev1.CoreV1Interface, namespace string, retries int, lo metav1.ListOptions) ([]*v1.Pod, error)

func WaitUntilOperatorReady

func WaitUntilOperatorReady(kubecli corev1.CoreV1Interface, namespace, name string) error

WaitUntilOperatorReady will wait until the first pod selected for the label name=nats-operator is ready.

func WaitUntilPodSizeAndRoutesReached

func WaitUntilPodSizeAndRoutesReached(t *testing.T, kubeClient corev1.CoreV1Interface, size, retries int, cl *spec.NatsCluster) ([]string, error)

func WaitUntilPodSizeAndVersionAndRoutesReached

func WaitUntilPodSizeAndVersionAndRoutesReached(t *testing.T, kubeClient corev1.CoreV1Interface, version string, size, retries int, cl *spec.NatsCluster) error

func WaitUntilPodSizeReached

func WaitUntilPodSizeReached(t *testing.T, kubeClient corev1.CoreV1Interface, size, retries int, cl *spec.NatsCluster) ([]string, error)