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
Ken Hibino
319d157d47
Change inspector's list methods to return specific task type for each
...
queue
2019-12-03 19:50:12 -08:00
Ken Hibino
28dae0fdd3
Add task types specific to each queue
2019-12-03 19:50:12 -08:00
Ken Hibino
9c2d2a612d
Create Inspector
2019-12-03 19:50:12 -08:00
Ken Hibino
57838600ef
Rename to RedisConfig
2019-12-03 19:43:01 -08:00
Ken Hibino
b9cb95b1e1
Add readme
2019-11-30 09:38:46 -08:00
Ken Hibino
d31532c8f5
Add .travis.yml
2019-11-30 09:08:14 -08:00
Ken Hibino
09662432c8
Update todos
2019-11-29 20:16:39 -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
ac3190a0d5
Update comments
2019-11-23 16:44:22 -08:00
Ken Hibino
80f477212d
Add ID field to taskMessage
2019-11-22 06:16:43 -08:00
Ken Hibino
67a9e8aa00
Track in-progress tasks with redis SET
2019-11-21 21:45:27 -08:00
Ken Hibino
e9069bfb47
Move client and launcher to its own files
2019-11-19 21:19:46 -08:00
Ken Hibino
85a04cbabb
Extract redis logic to type rdb
2019-11-19 21:08:06 -08:00
Ken Hibino
4c5b6081de
Update todo comments
2019-11-19 07:47:21 -08:00
Ken Hibino
eb6a5032f6
Make Launcher thread safe
2019-11-19 07:46:04 -08:00
Ken Hibino
195fd893be
Extract manager to its own type
2019-11-19 06:52:26 -08:00
Ken Hibino
89c54fb47d
Rename Workers to Launcher
2019-11-19 06:19:22 -08:00
Ken Hibino
4485b6e3a9
Extract polling logic to poller type
2019-11-18 21:23:49 -08:00
Ken Hibino
3daef02632
Fix bug around releasing semaphore token
2019-11-18 07:42:26 -08:00
Ken Hibino
c6f482d4f8
Make Run method stateful
2019-11-17 21:21:32 -08:00