2
0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-15 11:58:47 +08:00
Commit Graph

80 Commits

Author SHA1 Message Date
Ken Hibino
cea5110d15 Add IsOrphaned field to TaskInfo 2022-02-19 06:15:44 -08:00
Ken Hibino
f4ddac4dcc Introduce Task Results
* Added Retention Option to specify retention TTL for tasks
* Added ResultWriter as a client interface to write result data for the associated task
2021-11-06 15:18:42 -07:00
Ken Hibino
2261c7c9a0 Change TaskMessage.ID type from uuid.UUID to string 2021-11-06 15:18:42 -07:00
Ken Hibino
83cae4bb24 Update NewTask function to take Option as varargs 2021-11-06 15:18:42 -07:00
Jason White
b3ef9e91a9
Upgrade go-redis/redis to version 8 2021-09-02 05:56:02 -07:00
Ken Hibino
a9feec5967 Change TaskInfo to use public fields instead of methods 2021-06-29 16:34:21 -07:00
Ken Hibino
08d8f0b37c Add String method to TaskState 2021-06-29 16:34:21 -07:00
Ken Hibino
cd351d49b9 Add LastFailedAt to TaskInfo 2021-06-29 16:34:21 -07:00
Ken Hibino
09cbea66f6 Define TaskInfo type 2021-06-29 16:34:21 -07:00
Ken Hibino
476812475e Change payload to byte slice 2021-06-29 16:34:21 -07:00
Ken Hibino
901105a8d7 Add dial, read, write timeout options to RedisConnOpt 2021-03-24 16:49:04 -07:00
Ken Hibino
aa936466b3 Minor fix 2021-03-07 16:27:14 -08:00
Ken Hibino
97b5516183 Update RedisConnOpt interface 2021-01-31 06:09:40 -08:00
Ken Hibino
450a9aa1e2 Add MaxRedirects field in RedisClusterClientOpt 2020-09-12 12:59:03 -07:00
Ken Hibino
6e294a7013 Add Username field to RedisConnOpt 2020-09-12 12:59:03 -07:00
Ken Hibino
27f4027447 Add RedisClusterClientOpt to connect to redis cluster 2020-09-12 12:59:03 -07:00
Ken Hibino
eb8ced6bdd Add ParseRedisURI helper function 2020-04-25 13:06:20 -07:00
Ken Hibino
7c7f8e5f30 Move Broker interface to base package 2020-04-19 08:51:17 -07:00
Ken Hibino
f8a94fb839 Define broker interface 2020-04-19 08:51:17 -07:00
Ken Hibino
742ed6546f Add ServeMux type
Allow user to use ServeMux type to be used as a Handler.
ServeMux API is design to be similar to net/http.ServeMux API.
2020-03-01 15:53:18 -08:00
Ken Hibino
7af69c8d3c [ci skip] Fix comments 2020-02-06 20:46:59 -08:00
Ken Hibino
0c2591ad7e [ci skip] Update docs 2020-01-16 21:04:46 -08:00
Ken Hibino
43d7591250 Remove redis.Client type from asynq package API 2020-01-16 21:04:46 -08:00
Ken Hibino
f3a23b9b12 Make Task type immutable
This change makes it impossible to mutate payload within Handler or
RetryDelayFunc.
2020-01-05 09:55:39 -08:00
Ken Hibino
c62833540c Add license comment to all src files 2020-01-02 18:13:16 -08:00
Ken Hibino
9c0233c388 Update todos 2020-01-02 18:04:36 -08:00
Ken Hibino
fc71857c7c Change NewBackground API to take *redis.Client 2019-12-29 14:55:16 -08:00
Ken Hibino
4ceb49cfd1 Minor improvements 2019-12-28 06:41:39 -08:00
Ken Hibino
190d671546 Add kill and killall command to asynqmon 2019-12-27 15:17:45 -08:00
Ken Hibino
9b87f7c1f1 Show processed/failed count and error rate in asynqmon stats command 2019-12-25 20:29:58 -08:00
Ken Hibino
ee7a22adef Display redis info in stats command 2019-12-22 14:31:08 -08:00
Ken Hibino
4229073a24 Allow user to define a max retry count for a task 2019-12-21 09:47:45 -08:00
Ken Hibino
324a785233 Add Hash method to Payload 2019-12-20 20:14:40 -08:00
Ken Hibino
14ac5f6674 Add Get* methods to Payload type 2019-12-20 16:01:32 -08:00
Ken Hibino
3fd096a90a [ci skip] Update todos 2019-12-18 21:18:13 -08:00
Ken Hibino
b2bc0ef91c [ci skip] Update todos 2019-12-17 20:37:54 -08:00
Ken Hibino
bcaccf1174 [ci skip] Update todos 2019-12-16 06:41:15 -08:00
Ken Hibino
1b1662bb12 Add Retry method to *RDB
(*RDB).Retry method takes a TaskMessage and will atomically moves the
message from in_progress queue to retry queue. Additionally it
increments the Retried counter and assigns the error message to the
message.
2019-12-15 16:15:07 -08:00
Ken Hibino
04836194f9 Clean up rdb package tests 2019-12-14 13:43:06 -08:00
Ken Hibino
d2eeaf6ab1 [ci skip] Update todos 2019-12-12 19:05:25 -08:00
Ken Hibino
be746d01a5 Add delete methods to rdb 2019-12-11 20:15:30 -08:00
Ken Hibino
8b6e3172ce [ci skip] Update todos 2019-12-11 07:13:04 -08:00
Ken Hibino
a96719413c Add enqall command to asynqmon CLI 2019-12-10 21:40:28 -08:00
Ken Hibino
0d74c518bf Add methods to rdb to enqueue all tasks from dead, retry and scheduled
queue
2019-12-10 20:28:31 -08:00
Ken Hibino
764edc35e3 [ci skip] Update todos 2019-12-09 06:52:43 -08:00
Ken Hibino
8932ca41b3 Minor improvement 2019-12-09 06:30:45 -08:00
Ken Hibino
8e2c4e5716 Update todos 2019-12-07 20:25:46 -08:00
Ken Hibino
aa8a3b8aaa Update exported package API docs 2019-12-06 22:00:09 -08:00
Ken Hibino
20ad6daa6e Update todos 2019-12-05 17:28:05 -08:00
Ken Hibino
d4e442d04f Extract rdb to internal package 2019-12-03 22:13:48 -08:00