Skip to content

Commit 70a5ba4

Browse files
aslafy-zcsatib02
authored andcommitted
fix(syslogng): align metrics service names and reuse object metadata
Signed-off-by: Zadkiel AHARONIAN <hello@zadkiel.fr>
1 parent 86c7d79 commit 70a5ba4

File tree

1 file changed

+12
-8
lines changed

1 file changed

+12
-8
lines changed

pkg/resources/syslogng/service.go

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,11 @@ func (r *Reconciler) service() (runtime.Object, reconciler.DesiredState, error)
7070
}
7171

7272
func (r *Reconciler) serviceMetrics() (runtime.Object, reconciler.DesiredState, error) {
73+
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-metrics", ComponentSyslogNG)
74+
7375
if r.syslogNGSpec.Metrics != nil && r.syslogNGSpec.Metrics.IsEnabled() {
7476
desired := &corev1.Service{
75-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-metrics", ComponentSyslogNG),
77+
ObjectMeta: objectMetadata,
7678
Spec: corev1.ServiceSpec{
7779
Ports: []corev1.ServicePort{
7880
{
@@ -95,19 +97,19 @@ func (r *Reconciler) serviceMetrics() (runtime.Object, reconciler.DesiredState,
9597
return desired, reconciler.StatePresent, nil
9698
}
9799
return &corev1.Service{
98-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-monitor", ComponentSyslogNG),
100+
ObjectMeta: objectMetadata,
99101
Spec: corev1.ServiceSpec{}}, reconciler.StateAbsent, nil
100102
}
101103

102104
func (r *Reconciler) monitorServiceMetrics() (runtime.Object, reconciler.DesiredState, error) {
103105
var SampleLimit uint64 = 0
106+
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-metrics", ComponentSyslogNG)
104107

105108
if r.syslogNGSpec.Metrics.ServiceMonitorConfig.Scheme == "" {
106109
r.syslogNGSpec.Metrics.ServiceMonitorConfig.Scheme = kubetool.To(v1.SchemeHTTP).String()
107110
}
108111

109112
if r.syslogNGSpec.Metrics != nil && r.syslogNGSpec.Metrics.IsEnabled() && r.syslogNGSpec.Metrics.ServiceMonitor {
110-
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-metrics", ComponentSyslogNG)
111113
if r.syslogNGSpec.Metrics.ServiceMonitorConfig.AdditionalLabels != nil {
112114
for k, v := range r.syslogNGSpec.Metrics.ServiceMonitorConfig.AdditionalLabels {
113115
objectMetadata.Labels[k] = v
@@ -138,20 +140,22 @@ func (r *Reconciler) monitorServiceMetrics() (runtime.Object, reconciler.Desired
138140
}, reconciler.StatePresent, nil
139141
}
140142
return &v1.ServiceMonitor{
141-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-metrics", ComponentSyslogNG),
143+
ObjectMeta: objectMetadata,
142144
Spec: v1.ServiceMonitorSpec{},
143145
}, reconciler.StateAbsent, nil
144146
}
145147

146148
func (r *Reconciler) serviceBufferMetrics() (runtime.Object, reconciler.DesiredState, error) {
149+
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-buffer-metrics", ComponentSyslogNG)
150+
147151
if r.syslogNGSpec.BufferVolumeMetrics != nil && r.syslogNGSpec.BufferVolumeMetrics.IsEnabled() {
148152
port := int32(defaultBufferVolumeMetricsPort)
149153
if r.syslogNGSpec.BufferVolumeMetrics.Port != 0 {
150154
port = r.syslogNGSpec.BufferVolumeMetrics.Port
151155
}
152156

153157
desired := &corev1.Service{
154-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-buffer-metrics", ComponentSyslogNG),
158+
ObjectMeta: objectMetadata,
155159
Spec: corev1.ServiceSpec{
156160
Ports: []corev1.ServicePort{
157161
{
@@ -174,19 +178,19 @@ func (r *Reconciler) serviceBufferMetrics() (runtime.Object, reconciler.DesiredS
174178
return desired, reconciler.StatePresent, nil
175179
}
176180
return &corev1.Service{
177-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-buffer-monitor", ComponentSyslogNG),
181+
ObjectMeta: objectMetadata,
178182
Spec: corev1.ServiceSpec{}}, reconciler.StateAbsent, nil
179183
}
180184

181185
func (r *Reconciler) monitorBufferServiceMetrics() (runtime.Object, reconciler.DesiredState, error) {
182186
var SampleLimit uint64 = 0
187+
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-buffer-metrics", ComponentSyslogNG)
183188

184189
if r.syslogNGSpec.BufferVolumeMetrics.ServiceMonitorConfig.Scheme == "" {
185190
r.syslogNGSpec.BufferVolumeMetrics.ServiceMonitorConfig.Scheme = kubetool.To(v1.SchemeHTTP).String()
186191
}
187192

188193
if r.syslogNGSpec.BufferVolumeMetrics != nil && r.syslogNGSpec.BufferVolumeMetrics.IsEnabled() && r.syslogNGSpec.BufferVolumeMetrics.ServiceMonitor {
189-
objectMetadata := r.SyslogNGObjectMeta(ServiceName+"-buffer-metrics", ComponentSyslogNG)
190194
if r.syslogNGSpec.BufferVolumeMetrics.ServiceMonitorConfig.AdditionalLabels != nil {
191195
for k, v := range r.syslogNGSpec.BufferVolumeMetrics.ServiceMonitorConfig.AdditionalLabels {
192196
objectMetadata.Labels[k] = v
@@ -216,7 +220,7 @@ func (r *Reconciler) monitorBufferServiceMetrics() (runtime.Object, reconciler.D
216220
}, reconciler.StatePresent, nil
217221
}
218222
return &v1.ServiceMonitor{
219-
ObjectMeta: r.SyslogNGObjectMeta(ServiceName+"-buffer-metrics", ComponentSyslogNG),
223+
ObjectMeta: objectMetadata,
220224
Spec: v1.ServiceMonitorSpec{},
221225
}, reconciler.StateAbsent, nil
222226
}

0 commit comments

Comments
 (0)