################################################################################
#   Copyright (c) 2021 Nordix Foundation.                                      #
#                                                                              #
#   Licensed under the Apache License, Version 2.0 (the "License");            #
#   you may not use this file except in compliance with the License.           #
#   You may obtain a copy of the License at                                    #
#                                                                              #
#       http://www.apache.org/licenses/LICENSE-2.0                             #
#                                                                              #
#   Unless required by applicable law or agreed to in writing, software        #
#   distributed under the License is distributed on an "AS IS" BASIS,          #
#   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
#   See the License for the specific language governing permissions and        #
#   limitations under the License.                                             #
################################################################################

kind: StatefulSet
apiVersion: apps/v1
metadata: {{- include "common.resourceMetadata" . | nindent 2 }}
spec:
  serviceName: {{ include "common.name" . }}
  replicas: 1
  selector: {{- include "common.selectors" . | nindent 4 }}
  template:
    metadata: {{- include "common.templateMetadata" . | nindent 6 }}
    spec:
      hostname: {{ include "common.name" . }}
      {{- if .Values.dmaapTopicInit.enabled }}
      initContainers: {{- include "dmaapTopic.initContainer" . | nindent 6 }}
      {{- end }}
      containers:
      - name: {{ include "common.containername" . }}
        image: {{ .Values.image.registry }}/{{ .Values.image.name }}:{{ .Values.image.tag }}
        imagePullPolicy: {{ .Values.imagePullPolicy }}
        ports: {{- include "common.containerPorts" . | nindent 8 }}
        {{- /* Only the info producer port is active */ -}}
        {{- include "common.tcpsocketProbes" (dict "port" ((first .Values.service.ports).internalPort_tls) "dot" .) | nindent 8 }}
        volumeMounts:
        - name: {{ include "common.name" . }}-dmaapmediator-data
          mountPath: /configs/type_config.json
          subPath: type_config.json
        env:
          - name: INFO_PRODUCER_HOST
            value: "{{ default (print "https://" ( include "common.name" . )) .Values.infoProducerHost }}"
          - name: INFO_PRODUCER_PORT
            value: "{{ default (first .Values.service.ports).internalPort_tls .Values.infoProducerPort }}"
          - name: INFO_COORD_ADDR
            value: "{{ .Values.infoCoordinatorAddr }}"
          - name: DMAAP_MR_ADDR
            value: "{{ .Values.dmaapMrAddr }}"
          - name: LOG_LEVEL
            value: "{{ .Values.logLevel }}"
      volumes:
        - name: {{ include "common.name" . }}-dmaapmediator-data
          configMap:
            name: {{ include "common.name" . }}-type-configmap
        {{- if .Values.dmaapTopicInit.enabled -}}
        {{- include "dmaapTopic.initVolume" . | nindent 8 }}
        {{- end }}