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

636 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Ken Hibino
87e82dd665 Update Inspector.List*Task methods to return ErrQueueNotFound 2021-06-22 16:40:48 -07:00
Ken Hibino
bab489a2a1 Update Inspector.ListArchivedTasks 2021-06-22 16:40:48 -07:00
Ken Hibino
c28b40daef Add LastFailedAt to TaskInfo 2021-06-22 16:40:48 -07:00
Ken Hibino
95bd979c06 Record last_failed_at time on Retry or Archive event 2021-06-22 16:40:48 -07:00
Ken Hibino
776a495f25 Add LastFailedAt field to TaskMessage 2021-06-22 16:40:48 -07:00
Ken Hibino
77e8eef1f1 Update List methods (expect for ListArchived) 2021-06-22 16:40:48 -07:00
Ken Hibino
043088b379 Move inspeq package content to asynq package 2021-06-22 16:40:48 -07:00
Ken Hibino
6bfe641a2e Replace ArchiveTaskByKey with ArchiveTask in Inspector 2021-06-22 16:40:48 -07:00
Ken Hibino
5a7a38d2f1 Replace DeleteTaskByKey with DeleteTask in Inspector 2021-06-22 16:40:48 -07:00
Ken Hibino
976d39676e Replace RunTaskByKey with RunTask in Inspector 2021-06-22 16:40:48 -07:00
Ken Hibino
7eee841d63 Update Client.Enqueue to return TaskInfo 2021-06-22 16:40:48 -07:00
Ken Hibino
7ee8bbb5e4 Define TaskInfo type 2021-06-22 16:40:48 -07:00
Ken Hibino
f0aefb0430 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-22 16:40:48 -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
Ken Hibino
4693ffec05 Create internal errors package 2021-06-07 16:13:59 -07:00
Ken Hibino
3fbf3dab76 Update rdb.ArchiveTask with more specific error types 2021-06-07 16:13:59 -07:00
Ken Hibino
4d2ff9e375 Rename error types 2021-06-07 16:13:58 -07:00
Ken Hibino
d45fc45b01 Add a list of canonical errors in base package 2021-06-07 16:13:58 -07:00
Ken Hibino
2a509ecd4f Update RDB.ArchiveTask with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
69aa071632 Update RDB.RunTask with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
4f7f7e91de Update RDB.Requeue with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
08e6dc08d5 Update RDB.Retry, RDB.Archive with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
a5a28a0a40 Update RDB.Dequeue with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
a647cd7225 Update RDB.ForwardIfReady with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
df4e5c8d45 Update RDB.ScheduleUnique with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
eb40c8a2b4 Update RDB.Schedule with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
691bc7db81 Update RDB.EnqueueUnique with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
bf512f4ec2 Update RDB.Enqueue with task state 2021-06-07 16:13:58 -07:00
Ken Hibino
d6e7e0df05 Change Server API 
* Rename ServerStatus to ServerState internally

* Rename terminate to shutdown internally

* Update Scheduler API to match Server API
 2021-06-07 16:13:58 -07:00
Ken Hibino
585e7fdd53 Change payload to byte slice 2021-06-07 16:13:58 -07:00