asynq

go-pkg/asynq

Fork 0

mirror of https://github.com/hibiken/asynq.git synced 2024-12-25 07:12:17 +08:00

Commit Graph

Select branches

Hide Pull Requests

dependabot/go_modules/github.com/spf13/cast-1.7.1

dependabot/go_modules/golang.org/x/sys-0.28.0

dependabot/go_modules/google.golang.org/protobuf-1.36.1

dependabot/go_modules/tools/github.com/gdamore/tcell/v2-2.7.4

dependabot/go_modules/tools/github.com/hibiken/asynq-0.25.1

dependabot/go_modules/tools/github.com/prometheus/client_golang-1.20.5

dependabot/go_modules/tools/github.com/spf13/cobra-1.8.1

dependabot/go_modules/tools/github.com/spf13/viper-1.19.0

dependabot/go_modules/x/github.com/google/uuid-1.6.0

dependabot/go_modules/x/github.com/hibiken/asynq-0.25.1

develop

go-versions

master

revert-491-master

revert-937-dependabot/go_modules/golang.org/x/time-0.7.0

sohail/activate-dependabot

sohail/changelog/v0.25.0

sohail/pm-redis-conn-hotfix

sohail/release-v0.25.0

sohail/unix-stop-signal

#1

#10

#100

#101

#102

#106

#107

#11

#110

#111

#112

#113

#114

#115

#116

#117

#118

#12

#120

#126

#127

#128

#13

#130

#133

#134

#135

#136

#137

#14

#140

#141

#142

#144

#145

#146

#148

#149

#15

#150

#151

#152

#153

#156

#157

#159

#16

#161

#162

#163

#165

#169

#17

#170

#171

#174

#176

#177

#178

#18

#180

#181

#184

#185

#186

#188

#188

#189

#190

#191

#193

#2

#200

#202

#205

#207

#208

#209

#21

#211

#217

#219

#22

#225

#226

#229

#231

#232

#234

#235

#236

#237

#238

#239

#24

#247

#248

#249

#25

#251

#252

#253

#254

#255

#257

#258

#262

#268

#27

#272

#276

#279

#280

#283

#287

#289

#29

#294

#296

#298

#3

#30

#302

#303

#31

#310

#312

#317

#319

#32

#323

#324

#33

#331

#333

#336

#337

#34

#345

#346

#35

#350

#36

#364

#365

#366

#367

#370

#374

#375

#377

#378

#384

#386

#391

#392

#394

#399

#4

#400

#402

#404

#406

#407

#408

#41

#415

#42

#424

#426

#43

#432

#433

#44

#440

#448

#451

#452

#454

#455

#457

#467

#469

#47

#470

#476

#477

#48

#482

#484

#486

#49

#490

#491

#494

#494

#496

#5

#502

#505

#505

#509

#51

#514

#514

#517

#52

#528

#533

#534

#537

#54

#543

#543

#550

#557

#559

#56

#560

#561

#562

#563

#563

#564

#564

#567

#57

#576

#576

#577

#58

#585

#588

#59

#596

#597

#598

#598

#6

#602

#606

#606

#607

#61

#614

#615

#616

#619

#62

#620

#621

#623

#623

#627

#637

#638

#64

#644

#644

#647

#647

#65

#657

#658

#66

#665

#667

#67

#673

#674

#676

#677

#677

#68

#680

#682

#683

#683

#687

#689

#692

#694

#696

#697

#698

#699

#7

#70

#700

#701

#702

#703

#704

#705

#706

#707

#708

#709

#71

#712

#713

#714

#715

#72

#720

#726

#727

#73

#732

#734

#736

#736

#739

#74

#740

#742

#743

#75

#750

#753

#754

#758

#759

#76

#760

#761

#767

#770

#771

#772

#776

#777

#778

#779

#780

#784

#788

#79

#791

#795

#796

#8

#80

#802

#807

#809

#81

#810

#812

#813

#814

#815

#816

#817

#818

#818

#82

#822

#823

#824

#825

#827

#828

#829

#833

#834

#834

#835

#838

#838

#839

#840

#841

#843

#849

#85

#857

#858

#86

#860

#865

#865

#868

#870

#874

#876

#877

#877

#878

#878

#879

#879

#882

#89

#891

#895

#896

#9

#914

#916

#918

#92

#920

#921

#922

#924

#925

#926

#927

#928

#929

#93

#930

#931

#932

#933

#934

#935

#936

#937

#938

#939

#939

#94

#940

#940

#941

#942

#944

#945

#946

#947

#948

#95

#950

#953

#954

#955

#956

#957

#958

#96

#962

#963

#964

#965

#966

#969

#969

#97

#970

#971

#972

#973

#973

#976

#976

#977

#978

#978

#980

#982

#984

#984

#988

#988

#989

#989

#99

#990

#991

#991

#992

#992

#995

#995

#996

#996

v0.1.0

v0.10.0

v0.10.0.rc1

v0.11.0

v0.12.0

v0.13.0

v0.13.1

v0.14.0

v0.14.1

v0.15.0

v0.16.0

v0.16.1

v0.17.0

v0.17.1

v0.17.2

v0.18.0

v0.18.1

v0.18.2

v0.18.3

v0.18.4

v0.18.5

v0.18.6

v0.19.0

v0.19.1

v0.2.0

v0.2.1

v0.2.2

v0.20.0

v0.21.0

v0.22.0

v0.22.1

v0.23.0

v0.24.0

v0.24.1

v0.25.0

v0.25.1

v0.3.0

v0.4.0

v0.5.0

v0.6.0

v0.6.1

v0.6.2

v0.7.0

v0.7.1

v0.8.0

v0.8.1

v0.8.2

v0.8.3

v0.9.0

v0.9.1

v0.9.2

v0.9.3

v0.9.4

7fb5b25944 Add Inspector.ListAggregatingTasks Ken Hibino 2022-03-22 06:23:22 -0700
71bd8f0535 Add RDB.ListAggregating Ken Hibino 2022-03-20 06:27:41 -0700
4c8432e0ce Add Inspector.Groups method Ken Hibino 2022-03-19 07:23:09 -0700
e939b5d166 Rename asynqtest package to testutil Ken Hibino 2022-03-19 07:16:55 -0700
1acd62c760 Move test helpers to asynqtest package Ken Hibino 2022-03-19 07:12:41 -0700
0149396bae Add RDB.GroupStats for inspecting groups Ken Hibino 2022-03-18 06:55:22 -0700
45ed560708 Add Group field to TaskInfo struct Ken Hibino 2022-03-16 20:22:07 -0700
01eeb8756e (cli): Update queue inspect cmd to show # of groups and aggregating tasks Ken Hibino 2022-03-16 16:41:44 -0700
47af17cfb4 Fix RDB.CurrentStats to report the correct queue size Ken Hibino 2022-03-16 16:31:19 -0700
eb064c2bab Fix AggregationCheck with unlimited size to clear group name from all-groups set Ken Hibino 2022-03-15 17:03:09 -0700
652939dd3a Update memory usage redis lua script to account for groups Ken Hibino 2022-03-15 16:30:25 -0700
efe3c74037 Show number of groups and aggregating task count in QueueInfo Ken Hibino 2022-03-15 06:52:56 -0700
74d2eea4e0 Clear group if aggregation set empties the group Ken Hibino 2022-03-13 06:44:42 -0700
60a4dc1401 Add test for DeleteAggregationSet error case Ken Hibino 2022-03-12 15:29:38 -0800
4b716780ef Rewrite test for DeleteAggregationSet function with a new pattern Ken Hibino 2022-03-12 15:18:32 -0800
e63f41fb24 Fix DeleteAggregationSet Ken Hibino 2022-03-11 15:54:47 -0800
1c388baf06 Implement RDB.ReclaimStaleAggregationSets Ken Hibino 2022-03-11 12:04:35 -0800
47a66231b3 Store aggregation set *key* in all aggreationsets zset Ken Hibino 2022-03-11 11:10:44 -0800
3551d3334c Use zset for aggregation set to preserve score Ken Hibino 2022-03-11 10:59:05 -0800
8b16ede8bc Declare ReclaimStaleAggregationSets Ken Hibino 2022-03-11 10:44:12 -0800
c8658a53e6 Add aggregator test Ken Hibino 2022-03-11 08:54:00 -0800
562506c7ba Fix client to return error when nil task is passed Ken Hibino 2022-03-10 15:59:58 -0800
888b5590fb Make GroupMaxSize and GroupMaxDelay config optional Ken Hibino 2022-03-10 15:48:02 -0800
196db64d4d Run aggregator on the server Ken Hibino 2022-03-10 12:15:28 -0800
4b35eb0e1a Fix RDB.AggregationCheck when run against an empty group Ken Hibino 2022-03-10 11:54:47 -0800
b29fe58434 Implement RDB.ListGroups Ken Hibino 2022-03-10 11:06:48 -0800
7849b1114c Implement RDB.DeleteAggregationSet Ken Hibino 2022-03-10 11:00:28 -0800
99c00bffeb Implement RDB.AggregationCheck Ken Hibino 2022-03-09 17:05:16 -0800
4542b52da8 Check for aggregation at an interval <= gracePeriod Ken Hibino 2022-03-09 06:01:37 -0800
d841dc2f8d Add initial implementation of aggregator Ken Hibino 2022-03-08 06:38:35 -0800
ab28234767 Update client dependency to base.Broker Ken Hibino 2022-03-08 05:59:58 -0800
eb27b0fe1e Add TaskMessageBuilder type as a test helper Ken Hibino 2022-03-06 16:51:35 -0800
088be63ee4 Update forwarder to use time.Timer Ken Hibino 2022-03-06 07:46:34 -0800
ed69667e86 Update ForwardIfReady test with group Ken Hibino 2022-03-06 06:04:56 -0800
4e8885276c Update client to store groupKey under TaskMessage Ken Hibino 2022-03-06 05:53:59 -0800
401f7fb4fe Add GroupKey field to TaskMessage Ken Hibino 2022-03-06 05:51:27 -0800
61854ea1dc Update RDB.ForwardIfReady to forward to group if groupKey is specified Ken Hibino 2022-03-06 05:45:33 -0800
f17c157b0f Update Client to add task to group if Group option is specified Ken Hibino 2022-03-05 06:41:44 -0800
8b582899ad Add RDB.AddToGroup and RDB.AddToGroupUnique methods Ken Hibino 2022-03-05 06:08:43 -0800
e3d2939a4c Add helper functions to generate group key Ken Hibino 2022-03-04 15:01:44 -0800
2ce71e83b0 Add Group task option Ken Hibino 2022-03-04 11:51:08 -0800
1608366032 Add group related configuration options Ken Hibino 2022-03-04 11:37:27 -0800
3d342e20dc Update CHANGELOG.md Ken Hibino 2022-04-11 16:52:07 -0700
e603189e06 Rename variables for public API documentation Ken Hibino 2022-04-10 17:55:21 -0700
0877f41015 (cli): Update stats command to print the number of aggregating tasks Ken Hibino 2022-04-09 15:52:58 -0700
2dcfeeb0a5 (cli): Extend task ls command to list aggregating tasks Ken Hibino 2022-04-09 15:47:33 -0700
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