Added ingress support to the logstash chart

logstash/README.md

@@ -92,6 +92,8 @@ in this [note][]).
 to make default probes work. If restricting HTTP API to 127.0.0.1 is required by
 using `http.host: 127.0.0.1`, default probes should be disabled or overrided
 (see [values.yaml][] for the good syntax).
+* An ingress is provided that can be used to expose the HTTP port. This can be 
+useful for the [http input plugin][], for instance.
 
 
 ## Configuration
@@ -111,9 +113,10 @@ using `http.host: 127.0.0.1`, default probes should be disabled or overrided
 | `httpPort`                | The http port that Kubernetes will use for the healthchecks and the service                                                                                                                                                          | `9600`                                |
 | `imagePullPolicy`         | The Kubernetes [imagePullPolicy][] value                                                                                                                                                                                             | `IfNotPresent`                        |
 | `imagePullSecrets`        | Configuration for [imagePullSecrets][] so that you can use a private registry for your image                                                                                                                                         | `[]`                                  |
-| `imageTag`                | The Logstash Docker image tag                                                                                                                                                                                                        | `8.0.0-SNAPSHOT`                               |
+| `imageTag`                | The Logstash Docker image tag                                                                                                                                                                                                        | `8.0.0-SNAPSHOT`                      |
 | `image`                   | The Logstash Docker image                                                                                                                                                                                                            | `docker.elastic.co/logstash/logstash` |
 | `labels`                  | Configurable [labels][] applied to all Logstash pods                                                                                                                                                                                 | `{}`                                  |
+| `ingress`                 | Configurable [ingress][] for external access to Logstash HTTP port.                                                                                                                                                                  | see [values.yaml][]                   |
 | `lifecycle`               | Allows you to add lifecycle configuration. See [values.yaml][] for an example of the formatting                                                                                                                                      | `{}`                                  |
 | `livenessProbe`           | Configuration fields for the liveness [probe][]                                                                                                                                                                                      | see [values.yaml][]                   |
 | `logstashConfig`          | Allows you to add any config files in `/usr/share/logstash/config/` such as `logstash.yml` and `log4j2.properties` See [values.yaml][] for an example of the formatting                                                              | `{}`                                  |
@@ -200,8 +203,10 @@ about our development and testing process.
 [examples/oss]: https://github.com/elastic/helm-charts/tree/master/logstash/examples/oss
 [helm]: https://helm.sh
 [helm 3 (beta)]: https://github.com/elastic/helm-charts/tree/master/README.md#helm-3-beta
+[http input plugin]: https://www.elastic.co/guide/en/logstash/current/plugins-inputs-http.html
 [imagePullPolicy]: https://kubernetes.io/docs/concepts/containers/images/#updating-images
 [imagePullSecrets]: https://kubernetes.io/docs/tasks/configure-pod-container/pull-image-private-registry/#create-a-pod-that-uses-your-secret
+[ingress]: https://kubernetes.io/docs/concepts/services-networking/ingress/
 [kubernetes secrets]: https://kubernetes.io/docs/concepts/configuration/secret/
 [labels]: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/
 [logstash docker image]: https://www.elastic.co/guide/en/logstash/current/docker.html

logstash/templates/_helpers.tpl

@@ -29,3 +29,14 @@ Return the appropriate apiVersion for statefulset.
 {{- print "apps/v1" -}}
 {{- end -}}
 {{- end -}}
+
+{{/*
+Return the appropriate apiVersion for ingress.
+*/}}
+{{- define "logstash.ingress.apiVersion" -}}
+{{- if semverCompare "<1.14-0" .Capabilities.KubeVersion.GitVersion -}}
+{{- print "extensions/v1beta1" -}}
+{{- else -}}
+{{- print "networking.k8s.io/v1beta1" -}}
+{{- end -}}
+{{- end -}}

logstash/templates/ingress.yaml

@@ -0,0 +1,34 @@
+{{- if .Values.ingress.enabled -}}
+{{- $fullName := include "logstash.fullname" . -}}
+{{- $ingressPath := .Values.ingress.path -}}
+apiVersion: {{ template "logstash.ingress.apiVersion" . }}
+kind: Ingress
+metadata:
+  name: {{ $fullName }}
+  labels:
+    app: {{ $fullName | quote}}
+    chart: "{{ .Chart.Name }}"
+    heritage: {{ .Release.Service | quote }}
+    release: {{ .Release.Name | quote }}
+{{- with .Values.ingress.annotations }}
+  annotations:
+{{ toYaml . | indent 4 }}
+{{- end }}
+spec:
+{{- if .Values.ingress.tls }}
+  tls:
+{{ toYaml .Values.ingress.tls | indent 4 }}
+{{- end }}
+  rules:
+  {{- range $.Values.ingress.hosts }}
+    - host: {{ .host }}
+      http:
+        paths:
+        {{- range .paths }}
+          - path: {{ .path }}
+            backend:
+              serviceName: {{ $fullName }}
+              servicePort: {{ .servicePort }}
+        {{- end }}    
+  {{- end }}
+{{- end }}

logstash/tests/logstash_test.py

@@ -234,7 +234,7 @@ def test_adding_persistence():
     assert c["volumeMounts"][0]["mountPath"] == "/usr/share/logstash/data"
     assert c["volumeMounts"][0]["name"] == name
 
-    v = r["statefulset"]["release-name-logstash"]["spec"]["volumeClaimTemplates"][0]
+    v = r["statefulset"][name]["spec"]["volumeClaimTemplates"][0]
     assert v["metadata"]["name"] == name
     assert v["spec"]["accessModes"] == ["ReadWriteOnce"]
     assert v["spec"]["resources"]["requests"]["storage"] == "1Gi"
@@ -540,7 +540,7 @@ def test_adding_a_node_affinity():
         - myvalue
 """
     r = helm_template(config)
-    assert r["statefulset"]["release-name-logstash"]["spec"]["template"]["spec"][
+    assert r["statefulset"][name]["spec"]["template"]["spec"][
         "affinity"
     ]["nodeAffinity"] == {
         "preferredDuringSchedulingIgnoredDuringExecution": [
@@ -581,7 +581,7 @@ def test_adding_in_logstash_config():
     s = r["statefulset"][name]["spec"]["template"]["spec"]
 
     assert {
-        "configMap": {"name": "release-name-logstash-config"},
+        "configMap": {"name": name + "-config"},
         "name": "logstashconfig",
     } in s["volumes"]
     assert {
@@ -876,3 +876,33 @@ def test_setting_fullnameOverride():
         ]
         == "logstash"
     )
+
+def test_adding_an_ingress():
+    config = """
+ingress:
+  enabled: true
+  annotations: {}
+  hosts:
+    - host: logstash.local
+      paths:
+        - path: /logs
+          servicePort: 8080
+"""
+    r = helm_template(config)
+    s = r["ingress"][name]
+    assert s["metadata"]["name"] == name
+    assert len(s["spec"]["rules"]) == 1
+    assert s["spec"]["rules"][0] == {
+        "host": "logstash.local",
+        "http": {
+            "paths": [
+                {
+                    "path": "/logs",
+                    "backend": {
+                        "serviceName": name,
+                        "servicePort": 8080
+                    }
+                }
+            ]
+        }
+    }

logstash/values.yaml

@@ -246,3 +246,13 @@ service: {}
 #      port: 8080
 #      protocol: TCP
 #      targetPort: 8080
+
+ingress:
+  enabled: true
+#  annotations: {}
+#  hosts:
+#    - host: logstash.local
+#      paths:
+#        - path: /logs
+#          servicePort: 8080
+#  tls: []