(t *testing.T)
| 530 | } |
| 531 | |
| 532 | func TestAddIngesterReplacesExistingTokens(t *testing.T) { |
| 533 | r := NewDesc() |
| 534 | |
| 535 | const ing1Name = "ing1" |
| 536 | |
| 537 | // old tokens will be replaced |
| 538 | r.Ingesters[ing1Name] = InstanceDesc{ |
| 539 | Tokens: []uint32{11111, 22222, 33333}, |
| 540 | } |
| 541 | |
| 542 | newTokens := initTokenGenerator(t).GenerateTokens(128, nil) |
| 543 | |
| 544 | r.AddIngester(ing1Name, "addr", "1", newTokens, ACTIVE, time.Now(), false, time.Time{}, nil) |
| 545 | |
| 546 | require.Equal(t, newTokens, Tokens(r.Ingesters[ing1Name].Tokens)) |
| 547 | } |
| 548 | |
| 549 | func TestRing_Get_ZoneAwarenessWithIngesterLeaving(t *testing.T) { |
| 550 | const testCount = 10000 |
nothing calls this directly
no test coverage detected