Joe
|
5de9b1faf0
|
Feature: Add Headers Support to Tasks (#1070)
* feat(task): Add headers support to tasks
* fix: cleanup copy map code
* fix: Add tests
|
2025-11-04 20:07:59 +03:00 |
|
Ken Hibino
|
39718f8bea
|
Always enqueue the aggregated task in the same queue
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
829f64fd38
|
Define GroupAggregator interface
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
888b5590fb
|
Make GroupMaxSize and GroupMaxDelay config optional
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
196db64d4d
|
Run aggregator on the server
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
99c00bffeb
|
Implement RDB.AggregationCheck
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
4542b52da8
|
Check for aggregation at an interval <= gracePeriod
|
2022-04-11 16:55:43 -07:00 |
|
Ken Hibino
|
d841dc2f8d
|
Add initial implementation of aggregator
|
2022-04-11 16:55:43 -07:00 |
|