Update chart to support NATS Jetstream

Test by deploying chart with `--set nats.queueMode=jetstream`

Signed-off-by: Han Verstraete (OpenFaaS Ltd) <[email protected]>

Author: welteki

chart/openfaas/templates/nats-dep.yaml

@@ -29,7 +29,11 @@ spec:
       - name:  nats
         resources:
           {{- .Values.nats.resources | toYaml | nindent 12 }}
+        {{- if eq .Values.nats.queueMode "jetstream" }}
         image: {{ .Values.nats.image }}
+        {{- else }}
+        image: {{ .Values.stan.image }}
+        {{- end }}
         imagePullPolicy: {{ .Values.openfaasImagePullPolicy }}
         ports:
         - containerPort: 4222
@@ -38,12 +42,18 @@ spec:
         - containerPort: 8222
           protocol: TCP
         {{- end }}
+        {{- if not (eq .Values.nats.queueMode "jetstream") }}
         command: ["/nats-streaming-server"]
+        {{- end }}
         args:
+          {{- if eq .Values.nats.queueMode "jetstream" }}
+          - --js
+          {{- else}}
           - --store
           - memory
           - --cluster_id
           - faas-cluster
+          {{- end }}
           {{- if or .Values.nats.enableMonitoring .Values.nats.metrics.enabled }}
           - -m
           - "8222"
@@ -62,8 +72,12 @@ spec:
         - -routez
         - -subz
         - -varz
+        {{- if eq .Values.nats.queueMode "jetstream" }}
+        - -jsz=all
+        {{- else }}
         - -channelz
         - -serverz
+        {{- end }}
         - http://localhost:8222
       {{- end }}
     {{- with .Values.nodeSelector }}

chart/openfaas/values.yaml

@@ -226,15 +226,19 @@ alertmanager:
     limits:
       memory: "50Mi"
 
+stan:
+  image: nats-streaming:0.22.0
+
 # NATS is required for async
 nats:
   channel: "faas-request"
+  queueMode: ""
   external:
     clusterName: ""
     enabled: false
     host: ""
     port: ""
-  image: nats-streaming:0.22.0
+  image: nats:2.8.4
   enableMonitoring: false
   metrics:
     # Should stay off by default because the exporter is not multi-arch (yet)