From 2c480044253f07166a6661789ea4b30326a81074 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gre=CC=81gory=20Cuellar?= Date: Tue, 12 Sep 2023 15:06:16 +0200 Subject: [PATCH] fix: expose ports on collector statefulset MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Grégory Cuellar --- pkg/operator/collector-statefulset.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/operator/collector-statefulset.go b/pkg/operator/collector-statefulset.go index 79edaf1f7..fd5f72f87 100644 --- a/pkg/operator/collector-statefulset.go +++ b/pkg/operator/collector-statefulset.go @@ -117,6 +117,10 @@ func MakefbStatefulset(co fluentbitv1alpha2.Collector) *appsv1.StatefulSet { statefulset.Spec.Template.Spec.Containers[0].VolumeMounts = append(statefulset.Spec.Template.Spec.Containers[0].VolumeMounts, co.Spec.VolumesMounts...) } + if co.Spec.Ports != nil { + statefulset.Spec.Template.Spec.Containers[0].Ports = append(statefulset.Spec.Template.Spec.Containers[0].Ports, co.Spec.Ports...) + } + // Mount Secrets for _, secret := range co.Spec.Secrets { statefulset.Spec.Template.Spec.Volumes = append(statefulset.Spec.Template.Spec.Volumes, corev1.Volume{