| 369 | } |
| 370 | |
| 371 | func (h *TempoHarness) WaitTracesWritable(t *testing.T) { |
| 372 | t.Helper() |
| 373 | |
| 374 | matchers := []*labels.Matcher{ |
| 375 | {Type: labels.MatchEqual, Name: "state", Value: "Active"}, |
| 376 | {Type: labels.MatchEqual, Name: "name", Value: "livestore-partitions"}, |
| 377 | } |
| 378 | |
| 379 | // distributors have to be non-nil if we're writing anything |
| 380 | distributor := h.Services[ServiceDistributor] |
| 381 | require.NoError(t, distributor.WaitSumMetricsWithOptions( |
| 382 | e2e.Equals(float64(1)), |
| 383 | []string{"tempo_partition_ring_partitions"}, |
| 384 | e2e.WithLabelMatchers(matchers...)), "distributor failed to see the partition ring") |
| 385 | } |
| 386 | |
| 387 | func (h *TempoHarness) WaitTracesQueryable(t *testing.T, traces int) { |
| 388 | t.Helper() |