Let cassandra servers contain whitespace in config (#1301)

Author: karlpokus

plugin/storage/cassandra/options.go

@@ -216,7 +216,7 @@ func (cfg *namespaceConfig) initFromViper(v *viper.Viper) {
 	cfg.MaxRetryAttempts = v.GetInt(cfg.namespace + suffixMaxRetryAttempts)
 	cfg.Timeout = v.GetDuration(cfg.namespace + suffixTimeout)
 	cfg.ReconnectInterval = v.GetDuration(cfg.namespace + suffixReconnectInterval)
-	cfg.servers = v.GetString(cfg.namespace + suffixServers)
+	cfg.servers = stripWhiteSpace(v.GetString(cfg.namespace + suffixServers))
 	cfg.Port = v.GetInt(cfg.namespace + suffixPort)
 	cfg.Keyspace = v.GetString(cfg.namespace + suffixKeyspace)
 	cfg.LocalDC = v.GetString(cfg.namespace + suffixDC)
@@ -256,3 +256,8 @@ func (opt *Options) Get(namespace string) *config.Configuration {
 	nsCfg.Servers = strings.Split(nsCfg.servers, ",")
 	return &nsCfg.Configuration
 }
+
+// stripWhiteSpace removes all whitespace characters from a string
+func stripWhiteSpace(str string) string {
+	return strings.Replace(str, " ", "", -1)
+}

plugin/storage/cassandra/options_test.go

@@ -50,7 +50,7 @@ func TestOptionsWithFlags(t *testing.T) {
 	command.ParseFlags([]string{
 		"--cas.keyspace=jaeger",
 		"--cas.local-dc=mojave",
-		"--cas.servers=1.1.1.1,2.2.2.2",
+		"--cas.servers=1.1.1.1, 2.2.2.2",
 		"--cas.connections-per-host=42",
 		"--cas.reconnect-interval=42s",
 		"--cas.max-retry-attempts=42",
@@ -62,7 +62,7 @@ func TestOptionsWithFlags(t *testing.T) {
 		// enable aux with a couple overrides
 		"--cas-aux.enabled=true",
 		"--cas-aux.keyspace=jaeger-archive",
-		"--cas-aux.servers=3.3.3.3,4.4.4.4",
+		"--cas-aux.servers=3.3.3.3, 4.4.4.4",
 	})
 	opts.InitFromViper(v)