support optional env which dictates status check url format

Makefile

@@ -11,6 +11,8 @@ BUNDLE_DEFAULT_CHANNEL := --default-channel=$(DEFAULT_CHANNEL)
 endif
 BUNDLE_METADATA_OPTS ?= $(BUNDLE_CHANNELS) $(BUNDLE_DEFAULT_CHANNEL)
 
+# Kubernetes cluster domain
+K6_CLUSTER_DOMAIN ?= ".cluster.local"
 # Image to use for building Go
 GO_BUILDER_IMG ?= "golang:1.17"
 # Image URL to use all building/pushing image targets
@@ -78,7 +80,8 @@ uninstall: manifests kustomize
 # Deploy controller in the configured Kubernetes cluster in ~/.kube/config
 deploy: manifests kustomize
 	cd config/manager && $(KUSTOMIZE) edit set image controller=${IMG}
-	$(KUSTOMIZE) build config/default | kubectl apply -f -
+	export K6_CLUSTER_DOMAIN=$(K6_CLUSTER_DOMAIN); \
+		$(KUSTOMIZE) build config/default | envsubst | kubectl apply -f -
 
 # Delete operator from a cluster
 delete: manifests kustomize
@@ -102,7 +105,8 @@ generate: controller-gen
 
 # Build the docker image
 docker-build: test
-	docker build . -t ${IMG} -f ${DOCKERFILE} --build-arg GO_BUILDER_IMG=${GO_BUILDER_IMG}
+	docker build . -t ${IMG} -f ${DOCKERFILE} \
+		--build-arg GO_BUILDER_IMG=${GO_BUILDER_IMG}
 
 # Push the docker image
 docker-push:

README.md

@@ -15,6 +15,15 @@ Install the operator by running the command below:
 $ make deploy
 ```
 
+_note:_ by default K6 assumes your kubernetes cluster domain is .cluster.local.
+If your Kubernetes cluster uses something else, e.g. `.cluster.example` you can
+override this with the environment variable `K6_CLUSTER_DOMAIN`. e.g.
+
+```bash
+export K6_CLUSTER_DOMAIN=.cluster.example
+make deploy
+```
+
 ### Installing the CRD
 
 The k6 operator includes one custom resource called `K6`. This will be automatically installed when you do a

config/manager/manager.yaml

@@ -32,6 +32,9 @@ spec:
             - --enable-leader-election
           image: controller:latest
           name: manager
+          env:
+            - name: K6_CLUSTER_DOMAIN
+              value: $K6_CLUSTER_DOMAIN
           resources:
             limits:
               cpu: 100m

controllers/k6_start.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"net/http"
+	"os"
 	"time"
 
 	"github.com/go-logr/logr"
@@ -17,7 +18,17 @@ import (
 )
 
 func isServiceReady(log logr.Logger, service *v1.Service) bool {
-	resp, err := http.Get(fmt.Sprintf("http://%v.%v.svc.cluster.local:6565/v1/status", service.ObjectMeta.Name, service.ObjectMeta.Namespace))
+	clusterDomain := ".cluster.local"
+	if envClusterDomain, ok := os.LookupEnv("K6_CLUSTER_DOMAIN"); ok {
+		clusterDomain = envClusterDomain
+	}
+	resp, err := http.Get(
+		fmt.Sprintf(
+			"http://%s.%s.svc"+clusterDomain+":6565/v1/status",
+			service.ObjectMeta.Name,
+			service.ObjectMeta.Namespace,
+		),
+	)
 
 	if err != nil {
 		log.Error(err, fmt.Sprintf("failed to get status from %v", service.ObjectMeta.Name))