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

169 Commits

Author SHA1 Message Date
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
6176565abc Fix flaky ProcessorRetry test 2020-09-02 06:35:27 -07:00
Ken Hibino
ecbfac2c46 Add RedisClusterClientOpt to connect to redis cluster 2020-09-02 06:35:26 -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
34aa0b2277 Add more processor tests 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
7929a1d6d3 Update Broker interface 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
87124993f8 Move unique key generator function to base 2020-09-02 06:35:26 -07:00
Ken Hibino
03ea601c05 Update base package to generate redis keys with hashtag 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
92d77bbc6e Minor comment fix 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
486dcd799b Add version command to CLI 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
7c7de0d8e0 Fix processor 2020-07-06 05:48:31 -07:00
Ken Hibino
4e8ac151ae Update processor to adapt for deadlines set change 
- Processor dequeues tasks only when it's available to process
- Processor retries a task when its context's Done channel is closed
 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