(cc *grpc.ClientConn)
| 3505 | } |
| 3506 | |
| 3507 | func NewStreamingQuerierClient(cc *grpc.ClientConn) StreamingQuerierClient { |
| 3508 | return &streamingQuerierClient{cc} |
| 3509 | } |
| 3510 | |
| 3511 | func (c *streamingQuerierClient) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (StreamingQuerier_SearchClient, error) { |
| 3512 | stream, err := c.cc.NewStream(ctx, &_StreamingQuerier_serviceDesc.Streams[0], "/tempopb.StreamingQuerier/Search", opts...) |
no outgoing calls