1- {{- if and (eq .Values.messageBroker.type "mqtt") .Values.mqtt.enabled -}}
2- ---
3- apiVersion : v1
4- kind : Service
5- metadata :
6- name : {{ .Values.mqtt.service.name }}
7- labels :
8- {{- include "maestro-server.labels" . | nindent 4 }}
9- annotations :
10- template.openshift.io/expose-uri : tcp://{.spec.clusterIP}:{.spec.ports[?(.name==\mosquitto\)].port}
11- spec :
12- ports :
13- - name : mosquitto
14- protocol : TCP
15- port : {{ .Values.mqtt.service.port }}
16- targetPort : {{ .Values.mqtt.service.port }}
17- selector :
18- name : {{ .Values.mqtt.service.name }}
19- type : ClusterIP
20- ---
21- apiVersion : apps/v1
22- kind : Deployment
23- metadata :
24- name : {{ .Values.mqtt.service.name }}
25- labels :
26- {{- include "maestro-server.labels" . | nindent 4 }}
27- spec :
28- replicas : 1
29- selector :
30- matchLabels :
31- name : {{ .Values.mqtt.service.name }}
32- strategy :
33- type : Recreate
34- template :
35- metadata :
36- labels :
37- name : {{ .Values.mqtt.service.name }}
38- spec :
39- serviceAccountName : {{ include "maestro-server.serviceAccountName" . }}
40- containers :
41- - image : {{ .Values.mqtt.image }}
42- imagePullPolicy : IfNotPresent
43- name : mosquitto
44- ports :
45- - containerPort : {{ .Values.mqtt.service.port }}
46- name : mosquitto
47- volumeMounts :
48- - name : mosquitto-persistent-storage
49- mountPath : /mosquitto/data
50- - name : mosquitto-config
51- mountPath : /mosquitto/config/mosquitto.conf
52- subPath : mosquitto.conf
53- {{- if .Values.mqtt.tls.enabled }}
54- - name : mosquitto-certs
55- mountPath : /mosquitto/certs
56- readOnly : true
57- {{- end }}
58- volumes :
59- - name : mosquitto-persistent-storage
60- emptyDir : {}
61- - name : mosquitto-config
62- configMap :
63- name : {{ .Values.mqtt.service.name }}
64- {{- if .Values.mqtt.tls.enabled }}
65- - name : mosquitto-certs
66- secret :
67- secretName : maestro-mqtt-certs
68- {{- end }}
69- ---
70- apiVersion : v1
71- kind : ConfigMap
72- metadata :
73- name : {{ .Values.mqtt.service.name }}
74- labels :
75- {{- include "maestro-server.labels" . | nindent 4 }}
76- data :
77- mosquitto.conf : |
78- listener {{ .Values.mqtt.service.port }} 0.0.0.0
79- {{- if .Values.mqtt.tls.enabled }}
80- cafile /mosquitto/certs/ca.crt
81- certfile /mosquitto/certs/server.crt
82- keyfile /mosquitto/certs/server.key
83- require_certificate true
84- use_identity_as_username true
85- {{- else }}
86- allow_anonymous true
87- {{- end }}
1+ {{- if and (eq .Values.messageBroker.type "mqtt") .Values.messageBroker.secretName }}
882---
893apiVersion : v1
904kind : Secret
@@ -94,19 +8,25 @@ metadata:
948 {{- include "maestro-server.labels" . | nindent 4 }}
959stringData :
9610 config.yaml : |
97- brokerHost: {{ .Values.mqtt.host }}:{{ .Values.mqtt.service .port }}
98- {{- if .Values.mqtt.user }}
99- username: {{ .Values.mqtt.user }}
11+ brokerHost: {{ .Values.messageBroker. mqtt.host }}:{{ .Values.messageBroker.mqtt .port }}
12+ {{- if .Values.messageBroker. mqtt.user }}
13+ username: {{ .Values.messageBroker. mqtt.user }}
10014 {{- end }}
101- {{- if .Values.mqtt.password }}
102- password: {{ .Values.mqtt.password }}
15+ {{- if .Values.messageBroker. mqtt.password }}
16+ password: {{ .Values.messageBroker. mqtt.password }}
10317 {{- end }}
104- {{- if .Values.mqtt.tls.enabled }}
105- caFile: {{ .Values.mqtt.tls.caFile }}
106- clientCertFile: {{ .Values.mqtt.tls.clientCertFile }}
107- clientKeyFile: {{ .Values.mqtt.tls.clientKeyFile }}
18+ {{- if .Values.messageBroker. mqtt.tls.enabled }}
19+ caFile: {{ .Values.messageBroker. mqtt.tls.caFile }}
20+ clientCertFile: {{ .Values.messageBroker. mqtt.tls.clientCertFile }}
21+ clientKeyFile: {{ .Values.messageBroker. mqtt.tls.clientKeyFile }}
10822 {{- end }}
23+ {{- if .Values.messageBroker.mqtt.topics }}
10924 topics:
110- sourceEvents: sources/maestro/consumers/+/sourceevents
111- agentEvents: {{ .Values.mqtt.agentTopic }}
25+ {{- if .Values.messageBroker.mqtt.topics.sourceEvents }}
26+ sourceEvents: {{ .Values.messageBroker.mqtt.topics.sourceEvents }}
27+ {{- end }}
28+ {{- if .Values.messageBroker.mqtt.topics.agentEvents }}
29+ agentEvents: {{ .Values.messageBroker.mqtt.topics.agentEvents }}
30+ {{- end }}
31+ {{- end }}
11232{{- end }}
0 commit comments