Skip to content

Commit 9eb87f0

Browse files
authored
[-] fix "could not parse ETCD node..." for patroni resolving, fixes #990 (#991)
1 parent 7f8be8c commit 9eb87f0

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

internal/sources/resolver.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -168,16 +168,16 @@ func getEtcdClusterMembers(s Source, hc HostConfig) ([]PatroniClusterMember, err
168168
}
169169

170170
for _, node := range resp.Kvs {
171-
nodeData, err := jsonTextToStringMap(string(node.Value))
172-
if err != nil {
173-
logger.Errorf("Could not parse ETCD node data for node \"%s\": %s", node, err)
174-
continue
175-
}
176171
// remove leading slash and split by "/"
177172
parts := strings.Split(strings.TrimPrefix(string(node.Key), "/"), "/")
178173
if len(parts) < 4 || parts[2] != "members" {
179174
continue // skip non-member keys
180175
}
176+
nodeData, err := jsonTextToStringMap(string(node.Value))
177+
if err != nil {
178+
logger.Errorf("Could not parse ETCD node data for node \"%s\": %s", node.Key, err)
179+
continue
180+
}
181181
role := nodeData["role"]
182182
connURL := nodeData["conn_url"]
183183
scope := parts[1]

0 commit comments

Comments
 (0)