Bo-Yi Wu
14f19fcb20
chore: move queue to appleboy/queue ( #612 )
...
* chore: move queue to appleboy/queue
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 17:18:35 +08:00
Bo-Yi Wu
fcfa195bc6
chore(queue): add custom logger.
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 11:11:13 +08:00
Bo-Yi Wu
6db9768758
chore(queue): returns the numbers of workers has been created ( #611 )
...
* chore(queue): returns the numbers of workers has been created
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
* chore: enable logger.
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 10:51:26 +08:00
Bo-Yi Wu
6ebbbe5026
chore(queue): Shutdown service once. ( #610 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 10:17:42 +08:00
Bo-Yi Wu
d9947ea44d
chore: rename gorush to notify package ( #609 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 01:56:33 +08:00
Bo-Yi Wu
ce6e87639a
chore: support custom parameter in queue ( #608 )
...
* chore: support custom parameter in queue
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-24 01:29:47 +08:00
Bo-Yi Wu
2d01f8b854
chore: init log package ( #606 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-20 21:16:53 +08:00
Bo-Yi Wu
05ec3209f6
refactor(queue): update run func in simple channel ( #605 )
2021-07-18 19:34:30 +08:00
Bo-Yi Wu
ed25b0f42a
chore(queue): support custom run func ( #603 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-18 09:03:57 +08:00
Bo-Yi Wu
380162a38a
chore(queue): add queue message interface ( #602 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-18 01:58:46 +08:00
Bo-Yi Wu
2e2dd9b8d6
chore(queue): support NSQ as backend. ( #600 )
2021-07-17 20:14:19 +08:00
Bo-Yi Wu
95866bf205
chore(queue): to handle panic cases from inside the worker ( #594 )
2021-07-17 08:20:45 +08:00
Bo-Yi Wu
4349a17017
chore(queue): support option setting ( #593 )
2021-07-17 06:56:42 +08:00
Bo-Yi Wu
41c61f11c4
chore: update worker interface ( #592 )
...
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com >
2021-07-16 19:26:19 +08:00
Bo-Yi Wu
73ff554b19
Only initial MaxConcurrentIOSPushes once. ( #591 )
2021-07-16 16:30:01 +08:00
Bo-Yi Wu
ab8b1991ab
chore: support single queue and multiple worker ( #589 )
2021-07-16 12:10:34 +08:00
