Emanuel Bennici
0275df8df4
Update redis/go-redis to v9
...
Version v9 implements the support for Redis v7 and has some
other improvements.
2023-04-17 22:30:33 -07:00
Jeffrey Lo
9116c096ec
docs: correct typo (deafult => default)
2022-05-04 19:10:09 -07:00
Ken Hibino
8b2a787759
Rename variables for public API documentation
2022-04-11 16:55:43 -07:00
Ken Hibino
562506c7ba
Fix client to return error when nil task is passed
2022-04-11 16:55:43 -07:00
Ken Hibino
ab28234767
Update client dependency to base.Broker
2022-04-11 16:55:43 -07:00
Ken Hibino
4e8885276c
Update client to store groupKey under TaskMessage
2022-04-11 16:55:43 -07:00
Ken Hibino
f17c157b0f
Update Client to add task to group if Group option is specified
2022-04-11 16:55:43 -07:00
Ken Hibino
2ce71e83b0
Add Group task option
2022-04-11 16:55:43 -07:00
Ken Hibino
9f2c321e98
Add EnqueueContext method to Client
2021-11-15 16:34:26 -08:00
Ken Hibino
e2b61c9056
Return error if Unique TTL is less than 1s
2021-11-09 16:37:02 -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
9e2f88c00d
Add TaskID option to allow user to specify task id
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
Luqqk
95c90a5cb8
Add changelog entry, add additional test case
2021-08-02 20:20:09 -07:00
Luqqk
6817af366a
Adjust error message, use TrimSpace for more robust empty typename check
2021-08-02 20:20:09 -07:00
Luqqk
4bce28d677
client.Enqueue - prevent empty task's typename
2021-08-02 20:20:09 -07:00
Ken Hibino
46b23d6495
Allow upper case characters in queue name
2021-07-15 06:55:47 -07:00
Ken Hibino
a9feec5967
Change TaskInfo to use public fields instead of methods
2021-06-29 16:34:21 -07:00
Ken Hibino
b835090ad8
Update Client.Enqueue to return TaskInfo
2021-06-29 16:34:21 -07:00
Ken Hibino
1812d05d21
Fix build
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
97b5516183
Update RedisConnOpt interface
2021-01-31 06:09:40 -08:00
Ken Hibino
e13122723a
Move all inspector related code to subpackage inspeq
2021-01-31 06:09:40 -08:00
Ken Hibino
b604d25937
Add helper function to parse Option string
2021-01-14 06:43:44 -08: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
a293efcdab
Add Close to Inspector
2020-09-12 12:59:03 -07:00
Ken Hibino
cca680a7fd
Change Client.Enqueue to take ProcessAt and ProcessIn as Option
2020-09-12 12:59:03 -07:00
Ken Hibino
dab8295883
Validate queue name in Inspector
2020-09-12 12:59:03 -07:00
Ken Hibino
131ac823fd
Return error if queue name is empty when enqueueing
2020-09-12 12:59:03 -07:00
Ken Hibino
50b6034bf9
Move unique key generator function to base
2020-09-12 12:59:03 -07:00
Ken Hibino
34b90ecc8a
Return Result struct to caller of Enqueue
2020-07-06 05:48:31 -07:00
Ken Hibino
8b60e6a268
Replace github.com/rs/xid with github.com/google/uuid
2020-07-06 05:48:31 -07:00
Ken Hibino
2e2c9b9f6b
Update docs
2020-07-06 05:48:31 -07:00
Ken Hibino
7e942ec241
Use int64 type for Timeout and Deadline in TaskMessage
2020-07-06 05:48:31 -07:00
Ken Hibino
716d3d987e
Use default timeout of 30mins if both timeout and deadline are not
...
provided
2020-07-06 05:48:31 -07:00
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
