{{/* Define the pulsar autorecovery service */}} {{- define "pulsar.autorecovery.service" -}} {{ template "pulsar.fullname" . }}-{{ .Values.autorecovery.component }} {{- end }} {{/* Define the autorecovery hostname */}} {{- define "pulsar.autorecovery.hostname" -}} ${HOSTNAME}.{{ template "pulsar.autorecovery.service" . }}.{{ .Values.namespace }}.svc.cluster.local {{- end -}} {{/* Define autorecovery zookeeper client tls settings */}} {{- define "pulsar.autorecovery.zookeeper.tls.settings" -}} {{- if and .Values.tls.enabled .Values.tls.zookeeper.enabled }} /pulsar/keytool/keytool.sh autorecovery {{ template "pulsar.autorecovery.hostname" . }} true; {{- end }} {{- end }} {{/* Define autorecovery tls certs mounts */}} {{- define "pulsar.autorecovery.certs.volumeMounts" -}} {{- if and .Values.tls.enabled .Values.tls.zookeeper.enabled }} - name: autorecovery-certs mountPath: "/pulsar/certs/autorecovery" readOnly: true - name: ca mountPath: "/pulsar/certs/ca" readOnly: true {{- if .Values.tls.zookeeper.enabled }} - name: keytool mountPath: "/pulsar/keytool/keytool.sh" subPath: keytool.sh {{- end }} {{- end }} {{- end }} {{/* Define autorecovery tls certs volumes */}} {{- define "pulsar.autorecovery.certs.volumes" -}} {{- if and .Values.tls.enabled .Values.tls.zookeeper.enabled }} - name: autorecovery-certs secret: secretName: "{{ template "pulsar.fullname" . }}-{{ .Values.tls.autorecovery.cert_name }}" items: - key: tls.crt path: tls.crt - key: tls.key path: tls.key - name: ca secret: secretName: "{{ template "pulsar.fullname" . }}-ca-tls" items: - key: ca.crt path: ca.crt {{- if .Values.tls.zookeeper.enabled }} - name: keytool configMap: name: "{{ template "pulsar.fullname" . }}-keytool-configmap" defaultMode: 0755 {{- end }} {{- end }} {{- end }} {{/* Define autorecovery init container : verify cluster id */}} {{- define "pulsar.autorecovery.init.verify_cluster_id" -}} bin/apply-config-from-env.py conf/bookkeeper.conf; {{- include "pulsar.autorecovery.zookeeper.tls.settings" . -}} until bin/bookkeeper shell whatisinstanceid; do sleep 3; done; {{- end }}