| 3693 | } |
| 3694 | |
| 3695 | func (x *streamingQuerierMetricsQueryRangeClient) Recv() (*QueryRangeResponse, error) { |
| 3696 | m := new(QueryRangeResponse) |
| 3697 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 3698 | return nil, err |
| 3699 | } |
| 3700 | return m, nil |
| 3701 | } |
| 3702 | |
| 3703 | func (c *streamingQuerierClient) MetricsQueryInstant(ctx context.Context, in *QueryInstantRequest, opts ...grpc.CallOption) (StreamingQuerier_MetricsQueryInstantClient, error) { |
| 3704 | stream, err := c.cc.NewStream(ctx, &_StreamingQuerier_serviceDesc.Streams[6], "/tempopb.StreamingQuerier/MetricsQueryInstant", opts...) |