| 3629 | } |
| 3630 | |
| 3631 | func (x *streamingQuerierSearchTagValuesClient) Recv() (*SearchTagValuesResponse, error) { |
| 3632 | m := new(SearchTagValuesResponse) |
| 3633 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 3634 | return nil, err |
| 3635 | } |
| 3636 | return m, nil |
| 3637 | } |
| 3638 | |
| 3639 | func (c *streamingQuerierClient) SearchTagValuesV2(ctx context.Context, in *SearchTagValuesRequest, opts ...grpc.CallOption) (StreamingQuerier_SearchTagValuesV2Client, error) { |
| 3640 | stream, err := c.cc.NewStream(ctx, &_StreamingQuerier_serviceDesc.Streams[4], "/tempopb.StreamingQuerier/SearchTagValuesV2", opts...) |