Merge pull request #10 from burmanm/fix_snitch

Enforce snitch to be GossipingPropertyFileSnitch always in k8ssandra
k8ssandra · Aug 15, 2023 · e5ae32c · e5ae32c
2 parents 73bae73 + e6b6a82
commit e5ae32c
Show file tree

Hide file tree

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

diff --git a/pkg/config/builder_test.go b/pkg/config/builder_test.go
@@ -213,6 +213,7 @@ func TestCassandraYamlWriting(t *testing.T) {
 	seedProviders := cassandraYaml["seed_provider"].([]interface{})
 	seedProvider := seedProviders[0].(map[string]interface{})
 	require.Equal("org.apache.cassandra.locator.K8SeedProvider", seedProvider["class_name"])
+	require.Equal("GossipingPropertyFileSnitch", cassandraYaml["endpoint_snitch"])
 
 	listenIP := nodeInfo.ListenIP.String()
 	require.Equal(listenIP, cassandraYaml["listen_address"])