(s *grpc.Server, srv StreamingQuerierServer)
| 3770 | } |
| 3771 | |
| 3772 | func RegisterStreamingQuerierServer(s *grpc.Server, srv StreamingQuerierServer) { |
| 3773 | s.RegisterService(&_StreamingQuerier_serviceDesc, srv) |
| 3774 | } |
| 3775 | |
| 3776 | func _StreamingQuerier_Search_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 3777 | m := new(SearchRequest) |
no outgoing calls