From 88d56e653d3018cda49101eb2ebcac856cc62f94 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sat, 30 Nov 2019 21:20:33 +0000 Subject: [PATCH] revert some protocol changes for now --- grpc.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/grpc.go b/grpc.go index 6ca9258..ba7a384 100644 --- a/grpc.go +++ b/grpc.go @@ -71,13 +71,8 @@ func (g *grpcClient) next(request client.Request, opts client.CallOptions) (sele }, 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 - next, err := g.opts.Selector.Select(service, selectOptions...) + next, err := g.opts.Selector.Select(service, opts.SelectOptions...) if err != nil { if err == selector.ErrNotFound { return nil, errors.InternalServerError("go.micro.client", "service %s: %s", service, err.Error())