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
515 Commits 24 Branches 53 Tags
Commit Graph

143 Commits

Author SHA1 Message Date
Ken Hibino
279089f8b9 Minor test updates 2020-09-09 19:17:56 -07:00
Ken Hibino
008eb391f1 Close redis client after each test run 2020-09-08 06:51:01 -07:00
Ken Hibino
7f4533269f Display cluster info in stats command when --cluster flag is passed 2020-09-07 12:55:32 -07:00
Ken Hibino
0fa1c2b6e8 Rename Enqueue methods in Inspector to Run 2020-09-05 13:37:24 -07:00
Ken Hibino
8385383760 Rename InProgress to Active 2020-09-05 12:43:15 -07:00
Ken Hibino
5ecbbf4b40 Rename Enqueued to Pending 2020-09-05 07:04:49 -07:00
Ken Hibino
2298e3f913 Use different redis db number for rdb package tests 2020-09-02 06:35:27 -07:00
Ken Hibino
bbeed8050a Add ClusterNodes and ClusterKeySlot in Inspector 2020-09-02 06:35:27 -07:00
Ken Hibino
0b3732718f Add test flags to run tests using redis cluster 2020-09-02 06:35:27 -07:00
Ken Hibino
7ee1e27822 Fix done lua script 
If UniqueKey is an empty string, do not provide the key to Lua script
because that will cause CROSSSLOT error in redis cluster (since it
doesn't have any hash tag).
 2020-09-02 06:35:26 -07:00
Ken Hibino
8daac4af0f Fix dequeue Lua script to use a single hash tag 2020-09-02 06:35:26 -07:00
Ken Hibino
24f5908b44 Restructure CLI commands with subcommands 2020-09-02 06:35:26 -07:00
Ken Hibino
68ee8d40f9 Update RemoveQueue in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
6aa63857d2 Update ListServers and ListWorkers methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
4583e3822c Update all delete methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
c06734408f Update all kill methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
0ff192bb72 Update enqueue methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
0715f8defd Update all list methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
a7d3f09b49 Update HistoricalStats method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
33919861d6 Update Pause and Unpause methods in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
d7c9508b4b Update CurrentStats method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
859e2656d8 Add AllQueues method to RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
a37afc6062 Remove stale benchmark test 2020-09-02 06:35:26 -07:00
Ken Hibino
76a768ae7e Update WriteServerState and ClearServerState in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
cc16910819 Minor fix 2020-09-02 06:35:26 -07:00
Ken Hibino
92c8a4dbbe Update ListDeadlineExceeded in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
6515d4522b Update CheckAndEnqueue method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
3795c42c98 Update Requeue method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
0ca14cb586 Update Kill method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
0e6d153572 Update Retry method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
f085296d70 Update Done method in RDB 2020-09-02 06:35:26 -07:00
Ken Hibino
62149e5a08 Update Dequeue command in rdb 2020-09-02 06:35:26 -07:00
Ken Hibino
faeeb2c820 Update Enqueue and Schedule commands in rdb 2020-09-02 06:35:26 -07:00
Ken Hibino
a913e6d73f Add healthchecker to check broker connection 2020-07-28 22:45:57 -07:00
Ken Hibino
a28f61f313 Add Inspector type 2020-07-28 22:45:57 -07:00
Ken Hibino
8b60e6a268 Replace github.com/rs/xid with github.com/google/uuid 2020-07-06 05:48:31 -07:00
Ken Hibino
199bf4d66a Minor code cleanup 2020-07-06 05:48:31 -07:00
Ken Hibino
7e942ec241 Use int64 type for Timeout and Deadline in TaskMessage 2020-07-06 05:48:31 -07:00
Ken Hibino
feee87adda Add recoverer 2020-07-06 05:48:31 -07:00
Ken Hibino
7657f560ec Add RDB.ListDeadlineExceeded 2020-07-06 05:48:31 -07:00
Ken Hibino
08b71672aa Update RDB.Requeue to remove message from deadlines set 2020-07-06 05:48:31 -07:00
Ken Hibino
92af00f9fd Update RDB.Dequeue to return deadline as time.Time 2020-07-06 05:48:31 -07:00
Ken Hibino
113451ce6a Update RDB.Kill to remove message from deadlines set 2020-07-06 05:48:31 -07:00
Ken Hibino
9cd9f3d6b4 Update RDB.Retry to remove message from deadlines set 2020-07-06 05:48:31 -07:00
Ken Hibino
7b9119c703 Update RDB.Done to remove message from deadlines set 2020-07-06 05:48:31 -07:00
Ken Hibino
9b05dea394 Update RDB.Dequeue to return message and deadline 2020-07-06 05:48:31 -07:00
Ken Hibino
6cc5bafaba Add task message to deadlines set on dequeue 
Updated dequeueCmd to decode the message and compute its deadline and add
the message to the Deadline set.
 2020-07-06 05:48:31 -07:00
Ken Hibino
7f30fa2bb6 Fix requeue logic in processor 2020-06-13 06:22:32 -07:00
Ken Hibino
a2abeedaa0 Fix JSON number ovewflow issue 2020-06-12 06:29:36 -07:00
Ken Hibino
06c4a1c7f8 Limit the number of tasks moved by CheckAndEnqueue to prevent a long 
running script
 2020-06-08 06:06:18 -07:00