907 Commits

This Branch

This Branch

All Branches

Author	SHA1	Message	Date
Ken Hibino	578321f226	(cli): Extend task ls command to list aggregating tasks	2022-04-11 16:55:43 -07:00
Ken Hibino	2c783566f3	(cli): Add group ls command	2022-04-11 16:55:43 -07: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	a369443955	Add batch actions to inspector for aggregating tasks ... Added: - Inspector.DeleteAllAggregatingTasks - Inspector.ArchiveAllAggregatingTasks - Inspector.RunAllAggregatingTasks	2022-04-11 16:55:43 -07:00
Ken Hibino	de139cc18e	Update RDB.RunTask to schedule aggregating task	2022-04-11 16:55:43 -07:00
Ken Hibino	74db013ab9	Add RDB.RunAllAggregatingTasks	2022-04-11 16:55:43 -07:00
Ken Hibino	725105ca03	Update RDB.ArchiveTask to archive aggregating task	2022-04-11 16:55:43 -07:00
Ken Hibino	d8f31e45f1	Add RDB.ArchiveAllAggregatingTasks	2022-04-11 16:55:43 -07:00
Ken Hibino	9023cbf4be	Update RDB.DeleteTask to handle aggregating task	2022-04-11 16:55:43 -07:00
Ken Hibino	9279c09125	Add RDB.DeleteAllAggregatingTasks	2022-04-11 16:55:43 -07:00
Ken Hibino	bc27126670	Fix memory usage lua script	2022-04-11 16:55:43 -07:00
Ken Hibino	0cfa7f47ba	Fix memory_usage lua script	2022-04-11 16:55:43 -07:00
Ken Hibino	8a4fb71dd5	Update go.mod with replace directive	2022-04-11 16:55:43 -07:00
Ken Hibino	7fb5b25944	Add Inspector.ListAggregatingTasks	2022-04-11 16:55:43 -07:00
Ken Hibino	71bd8f0535	Add RDB.ListAggregating	2022-04-11 16:55:43 -07:00
Ken Hibino	4c8432e0ce	Add Inspector.Groups method	2022-04-11 16:55:43 -07:00
Ken Hibino	e939b5d166	Rename asynqtest package to testutil	2022-04-11 16:55:43 -07:00
Ken Hibino	1acd62c760	Move test helpers to asynqtest package	2022-04-11 16:55:43 -07:00
Ken Hibino	0149396bae	Add RDB.GroupStats for inspecting groups	2022-04-11 16:55:43 -07:00
Ken Hibino	45ed560708	Add Group field to TaskInfo struct	2022-04-11 16:55:43 -07:00
Ken Hibino	01eeb8756e	(cli): Update queue inspect cmd to show # of groups and aggregating tasks	2022-04-11 16:55:43 -07:00
Ken Hibino	47af17cfb4	Fix RDB.CurrentStats to report the correct queue size	2022-04-11 16:55:43 -07:00
Ken Hibino	eb064c2bab	Fix AggregationCheck with unlimited size to clear group name from ... all-groups set	2022-04-11 16:55:43 -07:00
Ken Hibino	652939dd3a	Update memory usage redis lua script to account for groups	2022-04-11 16:55:43 -07:00
Ken Hibino	efe3c74037	Show number of groups and aggregating task count in QueueInfo	2022-04-11 16:55:43 -07:00
Ken Hibino	74d2eea4e0	Clear group if aggregation set empties the group	2022-04-11 16:55:43 -07:00
Ken Hibino	60a4dc1401	Add test for DeleteAggregationSet error case	2022-04-11 16:55:43 -07:00
Ken Hibino	4b716780ef	Rewrite test for DeleteAggregationSet function with a new pattern	2022-04-11 16:55:43 -07:00
Ken Hibino	e63f41fb24	Fix DeleteAggregationSet	2022-04-11 16:55:43 -07:00
Ken Hibino	1c388baf06	Implement RDB.ReclaimStaleAggregationSets	2022-04-11 16:55:43 -07:00
Ken Hibino	47a66231b3	Store aggregation set *key* in all aggreationsets zset	2022-04-11 16:55:43 -07:00
Ken Hibino	3551d3334c	Use zset for aggregation set to preserve score	2022-04-11 16:55:43 -07:00
Ken Hibino	8b16ede8bc	Declare ReclaimStaleAggregationSets	2022-04-11 16:55:43 -07:00
Ken Hibino	c8658a53e6	Add aggregator test	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	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	4b35eb0e1a	Fix RDB.AggregationCheck when run against an empty group	2022-04-11 16:55:43 -07:00
Ken Hibino	b29fe58434	Implement RDB.ListGroups	2022-04-11 16:55:43 -07:00
Ken Hibino	7849b1114c	Implement RDB.DeleteAggregationSet	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
Ken Hibino	ab28234767	Update client dependency to base.Broker	2022-04-11 16:55:43 -07:00
Ken Hibino	eb27b0fe1e	Add TaskMessageBuilder type as a test helper	2022-04-11 16:55:43 -07:00
Ken Hibino	088be63ee4	Update forwarder to use time.Timer	2022-04-11 16:55:43 -07:00
Ken Hibino	ed69667e86	Update ForwardIfReady test with group	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	401f7fb4fe	Add GroupKey field to TaskMessage	2022-04-11 16:55:43 -07:00