Inject app runtime supervisor address as env var

Signed-off-by: Rafal Lal <rafall@splunk.com>

Author: rafal-lal

pkg/splunk/enterprise/configuration.go

@@ -951,6 +951,10 @@ func updateSplunkPodTemplateWithConfig(ctx context.Context, client splcommon.Con
 		{Name: livenessProbeDriverPathEnv, Value: GetLivenessDriverFilePath()},
 		{Name: "SPLUNK_GENERAL_TERMS", Value: os.Getenv("SPLUNK_GENERAL_TERMS")},
 		{Name: "SPLUNK_SKIP_CLUSTER_BUNDLE_PUSH", Value: "true"},
+		{
+			Name:  "SPLUNK_APPRUNTIME_HEADLESS_SERVICE_FQDN",
+			Value: GetSplunkAppRuntimeServiceFQDN(cr.GetNamespace(), instanceType, cr.GetName()),
+		},
 	}
 
 	// update variables for licensing, if configured

pkg/splunk/enterprise/names.go

@@ -253,6 +253,17 @@ func GetSplunkServiceName(instanceType InstanceType, identifier string, isHeadle
 	return result
 }
 
+// GetSplunkAppRuntimeServiceName uses a template to name the headless Kubernetes Service for Splunk App Runtime instances.
+func GetSplunkAppRuntimeServiceName(instanceType InstanceType, identifier string) string {
+	appRuntimeInstanceType := fmt.Sprintf("%s-appruntime", instanceType)
+	return fmt.Sprintf(serviceTemplateStr, identifier, appRuntimeInstanceType, "headless")
+}
+
+// GetSplunkAppRuntimeServiceFQDN returns the fully qualified domain name for the headless Kubernetes service for Splunk App Runtime instances.
+func GetSplunkAppRuntimeServiceFQDN(namespace string, instanceType InstanceType, identifier string) string {
+	return splcommon.GetServiceFQDN(namespace, GetSplunkAppRuntimeServiceName(instanceType, identifier))
+}
+
 // GetSplunkDefaultsName uses a template to name a Kubernetes ConfigMap for a SplunkEnterprise resource.
 func GetSplunkDefaultsName(identifier string, instanceType InstanceType) string {
 	return fmt.Sprintf(defaultsTemplateStr, identifier, instanceType.ToKind())

pkg/splunk/enterprise/names_test.go

@@ -70,6 +70,27 @@ func TestGetSplunkServiceName(t *testing.T) {
 	test("splunk-stack1-license-manager-service", SplunkLicenseManager, LicenseManagerRefName, false)
 }
 
+func TestGetSplunkAppRuntimeServiceName(t *testing.T) {
+	test := func(want string, instanceType InstanceType, identifier string) {
+		got := GetSplunkAppRuntimeServiceName(instanceType, identifier)
+		if got != want {
+			t.Errorf("GetSplunkAppRuntimeServiceName(\"%s\",\"%s\") = %s; want %s",
+				instanceType.ToString(), identifier, got, want)
+		}
+	}
+
+	test("splunk-t1-standalone-appruntime-headless", SplunkStandalone, "t1")
+	test("splunk-t2-cluster-manager-appruntime-headless", SplunkClusterManager, "t2")
+}
+
+func TestGetSplunkAppRuntimeServiceFQDN(t *testing.T) {
+	want := "splunk-t1-search-head-appruntime-headless.splunktest.svc.cluster.local"
+	got := GetSplunkAppRuntimeServiceFQDN("splunktest", SplunkSearchHead, "t1")
+	if got != want {
+		t.Errorf("GetSplunkAppRuntimeServiceFQDN() = %s; want %s", got, want)
+	}
+}
+
 func TestGetSplunkDefaultsName(t *testing.T) {
 	got := GetSplunkDefaultsName("t1", SplunkSearchHead)
 	want := "splunk-t1-search-head-defaults"