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

188 Commits

Author SHA1 Message Date
Ken Hibino
e3455b633c Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors 2021-05-09 07:39:01 -07:00
Ken Hibino
8bec07ef51 Add errors.RedisCommandError type 2021-05-09 07:15:09 -07:00
Ken Hibino
c6a47f8797 Update RDB.CurrentStats and RDB.HistoricalStats with specific errors 2021-05-09 07:05:10 -07:00
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
26a1a2f861 Update RDB.ArchiveTask with custom errors 2021-05-02 06:47:32 -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
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
544c301a8b Fix bug in RDB.memoryUsage 2021-04-04 12:49:19 -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
f618f5b1f5 Add benchmark tests for rdb package 2021-03-07 16:27:14 -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
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
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
96b2318300 Add EnqueueErrorHandler option to SchedulerOpts 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
Ken Hibino
29e542e591 Rename Enqueue methods in Inspector to Run 2020-09-12 12:59:03 -07:00
Ken Hibino
a891ce5568 Rename InProgress to Active 2020-09-12 12:59:03 -07:00