use uint64 for priority variable

Signed-off-by: Juan Peña <[email protected]>

Author: piggito

client/v3/experimental/recipes/priority_queue.go

@@ -35,7 +35,7 @@ func NewPriorityQueue(client *v3.Client, key string) *PriorityQueue {
 }
 
 // Enqueue puts a value into a queue with a given priority.
-func (q *PriorityQueue) Enqueue(val string, pr uint16) error {
+func (q *PriorityQueue) Enqueue(val string, pr uint64) error {
 	prefix := fmt.Sprintf("%s%05d", q.key, pr)
 	_, err := newSequentialKV(q.client, prefix, val)
 	return err

tests/integration/clientv3/experimental/recipes/v3_queue_test.go

@@ -102,7 +102,7 @@ func TestPrQueueOneReaderOneWriter(t *testing.T) {
 	q := recipe.NewPriorityQueue(etcdc, "testprq")
 	for i := 0; i < 5; i++ {
 		// [0, 2] priority for priority collision to test seq keys
-		pr := uint16(rand.Intn(3))
+		pr := uint64(rand.Intn(3))
 		if err := q.Enqueue(fmt.Sprintf("%d", pr), pr); err != nil {
 			t.Fatalf("error enqueuing (%v)", err)
 		}
@@ -232,7 +232,7 @@ type flatPriorityQueue struct{ *recipe.PriorityQueue }
 
 func (q *flatPriorityQueue) Enqueue(val string) error {
 	// randomized to stress dequeuing logic; order isn't important
-	return q.PriorityQueue.Enqueue(val, uint16(rand.Intn(2)))
+	return q.PriorityQueue.Enqueue(val, uint64(rand.Intn(2)))
 }
 func (q *flatPriorityQueue) Dequeue() (string, error) {
 	return q.PriorityQueue.Dequeue()