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

228 Commits

Author SHA1 Message Date
Ken Hibino
c2592e758e Update RDB.RemoveQueue with specific error types 2021-05-09 06:48:44 -07:00
Ken Hibino
cfe0d673c9 Update rdb.List* methods with specific errors 2021-05-08 11:45:30 -07:00
Ken Hibino
1c9bda3b2e Return QueueNotFoundError from DeleteAll* methods 2021-05-07 16:48:36 -07:00
Ken Hibino
6b64feed38 Update RDB.RunAll* methods with task state 2021-05-07 16:31:07 -07:00
Ken Hibino
8e16c426e8 Return QueueNotFoundError from ArchiveAll* methods 2021-05-07 16:06:07 -07:00
Ken Hibino
e861e534bc Update tests for RDB.DeleteTask and RDB.ArchiveTask 2021-05-07 06:26:16 -07:00
Ken Hibino
b42a29cb8d Update RDB.RunTask with more specific errors 2021-05-07 05:59:30 -07:00
Ken Hibino
59a953eabe Update RDB.DeleteTask with task state 2021-05-05 16:00:40 -07:00
Ken Hibino
2e7b6876b1 Update RDB.ArchiveAll methods with task state 2021-05-03 20:07:00 -07:00
Ken Hibino
df0c635448 Update RDB.ArchiveAllPendingTasks with task state 2021-05-03 16:38:13 -07:00
Ken Hibino
bf1e3c7505 Reorganize test for RDB.ArchiveTask 2021-05-03 15:48:21 -07:00
Ken Hibino
31da4dd6eb Update errors package with detailed comments 2021-05-02 06:58:54 -07:00
Ken Hibino
26a1a2f861 Update RDB.ArchiveTask with custom errors 2021-05-02 06:47:32 -07:00
Ken Hibino
c0c7031ae6 Create internal errors package 2021-05-02 06:46:48 -07:00
Ken Hibino
8c402e104a Update rdb.ArchiveTask with more specific error types 2021-05-01 16:13:40 -07:00
Ken Hibino
aa2ddaf27d Rename error types 2021-05-01 06:47:49 -07:00
Ken Hibino
88608e770b Add a list of canonical errors in base package 2021-05-01 06:38:33 -07:00
Ken Hibino
29210e143c Update RDB.ArchiveTask with task state 2021-04-28 21:24:42 -07:00
Ken Hibino
011669a3e8 Update RDB.RunTask with task state 2021-04-28 07:27:35 -07:00
Ken Hibino
b8cd3e307d Update RDB.Requeue with task state 2021-04-26 07:13:48 -07:00
Ken Hibino
568c77e497 Update RDB.Retry, RDB.Archive with task state 2021-04-26 07:10:29 -07:00
Ken Hibino
305e979af5 Update RDB.Dequeue with task state 2021-04-26 07:07:12 -07:00
Ken Hibino
2f9cd9c758 Update RDB.ForwardIfReady with task state 2021-04-26 06:58:33 -07:00
Ken Hibino
e4dd39d814 Update RDB.ScheduleUnique with task state 2021-04-24 20:41:44 -07:00
Ken Hibino
2a1fbf6fa5 Update RDB.Schedule with task state 2021-04-24 06:56:48 -07:00
Ken Hibino
f7954c2683 Update RDB.EnqueueUnique with task state 2021-04-19 06:28:58 -07:00
Ken Hibino
a352ee2fa2 Update RDB.Enqueue with task state 2021-04-18 07:19:19 -07:00
Ken Hibino
dd25028027 Change Server API 
* Rename ServerStatus to ServerState internally

* Rename terminate to shutdown internally

* Update Scheduler API to match Server API
 2021-04-14 15:31:22 -07:00
Ken Hibino
dc275c4612 Change payload to byte slice 2021-04-14 15:31:22 -07:00
Ken Hibino
a0b52806c9 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-04-14 15:31:21 -07:00
Ken Hibino
32d3f329b9 v0.17.1 2021-04-04 12:51:00 -07:00
Ken Hibino
544c301a8b Fix bug in RDB.memoryUsage 2021-04-04 12:49:19 -07:00
Ken Hibino
8b997d2fab v0.17.0 2021-03-24 16:51:59 -07:00
Ken Hibino
aaa3f1d4fd v0.16.1 2021-03-20 06:27:03 -07:00
disc
4722ca2d3d Replaced blocking KEYS XXX:* command to non-blocking SCAN XXX:* 
More details: https://redis.io/commands/KEYS
 2021-03-20 06:24:08 -07:00
Ken Hibino
6a9d9fd717 v0.16.0 2021-03-10 20:39:46 -08:00
Ken Hibino
f618f5b1f5 Add benchmark tests for rdb package 2021-03-07 16:27:14 -08:00
Ken Hibino
bc77f6fe14 v0.15.0 2021-01-31 06:11:17 -08:00
Ken Hibino
e13122723a Move all inspector related code to subpackage inspeq 2021-01-31 06:09:40 -08:00
Ken Hibino
eba7c4e085 Record deadline within WorkerInfo 2021-01-31 06:09:40 -08:00
Ken Hibino
afde6a7266 Add MemoryUsage field to QueueStats 2021-01-31 06:09:40 -08:00
Ken Hibino
6529a1e0b1 Fix scheduler 
* Delete scheduler history data when scheduler stops

* Fix history trimming bug
 2021-01-31 06:09:40 -08:00
Ken Hibino
c9a6ab8ae1 Support delete and archive actions on PendingTask 
* Add `DeleteAllPendingTasks`, `ArchiveAllPendingTasks` to `Inspector`

* `DeleteTaskByKey` and `ArchiveTaskByKey` now supports deleting/archiving PendingTask

* Updated `asynq task` command with support for deleting/archiving pending tasks
 2021-01-31 06:09:40 -08:00
Ken Hibino
2884044e75 v0.14.1 2021-01-19 06:22:54 -08:00
Ken Hibino
42c7ac0746 v0.14.0 2021-01-14 06:49:36 -08:00
Ken Hibino
00a25ca570 Rename DeadTask to ArchivedTask and action "kill" to "archive" 2021-01-14 06:43:44 -08:00
Ken Hibino
c5100a9c23 Add a method to list running servers to Inspector 2021-01-14 06:43:44 -08:00
Ken Hibino
196d66f221 Fix ListSchedulerEnqueueEvents to list recent events first 2021-01-14 06:43:44 -08:00
Ken Hibino
f4dd8fe962 Add ListScheduelerEnqueueEvents to Inspector 2021-01-14 06:43:44 -08:00
Ken Hibino
f9c0673116 Add SchedulerEntries method to Inspector 2021-01-14 06:43:44 -08:00