kv: Log error when checking existence of server url key
This commit is contained in:
parent
c864d80270
commit
f621a46a2e
1 changed files with 5 additions and 1 deletions
|
@ -162,7 +162,11 @@ func (provider *Kv) list(keys ...string) []string {
|
||||||
func (provider *Kv) listServers(backend string) []string {
|
func (provider *Kv) listServers(backend string) []string {
|
||||||
serverNames := provider.list(backend, "/servers/")
|
serverNames := provider.list(backend, "/servers/")
|
||||||
return fun.Filter(func(serverName string) bool {
|
return fun.Filter(func(serverName string) bool {
|
||||||
if _, err := provider.kvclient.Get(fmt.Sprint(serverName, "/url")); err != nil {
|
key := fmt.Sprint(serverName, "/url")
|
||||||
|
if _, err := provider.kvclient.Get(key); err != nil {
|
||||||
|
if err != store.ErrKeyNotFound {
|
||||||
|
log.Errorf("Failed to retrieve value for key %s: %s", key, err)
|
||||||
|
}
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
return provider.checkConstraints(serverName, "/tags")
|
return provider.checkConstraints(serverName, "/tags")
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue