(t *testing.T, service *e2e.HTTPService, count int)
| 324 | } |
| 325 | |
| 326 | func waitActivePartitions(t *testing.T, service *e2e.HTTPService, count int) { |
| 327 | matchers := []*labels.Matcher{ |
| 328 | {Type: labels.MatchEqual, Name: "state", Value: "Active"}, |
| 329 | {Type: labels.MatchEqual, Name: "name", Value: "livestore-partitions"}, |
| 330 | } |
| 331 | require.NoError(t, service.WaitSumMetricsWithOptions( |
| 332 | e2e.Equals(float64(count)), |
| 333 | []string{"tempo_partition_ring_partitions"}, |
| 334 | e2e.WithLabelMatchers(matchers...)), "distributor failed to see the partition ring") |
| 335 | } |
| 336 | |
| 337 | func newLiveStore(name string, zone string) *e2e.HTTPService { |
| 338 | return util.NewTempoService(name, "live-store", e2e.NewHTTPReadinessProbe(3200, "/ready", 200, 299), nil, "-live-store.instance-availability-zone="+zone) |
no test coverage detected