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

616 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
Ken Hibino
5f61566284 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-07 16:13:55 -07:00
Ken Hibino
2516c4baba v0.17.2 v0.17.2 2021-06-06 06:51:30 -07:00
Ken Hibino
ebe482a65c Free uniqueness lock when task is deleted 2021-06-06 06:48:59 -07:00
Vic Shóstak
3e9fc2f972
Update README 2021-04-28 10:25:34 -07:00
Vic Shóstak
63ce9ed0f9
Update README with a new logo 2021-04-14 10:21:47 -07:00
Ken Hibino
32d3f329b9 v0.17.1 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 v0.17.0 2021-03-24 16:51:59 -07:00
Ken Hibino
901105a8d7 Add dial, read, write timeout options to RedisConnOpt 2021-03-24 16:49:04 -07:00
Ken Hibino
aaa3f1d4fd v0.16.1 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 v0.16.0 2021-03-10 20:39:46 -08:00
Ken Hibino
de28c1ea19 Add Unregister method to Scheduler 2021-03-10 20:38:44 -08:00
Ken Hibino
f618f5b1f5 Add benchmark tests for rdb package 2021-03-07 16:27:14 -08:00
Ken Hibino
aa936466b3 Minor fix 2021-03-07 16:27:14 -08:00
Ken Hibino
5d1ec70544 Run CI build with go1.16 2021-02-25 09:31:17 -08:00
Ken Hibino
d1d3be9b00 Add Web UI section in README 2021-02-01 17:01:04 -08:00
Ken Hibino
bc77f6fe14 v0.15.0 v0.15.0 2021-01-31 06:11:17 -08:00
Ken Hibino
efe197a47b Use db13 for inspeq package testing 2021-01-31 06:09:40 -08:00
Ken Hibino
97b5516183 Update RedisConnOpt interface 2021-01-31 06:09:40 -08:00