swh/storage: update configmap for journal access

swh/templates/storage/configmap.yaml

@@ -32,4 +32,18 @@ data:
         objstorages:
         {{ .Values.storage.objstorageConfig }}
       {{- end }}
+      {{- if .Values.storage.journalWriter }}
+        {{- with .Values.storage.journalWriter }}
+      journal_writer:
+        cls: kafka
+        brokers:
+          {{- range $broker := .brokers }}
+          - {{ $broker }}
+          {{- end}}
+        prefix: {{ .prefix | default "swh.journal.objects" }}
+        client_id: {{ .clientId }}
+        anonymize: {{ .anonymize | default true }}
+        producer_config: {{ .producerConfig | nindent 10 }}
+        {{- end }}
+      {{- end }}
 {{- end -}}

swh/values.yaml

@@ -245,6 +245,22 @@ storage:
     # the hostname on which the storage must be reachable
     # host: mystorage.localdomain
 
+  ## if journal access is required
+  ## mandatory values
+  #journalWriter:
+  #  brokers:
+  #    - kafka1
+  #    - kafka2
+  #    - kafka3
+  #  clientId: swh.storage.journal_writer.storage1
+  #  producerConfig: |-
+  #    message.max.bytes: 1000000000
+  #    item2: value2
+  #    item3: value3
+  ## optional values with their default value
+  #  prefix: swh.journal.objects
+  #  anonymize: true
+
 web:
   enabled: false
   logLevel: INFO

swh/values/staging-cassandra.yaml

@@ -199,6 +199,13 @@ storage:
   gunicorn:
     threads: 4
     workers: 8
+  #journalWriter:
+  #  brokers:
+  #    - journal1.internal.staging.swh.network
+  #    - journal2.internal.staging.swh.network
+  #  clientId: swh.storage.journal_writer.storage
+  #  producerConfig: |-
+  #    message.max.bytes: 1000000000
 
 web:
   enabled: true