go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-14 11:31:18 +08:00
Code Issues Projects Releases Wiki Activity

Commit Graph

  • af40b3fef7 (cli): Add group ls command Ken Hibino 2022-04-09 06:49:22 -0700
  • 643247fb46 Always enqueue the aggregated task in the same queue Ken Hibino 2022-04-07 06:19:04 -0700
  • 2471f1ebe2 Define GroupAggregator interface Ken Hibino 2022-04-07 06:13:49 -0700
  • 7a10e61030 Add batch actions to inspector for aggregating tasks Ken Hibino 2022-03-30 05:58:38 -0700
  • 3f4f0c1daa
         Use explicit types for limit constants ashang 2022-03-29 21:30:10 +0800
  • cfcdc5ebaf Update RDB.RunTask to schedule aggregating task Ken Hibino 2022-03-29 06:27:56 -0700
  • ccff18fec9 Add RDB.RunAllAggregatingTasks Ken Hibino 2022-03-29 06:15:01 -0700
  • 2e177601ee proposal: math: Go 2: use explicit types for limit constants Ashang 2022-03-29 10:13:53 +0800
  • 0e2e3cedab Update RDB.ArchiveTask to archive aggregating task Ken Hibino 2022-03-28 06:59:57 -0700
  • 082fbb7ffc Add RDB.ArchiveAllAggregatingTasks Ken Hibino 2022-03-28 06:29:44 -0700
  • edca226858 Update RDB.DeleteTask to handle aggregating task Ken Hibino 2022-03-27 16:25:03 -0700
  • 4a86d42fd7 Add RDB.DeleteAllAggregatingTasks Ken Hibino 2022-03-27 15:52:46 -0700
  • 36ddadcc3a Fix memory usage lua script Ken Hibino 2022-03-26 14:33:03 -0700
  • 3d918f3986 Fix memory_usage lua script Ken Hibino 2022-03-23 16:21:45 -0700
  • 1647dee155 Update go.mod with replace directive Ken Hibino 2022-03-22 06:30:43 -0700
  • 6579e44710 Add Inspector.ListAggregatingTasks Ken Hibino 2022-03-22 06:23:22 -0700
  • a278e31710 Add RDB.ListAggregating Ken Hibino 2022-03-20 06:27:41 -0700
  • ba709fd4c4 Add Inspector.Groups method Ken Hibino 2022-03-19 07:23:09 -0700
  • c28293b3b7 Rename asynqtest package to testutil Ken Hibino 2022-03-19 07:16:55 -0700
  • ba3eafaf94 Move test helpers to asynqtest package Ken Hibino 2022-03-19 07:12:41 -0700
  • 471c4ff1ed Add RDB.GroupStats for inspecting groups Ken Hibino 2022-03-18 06:55:22 -0700
  • cf1979ced9 Add Group field to TaskInfo struct Ken Hibino 2022-03-16 20:22:07 -0700
  • 1e8756a52d (cli): Update queue inspect cmd to show # of groups and aggregating tasks Ken Hibino 2022-03-16 16:41:44 -0700
  • 1a513a529b Fix RDB.CurrentStats to report the correct queue size Ken Hibino 2022-03-16 16:31:19 -0700
  • bfd0980d7a Fix AggregationCheck with unlimited size to clear group name from all-groups set Ken Hibino 2022-03-15 17:03:09 -0700
  • 1998ca80ea Update memory usage redis lua script to account for groups Ken Hibino 2022-03-15 16:30:25 -0700
  • 7fa02db7ff Show number of groups and aggregating task count in QueueInfo Ken Hibino 2022-03-15 06:52:56 -0700
  • 6bdce095dd Clear group if aggregation set empties the group Ken Hibino 2022-03-13 06:44:42 -0700
  • d43eb5a447 Add test for DeleteAggregationSet error case Ken Hibino 2022-03-12 15:29:38 -0800
  • ae7b20634c Rewrite test for DeleteAggregationSet function with a new pattern Ken Hibino 2022-03-12 15:18:32 -0800
  • 4d797f55d8 Fix DeleteAggregationSet Ken Hibino 2022-03-11 15:54:47 -0800
  • 979fcfd2e9 Implement RDB.ReclaimStaleAggregationSets Ken Hibino 2022-03-11 12:04:35 -0800
  • 574de97db3 Store aggregation set *key* in all aggreationsets zset Ken Hibino 2022-03-11 11:10:44 -0800
  • 26bf13485b Use zset for aggregation set to preserve score Ken Hibino 2022-03-11 10:59:05 -0800
  • df85894c5c Declare ReclaimStaleAggregationSets Ken Hibino 2022-03-11 10:44:12 -0800
  • 1f23b66e60 Add aggregator test Ken Hibino 2022-03-11 08:54:00 -0800
  • 7860506e1e Fix client to return error when nil task is passed Ken Hibino 2022-03-10 15:59:58 -0800
  • 167c8678f5 Make GroupMaxSize and GroupMaxDelay config optional Ken Hibino 2022-03-10 15:48:02 -0800
  • 084fbbda0e Run aggregator on the server Ken Hibino 2022-03-10 12:15:28 -0800
  • d164bdcdb6 Fix RDB.AggregationCheck when run against an empty group Ken Hibino 2022-03-10 11:54:47 -0800
  • bc89901b3e Implement RDB.ListGroups Ken Hibino 2022-03-10 11:06:48 -0800
  • d0907657f8 Implement RDB.DeleteAggregationSet Ken Hibino 2022-03-10 11:00:28 -0800
  • bcb8e2b452 Implement RDB.AggregationCheck Ken Hibino 2022-03-09 17:05:16 -0800
  • 00f1c8ecf3 Check for aggregation at an interval <= gracePeriod Ken Hibino 2022-03-09 06:01:37 -0800
  • af9ac9aa71 Add initial implementation of aggregator Ken Hibino 2022-03-08 06:38:35 -0800
  • 68f0be934e Update client dependency to base.Broker Ken Hibino 2022-03-08 05:59:58 -0800
  • 4418143729 Add TaskMessageBuilder type as a test helper Ken Hibino 2022-03-06 16:51:35 -0800
  • 15619fc890 Update forwarder to use time.Timer Ken Hibino 2022-03-06 07:46:34 -0800
  • 39cf648c02 Update ForwardIfReady test with group Ken Hibino 2022-03-06 06:04:56 -0800
  • 19229645ff Update client to store groupKey under TaskMessage Ken Hibino 2022-03-06 05:53:59 -0800
  • 47acff3684 Add GroupKey field to TaskMessage Ken Hibino 2022-03-06 05:51:27 -0800
  • 17e9725287 Update RDB.ForwardIfReady to forward to group if groupKey is specified Ken Hibino 2022-03-06 05:45:33 -0800
  • a88f6498af Update Client to add task to group if Group option is specified Ken Hibino 2022-03-05 06:41:44 -0800
  • 278b2d7431 Add RDB.AddToGroup and RDB.AddToGroupUnique methods Ken Hibino 2022-03-05 06:08:43 -0800
  • 19f127b30e Add helper functions to generate group key Ken Hibino 2022-03-04 15:01:44 -0800
  • 976f76fe5e Add Group task option Ken Hibino 2022-03-04 11:51:08 -0800
  • 91a62214d6 Add group related configuration options Ken Hibino 2022-03-04 11:37:27 -0800
  • f94a65dc9f Add go1.18 to build workflow matrix Ken Hibino 2022-03-22 06:32:15 -0700
  • 1a16b64ad9 Add go1.18 to build workflow matrix Ken Hibino 2022-03-22 06:32:15 -0700
  • 21d91a1313 chore(): 设置jobId 为cmdb的instanceId pacinochen 2022-03-07 15:54:36 +0800
  • b345b237c7
         Merge pull request #1 from easy-monitor/pacino/tasks davidcui 2022-02-28 10:33:36 +0800
  • 311477639e chore(): 调度者队列任务过期时间设置为60s pacinochen 2022-02-27 21:21:54 +0800
  • dc34e963e2
         update readme Erwan Leboucher 2022-02-25 15:43:57 +0100
  • 40b346dd22
         Add change to the changelog Erwan Leboucher 2022-02-25 15:27:35 +0100
  • 8e9ad91046
         Add options for the client to set default timeout and max retries Erwan Leboucher 2022-02-25 15:24:02 +0100
  • 04d7c8c38c
         Add rediss url parsing support Erwan Leboucher 2022-02-24 17:30:55 +0100
  • 0fd8262f24 add UniqueKey option to extend Unique's behaviour Benjamin Große 2022-02-24 15:43:15 +0000
  • 351b2d87a6
         update godoc about support redis protocols Erwan Leboucher 2022-02-24 16:06:27 +0100
  • 1557102bd7
         Add changes to the changelog Erwan Leboucher 2022-02-24 15:02:40 +0100
  • 2f7d7a88dd chore(): 从内存里面读取任务 pacinochen 2022-02-24 20:13:34 +0800
  • c27684bf15
         Enable rediss url parsing support Erwan Leboucher 2022-02-24 13:03:12 +0100
  • e55a693fa0 chore(): 从内存里面读取任务 pacinochen 2022-02-24 14:47:04 +0800
  • 9530912680 chore(): log pacinochen 2022-02-22 23:13:53 +0800
  • c04fd41653 v0.22.1 v0.22.1 Ken Hibino 2022-02-20 06:22:55 -0800
  • 7e5efb0e30 Drop GT option from RDB.ExtendLease Ken Hibino 2022-02-20 05:40:09 -0800
  • 3af36e8832 Drop GT option from RDB.ExtendLease Ken Hibino 2022-02-20 05:40:09 -0800
  • cabf8d3627 Fix changelog Ken Hibino 2022-02-19 06:21:56 -0800
  • a19909f5f4 v0.22.0 v0.22.0 Ken Hibino 2022-02-19 06:20:05 -0800
  • cea5110d15 Add IsOrphaned field to TaskInfo Ken Hibino 2022-02-18 20:50:18 -0800
  • 9b63e23274 Update log messages Ken Hibino 2022-02-17 06:21:26 -0800
  • de25201d9f Make timeutil.SimulatedClock concurrency safe Ken Hibino 2022-02-17 05:50:39 -0800
  • ec560afb01 Fix processor test Ken Hibino 2022-02-16 20:42:08 -0800
  • d4006894ad Remove base.DeadlinesKey Ken Hibino 2022-02-16 06:27:08 -0800
  • 59927509d8 Remove timeout and deadline fields under task key Ken Hibino 2022-02-16 06:17:08 -0800
  • 8211167de2 Update processor to create a lease and watch for expiration Ken Hibino 2022-02-15 06:58:54 -0800
  • d7169cd445 Update heartbeat to extend lease of active workers Ken Hibino 2022-02-14 07:17:51 -0800
  • dfae8638e1 Update RDB methods to work with lease Ken Hibino 2022-02-13 14:34:38 -0800
  • b9943de2ab Add Lease type to base package Ken Hibino 2022-02-13 14:06:26 -0800
  • 871474f220 Update heartbeat goroutine to call ExtendLease on active tasks Ken Hibino 2022-02-12 09:48:07 -0800
  • 87dc392c7f Add RDB.ExtendLease method Ken Hibino 2022-02-12 06:49:53 -0800
  • dabcb120d5 Update recoverer to use ListLeaseExpired Ken Hibino 2022-02-11 06:18:27 -0800
  • bc2f1986d7 Update ListDeadlineExceeded to ListLeaseExpired Ken Hibino 2022-02-11 05:54:56 -0800
  • b8cb579407 Update RDB methods to use lease instead of deadlines set Ken Hibino 2022-02-10 19:01:05 -0800
  • bca624792c Move task deadline compute logic to processor Ken Hibino 2022-02-09 06:21:39 -0800
  • d865d89900 Update RDB.Dequeue to insert task ID to lease set Ken Hibino 2022-02-08 06:47:31 -0800
  • 852af7abd1 Add base.LeaseKey helper function Ken Hibino 2022-02-08 05:53:42 -0800
  • 4929d33572 Add IsOrphaned field to TaskInfo Ken Hibino 2022-02-18 20:50:18 -0800
  • 309acd2a97 Update log messages Ken Hibino 2022-02-17 06:21:26 -0800
  • 88942061df Make timeutil.SimulatedClock concurrency safe Ken Hibino 2022-02-17 05:50:39 -0800
  • 80326824dc Fix processor test Ken Hibino 2022-02-16 20:42:08 -0800