feat: jetstream eventbus (#589)

* feat: jetstream eventbus

Author: mikhail-klimko

charts/gitops-runtime/templates/eventbus/codefresh-eventbus.yaml

@@ -1,5 +1,6 @@
 {{- $eventBusName := default "codefresh-eventbus" .Values.global.runtime.eventBus.name }}
 {{- $eventBusSpec := .Values.global.runtime.eventBus }}
+{{- $eventBusType := .Values.global.runtime.eventBus.type }}
 {{/* Remove name from eventbus spec */}}
 {{- if hasKey $eventBusSpec "name" }}
 {{- $eventBusSpec = unset $eventBusSpec "name" }}
@@ -8,12 +9,22 @@
 {{- if hasKey $eventBusSpec "pdb" }}
 {{- $eventBusSpec = unset $eventBusSpec "pdb" }}
 {{- end }}
+{{/* Remove annotations from eventbus spec */}}
 {{- if hasKey $eventBusSpec "annotations" }}
 {{- $eventBusSpec = unset $eventBusSpec "annotations" }}
 {{- end }}
 
-{{- $_ := set $eventBusSpec.nats.native "nodeSelector" ($eventBusSpec.nats.native.nodeSelector | default .Values.global.nodeSelector) }}
-{{- $_ := set $eventBusSpec.nats.native "tolerations" ($eventBusSpec.nats.native.tolerations | default .Values.global.tolerations) }}
+{{- if eq $eventBusType "nats" }}
+  {{- $eventBusSpec = unset $eventBusSpec "jetstream" }}
+  {{- $_ := set $eventBusSpec.nats.native "nodeSelector" ($eventBusSpec.nats.native.nodeSelector | default .Values.global.nodeSelector) }}
+  {{- $_ := set $eventBusSpec.nats.native "tolerations" ($eventBusSpec.nats.native.tolerations | default .Values.global.tolerations) }}
+{{- end }}
+
+{{- if eq $eventBusType "jetstream" }}
+  {{- $eventBusSpec = unset $eventBusSpec "nats" }}
+  {{- $_ := set $eventBusSpec.jetstream "nodeSelector" ($eventBusSpec.jetstream.nodeSelector | default .Values.global.nodeSelector) }}
+  {{- $_ := set $eventBusSpec.jetstream "tolerations" ($eventBusSpec.jetstream.tolerations | default .Values.global.tolerations) }}
+{{- end }}
 
 apiVersion: argoproj.io/v1alpha1
 kind: EventBus

charts/gitops-runtime/tests/eventbus_test.yaml

@@ -0,0 +1,28 @@
+# yaml-language-server: $schema=https://raw.githubusercontent.com/helm-unittest/helm-unittest/main/schema/helm-testsuite.json
+suite: eventbus tests
+templates:
+  - eventbus/codefresh-eventbus.yaml
+tests:
+  - it: Should create an EventBus with the correct type (nats)
+    template: eventbus/codefresh-eventbus.yaml
+    values:
+      - ./values/mandatory-values.yaml
+    set:
+      global.runtime.eventBus.type: nats
+    asserts:
+      - exists:
+          path: spec.nats
+      - notExists:
+          path: spec.jetstream
+
+  - it: Should create an EventBus with the correct type (jetstream)
+    template: eventbus/codefresh-eventbus.yaml
+    values:
+      - ./values/mandatory-values.yaml
+    set:
+      global.runtime.eventBus.type: jetstream
+    asserts:
+      - exists:
+          path: spec.jetstream
+      - notExists:
+          path: spec.nats

charts/gitops-runtime/values.yaml

@@ -89,6 +89,7 @@ global:
         enabled: true
         # -- Minimum number of available eventbus pods. For eventbus to stay functional the majority of its replicas should always be available.
         minAvailable: 2
+      type: nats # -- Eventbus type. Can be nats or jetstream.
       nats:
         native:
           nodeSelector: {}
@@ -107,6 +108,24 @@ global:
                 cpu: 200m
                 memory: 1Gi
                 ephemeral-storage: 2Gi
+      jetstream:
+        version: latest
+        nodeSelector: {}
+        tolerations: []
+        affinity: {}
+        replicas: 3
+        maxPayload: "4MB"
+        containerTemplate:
+          resources:
+            limits:
+              cpu: 500m
+              memory: 4Gi
+              ephemeral-storage: 2Gi
+            requests:
+              cpu: 200m
+              memory: 1Gi
+              ephemeral-storage: 2Gi
+
   # -- Configuration for external ArgoCD
   # Should be used when `argo-cd.enabled` is set to false
   external-argo-cd: