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

219 Commits

Author SHA1 Message Date
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
Ken Hibino
e9239260ae Add DeleteQueue method to Inspector 
- Added ErrQueueNotFound and ErrQueueNotEmpty type to indicate the kind
  of an error returned from the method.
 2021-01-14 06:43:44 -08:00
MinJae Kwon
c4dc993241
fix: resolve go vet lint 2020-12-20 06:09:51 -08:00
Ken Hibino
942345ee80 v0.13.0 2020-10-13 06:33:47 -07:00
Ken Hibino
96b2318300 Add EnqueueErrorHandler option to SchedulerOpts 2020-10-13 06:31:47 -07:00
Ken Hibino
8312515e64 Update Option interface 
- Added `String()`, `Type()`, and `Value()` methods to the interface to
  aid with debugging and error handling.
 2020-10-13 06:31:47 -07:00
Ken Hibino
50e7f38365 Add Scheduler 
- Renamed previously called scheduler to forwarder to resolve name
  conflicts
 2020-10-13 06:31:47 -07:00
Ken Hibino
c43fb21a0a Minor test updates 2020-09-12 12:59:03 -07:00
Ken Hibino
69d7ec725a Close redis client after each test run 2020-09-12 12:59:03 -07:00
Ken Hibino
c26b7469bd Display cluster info in stats command when --cluster flag is passed 2020-09-12 12:59:03 -07:00