[logstash] add externalTrafficPolicy support (elastic#1570)

* [logstash] add externalTrafficPolicy support Fix elastic#1548 * fixup! [logstash] add externalTrafficPolicy support
jmlrt · Mar 2, 2022 · d0f2264 · d0f2264
1 parent 5a1d6a4
commit d0f2264
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/logstash/templates/service.yaml b/logstash/templates/service.yaml
@@ -19,6 +19,9 @@ spec:
 {{- with .Values.service.loadBalancerSourceRanges }}
   loadBalancerSourceRanges:
 {{ toYaml . | indent 4 }}
+{{- end }}
+{{- if .Values.service.externalTrafficPolicy }}
+  externalTrafficPolicy: {{ .Values.service.externalTrafficPolicy }}
 {{- end }}
   selector:
     app: "{{ template "logstash.fullname" . }}"

diff --git a/logstash/tests/logstash_test.py b/logstash/tests/logstash_test.py
@@ -964,6 +964,17 @@ def test_adding_a_service():
     assert "loadBalancerIP" not in s["spec"]
 
 
+def test_adding_an_externalTrafficPolicy():
+    config = """
+    service:
+      externalTrafficPolicy: Local
+    """
+
+    r = helm_template(config)
+
+    assert r["service"][name]["spec"]["externalTrafficPolicy"] == "Local"
+
+
 def test_setting_fullnameOverride():
     config = """
 fullnameOverride: 'logstash-custom'

diff --git a/logstash/values.yaml b/logstash/values.yaml
@@ -264,6 +264,7 @@ service: {}
 #  annotations: {}
 #  type: ClusterIP
 #  loadBalancerIP: ""
+#  externalTrafficPolicy: ""
 #  ports:
 #    - name: beats
 #      port: 5044