(t *testing.T, service *e2e.HTTPService, expectedState string, expectedCount int)
| 289 | } |
| 290 | |
| 291 | func verifyPartitionState(t *testing.T, service *e2e.HTTPService, expectedState string, expectedCount int) { |
| 292 | partitionStateMatchers := []*labels.Matcher{ |
| 293 | {Type: labels.MatchEqual, Name: "state", Value: expectedState}, |
| 294 | {Type: labels.MatchEqual, Name: "name", Value: "livestore-partitions"}, |
| 295 | } |
| 296 | require.NoError(t, service.WaitSumMetricsWithOptions( |
| 297 | e2e.Equals(float64(expectedCount)), |
| 298 | []string{"tempo_partition_ring_partitions"}, |
| 299 | e2e.WithLabelMatchers(partitionStateMatchers...), |
| 300 | )) |
| 301 | } |
| 302 | |
| 303 | func waitForTraceInLiveStore(t *testing.T, expectedTraces int, liveStores ...*e2e.HTTPService) *e2e.HTTPService { |
| 304 | ch := make(chan *e2e.HTTPService) |
no test coverage detected