in clients/zk_client/zk_client.go [112:127]
func (zc *ShenYuZkClient) GetServiceInstanceInfo(metaData interface{}) (instances interface{}, err error) {
mdr := zc.checkCommonParam(metaData, err)
path := zc.Zcp.ZkRoot + "/" + mdr.AppName
var nodes []*model.MetaDataRegister
data, _, err := zc.ZkClient.Get(path)
if err != nil {
logger.Fatalf("zk Get node failure, err %v:", err)
}
node := new(model.MetaDataRegister)
err = json.Unmarshal(data, node)
if err != nil {
return nil, err
}
nodes = append(nodes, node)
return nodes, nil
}