package core

import "hash/fnv"

const DefaultMaxParallelism = 128

func AssignToKeyGroup(key string, maxParallelism int) int {

	if maxParallelism <= 0 {
		maxParallelism = DefaultMaxParallelism
	}

	// hash
	h := fnv.New32a()
	h.Write([]byte(key))
	hash := h.Sum32()

	return int(hash % uint32(maxParallelism))
}