2
0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-22 16:50:18 +08:00

Refactor redis keys and store messages in protobuf

Changes:
- Task messages are stored under "asynq:{<qname>}:t:<task_id>" key in redis, value is a HASH type and message are stored under "msg" key in the hash. The hash also stores "deadline", "timeout".
- Redis LIST and ZSET stores task message IDs
- Task messages are serialized using protocol buffer
This commit is contained in:
Ken Hibino 2021-03-12 16:23:08 -08:00
parent e425cf0fb1
commit f3c848f25f

View File

@ -765,10 +765,17 @@ func (r *RDB) DeletePendingTask(qname string, id uuid.UUID) error {
n, ok := res.(int64)
if !ok {
return fmt.Errorf("command error: unexpected return value %v", res)
<<<<<<< HEAD
}
if n == 0 {
return ErrTaskNotFound
}
=======
}
if n == 0 {
return ErrTaskNotFound
}
>>>>>>> e0402fe... Refactor redis keys and store messages in protobuf
return nil
}