Fix etcd backend with prefix /
Signed-off-by: Emile Vauge <emile@vauge.com>
This commit is contained in:
parent
11a6331185
commit
61def880db
3 changed files with 31 additions and 2 deletions
|
@ -170,7 +170,7 @@ func (provider *Kv) list(keys ...string) []string {
|
|||
}
|
||||
directoryKeys := make(map[string]string)
|
||||
for _, key := range keysPairs {
|
||||
directory := strings.Split(strings.TrimPrefix(key.Key, strings.TrimPrefix(joinedKeys, "/")), "/")[0]
|
||||
directory := strings.Split(strings.TrimPrefix(key.Key, joinedKeys), "/")[0]
|
||||
directoryKeys[directory] = joinedKeys + directory
|
||||
}
|
||||
return fun.Values(directoryKeys).([]string)
|
||||
|
@ -178,7 +178,7 @@ func (provider *Kv) list(keys ...string) []string {
|
|||
|
||||
func (provider *Kv) get(defaultValue string, keys ...string) string {
|
||||
joinedKeys := strings.Join(keys, "")
|
||||
keyPair, err := provider.kvclient.Get(joinedKeys)
|
||||
keyPair, err := provider.kvclient.Get(strings.TrimPrefix(joinedKeys, "/"))
|
||||
if err != nil {
|
||||
log.Warnf("Error getting key %s %s, setting default %s", joinedKeys, err, defaultValue)
|
||||
return defaultValue
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue