(t *testing.T, rindDesc *Desc, prefix string, zones []string, minimizeTokenGenerator *MinimizeSpreadTokenGenerator, dups map[uint32]bool)
| 145 | } |
| 146 | |
| 147 | func generateTokensForIngesters(t *testing.T, rindDesc *Desc, prefix string, zones []string, minimizeTokenGenerator *MinimizeSpreadTokenGenerator, dups map[uint32]bool) { |
| 148 | for _, zone := range zones { |
| 149 | id := fmt.Sprintf("%v-%v", prefix, zone) |
| 150 | tokens := minimizeTokenGenerator.GenerateTokens(rindDesc, id, zone, 512, true) |
| 151 | for _, token := range tokens { |
| 152 | if dups[token] { |
| 153 | t.Fatal("GenerateTokens returned duplicated tokens") |
| 154 | } |
| 155 | dups[token] = true |
| 156 | } |
| 157 | require.Len(t, tokens, 512) |
| 158 | rindDesc.AddIngester(id, id, zone, tokens, ACTIVE, time.Now()) |
| 159 | } |
| 160 | } |
| 161 | |
| 162 | type mockedTokenGenerator struct { |
| 163 | totalZones int |
no test coverage detected