go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-21 16:20:18 +08:00
Code Issues Projects Releases Wiki Activity

Export (High|Low)PriorityQueue constant from base pkg

Browse Source
This commit is contained in:
Ken Hibino 2020-01-01 12:12:49 -08:00
parent 2e95166f39
commit eb191c07d1
2 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/base/base.go
View File

@ -9,14 +9,16 @@ import (
// Redis keys
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>
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:<yyyy-mm-dd>
failurePrefix = "asynq:failure:" // STRING - asynq:failure:<yyyy-mm-dd>
queuePrefix = "asynq:queues:" // LIST - asynq:queues:<qname>
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.

6
internal/base/base_test.go
View File

@ -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 {