()
| 23 | func (a byFirstTime) Less(i, j int) bool { return a[i].minTime() < a[j].minTime() } |
| 24 | |
| 25 | func (resp *PrometheusResponse) minTime() int64 { |
| 26 | data := resp.GetData() |
| 27 | res := data.GetResult() |
| 28 | // minTime should only be called when the response is fron range query. |
| 29 | matrix := res.GetMatrix() |
| 30 | sampleStreams := matrix.GetSampleStreams() |
| 31 | if len(sampleStreams) == 0 { |
| 32 | return -1 |
| 33 | } |
| 34 | if len(sampleStreams[0].Samples) == 0 { |
| 35 | return -1 |
| 36 | } |
| 37 | return sampleStreams[0].Samples[0].TimestampMs |
| 38 | } |
| 39 | |
| 40 | // MergeResponse merges multiple Response into one. |
| 41 | func MergeResponse(ctx context.Context, sumStats bool, req Request, responses ...Response) (Response, error) { |
no test coverage detected