go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-14 11:31:18 +08:00
Code Issues Projects Releases Wiki Activity
413 Commits 12 Branches 52 Tags 11 MiB
5dddc35d7c
Commit Graph

33 Commits

Author SHA1 Message Date
Ken Hibino
4e5f596910 Fix Client.Enqueue to always call enqueue 
Closes https://github.com/hibiken/asynq/issues/158
 2020-06-14 05:54:18 -07:00
t-asaka
44aad7f037 Add redis conn close func to client 2020-05-08 06:15:14 -07:00
Ken Hibino
e33d297d8e Add SetDefaultOptions method to Client 2020-04-27 06:45:13 -07:00
Ken Hibino
c33dd447ac Allow client to enqueue a task with unique option 
Changes:

- Added Unique option for clients
- Require go v.13 or above (to use new errors wrapping functions)
- Fixed adding queue key to all-queues set (asynq:queues) when scheduling.
 2020-03-21 11:40:40 -07:00
Ken Hibino
3c722386b0 Add Deadline option when enqueuing tasks 
Deadline option sets the deadline for the given task's context deadline.
 2020-03-08 17:12:42 -07:00
Ken Hibino
49c117f4d1 Change Client APIs 
Use `Enqueue`, `EnqueueAt`, and `EnqueueIn` to enqueue and schedule
tasks.
`Schedule` method was removed.
 2020-02-23 20:40:40 -08:00
Ken Hibino
39459b4412 Allow user to specify timeout per task 2020-02-13 06:23:51 -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
1d99d99692 Update comment 2020-01-07 21:55:18 -08:00
Ken Hibino
ca78b92078 Add Queue option to allow user to specify queue from client 
Added base.QueueKey method to get redis key for given queue name.
Changed asynqtest.GetEnqueuedMessages to optionally take queue name.
 2020-01-07 21:55:18 -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
606b0fae64 Rename Client Process method to Schedule 2020-01-03 20:29:35 -08:00
Ken Hibino
c62833540c Add license comment to all src files 2020-01-02 18:13:16 -08:00
Ken Hibino
9af14d9a6d Add Config type to configure background processing behavior 2019-12-30 07:14:49 -08:00
Ken Hibino
62624cb0d8 Change NewClient API to take *redis.Client 2019-12-29 14:55:16 -08:00
Ken Hibino
3fd248615b Create base internal package 2019-12-22 07:40:25 -08:00
Ken Hibino
f5b7e0cccd Document options precedence 2019-12-21 10:02:03 -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
edcd70b221 Replace google/uuid package with rs/xid for more compact id 2019-12-11 07:41:38 -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
aa8a3b8aaa Update exported package API docs 2019-12-06 22:00:09 -08:00
Ken Hibino
afacc31990 Minor improvements 2019-12-04 16:58:07 -08:00
Ken Hibino
4531e90b9d Define Schedule and RetryLater method for RDB 2019-12-04 06:45:30 -08:00
Ken Hibino
d4e442d04f Extract rdb to internal package 2019-12-03 22:13:48 -08:00
Ken Hibino
57838600ef Rename to RedisConfig 2019-12-03 19:43:01 -08:00
Ken Hibino
47e2a57d05 Rename (*rdb).zadd to (*rdb).schedule 2019-11-27 07:16:16 -08:00
Ken Hibino
fab2dcb56e Change newRDB signature 2019-11-27 06:41:54 -08:00
Ken Hibino
faa9b6ee22 Rename (*rdb).push to enqueue 2019-11-25 19:58:24 -08:00
Ken Hibino
f91004e6aa Add DB field to RedisOpt to specify redis db index 2019-11-24 18:41:55 -08:00
Ken Hibino
80f477212d Add ID field to taskMessage 2019-11-22 06:16:43 -08:00
Ken Hibino
e9069bfb47 Move client and launcher to its own files 2019-11-19 21:19:46 -08:00