@@ -56,7 +56,7 @@ func (w *Watcher) Next() (*registry.Result, error) {
|
||||
return nil, errors.New("invalid service key")
|
||||
}
|
||||
svc.Name = parts[0]
|
||||
// ocis registers nodes with a - seperator
|
||||
// ocis registers nodes with a - separator
|
||||
svc.Nodes = []*registry.Node{{Id: parts[0] + "-" + parts[1]}}
|
||||
svc.Version = parts[2]
|
||||
} else {
|
||||
|
||||
@@ -65,6 +65,7 @@ func BuildHTTPService(serviceID, address string, version string) *mRegistry.Serv
|
||||
}
|
||||
|
||||
node := &mRegistry.Node{
|
||||
// This id is read by the registry watcher
|
||||
Id: serviceID + "-" + server.DefaultId,
|
||||
Address: net.JoinHostPort(addr, fmt.Sprint(port)),
|
||||
Metadata: make(map[string]string),
|
||||
|
||||
Reference in New Issue
Block a user