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
The following commit(s) were added to refs/heads/master by this push:
new 75df6c3 feat: Add option to print JVM command in integration logs
75df6c3 is described below
commit 75df6c3e28196439dc0a6e7e20da8c9bab5543e5
Author: Antonin Stefanutti <anto...@stefanutti.fr>
AuthorDate: Fri Jun 5 11:15:46 2020 +0200
feat: Add option to print JVM command in integration logs
---
deploy/traits.yaml | 4 ++
docs/modules/traits/pages/jvm.adoc | 4 ++
pkg/trait/jvm.go | 108 +++++++++++++++++++++----------------
pkg/trait/jvm_test.go | 1 +
4 files changed, 71 insertions(+), 46 deletions(-)
diff --git a/deploy/traits.yaml b/deploy/traits.yaml
index b282184..19d78b6 100755
--- a/deploy/traits.yaml
+++ b/deploy/traits.yaml
@@ -419,6 +419,10 @@ traits:
- name: options
type: string
description: A comma-separated list of JVM options
+ - name: print-command
+ type: bool
+ description: Prints the command used the start the JVM in the container
logs (default
+ `true`)
- name: knative-service
platform: false
profiles:
diff --git a/docs/modules/traits/pages/jvm.adoc
b/docs/modules/traits/pages/jvm.adoc
index 8dbfad4..d395980 100755
--- a/docs/modules/traits/pages/jvm.adoc
+++ b/docs/modules/traits/pages/jvm.adoc
@@ -42,6 +42,10 @@ The following configuration options are available:
| string
| A comma-separated list of JVM options
+| jvm.print-command
+| bool
+| Prints the command used the start the JVM in the container logs (default
`true`)
+
|===
// End of autogenerated code - DO NOT EDIT! (configuration)
diff --git a/pkg/trait/jvm.go b/pkg/trait/jvm.go
index 4596623..e09c2c5 100644
--- a/pkg/trait/jvm.go
+++ b/pkg/trait/jvm.go
@@ -22,7 +22,7 @@ import (
"sort"
"strings"
- inf "gopkg.in/inf.v0"
+ "gopkg.in/inf.v0"
"github.com/pkg/errors"
"github.com/scylladb/go-set/strset"
@@ -48,6 +48,8 @@ type jvmTrait struct {
DebugAddress string `property:"debug-address"`
// A comma-separated list of JVM options
Options *string `property:"options"`
+ // Prints the command used the start the JVM in the container logs
(default `true`)
+ PrintCommand bool `property:"print-command"`
}
func newJvmTrait() Trait {
@@ -55,6 +57,7 @@ func newJvmTrait() Trait {
BaseTrait: NewBaseTrait("jvm", 2000),
// To be defaulted to "*:5005" when upgrading the default base
image to JDK9+
DebugAddress: "5005",
+ PrintCommand: true,
}
}
@@ -106,59 +109,72 @@ func (t *jvmTrait) Apply(e *Environment) error {
}
container := e.getIntegrationContainer()
- if container != nil {
- // Set the container command and working directory
- container.Command = []string{"java"}
- container.WorkingDir = "/deployments"
-
- // Remote debugging
- if t.Debug {
- suspend := "n"
- if t.DebugSuspend {
- suspend = "y"
- }
- container.Args = append(container.Args,
-
fmt.Sprintf("-agentlib:jdwp=transport=dt_socket,server=y,suspend=%s,address=%s",
- suspend, t.DebugAddress))
- }
+ if container == nil {
+ return nil
+ }
- hasHeapSizeOption := false
- // Add JVM options
- if t.Options != nil {
- hasHeapSizeOption = strings.Contains(*t.Options,
"-Xmx") ||
- strings.Contains(*t.Options, "-XX:MaxHeapSize")
||
- strings.Contains(*t.Options,
"-XX:MinRAMPercentage") ||
- strings.Contains(*t.Options,
"-XX:MaxRAMPercentage")
+ // Build the container command
+ var args []string
- container.Args = append(container.Args,
strings.Split(*t.Options, ",")...)
+ // Remote debugging
+ if t.Debug {
+ suspend := "n"
+ if t.DebugSuspend {
+ suspend = "y"
}
+ args = append(args,
+
fmt.Sprintf("-agentlib:jdwp=transport=dt_socket,server=y,suspend=%s,address=%s",
+ suspend, t.DebugAddress))
+ }
- // Tune JVM maximum heap size based on the container memory
limit, if any.
- // This is configured off-container, thus is limited to
explicit user configuration.
- // We may want to inject a wrapper script into the container
image, so that it can
- // be performed in-container, based on CGroups memory resource
control files.
- if memory, hasLimit :=
container.Resources.Limits[corev1.ResourceMemory]; !hasHeapSizeOption &&
hasLimit {
- // Simple heuristic that caps the maximum heap size to
50% of the memory limit
- percentage := int64(50)
- // Unless the memory limit is lower than 300M, in which
case we leave more room for the non-heap memory
- if resource.NewScaledQuantity(300, 6).Cmp(memory) > 0 {
- percentage = 25
- }
- memory.AsDec().Mul(memory.AsDec(),
inf.NewDec(percentage, 2))
- container.Args = append(container.Args,
fmt.Sprintf("-Xmx%dM", memory.ScaledValue(resource.Mega)))
- }
+ hasHeapSizeOption := false
+ // Add JVM options
+ if t.Options != nil {
+ hasHeapSizeOption = strings.Contains(*t.Options, "-Xmx") ||
+ strings.Contains(*t.Options, "-XX:MaxHeapSize") ||
+ strings.Contains(*t.Options, "-XX:MinRAMPercentage") ||
+ strings.Contains(*t.Options, "-XX:MaxRAMPercentage")
- // Add mounted resources to the class path
- for _, m := range container.VolumeMounts {
- classpath.Add(m.MountPath)
+ args = append(args, strings.Split(*t.Options, ",")...)
+ }
+
+ // Tune JVM maximum heap size based on the container memory limit, if
any.
+ // This is configured off-container, thus is limited to explicit user
configuration.
+ // We may want to inject a wrapper script into the container image, so
that it can
+ // be performed in-container, based on CGroups memory resource control
files.
+ if memory, hasLimit :=
container.Resources.Limits[corev1.ResourceMemory]; !hasHeapSizeOption &&
hasLimit {
+ // Simple heuristic that caps the maximum heap size to 50% of
the memory limit
+ percentage := int64(50)
+ // Unless the memory limit is lower than 300M, in which case we
leave more room for the non-heap memory
+ if resource.NewScaledQuantity(300, 6).Cmp(memory) > 0 {
+ percentage = 25
}
- items := classpath.List()
- // Keep class path sorted so that it's consistent over
reconciliation cycles
- sort.Strings(items)
+ memory.AsDec().Mul(memory.AsDec(), inf.NewDec(percentage, 2))
+ args = append(args, fmt.Sprintf("-Xmx%dM",
memory.ScaledValue(resource.Mega)))
+ }
- container.Args = append(container.Args, "-cp",
strings.Join(items, ":"))
- container.Args = append(container.Args,
e.CamelCatalog.Runtime.ApplicationClass)
+ // Add mounted resources to the class path
+ for _, m := range container.VolumeMounts {
+ classpath.Add(m.MountPath)
}
+ items := classpath.List()
+ // Keep class path sorted so that it's consistent over reconciliation
cycles
+ sort.Strings(items)
+
+ args = append(args, "-cp", strings.Join(items, ":"))
+ args = append(args, e.CamelCatalog.Runtime.ApplicationClass)
+
+ if t.PrintCommand {
+ args = append([]string{"java"}, args...)
+ container.Command = []string{"/bin/sh", "-c"}
+ cmd := strings.Join(args, " ")
+ container.Args = []string{"echo " + cmd + " && " + cmd}
+ } else {
+ container.Command = []string{"java"}
+ container.Args = args
+ }
+
+ container.WorkingDir = "/deployments"
return nil
}
diff --git a/pkg/trait/jvm_test.go b/pkg/trait/jvm_test.go
index 15f012b..9309384 100644
--- a/pkg/trait/jvm_test.go
+++ b/pkg/trait/jvm_test.go
@@ -204,6 +204,7 @@ func createJvmTestWithKitType(kitType string) (*jvmTrait,
*Environment) {
trait := newJvmTrait().(*jvmTrait)
enabled := true
trait.Enabled = &enabled
+ trait.PrintCommand = false
trait.Ctx = context.TODO()
trait.Client = client
