Add ability to specify JMX variables

api/v2/cassandracluster_types.go

@@ -172,7 +172,7 @@
 	if len(cc.Status.Phase) == 0 {
 		cc.Status.Phase = ClusterPhaseInitial.Name
 		if cc.InitCassandraRackList() < 1 {
 			logrus.Errorf("[%s]: We should have at list One Rack, Please correct the Error", cc.Name)
 		}
 		if cc.Status.SeedList == nil {
 			cc.Status.SeedList = cc.InitSeedList()
@@ -815,8 +815,21 @@
 	// +optional
 	ShareProcessNamespace *bool `json:"shareProcessNamespace,omitempty" protobuf:"varint,27,opt,name=shareProcessNamespace"`
 
-	BackRestSidecar    *BackRestSidecar `json:"backRestSidecar,omitempty"`
-	ServiceAccountName string           `json:"serviceAccountName,omitempty"`
+	BackRestSidecar    *BackRestSidecar  `json:"backRestSidecar,omitempty"`
+	ServiceAccountName string            `json:"serviceAccountName,omitempty"`
+	JMXConfiguration   *JMXConfiguration `json:"jmxConfiguration,omitempty"`
+}
+
+// JMXConfiguration defines Cassandra JMX variables configuration
+type JMXConfiguration struct {
+	// Flag to tell that JMX remote is enabled
+	// +kubebuilder:default:=false
+	JMXRemote bool `json:"jmxRemoteEnable,omitempty"`
+	// JMX Remote port number
+	// +kubebuilder:default:=7199
+	JMXRemotePort         int  `json:"jmxRemotePort,omitempty"`
+	JXMRemoteSSL          bool `json:"jmxRemoteSSL,omitempty"`
+	JMXRemoteAuthenticate bool `json:"jmxRemoteAuthenticate,omitempty"`
 }
 
 // StorageConfig defines additional storage configurations

config/crd/bases/db.orange.com_cassandraclusters.yaml

@@ -236,6 +236,22 @@ spec:
                 imagepullpolicy:
                   description: ImagePullPolicy define the pull policy for C* docker image
                   type: string
+                jmxConfiguration:
+                  description: JMXConfiguration defines Cassandra JMX variables configuration
+                  type: object
+                  properties:
+                    jmxRemoteAuthenticate:
+                      type: boolean
+                    jmxRemoteEnable:
+                      description: Flag to tell that JMX remote is enabled
+                      type: boolean
+                      default: false
+                    jmxRemotePort:
+                      description: JMX Remote port number
+                      type: integer
+                      default: 7199
+                    jmxRemoteSSL:
+                      type: boolean
                 keyspaceCleanupThreads:
                   description: |-
                     Number of jobs (threads) for keyspace cleanup command.

controllers/cassandracluster/generator.go

@@ -17,6 +17,7 @@ package cassandracluster
 import (
 	"encoding/json"
 	"fmt"
+	"reflect"
 
 	"github.com/Jeffail/gabs"
 	"github.com/banzaicloud/k8s-objectmatcher/patch"
@@ -65,6 +66,7 @@ const (
 
 	cassandraConfigMapName = "cassandra-config"
 	defaultBackRestPort    = 4567
+	jvmOptsName            = "JVM_OPTS"
 )
 
 type containerType int
@@ -76,6 +78,15 @@ const (
 	backrestContainer
 )
 
+// JMXConfigurationMap
+// Create a JMX Configuration map to convert values from CR to how they look like as env vars
+var JMXConfigurationMap = map[string]string{
+	"JMXRemote":             "-Dcom.sun.management.jmxremote=",
+	"JMXRemotePort":         "-Dcom.sun.management.jmxremote.port=",
+	"JXMRemoteSSL":          "-Dcom.sun.management.jmxremote.ssl=",
+	"JMXRemoteAuthenticate": "-Dcom.sun.management.jmxremote.authenticate=",
+}
+
 type NodeConfig map[string]map[string]interface{}
 
 func generateCassandraService(cc *api.CassandraCluster, labels map[string]string,
@@ -293,6 +304,21 @@ func generateVolumeClaimTemplate(cc *api.CassandraCluster, labels map[string]str
 	return pvc, nil
 }
 
+func generateJMXConfiguration(jmxConf api.JMXConfiguration) v1.EnvVar {
+	var jmxEnvVar v1.EnvVar
+	var jmxParam string
+	values := reflect.ValueOf(jmxConf)
+	types := reflect.TypeOf(jmxConf)
+	for i := 0; i < values.NumField(); i++ {
+		fieldName := types.Field(i).Name
+		fieldValue := values.Field(i).Interface()
+		param := JMXConfigurationMap[fieldName] + fmt.Sprintf("%v", fieldValue) + " "
+		jmxParam += param
+	}
+	jmxEnvVar = v1.EnvVar{Name: jvmOptsName, Value: jmxParam}
+	return jmxEnvVar
+}
+
 func generateCassandraStatefulSet(cc *api.CassandraCluster, status *api.CassandraClusterStatus,
 	dcName string, dcRackName string, labels map[string]string, nodeSelector map[string]string,
 	ownerRefs []metav1.OwnerReference) (*appsv1.StatefulSet, error) {
@@ -932,6 +958,10 @@ func createCassandraContainer(cc *api.CassandraCluster, status *api.CassandraClu
 		Value: "-Dcom.sun.jndi.rmiURLParsing=legacy",
 	})
 
+	if cc.Spec.JMXConfiguration != nil {
+		jmxEnvVariable := generateJMXConfiguration(*cc.Spec.JMXConfiguration)
+		cassandraEnv = append(cassandraEnv, jmxEnvVariable)
+	}
 	cassandraContainer := v1.Container{
 		Name:            cassandraContainerName,
 		Image:           cc.Spec.CassandraImage,

controllers/cassandracluster/generator_test.go

@@ -691,6 +691,7 @@ func checkVarEnv(t *testing.T, containers []v1.Container, cc *api.CassandraClust
 	cassieResources := cc.Spec.Resources
 	initContainerEnvVar := initContainerEnvVar(cc, &cc.Status, cassieResources, dcRackName)
 	bootstrapContainerEnvVar := bootstrapContainerEnvVar(cc, &cc.Status)
+	jmxEnvVar := generateJMXConfiguration(*cc.Spec.JMXConfiguration)
 
 	assert := assert.New(t)
 
@@ -755,6 +756,7 @@ func checkVarEnv(t *testing.T, containers []v1.Container, cc *api.CassandraClust
 				},
 			}
 			assert.Contains(container.Env, podIP)
+			assert.Contains(container.Env, jmxEnvVar)
 
 			checkInitContainerVarEnv(t, initContainerEnvVar, vars)
 		}

controllers/cassandracluster/testdata/cassandracluster-2DC.yaml

@@ -31,6 +31,11 @@ spec:
   nodesPerRacks: 1
   cassandraImage: cassandra:3.11.7
   restartCountBeforePodDeletion: 3
+  jmxConfiguration:
+    jmxRemoteEnable: false
+    jmxRemotePort: 7199
+    jmxRemoteSSL: false
+    jmxRemoteAuthenticate: false
   imagePullSecret:
     name: advisedev # To authenticate on docker registry
   rollingPartition: 0