ByCoordinates returns a field selector that can be used to filter Kubernetes resources based on their name and namespace.

ClientServiceName returns the name of the client service based on the specified cluster name.

We are using internal api types for cluster related.

ConfigSecret returns the name of the secret that contains the configuration for the NATS cluster with the specified name.

CreateAndWaitPod is an util for testing.

CreateConfigSecret creates the secret that contains the configuration file for a given NATS cluster..

CreateMgmtService creates an headless service for NATS management purposes.

ExecInContainer runs a command in the specified container, blocking until the command finishes execution or the specified context times out.

InitCRDs registers the CRDs for the nats.io/v1alpha2 API and waits for them to become ready.

IsPodReady returns false if the Pod Status is nil.

LabelSelectorForCluster returns a label selector that matches resources belonging to the NATS cluster with the specified name.

MustNewKubeClientFromConfig builds a Kubernetes client based on the specified configuration object.

MustNewKubeConfig builds a configuration object by either reading from the specified kubeconfig file or by using an in-cluster config.

MustNewKubeExtClient creates a new client for the apiextensions.k8s.io/v1 API.

MustNewNatsClientFromConfig builds a client for our API based on the specified configuration object.

NatsServiceRoleLabelSelectorForCuster returns a label selector that matches NatsServiceRole resources referencing the NATS cluster with the specified name.

NewNatsPodSpec returns a NATS peer pod specification, based on the cluster specification.

PodWithAntiAffinity sets pod anti-affinity with the pods in the same NATS cluster.

ResourceKey returns the "namespace/name" key that represents the specified resource.

UniquePodName generates a unique name for the Pod.

UpdateConfigSecret applies the new configuration of the cluster, such as modifying the routes available in the cluster.

WaitCRDs waits for the CRDs to become ready.

WaitUntilDeploymentCondition establishes a watch on the specified deployment and blocks until the specified condition function is satisfied.

WaitUntilPodCondition establishes a watch on the specified pod and blocks until the specified condition function is satisfied.

WaitUntilPodReady establishes a watch on the specified pod and blocks until the pod is running, ready and has its ".status.podIP" field populated.

NatsClusterCRUpdateFunc is a function to be used when atomically updating a Cluster CR.