Add Priority type in base package

internal/base/base.go

@@ -11,14 +11,33 @@ import (
 const (
 	processedPrefix = "asynq:processed:"      // STRING - asynq:processed:<yyyy-mm-dd>
 	failurePrefix   = "asynq:failure:"        // STRING - asynq:failure:<yyyy-mm-dd>
-	QueuePrefix     = "asynq:queues:"         // LIST   - asynq:queues:<qname>
+	queuePrefix     = "asynq:queues:"         // LIST   - asynq:queues:<qname>
-	DefaultQueue    = QueuePrefix + "default" // LIST
+	DefaultQueue    = queuePrefix + "default" // LIST
 	ScheduledQueue  = "asynq:scheduled"       // ZSET
 	RetryQueue      = "asynq:retry"           // ZSET
 	DeadQueue       = "asynq:dead"            // ZSET
 	InProgressQueue = "asynq:in_progress"     // LIST
 )
 
+// Priority indicates importance of a task in comparison with others.
+type Priority int
+
+// Levels of priority in descending order.
+const (
+	PriorityHigh Priority = iota
+	PriorityDefault
+	PriorityLow
+)
+
+func (p Priority) String() string {
+	return [...]string{"high", "default", "low"}[p]
+}
+
+// QueueKey returns a redis key string for the given priority.
+func QueueKey(p Priority) string {
+	return queuePrefix + p.String()
+}
+
 // ProcessedKey returns a redis key string for procesed count
 // for the given day.
 func ProcessedKey(t time.Time) string {

internal/base/base_test.go

@@ -5,6 +5,24 @@ import (
 	"time"
 )
 
+func TestQueueKey(t *testing.T) {
+	tests := []struct {
+		p    Priority
+		want string
+	}{
+		{PriorityHigh, "asynq:queues:high"},
+		{PriorityDefault, "asynq:queues:default"},
+		{PriorityLow, "asynq:queues:low"},
+	}
+
+	for _, tc := range tests {
+		got := QueueKey(tc.p)
+		if got != tc.want {
+			t.Errorf("QueueKey(%v) = %q, want %q", tc.p, got, tc.want)
+		}
+	}
+}
+
 func TestProcessedKey(t *testing.T) {
 	tests := []struct {
 		input time.Time