Propagate cluster_name to cassandra.yaml

k8ssandra · Oct 29, 2023 · 3242e3c · 3242e3c
1 parent 3da3d9b
commit 3242e3c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/pkg/config/builder.go b/pkg/config/builder.go
@@ -471,6 +471,7 @@ func k8ssandraOverrides(merged map[string]interface{}, configInput *ConfigInput,
 	delete(merged, "broadcast_address") // Sets it to the same as listen_address
 	merged["broadcast_rpc_address"] = nodeInfo.BroadcastIP
 	merged["endpoint_snitch"] = "GossipingPropertyFileSnitch"
+	merged["cluster_name"] = configInput.ClusterInfo.Name
 
 	return merged
 }

diff --git a/pkg/config/builder_test.go b/pkg/config/builder_test.go
@@ -210,6 +210,9 @@ func TestCassandraYamlWriting(t *testing.T) {
 	}
 
 	// Verify our k8ssandra overrides are set
+	clusterName := configInput.ClusterInfo.Name
+	require.Equal(clusterName, cassandraYaml["cluster_name"])
+
 	seedProviders := cassandraYaml["seed_provider"].([]interface{})
 	seedProvider := seedProviders[0].(map[string]interface{})
 	require.Equal("org.apache.cassandra.locator.K8SeedProvider", seedProvider["class_name"])