Method GenerateTokens

pkg/ring/token_generator.go:38–66

(ring *Desc, _, _ string, numTokens int, _ bool)

}

func (g *RandomTokenGenerator) GenerateTokens(ring *Desc, _, _ string, numTokens int, _ bool) []uint32 {
	if numTokens <= 0 {
		return []uint32{}
	}

	takenTokens := ring.GetTokens()
	r := rand.New(rand.NewSource(time.Now().UnixNano()))

	used := make(map[uint32]bool, len(takenTokens))
	for _, v := range takenTokens {
		used[v] = true
	}

	tokens := make([]uint32, 0, numTokens)
	for i := 0; i < numTokens; {
		candidate := r.Uint32()
		if used[candidate] {
			continue
		}
		used[candidate] = true
		tokens = append(tokens, candidate)
		i++
	}

	// Ensure returned tokens are sorted.
	slices.Sort(tokens)

	return tokens
}

type MinimizeSpreadTokenGenerator struct {
	innerGenerator TokenGenerator