refactor:replace traffic-engine.config.olap-address with traffic-engine.config.addresses.converter.
This commit is contained in:
@@ -18,7 +18,7 @@ TRAFFIC_VSYSTEM_ID={{ .Values.vsys_id }}
|
||||
COMPRESSION_TYPE="snappy"
|
||||
SASL_USERNAME="{{ .Values.external_resources.olap.kafka_brokers.sasl_username }}"
|
||||
SASL_PASSWD="{{ .Values.external_resources.olap.kafka_brokers.sasl_password }}"
|
||||
BROKER_LIST="{{- include "traffic-engine.config.olap-address" (list . ",") }}"
|
||||
BROKER_LIST="{{- include "traffic-engine.config.addresses.converter" (list .Values.external_resources.olap.kafka_brokers.addresses ",") }}"
|
||||
|
||||
{{- if eq .Values.firewall.logs.contains_app_id.enable .Values.define_enable_val_yes }}
|
||||
SEND_APP_ID_SWITCH=1
|
||||
|
||||
@@ -23,7 +23,7 @@
|
||||
[[outputs.kafka]]
|
||||
sasl_username = "{{ .Values.external_resources.olap.kafka_brokers.sasl_username }}"
|
||||
sasl_password = "{{ .Values.external_resources.olap.kafka_brokers.sasl_password }}"
|
||||
brokers = [ "{{- include "traffic-engine.config.olap-address" (list . "\",\"") }}" ]
|
||||
brokers = [ "{{- include "traffic-engine.config.addresses.converter" (list .Values.external_resources.olap.kafka_brokers.addresses "\",\"") }}" ]
|
||||
topic = "POLICY-RULE-METRIC"
|
||||
data_format = "json"
|
||||
json_timestamp_units = "1ms"
|
||||
|
||||
@@ -66,7 +66,7 @@
|
||||
[[outputs.kafka]]
|
||||
sasl_username = "{{ .Values.external_resources.olap.kafka_brokers.sasl_username }}"
|
||||
sasl_password = "{{ .Values.external_resources.olap.kafka_brokers.sasl_password }}"
|
||||
brokers = [ "{{- include "traffic-engine.config.olap-address" (list . "\",\"") }}" ]
|
||||
brokers = [ "{{- include "traffic-engine.config.addresses.converter" (list .Values.external_resources.olap.kafka_brokers.addresses "\",\"") }}" ]
|
||||
topic = "POLICY-RULE-METRIC"
|
||||
data_format = "json"
|
||||
json_timestamp_units = "1ms"
|
||||
|
||||
@@ -91,7 +91,7 @@
|
||||
[[outputs.kafka]]
|
||||
sasl_username = "{{ .Values.external_resources.olap.kafka_brokers.sasl_username }}"
|
||||
sasl_password = "{{ .Values.external_resources.olap.kafka_brokers.sasl_password }}"
|
||||
brokers = [ "{{- include "traffic-engine.config.olap-address" (list . "\",\"") }}" ]
|
||||
brokers = [ "{{- include "traffic-engine.config.addresses.converter" (list .Values.external_resources.olap.kafka_brokers.addresses "\",\"") }}" ]
|
||||
topic = "POLICY-RULE-METRIC"
|
||||
fielddrop = ["*pkts*max", "*bytes*max", "*session*max", "*queue*max", "*latency*sum"]
|
||||
data_format = "json"
|
||||
|
||||
@@ -177,7 +177,7 @@ default_vlan_id=0
|
||||
|
||||
[kafka]
|
||||
enable=1
|
||||
kafka_brokerlist={{- include "traffic-engine.config.olap-address" (list . ",") }}
|
||||
kafka_brokerlist={{- include "traffic-engine.config.addresses.converter" (list .Values.external_resources.olap.kafka_brokers.addresses ",") }}
|
||||
logger_send_topic=PROXY-EVENT
|
||||
file_bucket_topic=TRAFFIC-FILE-STREAM-RECORD
|
||||
mc_cache_topic=PXY-EXCH-INTERMEDIA-CERT
|
||||
|
||||
@@ -1,15 +1,3 @@
|
||||
{{- define "traffic-engine.config.olap-address" -}}
|
||||
{{- $kafka_brokers := list -}}
|
||||
{{- $separtor := index . 1 -}}
|
||||
{{- with index . 0 }}
|
||||
{{- range .Values.external_resources.olap.kafka_brokers.addresses -}}
|
||||
{{- $broker_address := ( print .address ":" .port ) -}}
|
||||
{{- $kafka_brokers = append $kafka_brokers $broker_address -}}
|
||||
{{- end -}}
|
||||
{{- end }}
|
||||
{{- join $separtor $kafka_brokers }}
|
||||
{{- end -}}
|
||||
|
||||
{{- define "traffic-engine.config.addresses.converter" -}}
|
||||
{{- $addresses := list -}}
|
||||
{{- $source := index . 0 -}}
|
||||
|
||||
Reference in New Issue
Block a user