You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by as...@apache.org on 2019/10/01 07:48:18 UTC
[camel-k] 04/05: fix(prometheus): Fix Prometheus service condition
message
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit d433821d2766e56a31e8f0d8f41c7bad76edcadc
Author: Antonin Stefanutti <an...@stefanutti.fr>
AuthorDate: Tue Sep 24 18:32:17 2019 +0200
fix(prometheus): Fix Prometheus service condition message
---
pkg/trait/prometheus.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pkg/trait/prometheus.go b/pkg/trait/prometheus.go
index bbef5b8..b5dd77d 100644
--- a/pkg/trait/prometheus.go
+++ b/pkg/trait/prometheus.go
@@ -92,7 +92,7 @@ func (t *prometheusTrait) Apply(e *Environment) (err error) {
// Add the container port
containerPort := t.getContainerPort()
container.Ports = append(container.Ports, *containerPort)
- condition.Message += fmt.Sprintf("%s(%s/%d)", container.Name, containerPort.Name, containerPort.ContainerPort)
+ condition.Message = fmt.Sprintf("%s(%s/%d)", container.Name, containerPort.Name, containerPort.ContainerPort)
// Retrieve the service or create a new one if the service trait is enabled
serviceEnabled := false
@@ -114,7 +114,7 @@ func (t *prometheusTrait) Apply(e *Environment) (err error) {
if serviceEnabled {
servicePort := t.getServicePort()
service.Spec.Ports = append(service.Spec.Ports, *servicePort)
- condition.Message += fmt.Sprintf("%s(%s/%d) -> ", service.Name, servicePort.Name, servicePort.Port)
+ condition.Message = fmt.Sprintf("%s(%s/%d) -> ", service.Name, servicePort.Name, servicePort.Port) + condition.Message
// Add the ServiceMonitor resource
if t.ServiceMonitor {