go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-10-25 23:06:12 +08:00
Code Issues Projects Releases Wiki Activity
806 Commits 25 Branches 53 Tags
2dcfeeb0a5362e94e58a033d25edb383b37ec5d3
Commit Graph

7 Commits

Author SHA1 Message Date
Ken Hibino
643247fb46 Always enqueue the aggregated task in the same queue 2022-04-07 06:19:04 -07:00
Ken Hibino
2471f1ebe2 Define GroupAggregator interface 2022-04-07 06:13:49 -07:00
Ken Hibino
167c8678f5 Make GroupMaxSize and GroupMaxDelay config optional 2022-03-22 06:52:03 -07:00
Ken Hibino
084fbbda0e Run aggregator on the server 2022-03-22 06:52:03 -07:00
Ken Hibino
bcb8e2b452 Implement RDB.AggregationCheck 2022-03-22 06:52:02 -07:00
Ken Hibino
00f1c8ecf3 Check for aggregation at an interval <= gracePeriod 2022-03-22 06:52:02 -07:00
Ken Hibino
af9ac9aa71 Add initial implementation of aggregator 2022-03-22 06:52:02 -07:00