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

129 Commits

Author SHA1 Message Date
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
Ken Hibino
4e800a7f68 Update stats command to show queue paused status 2020-06-08 06:06:18 -07:00
Ken Hibino
363cfedb49 Update Dequeue operation to skip paused queues 2020-06-08 06:06:18 -07:00
Ken Hibino
4595bd41c3 Add Pause and Unpause methods to rdb 2020-06-08 06:06:18 -07:00
Ken Hibino
a38f628f3b Refactor server state management 2020-05-31 06:41:19 -07:00
Ken Hibino
239ef27a6e Update doc comments 2020-04-19 08:51:17 -07:00
Ken Hibino
b086e88a47 Rename ps command to servers 2020-04-19 08:51:17 -07:00
Ken Hibino
aafd8a5b74 Rename internal ProcessState to ServerState 2020-04-19 08:51:17 -07:00
Ken Hibino
b14c73809e Refactor server state 2020-04-19 08:51:17 -07:00
Ken Hibino
9b4438347e Fix comment 2020-03-21 11:44:26 -07:00
Ken Hibino
c33dd447ac Allow client to enqueue a task with unique option 
Changes:

- Added Unique option for clients
- Require go v.13 or above (to use new errors wrapping functions)
- Fixed adding queue key to all-queues set (asynq:queues) when scheduling.
 2020-03-21 11:40:40 -07:00
Bo-Yi Wu
30b68728d4 chore(lint): fix from gofmt -s 2020-03-13 20:01:39 -07:00
Ken Hibino
a425f54d23 [ci skip] Remove todo comment 2020-03-09 06:09:07 -07:00
Ken Hibino
26e399bc9c Add workers command to asynqmon 2020-02-22 21:21:55 -08:00
Ken Hibino
e21fe3bd79 Add ListWorkers to RDB 2020-02-22 21:21:55 -08:00