diff --git a/client/grpc/grpc.go b/client/grpc/grpc.go index 6ca92586..ba7a3842 100644 --- a/client/grpc/grpc.go +++ b/client/grpc/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()) diff --git a/client/rpc_client.go b/client/rpc_client.go index 71f55708..c75a67b3 100644 --- a/client/rpc_client.go +++ b/client/rpc_client.go @@ -350,13 +350,8 @@ func (r *rpcClient) next(request Request, opts CallOptions) (selector.Next, erro }, 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 - next, err := r.opts.Selector.Select(service, selectOptions...) + next, err := r.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())