Skip to content

Commit

Permalink
Cluster auto dicovery from conf
Browse files Browse the repository at this point in the history
  • Loading branch information
svaroqui committed Feb 12, 2017
1 parent 623f09f commit 36ecece
Showing 1 changed file with 23 additions and 0 deletions.
23 changes: 23 additions & 0 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,29 @@ func initConfig() {
if _, ok := err.(viper.ConfigParseError); ok {
log.Fatalln("ERROR: Could not parse config file:", err)
}
m := viper.AllKeys()
if cfgGroup == "" {
var clusterDicovery = map[string]string{}
var discoveries []string
for _, k := range m {

if strings.Contains(k, ".") {
mycluster := strings.Split(k, ".")[0]
if mycluster != "default" {
_, ok := clusterDicovery[mycluster]
if !ok {
clusterDicovery[mycluster] = mycluster
discoveries = append(discoveries, mycluster)
// log.Println(strings.Split(k, ".")[0])
}
}

}
}
cfgGroup = strings.Join(discoveries, ",")
log.Printf("INFO : Discovered clusters %s", cfgGroup)

}
cfgGroupIndex = 0

cf1 := viper.Sub("Default")
Expand Down

0 comments on commit 36ecece

Please sign in to comment.