(i int)
| 243 | } |
| 244 | |
| 245 | func createStreamResponse(i int) *ingester_client.QueryStreamResponse { |
| 246 | return &ingester_client.QueryStreamResponse{Chunkseries: []ingester_client.TimeSeriesChunk{ |
| 247 | { |
| 248 | FromIngesterId: strconv.Itoa(i), |
| 249 | Labels: createLabels(i), |
| 250 | Chunks: []ingester_client.Chunk{ |
| 251 | { |
| 252 | StartTimestampMs: int64(i), |
| 253 | EndTimestampMs: int64(i), |
| 254 | Encoding: int32(i), |
| 255 | Data: []byte(strconv.Itoa(i)), |
| 256 | }, |
| 257 | }, |
| 258 | }, |
| 259 | }} |
| 260 | } |
| 261 | |
| 262 | func createRequest(i int) *cortexpb.WriteRequest { |
| 263 | labels := createLabels(i) |
no test coverage detected