Custom Cassandra YAML and JVM options.

operator/params.yaml

@@ -659,6 +659,10 @@ parameters:
     description: "How many milliseconds to wait between two expiration runs on the backlog (queue) of the OutboundTcpConnection."
     default: ""
 
+  - name: CUSTOM_CASSANDRA_YAML_BASE64
+    description: "Base64-encoded Cassandra properties appended to cassandra.yaml."
+    default: ""
+
   ################################################################################
   ################################ JVM Options ###################################
   ################################################################################
@@ -766,3 +770,7 @@ parameters:
   - name: JVM_OPT_G1R_SET_UPDATING_PAUSE_TIME_PERCENT
     description: "Have the JVM do less remembered set work during STW, instead preferring concurrent GC. Reduces p99.9 latency."
     default: ""
+
+  - name: CUSTOM_JVM_OPTIONS_BASE64
+    description: "Base64-encoded JVM options appended to jvm.options."
+    default: ""

operator/templates/cassandra-yaml.yaml

@@ -1352,3 +1352,7 @@ data:
     {{ if .Params.OTC_BACKLOG_EXPIRATION_INTERVAL_MS }}
     otc_backlog_expiration_interval_ms: {{ .Params.OTC_BACKLOG_EXPIRATION_INTERVAL_MS }}
     {{ end }}
+
+    {{ if .Params.CUSTOM_CASSANDRA_YAML_BASE64 }}
+    {{ .Params.CUSTOM_CASSANDRA_YAML_BASE64 | b64dec }}
+    {{ end }}

operator/templates/jvm-options.yaml

@@ -345,3 +345,7 @@ data:
     ### Cassandra 4.0 which will use JDK 11.
     -XX:+UnlockExperimentalVMOptions
     -XX:+UseCGroupMemoryLimitForHeap
+
+    {{ if .Params.CUSTOM_JVM_OPTIONS_BASE64 }}
+    {{ .Params.CUSTOM_JVM_OPTIONS_BASE64 | b64dec }}
+    {{ end }}

tests/go.mod

@@ -5,7 +5,7 @@ go 1.13
 require (
 	github.com/avast/retry-go v2.4.1+incompatible
 	github.com/imdario/mergo v0.3.8 // indirect
-	github.com/kudobuilder/kudo v0.8.0-pre.2
+	github.com/kudobuilder/kudo v0.8.0-pre.3
 	github.com/mitchellh/go-homedir v1.1.0
 	github.com/onsi/ginkgo v1.10.1
 	github.com/onsi/gomega v1.7.0

tests/suites/sanity_test.go

@@ -1,6 +1,7 @@
 package suites
 
 import (
+	"encoding/base64"
 	"fmt"
 	"os"
 	"strings"
@@ -12,10 +13,10 @@ import (
 
 	// log "github.com/sirupsen/logrus"
 
-	cassandra "github.com/mesosphere/kudo-cassandra-operator/tests/utils/cassandra"
-	k8s "github.com/mesosphere/kudo-cassandra-operator/tests/utils/k8s"
-	kubectl "github.com/mesosphere/kudo-cassandra-operator/tests/utils/kubectl"
-	kudo "github.com/mesosphere/kudo-cassandra-operator/tests/utils/kudo"
+	"github.com/mesosphere/kudo-cassandra-operator/tests/utils/cassandra"
+	"github.com/mesosphere/kudo-cassandra-operator/tests/utils/k8s"
+	"github.com/mesosphere/kudo-cassandra-operator/tests/utils/kubectl"
+	"github.com/mesosphere/kudo-cassandra-operator/tests/utils/kudo"
 )
 
 var (
@@ -85,6 +86,63 @@ var _ = Describe(TestName, func() {
 		Expect(configuration[parameter]).To(Equal(desiredValue))
 	})
 
+	It("Configures Cassandra properties through custom properties", func() {
+		parameter := "otc_backlog_expiration_interval_ms"
+		initialValue := "200"
+		desiredValue := "300"
+		desiredEncodedProperties := base64.StdEncoding.EncodeToString(
+			[]byte(parameter + ": " + desiredValue),
+		)
+
+		configuration, err := cassandra.ClusterConfiguration(
+			TestNamespace, TestInstance,
+		)
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(initialValue))
+
+		err = kudo.UpdateInstanceParameters(
+			TestNamespace,
+			TestInstance,
+			map[string]string{"CUSTOM_CASSANDRA_YAML_BASE64": desiredEncodedProperties},
+		)
+		Expect(err).To(BeNil())
+
+		configuration, err = cassandra.ClusterConfiguration(
+			TestNamespace, TestInstance,
+		)
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(desiredValue))
+	})
+
+	It("Configures Cassandra JVM options through custom options", func() {
+		parameter := "-XX:CMSWaitDuration"
+		initialValue := "10000"
+		desiredValue := "11000"
+		desiredEncodedProperties := base64.StdEncoding.EncodeToString(
+			[]byte(parameter + "=" + desiredValue),
+		)
+
+		configuration, err := cassandra.NodeJvmOptions(
+			TestNamespace, TestInstance,
+		)
+
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(initialValue))
+
+		err = kudo.UpdateInstanceParameters(
+			TestNamespace,
+			TestInstance,
+			map[string]string{"CUSTOM_JVM_OPTIONS_BASE64": desiredEncodedProperties},
+		)
+		Expect(err).To(BeNil())
+
+		configuration, err = cassandra.NodeJvmOptions(
+			TestNamespace, TestInstance,
+		)
+		Expect(err).To(BeNil())
+		Expect(configuration[parameter]).To(Equal(desiredValue))
+	})
+
 	It("Uninstalls the operator", func() {
 		err := kudo.UninstallOperator(OperatorName, TestNamespace, TestInstance)
 		Expect(err).To(BeNil())

tests/utils/cassandra/cassandra.go

@@ -7,11 +7,36 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	kudo "github.com/mesosphere/kudo-cassandra-operator/tests/utils/kudo"
+	"github.com/mesosphere/kudo-cassandra-operator/tests/utils/kudo"
 )
 
 func ClusterConfiguration(
 	namespaceName string, instanceName string,
+) (map[string]string, error) {
+	return getConfigurationFromNodeLogs(
+		namespaceName,
+		instanceName,
+		"org.apache.cassandra.config.Config - Node configuration:\\[(.+)\\]",
+		";",
+	)
+}
+
+func NodeJvmOptions(
+	namespaceName string, instanceName string,
+) (map[string]string, error) {
+	return getConfigurationFromNodeLogs(
+		namespaceName,
+		instanceName,
+		"o.a.c.service.CassandraDaemon - JVM Arguments: \\[(.+)\\]",
+		",",
+	)
+}
+
+func getConfigurationFromNodeLogs(
+	namespaceName string,
+	instanceName string,
+	regexpr string,
+	separator string,
 ) (map[string]string, error) {
 	configuration := make(map[string]string)
 
@@ -27,9 +52,7 @@ func ClusterConfiguration(
 	}
 
 	scanner := bufio.NewScanner(logs)
-	configurationLinePattern := regexp.MustCompile(
-		"org.apache.cassandra.config.Config - Node configuration:\\[(.+)\\]",
-	)
+	configurationLinePattern := regexp.MustCompile(regexpr)
 	var configurationLine string
 	for scanner.Scan() {
 		match := configurationLinePattern.FindStringSubmatch(scanner.Text())
@@ -47,7 +70,7 @@ func ClusterConfiguration(
 		return configuration, err
 	}
 
-	for _, kv := range strings.Split(configurationLine, ";") {
+	for _, kv := range strings.Split(configurationLine, separator) {
 		parts := strings.Split(strings.TrimSpace(kv), "=")
 		if len(parts) == 2 {
 			configuration[parts[0]] = parts[1]