revert some protocol changes for now
This commit is contained in:
		
							
								
								
									
										7
									
								
								grpc.go
									
									
									
									
									
								
							
							
						
						
									
										7
									
								
								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()) | ||||
|   | ||||
		Reference in New Issue
	
	Block a user