feat: supprt non-kratos instance in consul registry (#1892)

3 years ago · e66a2905ab
parent e98c0078cb
commit e66a2905ab
1 changed files with 3 additions and 0 deletions
--- a/contrib/registry/consul/client.go
+++ b/contrib/registry/consul/client.go
@ -58,6 +58,9 @@ func defaultResolver(_ context.Context, entries []*api.ServiceEntry) []*registry
 			}
 			endpoints = append(endpoints, addr.Address)
 		}
+		if len(endpoints) == 0 && entry.Service.Address != "" && entry.Service.Port != 0 {
+			endpoints = append(endpoints, fmt.Sprintf("http://%s:%d", entry.Service.Address, entry.Service.Port))
+		}
 		services = append(services, &registry.ServiceInstance{
 			ID:        entry.Service.ID,
 			Name:      entry.Service.Service,