service: seperate coordinator and worker service

Signed-off-by: Parsa Yousefi <[email protected]>

Author: parsa97

charts/trino/README.md

@@ -436,6 +436,14 @@ Fast distributed SQL query engine for big data analytics that helps you explore
   A list of the Linux kernel capabilities that are dropped from every container. Valid values are listed in [the capabilities manual page](https://man7.org/linux/man-pages/man7/capabilities.7.html). Ensure # to remove the "CAP_" prefix which the kernel attaches to the names of permissions.
 * `shareProcessNamespace.coordinator` - bool, default: `false`
 * `shareProcessNamespace.worker` - bool, default: `false`
+* `serviceCoordinator.annotations` - object, default: `{}`
+* `serviceCoordinator.type` - string, default: `"ClusterIP"`
+* `serviceCoordinator.port` - int, default: `8080`
+* `serviceCoordinator.nodePort` - string, default: `""`
+* `serviceWorker.annotations` - object, default: `{}`
+* `serviceWorker.type` - string, default: `"ClusterIP"`
+* `serviceWorker.port` - int, default: `8080`
+* `serviceWorker.nodePort` - string, default: `""`
 * `service.annotations` - object, default: `{}`
 * `service.type` - string, default: `"ClusterIP"`
 * `service.port` - int, default: `8080`

charts/trino/templates/service-coordinator.yaml

@@ -1,3 +1,4 @@
+{{- $svc := .Values.serviceCoordinator | default .Values.service }}
 {{- $coordinatorJmx := merge .Values.jmx.coordinator (omit .Values.jmx "coordinator" "worker") -}}
 apiVersion: v1
 kind: Service
@@ -8,16 +9,16 @@ metadata:
     {{- include "trino.labels" . | nindent 4 }}
     app.kubernetes.io/component: coordinator
   annotations:
-    {{- toYaml .Values.service.annotations | nindent 4 }}
+    {{- toYaml $svc.annotations | nindent 4 }}
 spec:
-  type: {{ .Values.service.type }}
+  type: {{ $svc.type }}
   ports:
-    - port: {{ .Values.service.port }}
+    - port: {{ $svc.port }}
       targetPort: http
       protocol: TCP
       name: http
-      {{- if .Values.service.nodePort }}
-      nodePort: {{ .Values.service.nodePort }}
+      {{- if $svc.nodePort }}
+      nodePort: {{ $svc.nodePort }}
       {{- end }}
     {{- if .Values.server.config.https.enabled }}
     - port: {{ .Values.server.config.https.port }}

charts/trino/templates/service-worker.yaml

@@ -1,3 +1,4 @@
+{{- $svc := .Values.serviceWorker | default .Values.service }}
 {{- $workerJmx := merge .Values.jmx.worker (omit .Values.jmx "coordinator" "worker") -}}
 apiVersion: v1
 kind: Service
@@ -8,11 +9,11 @@ metadata:
     {{- include "trino.labels" . | nindent 4 }}
     app.kubernetes.io/component: worker
   annotations:
-    {{- toYaml .Values.service.annotations | nindent 4 }}
+    {{- toYaml $svc.annotations | nindent 4 }}
 spec:
   clusterIP: None
   ports:
-    - port: {{ .Values.service.port }}
+    - port: {{ $svc.port }}
       targetPort: http
       protocol: TCP
       name: http

charts/trino/values.yaml

@@ -486,6 +486,24 @@ shareProcessNamespace:
   coordinator: false
   worker: false
 
+serviceCoordinator:
+  annotations: {}
+  type: ClusterIP
+  port: 8080
+  # service.nodePort -- The port the service listens on the host, for the `NodePort` type. If not set, Kubernetes will
+  # [allocate a port
+  # automatically](https://kubernetes.io/docs/concepts/services-networking/service/#nodeport-custom-port).
+  nodePort: ""
+
+serviceWorker:
+  annotations: {}
+  type: ClusterIP
+  port: 8080
+  # service.nodePort -- The port the service listens on the host, for the `NodePort` type. If not set, Kubernetes will
+  # [allocate a port
+  # automatically](https://kubernetes.io/docs/concepts/services-networking/service/#nodeport-custom-port).
+  nodePort: ""
+
 service:
   annotations: {}
   type: ClusterIP

tests/trino/test-values.yaml

@@ -44,6 +44,12 @@ additionalConfigProperties:
   - http-server.authentication.allow-insecure-over-http=true
   - http-server.process-forwarded=true
 
+
+serviceCoordinator:
+  annotations:
+    custom/coordinator: value
+  port: 8080
+
 service:
   annotations:
     custom/name: value