go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-23 01:00:17 +08:00
Code Issues Projects Releases Wiki Activity
652 Commits 24 Branches 53 Tags
Commit Graph

652 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Ken Hibino
04ad1ddbc3 Fix recoverer test 2021-06-07 16:19:14 -07:00
Ken Hibino
e3b293193a Update ProcessorRetry test 2021-06-07 16:19:14 -07:00
Ken Hibino
5b58444821 Format payload bytes in CLI output 2021-06-07 16:19:14 -07:00
Ken Hibino
bf5e6b2190 Rename cli subcommand to not to use dash 2021-06-07 16:19:14 -07:00
Ken Hibino
25e6360e14 Add task inspect command 2021-06-07 16:19:14 -07:00
Ken Hibino
44d15e46bf Add String method to TaskState 2021-06-07 16:19:14 -07:00
Ken Hibino
e1a33c6b5e Minor fix in queue command 2021-06-07 16:19:14 -07:00
Ken Hibino
2e57764dff Fix asynq CLI build 2021-06-07 16:19:14 -07:00
Ken Hibino
28cd7d3633 Add Inspector.GetTaskInfo 2021-06-07 16:19:14 -07:00
Ken Hibino
f834edbc66 Fix lua scripts for redis cluster 2021-06-07 16:19:14 -07:00
Ken Hibino
802ee2665c Define RDB.GetTaskInfo 2021-06-07 16:19:14 -07:00
Ken Hibino
8ae62c4e1d Rename Inspector.CurrentStats to GetQueueInfo 2021-06-07 16:19:14 -07:00
Ken Hibino
2e719fd7ba Rename Inspector.CancelActiveTask to CancelProcessing 2021-06-07 16:19:14 -07:00
Ken Hibino
afb18225bc Make NodeCluster fields read-only 2021-06-07 16:19:14 -07:00
Ken Hibino
88ea30e23f Misc cleanup 2021-06-07 16:19:14 -07:00
Ken Hibino
3a14f43179 Update WorkerInfo and remove unnecessary types 2021-06-07 16:19:14 -07:00
Ken Hibino
ffa59f75a0 Update Inspector.List*Task methods to return ErrQueueNotFound 2021-06-07 16:19:14 -07:00
Ken Hibino
2046d7edc4 Update Inspector.ListArchivedTasks 2021-06-07 16:19:14 -07:00
Ken Hibino
ffa1c92aa9 Add LastFailedAt to TaskInfo 2021-06-07 16:19:14 -07:00
Ken Hibino
704fc5753b Record last_failed_at time on Retry or Archive event 2021-06-07 16:19:14 -07:00
Ken Hibino
4e24bb50c7 Add LastFailedAt field to TaskMessage 2021-06-07 16:19:14 -07:00
Ken Hibino
ad1abe5f8c Update List methods (expect for ListArchived) 2021-06-07 16:19:14 -07:00
Ken Hibino
ca047c474d Move inspeq package content to asynq package 2021-06-07 16:19:13 -07:00
Ken Hibino
a8a636ec4a Replace ArchiveTaskByKey with ArchiveTask in Inspector 2021-06-07 16:19:12 -07:00
Ken Hibino
95f8b1f4ee Replace DeleteTaskByKey with DeleteTask in Inspector 2021-06-07 16:18:38 -07:00
Ken Hibino
55a8ef036e Replace RunTaskByKey with RunTask in Inspector 2021-06-07 16:18:19 -07:00
Ken Hibino
c2998b7f57 Update Client.Enqueue to return TaskInfo 2021-06-07 16:17:52 -07:00
Ken Hibino
2b064aa6a7 Define TaskInfo type 2021-06-07 16:17:20 -07:00
Ken Hibino
5e89a2c2e8 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
 2021-06-07 16:16:26 -07:00
Ken Hibino
30723edcaf Add TaskState type to base package 2021-06-07 16:13:59 -07:00
Ken Hibino
9e5f39fa3a Fix build 2021-06-07 16:13:59 -07:00
Ken Hibino
252af60672 Update RDB methods with new errors package 2021-06-07 16:13:59 -07:00
Ken Hibino
f0964038c0 Update RDB.Dequeue with new errors package 2021-06-07 16:13:59 -07:00
Ken Hibino
5a661fcf05 Minor fixes 2021-06-07 16:13:59 -07:00
Ken Hibino
7948cb5dbf Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors 2021-06-07 16:13:59 -07:00
Ken Hibino
59ba0525a0 Add errors.RedisCommandError type 2021-06-07 16:13:59 -07:00
Ken Hibino
6ccb0ab5c4 Update RDB.CurrentStats and RDB.HistoricalStats with specific errors 2021-06-07 16:13:59 -07:00
Ken Hibino
3db8eff01b Update RDB.RemoveQueue with specific error types 2021-06-07 16:13:59 -07:00
Ken Hibino
95a6942b4e Update rdb.List* methods with specific errors 2021-06-07 16:13:59 -07:00
Ken Hibino
ba30b8b940 Return QueueNotFoundError from DeleteAll* methods 2021-06-07 16:13:59 -07:00
Ken Hibino
bfd7dd57d2 Update RDB.RunAll* methods with task state 2021-06-07 16:13:59 -07:00
Ken Hibino
2a30fcb6ea Return QueueNotFoundError from ArchiveAll* methods 2021-06-07 16:13:59 -07:00
Ken Hibino
b440702039 Update tests for RDB.DeleteTask and RDB.ArchiveTask 2021-06-07 16:13:59 -07:00
Ken Hibino
b6aa10e4ff Update RDB.RunTask with more specific errors 2021-06-07 16:13:59 -07:00
Ken Hibino
213f5326e1 Update RDB.DeleteTask with task state 2021-06-07 16:13:59 -07:00
Ken Hibino
020c09ce18 Update RDB.ArchiveAll methods with task state 2021-06-07 16:13:59 -07:00
Ken Hibino
cf98807307 Update RDB.ArchiveAllPendingTasks with task state 2021-06-07 16:13:59 -07:00
Ken Hibino
b0b1ece480 Reorganize test for RDB.ArchiveTask 2021-06-07 16:13:59 -07:00
Ken Hibino
8a5d5a4332 Update errors package with detailed comments 2021-06-07 16:13:59 -07:00
Ken Hibino
25173cd505 Update RDB.ArchiveTask with custom errors 2021-06-07 16:13:59 -07:00