diff options
Diffstat (limited to 'plugin')
| -rw-r--r-- | plugin/etcd/etcd.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/plugin/etcd/etcd.go b/plugin/etcd/etcd.go index 4734fe344..17422e347 100644 --- a/plugin/etcd/etcd.go +++ b/plugin/etcd/etcd.go @@ -139,13 +139,12 @@ Nodes: if err := json.Unmarshal(n.Value, serv); err != nil { return nil, fmt.Errorf("%s: %s", n.Key, err.Error()) } - b := msg.Service{Host: serv.Host, Port: serv.Port, Priority: serv.Priority, Weight: serv.Weight, Text: serv.Text, Key: string(n.Key)} - if _, ok := bx[b]; ok { + serv.Key = string(n.Key) + if _, ok := bx[*serv]; ok { continue } - bx[b] = struct{}{} + bx[*serv] = struct{}{} - serv.Key = string(n.Key) serv.TTL = e.TTL(n, serv) if serv.Priority == 0 { serv.Priority = priority |