feat: Implement probes for all services

Author: PavelYadrov

operator/charts/helm/zookeeper-service/templates/deployment.yaml

@@ -53,6 +53,26 @@ spec:
               memory: {{ default "128Mi" .Values.operator.resources.requests.memory }}
           securityContext:
             {{- include "zookeeper-service.globalContainerSecurityContext" . | nindent 12 }}
+          livenessProbe:
+            httpGet:
+              path: /healthz
+              port: 8081
+              scheme: HTTP
+            initialDelaySeconds: 30
+            timeoutSeconds: 5
+            periodSeconds: 15
+            successThreshold: 1
+            failureThreshold: 5
+          readinessProbe:
+            httpGet:
+              path: /readyz
+              port: 8081
+              scheme: HTTP
+            initialDelaySeconds: 40
+            timeoutSeconds: 15
+            periodSeconds: 15
+            successThreshold: 1
+            failureThreshold: 5
       {{- if .Values.operator.affinity }}
       affinity:
         {{ .Values.operator.affinity | toJson }}
@@ -68,4 +88,4 @@ spec:
         {{- include "zookeeper-service.globalPodSecurityContext" . | nindent 8 }}
         {{- with .Values.operator.securityContext }}
         {{- toYaml . | nindent 8 -}}
-        {{- end }}
+        {{- end }}

operator/charts/helm/zookeeper-service/templates/integration_tests/deployment.yaml

@@ -159,6 +159,14 @@ spec:
             periodSeconds: 20
             successThreshold: 1
             failureThreshold: 5
+          livenessProbe:
+            tcpSocket:
+              port: 8080
+            initialDelaySeconds: 20
+            timeoutSeconds: 5
+            periodSeconds: 20
+            successThreshold: 1
+            failureThreshold: 5
       volumes:
         - name: output
           emptyDir: {}

operator/controllers/provider/monitoring_provider.go

@@ -22,6 +22,7 @@ import (
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/intstr"
 	"strconv"
 )
 
@@ -178,6 +179,8 @@ func (mrp MonitoringResourceProvider) NewMonitoringDeployment() *appsv1.Deployme
 							Command:         mrp.getCommand(),
 							Args:            mrp.getArgs(),
 							SecurityContext: getDefaultContainerSecurityContext(),
+							LivenessProbe:   mrp.getLivenessProbe(),
+							ReadinessProbe:  mrp.getReadinessProbe(),
 						},
 					},
 					SecurityContext:    &mrp.spec.SecurityContext,
@@ -340,3 +343,27 @@ func (mrp MonitoringResourceProvider) GetMonitoringCustomLabels(monitoringLabels
 func (mrp MonitoringResourceProvider) GetServiceAccountName() string {
 	return mrp.GetServiceName()
 }
+
+func (mrp MonitoringResourceProvider) getLivenessProbe() *corev1.Probe {
+	probe := mrp.getProbe()
+	probe.Handler = corev1.Handler{
+		TCPSocket: &corev1.TCPSocketAction{
+			Port: intstr.FromInt(8096),
+		},
+	}
+	return probe
+}
+
+func (mrp MonitoringResourceProvider) getReadinessProbe() *corev1.Probe {
+	return mrp.getLivenessProbe()
+}
+
+func (mrp MonitoringResourceProvider) getProbe() *corev1.Probe {
+	return &corev1.Probe{
+		InitialDelaySeconds: 30,
+		TimeoutSeconds:      5,
+		PeriodSeconds:       10,
+		SuccessThreshold:    1,
+		FailureThreshold:    5,
+	}
+}