Cap priority value while dynamically increasing priority of goroutine…

…s. (#12)

* update priority value only if it's not max

* update priority value in test

* use constants in test

priority/priorityRateLimiter.go

@@ -81,8 +81,10 @@ func (p *PriorityLimiter) Wait(priority constants.PriorityValue) {
 				return
 			case <-ticker.C:
 				p.mu.Lock()
-				currentPriority := w.Priority
-				p.waitList.Update(w, currentPriority+1)
+				if w.Priority < int(constants.High) {
+					currentPriority := w.Priority
+					p.waitList.Update(w, currentPriority+1)
+				}
 				p.mu.Unlock()
 			}
 		}

priority/priorityRateLimiter_test.go

@@ -55,8 +55,8 @@ func TestDynamicPriority(t *testing.T) {
 	pVal = nl.waitList.Top()
 	pValItem = pVal.(queue.Item)
 	expectedVal2 := pValItem.Priority
-	assert.GreaterOrEqual(t, expectedVal1, 10)
-	assert.GreaterOrEqual(t, expectedVal2, 10)
+	assert.GreaterOrEqual(t, expectedVal1, int(constants.High))
+	assert.GreaterOrEqual(t, expectedVal2, int(constants.High))
 }
 
 func TestPriorityLimiter_Timeout(t *testing.T) {