unistack-org/micro
4
0
Fork 3
Code Issues 17 Pull Requests 1 Actions Packages Projects Releases 258 Wiki Activity

revert some protocol changes for now

Browse Source
This commit is contained in:
Asim Aslam 2019-11-30 21:20:33 +00:00
parent ce1942c578
commit 00bbb3ac61
2 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client/grpc/grpc.go
View File

@ -71,13 +71,8 @@ func (g *grpcClient) next(request client.Request, opts client.CallOptions) (sele
}, nil }, nil
} }
// only get the things that are of grpc protocol
selectOptions := append(opts.SelectOptions, selector.WithFilter(
selector.FilterLabel("protocol", "grpc"),
))
// get next nodes from the selector // get next nodes from the selector
next, err := g.opts.Selector.Select(service, selectOptions...) next, err := g.opts.Selector.Select(service, opts.SelectOptions...)
if err != nil { if err != nil {
if err == selector.ErrNotFound { if err == selector.ErrNotFound {
return nil, errors.InternalServerError("go.micro.client", "service %s: %s", service, err.Error()) return nil, errors.InternalServerError("go.micro.client", "service %s: %s", service, err.Error())

7
client/rpc_client.go
View File

@ -350,13 +350,8 @@ func (r *rpcClient) next(request Request, opts CallOptions) (selector.Next, erro
}, nil }, nil
} }
// only get the things that are of mucp protocol
selectOptions := append(opts.SelectOptions, selector.WithFilter(
selector.FilterLabel("protocol", "mucp"),
))
// get next nodes from the selector // get next nodes from the selector
next, err := r.opts.Selector.Select(service, selectOptions...) next, err := r.opts.Selector.Select(service, opts.SelectOptions...)
if err != nil { if err != nil {
if err == selector.ErrNotFound { if err == selector.ErrNotFound {
return nil, errors.InternalServerError("go.micro.client", "service %s: %s", service, err.Error()) return nil, errors.InternalServerError("go.micro.client", "service %s: %s", service, err.Error())