re
/
viper
forked from mirror/viper
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add support for consul

This commit is contained in:
Brian Ketelsen 2014-10-27 21:14:46 -04:00
parent 51da30f655
commit 563f4d44c4
1 changed files with 10 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
viper.go
View File

@ -523,17 +523,6 @@ func (rce RemoteConfigError) Error() string {
} }
func getRemoteConfig(provider *remoteProvider) (map[string]interface{}, error) { func getRemoteConfig(provider *remoteProvider) (map[string]interface{}, error) {
switch provider.provider {
case "etcd":
return getEtcdConfig(provider)
case "consul":
// not implemented yet
}
return config, nil
}
func getEtcdConfig(provider *remoteProvider) (map[string]interface{}, error) {
var cm crypt.ConfigManager var cm crypt.ConfigManager
var err error var err error
@ -543,9 +532,17 @@ func getEtcdConfig(provider *remoteProvider) (map[string]interface{}, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
cm, err = crypt.NewEtcdConfigManager([]string{provider.endpoint}, kr) if provider.provider == "etcd" {
cm, err = crypt.NewEtcdConfigManager([]string{provider.endpoint}, kr)
} else {
cm, err = crypt.NewConsulConfigManager([]string{provider.endpoint}, kr)
}
} else { } else {
cm, err = crypt.NewStandardEtcdConfigManager([]string{provider.endpoint}) if provider.provider == "etcd" {
cm, err = crypt.NewStandardEtcdConfigManager([]string{provider.endpoint})
} else {
cm, err = crypt.NewStandardConsulConfigManager([]string{provider.endpoint})
}
} }
if err != nil { if err != nil {
return nil, err return nil, err