| 3533 | } |
| 3534 | |
| 3535 | func (x *streamingQuerierSearchClient) Recv() (*SearchResponse, error) { |
| 3536 | m := new(SearchResponse) |
| 3537 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 3538 | return nil, err |
| 3539 | } |
| 3540 | return m, nil |
| 3541 | } |
| 3542 | |
| 3543 | func (c *streamingQuerierClient) SearchTags(ctx context.Context, in *SearchTagsRequest, opts ...grpc.CallOption) (StreamingQuerier_SearchTagsClient, error) { |
| 3544 | stream, err := c.cc.NewStream(ctx, &_StreamingQuerier_serviceDesc.Streams[1], "/tempopb.StreamingQuerier/SearchTags", opts...) |