| 3661 | } |
| 3662 | |
| 3663 | func (x *streamingQuerierSearchTagValuesV2Client) Recv() (*SearchTagValuesV2Response, error) { |
| 3664 | m := new(SearchTagValuesV2Response) |
| 3665 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 3666 | return nil, err |
| 3667 | } |
| 3668 | return m, nil |
| 3669 | } |
| 3670 | |
| 3671 | func (c *streamingQuerierClient) MetricsQueryRange(ctx context.Context, in *QueryRangeRequest, opts ...grpc.CallOption) (StreamingQuerier_MetricsQueryRangeClient, error) { |
| 3672 | stream, err := c.cc.NewStream(ctx, &_StreamingQuerier_serviceDesc.Streams[5], "/tempopb.StreamingQuerier/MetricsQueryRange", opts...) |