diff --git a/internal/base/base.go b/internal/base/base.go index 3b38fba..3c35555 100644 --- a/internal/base/base.go +++ b/internal/base/base.go @@ -9,14 +9,16 @@ import ( // Redis keys const ( - processedPrefix = "asynq:processed:" // STRING - asynq:processed: - failurePrefix = "asynq:failure:" // STRING - asynq:failure: - queuePrefix = "asynq:queues:" // LIST - asynq:queues: - DefaultQueue = queuePrefix + "default" // LIST - ScheduledQueue = "asynq:scheduled" // ZSET - RetryQueue = "asynq:retry" // ZSET - DeadQueue = "asynq:dead" // ZSET - InProgressQueue = "asynq:in_progress" // LIST + processedPrefix = "asynq:processed:" // STRING - asynq:processed: + failurePrefix = "asynq:failure:" // STRING - asynq:failure: + queuePrefix = "asynq:queues:" // LIST - asynq:queues: + DefaultQueue = queuePrefix + "default" // LIST + HighPriorityQueue = queuePrefix + "high" // LIST + LowPriorityQueue = queuePrefix + "low" // 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. diff --git a/internal/base/base_test.go b/internal/base/base_test.go index cd081c7..f4d54dd 100644 --- a/internal/base/base_test.go +++ b/internal/base/base_test.go @@ -10,9 +10,9 @@ func TestQueueKey(t *testing.T) { p Priority want string }{ - {PriorityHigh, "asynq:queues:high"}, - {PriorityDefault, "asynq:queues:default"}, - {PriorityLow, "asynq:queues:low"}, + {PriorityHigh, HighPriorityQueue}, + {PriorityDefault, DefaultQueue}, + {PriorityLow, LowPriorityQueue}, } for _, tc := range tests {