[camel-k] branch master updated: Configure Prometheus agent port based on trait property

[lb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git


The following commit(s) were added to refs/heads/master by this push:
     new b4f4e14  Configure Prometheus agent port based on trait property
b4f4e14 is described below

commit b4f4e141cb9a6ceeae83aec6483ec0c5e85918b1
Author: Antonin Stefanutti <an...@stefanutti.fr>
AuthorDate: Thu Jan 24 15:12:30 2019 +0100

    Configure Prometheus agent port based on trait property
---
 pkg/trait/prometheus.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/pkg/trait/prometheus.go b/pkg/trait/prometheus.go
index 56e64b9..8eaa179 100644
--- a/pkg/trait/prometheus.go
+++ b/pkg/trait/prometheus.go
@@ -18,6 +18,8 @@ limitations under the License.
 package trait
 
 import (
+	"strconv"
+
 	"github.com/apache/camel-k/pkg/apis/camel/v1alpha1"
 	"github.com/apache/camel-k/pkg/util/envvar"
 
@@ -61,6 +63,9 @@ func (t *prometheusTrait) Configure(e *Environment) (bool, error) {
 }
 
 func (t *prometheusTrait) Apply(e *Environment) (err error) {
+	// Configure the Prometheus Java agent
+	envvar.SetVal(&e.EnvVars, "AB_PROMETHEUS_PORT", strconv.Itoa(t.Port))
+
 	// TODO: update the existing integration service instead of
 	// creating an extra service dedicated to Prometheus
 	svc := t.getServiceFor(e)