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
809 Commits 25 Branches 53 Tags
3d342e20dce1e6a59c38b5b941c4c7bea58deeca
Commit Graph

809 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Ken Hibino
3d342e20dc Update CHANGELOG.md 2022-04-11 16:54:39 -07:00
Ken Hibino
e603189e06 Rename variables for public API documentation 2022-04-10 17:55:21 -07:00
Ken Hibino
0877f41015 (cli): Update stats command to print the number of aggregating tasks 2022-04-09 15:52:58 -07:00
Ken Hibino
2dcfeeb0a5 (cli): Extend task ls command to list aggregating tasks 2022-04-09 15:47:33 -07:00
Ken Hibino
af40b3fef7 (cli): Add group ls command 2022-04-09 15:45:12 -07:00
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
7a10e61030 Add batch actions to inspector for aggregating tasks 
Added:
- Inspector.DeleteAllAggregatingTasks
- Inspector.ArchiveAllAggregatingTasks
- Inspector.RunAllAggregatingTasks
 2022-03-30 05:58:38 -07:00
Ken Hibino
cfcdc5ebaf Update RDB.RunTask to schedule aggregating task 2022-03-29 06:27:56 -07:00
Ken Hibino
ccff18fec9 Add RDB.RunAllAggregatingTasks 2022-03-29 06:15:01 -07:00
Ken Hibino
0e2e3cedab Update RDB.ArchiveTask to archive aggregating task 2022-03-28 06:59:57 -07:00
Ken Hibino
082fbb7ffc Add RDB.ArchiveAllAggregatingTasks 2022-03-28 06:29:44 -07:00
Ken Hibino
edca226858 Update RDB.DeleteTask to handle aggregating task 2022-03-27 16:25:03 -07:00
Ken Hibino
4a86d42fd7 Add RDB.DeleteAllAggregatingTasks 2022-03-27 15:52:46 -07:00
Ken Hibino
36ddadcc3a Fix memory usage lua script 2022-03-26 14:33:03 -07:00
Ken Hibino
3d918f3986 Fix memory_usage lua script 2022-03-23 16:21:45 -07:00
Ken Hibino
1647dee155 Update go.mod with replace directive 2022-03-22 06:52:03 -07:00
Ken Hibino
6579e44710 Add Inspector.ListAggregatingTasks 2022-03-22 06:52:03 -07:00
Ken Hibino
a278e31710 Add RDB.ListAggregating 2022-03-22 06:52:03 -07:00
Ken Hibino
ba709fd4c4 Add Inspector.Groups method 2022-03-22 06:52:03 -07:00
Ken Hibino
c28293b3b7 Rename asynqtest package to testutil 2022-03-22 06:52:03 -07:00
Ken Hibino
ba3eafaf94 Move test helpers to asynqtest package 2022-03-22 06:52:03 -07:00
Ken Hibino
471c4ff1ed Add RDB.GroupStats for inspecting groups 2022-03-22 06:52:03 -07:00
Ken Hibino
cf1979ced9 Add Group field to TaskInfo struct 2022-03-22 06:52:03 -07:00
Ken Hibino
1e8756a52d (cli): Update queue inspect cmd to show # of groups and aggregating tasks 2022-03-22 06:52:03 -07:00
Ken Hibino
1a513a529b Fix RDB.CurrentStats to report the correct queue size 2022-03-22 06:52:03 -07:00
Ken Hibino
bfd0980d7a Fix AggregationCheck with unlimited size to clear group name from 
all-groups set
 2022-03-22 06:52:03 -07:00
Ken Hibino
1998ca80ea Update memory usage redis lua script to account for groups 2022-03-22 06:52:03 -07:00
Ken Hibino
7fa02db7ff Show number of groups and aggregating task count in QueueInfo 2022-03-22 06:52:03 -07:00
Ken Hibino
6bdce095dd Clear group if aggregation set empties the group 2022-03-22 06:52:03 -07:00
Ken Hibino
d43eb5a447 Add test for DeleteAggregationSet error case 2022-03-22 06:52:03 -07:00
Ken Hibino
ae7b20634c Rewrite test for DeleteAggregationSet function with a new pattern 2022-03-22 06:52:03 -07:00
Ken Hibino
4d797f55d8 Fix DeleteAggregationSet 2022-03-22 06:52:03 -07:00
Ken Hibino
979fcfd2e9 Implement RDB.ReclaimStaleAggregationSets 2022-03-22 06:52:03 -07:00
Ken Hibino
574de97db3 Store aggregation set *key* in all aggreationsets zset 2022-03-22 06:52:03 -07:00
Ken Hibino
26bf13485b Use zset for aggregation set to preserve score 2022-03-22 06:52:03 -07:00
Ken Hibino
df85894c5c Declare ReclaimStaleAggregationSets 2022-03-22 06:52:03 -07:00
Ken Hibino
1f23b66e60 Add aggregator test 2022-03-22 06:52:03 -07:00
Ken Hibino
7860506e1e Fix client to return error when nil task is passed 2022-03-22 06:52:03 -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
d164bdcdb6 Fix RDB.AggregationCheck when run against an empty group 2022-03-22 06:52:03 -07:00
Ken Hibino
bc89901b3e Implement RDB.ListGroups 2022-03-22 06:52:02 -07:00
Ken Hibino
d0907657f8 Implement RDB.DeleteAggregationSet 2022-03-22 06:52:02 -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
Ken Hibino
68f0be934e Update client dependency to base.Broker 2022-03-22 06:52:02 -07:00
Ken Hibino
4418143729 Add TaskMessageBuilder type as a test helper 2022-03-22 06:52:02 -07:00
Ken Hibino
15619fc890 Update forwarder to use time.Timer 2022-03-22 06:52:02 -07:00