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

779 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
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
Ken Hibino
39cf648c02 Update ForwardIfReady test with group 2022-03-22 06:52:02 -07:00
Ken Hibino
19229645ff Update client to store groupKey under TaskMessage 2022-03-22 06:52:02 -07:00
Ken Hibino
47acff3684 Add GroupKey field to TaskMessage 2022-03-22 06:52:02 -07:00
Ken Hibino
17e9725287 Update RDB.ForwardIfReady to forward to group if groupKey is specified 2022-03-22 06:52:02 -07:00
Ken Hibino
a88f6498af Update Client to add task to group if Group option is specified 2022-03-22 06:52:02 -07:00
Ken Hibino
278b2d7431 Add RDB.AddToGroup and RDB.AddToGroupUnique methods 2022-03-22 06:52:02 -07:00
Ken Hibino
19f127b30e Add helper functions to generate group key 2022-03-22 06:52:02 -07:00
Ken Hibino
976f76fe5e Add Group task option 2022-03-22 06:52:02 -07:00
Ken Hibino
91a62214d6 Add group related configuration options 2022-03-22 06:52:02 -07:00
Ken Hibino
f94a65dc9f Add go1.18 to build workflow matrix 2022-03-22 06:51:28 -07:00
Erwan Leboucher
04d7c8c38c Add rediss url parsing support 2022-02-24 08:30:55 -08:00
Ken Hibino
c04fd41653 v0.22.1 v0.22.1 2022-02-20 06:22:55 -08:00
Ken Hibino
7e5efb0e30 Drop GT option from RDB.ExtendLease 
GT option in ZAdd is supported for redis v6.2.0 or above.
This Change fixes redis version compatibility (currently v4.0+)
 2022-02-20 06:20:38 -08:00
Ken Hibino
cabf8d3627 Fix changelog 2022-02-19 06:21:56 -08:00
Ken Hibino
a19909f5f4 v0.22.0 v0.22.0 2022-02-19 06:20:05 -08:00
Ken Hibino
cea5110d15 Add IsOrphaned field to TaskInfo 2022-02-19 06:15:44 -08:00
Ken Hibino
9b63e23274 Update log messages 2022-02-19 06:15:44 -08:00
Ken Hibino
de25201d9f Make timeutil.SimulatedClock concurrency safe 2022-02-19 06:15:44 -08:00
Ken Hibino
ec560afb01 Fix processor test 2022-02-19 06:15:44 -08:00
Ken Hibino
d4006894ad Remove base.DeadlinesKey 2022-02-19 06:15:44 -08:00
Ken Hibino
59927509d8 Remove timeout and deadline fields under task key 2022-02-19 06:15:44 -08:00
Ken Hibino
8211167de2 Update processor to create a lease and watch for expiration 2022-02-19 06:15:44 -08:00
Ken Hibino
d7169cd445 Update heartbeat to extend lease of active workers 2022-02-19 06:15:44 -08:00
Ken Hibino
dfae8638e1 Update RDB methods to work with lease 2022-02-19 06:15:44 -08:00
Ken Hibino
b9943de2ab Add Lease type to base package 2022-02-19 06:15:44 -08:00
Ken Hibino
871474f220 Update heartbeat goroutine to call ExtendLease on active tasks 2022-02-19 06:15:44 -08:00
Ken Hibino
87dc392c7f Add RDB.ExtendLease method 2022-02-19 06:15:44 -08:00
Ken Hibino
dabcb120d5 Update recoverer to use ListLeaseExpired 2022-02-19 06:15:44 -08:00
Ken Hibino
bc2f1986d7 Update ListDeadlineExceeded to ListLeaseExpired 2022-02-19 06:15:44 -08:00
Ken Hibino
b8cb579407 Update RDB methods to use lease instead of deadlines set 2022-02-19 06:15:44 -08:00