调整consul取微服务支持tag
This commit is contained in:
parent
a7f76f00a9
commit
aed016e7be
|
|
@ -123,9 +123,9 @@ func FindNode(servicename, tag string) (*consulapi.AgentService, error) {
|
|||
return services[r.Intn(l)%l].Service, nil
|
||||
}
|
||||
|
||||
//FindServer 从consul中发现服务,并返回grpc连接实例
|
||||
func FindServer(servicename string) (*grpc.ClientConn, error) {
|
||||
node, err := FindNode(servicename, "") //无tag视为grpc服务
|
||||
//FindService 从consul中发现服务,并返回grpc连接实例
|
||||
func FindService(servicename, tag string) (*grpc.ClientConn, error) {
|
||||
node, err := FindNode(servicename, tag) //无tag视为grpc服务
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue