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

465 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
1bb9f10707 Update recoverer 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
281b80f4bb Update scheduler to check and enqueue for only the specified queues. 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
669c7995c4 Run CI builds using go v1.15.x 2020-09-02 06:34:58 -07:00
Ken Hibino
6d6a301379 v0.11.0 v0.11.0 2020-07-28 22:46:41 -07:00
Ken Hibino
53f9475582 Update changelog 2020-07-28 22:45:57 -07:00
Ken Hibino
e8fdbc5a72 Fix history command 2020-07-28 22:45:57 -07:00
Ken Hibino
5f06c308f0 Add Pause and Unpause queue methods to Inspector 2020-07-28 22:45:57 -07:00
Ken Hibino
a913e6d73f Add healthchecker to check broker connection 2020-07-28 22:45:57 -07:00
Ken Hibino
6978e93080 Fix flaky test 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
9bd3d8e19e v0.10.0 v0.10.0 2020-07-06 05:53:56 -07:00
Ken Hibino
7382e2aeb8 Do not start worker goroutine for task already exceeded its deadline 2020-07-06 05:48:31 -07:00
Ken Hibino
007fac8055 Invoke error handler when ctx.Done channel is closed 2020-07-06 05:48:31 -07:00
Ken Hibino
8d43fe407a Change ErrorHandler function signature 2020-07-06 05:48:31 -07:00
Ken Hibino
34b90ecc8a Return Result struct to caller of Enqueue 2020-07-06 05:48:31 -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
195f4603bb Add migrate command to CLI 
The command converts all messages in redis to be compatible for asynq
v0.10.0
 2020-07-06 05:48:31 -07:00
Ken Hibino
2e2c9b9f6b Update docs 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
379da8f7a2 Clean up processor test 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
83f1e20d74 Add deadline to syncRequest 
- syncer will drop a request if its deadline has been exceeded
 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
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