headless PublishNotReadyAddresses

Signed-off-by: Jordan Rodgers <jrodgers@mux.com>

Author: com6056

k8sutils/services.go

@@ -55,6 +55,7 @@ func generateServiceDef(serviceMeta metav1.ObjectMeta, epp exporterPortProvider,
 	}
 	if headless {
 		service.Spec.ClusterIP = "None"
+		service.Spec.PublishNotReadyAddresses = true
 	}
 	if exporterPort, ok := epp(); ok {
 		redisExporterService := enableMetricsPort(exporterPort)

k8sutils/services_test.go

@@ -102,9 +102,10 @@ func TestGenerateServiceDef(t *testing.T) {
 							Protocol:   corev1.ProtocolTCP,
 						},
 					},
-					Selector:  map[string]string{"role": "sentinel"},
-					ClusterIP: "None",
-					Type:      corev1.ServiceTypeClusterIP,
+					Selector:                 map[string]string{"role": "sentinel"},
+					ClusterIP:                "None",
+					Type:                     corev1.ServiceTypeClusterIP,
+					PublishNotReadyAddresses: true,
 				},
 			},
 		},
@@ -184,9 +185,10 @@ func TestGenerateServiceDef(t *testing.T) {
 							Protocol:   corev1.ProtocolTCP,
 						},
 					},
-					Selector:  map[string]string{"role": "redis"},
-					ClusterIP: "None",
-					Type:      corev1.ServiceTypeClusterIP,
+					Selector:                 map[string]string{"role": "redis"},
+					ClusterIP:                "None",
+					Type:                     corev1.ServiceTypeClusterIP,
+					PublishNotReadyAddresses: true,
 				},
 			},
 		},