rpc客户端修复

detached
杨赟 2 years ago
parent 4ccd04056a
commit a48abf027b

@ -203,7 +203,7 @@ func (d *ConsulDiscovery) watch() {
continue
}
for _, p := range ps {
if !strings.HasPrefix(p.Key, prefix) { // avoid prefix issue of consul List
if path.Dir(p.Key) != d.basePath {
continue
}
k := strings.TrimPrefix(p.Key, prefix)

Loading…
Cancel
Save