asynq

go-pkg/asynq

Fork 0

mirror of https://github.com/hibiken/asynq.git synced 2025-06-06 06:42:56 +08:00

Commit Graph

Select branches

Hide Pull Requests

dependabot/go_modules/github.com/redis/go-redis/v9-9.7.1

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

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

dependabot/go_modules/golang.org/x/time-0.11.0

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

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

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

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

dependabot/go_modules/tools/github.com/spf13/cobra-1.9.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

dependabot/go_modules/x/github.com/prometheus/client_golang-1.21.1

dependabot/go_modules/x/github.com/redis/go-redis/v9-9.7.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/recoverer-fix

sohail/release-v0.25.0

sohail/unix-stop-signal

#1

#10

#100

#1000

#1000

#1003

#1004

#1005

#1005

#1006

#1009

#101

#1010

#1011

#1012

#1012

#1014

#1018

#1019

#102

#1020

#1020

#1023

#1023

#1024

#1024

#1025

#1026

#1027

#1027

#1029

#1029

#1031

#1031

#1032

#1032

#1033

#1033

#1034

#1034

#1035

#1035

#1036

#1036

#1042

#1042

#1047

#1047

#1054

#1054

#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

#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

#941

#942

#944

#945

#946

#947

#948

#95

#950

#953

#954

#955

#956

#957

#958

#96

#962

#963

#964

#965

#966

#969

#97

#970

#971

#972

#973

#973

#976

#976

#977

#978

#978

#980

#982

#984

#984

#988

#988

#989

#99

#990

#991

#991

#992

#992

#995

#995

#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

becd26479b Update WriteServerState and ClearServerState in RDB Ken Hibino 2020-08-10 21:49:12 -07:00
4b81b91d3e Minor fix Ken Hibino 2020-08-10 06:13:06 -07:00
8e23b865e9 Update recoverer Ken Hibino 2020-08-10 06:10:14 -07:00
a873d488ee Update ListDeadlineExceeded in RDB Ken Hibino 2020-08-10 05:37:49 -07:00
e0a8f1252a Update scheduler to check and enqueue for only the specified queues. Ken Hibino 2020-08-09 07:13:42 -07:00
650d7fdbe9 Update CheckAndEnqueue method in RDB Ken Hibino 2020-08-09 06:26:14 -07:00
f6d504939e Update Requeue method in RDB Ken Hibino 2020-08-09 05:40:44 -07:00
74f08795f8 Update Kill method in RDB Ken Hibino 2020-08-08 12:44:08 -07:00
35b2b1782e Update Retry method in RDB Ken Hibino 2020-08-08 12:17:33 -07:00
f63dcce0c0 Update Done method in RDB Ken Hibino 2020-08-08 06:48:49 -07:00
565f86ee4f Update Dequeue command in rdb Ken Hibino 2020-08-08 06:04:16 -07:00
94aa878060 Update Enqueue and Schedule commands in rdb Ken Hibino 2020-08-07 06:31:02 -07:00
50b6034bf9 Move unique key generator function to base Ken Hibino 2020-08-07 05:36:54 -07:00
154113d0d0 Update base package to generate redis keys with hashtag Ken Hibino 2020-08-06 07:34:00 -07:00
669c7995c4 Run CI builds using go v1.15.x Ken Hibino 2020-09-02 06:27:11 -07:00
6d6a301379 v0.11.0 v0.11.0 Ken Hibino 2020-07-28 22:46:41 -07:00
53f9475582 Update changelog Ken Hibino 2020-07-28 22:45:22 -07:00
e8fdbc5a72 Fix history command Ken Hibino 2020-07-28 22:00:54 -07:00
5f06c308f0 Add Pause and Unpause queue methods to Inspector Ken Hibino 2020-07-28 21:56:48 -07:00
a913e6d73f Add healthchecker to check broker connection Ken Hibino 2020-07-25 18:49:27 -07:00
6978e93080 Fix flaky test Ken Hibino 2020-07-26 13:16:13 -07:00
92d77bbc6e Minor comment fix Ken Hibino 2020-07-26 07:01:19 -07:00
a28f61f313 Add Inspector type Ken Hibino 2020-07-13 06:29:41 -07:00
9bd3d8e19e v0.10.0 v0.10.0 Ken Hibino 2020-07-06 05:53:56 -07:00
7382e2aeb8 Do not start worker goroutine for task already exceeded its deadline Ken Hibino 2020-07-05 16:55:33 -07:00
007fac8055 Invoke error handler when ctx.Done channel is closed Ken Hibino 2020-07-04 06:31:56 -07:00
8d43fe407a Change ErrorHandler function signature Ken Hibino 2020-07-04 05:24:47 -07:00
34b90ecc8a Return Result struct to caller of Enqueue Ken Hibino 2020-07-03 05:49:52 -07:00
8b60e6a268 Replace github.com/rs/xid with github.com/google/uuid Ken Hibino 2020-07-02 06:21:20 -07:00
486dcd799b Add version command to CLI Ken Hibino 2020-06-29 13:56:53 -07:00
195f4603bb Add migrate command to CLI Ken Hibino 2020-06-26 06:11:39 -07:00
2e2c9b9f6b Update docs Ken Hibino 2020-06-24 05:42:06 -07:00
199bf4d66a Minor code cleanup Ken Hibino 2020-06-23 06:34:59 -07:00
7e942ec241 Use int64 type for Timeout and Deadline in TaskMessage Ken Hibino 2020-06-22 08:33:58 -07:00
379da8f7a2 Clean up processor test Ken Hibino 2020-06-22 05:55:04 -07:00
feee87adda Add recoverer Ken Hibino 2020-06-21 07:05:57 -07:00
7657f560ec Add RDB.ListDeadlineExceeded Ken Hibino 2020-06-20 06:29:58 -07:00
7c7de0d8e0 Fix processor Ken Hibino 2020-06-19 06:21:25 -07:00
83f1e20d74 Add deadline to syncRequest Ken Hibino 2020-06-19 05:51:50 -07:00
4e8ac151ae Update processor to adapt for deadlines set change Ken Hibino 2020-06-19 05:34:36 -07:00
08b71672aa Update RDB.Requeue to remove message from deadlines set Ken Hibino 2020-06-18 12:12:29 -07:00
92af00f9fd Update RDB.Dequeue to return deadline as time.Time Ken Hibino 2020-06-18 11:25:33 -07:00
113451ce6a Update RDB.Kill to remove message from deadlines set Ken Hibino 2020-06-18 10:53:58 -07:00
9cd9f3d6b4 Update RDB.Retry to remove message from deadlines set Ken Hibino 2020-06-18 10:25:01 -07:00
7b9119c703 Update RDB.Done to remove message from deadlines set Ken Hibino 2020-06-18 07:10:57 -07:00
9b05dea394 Update RDB.Dequeue to return message and deadline Ken Hibino 2020-06-18 05:45:10 -07:00
6cc5bafaba Add task message to deadlines set on dequeue Ken Hibino 2020-06-17 06:46:54 -07:00
716d3d987e Use default timeout of 30mins if both timeout and deadline are not provided Ken Hibino 2020-06-16 21:12:50 -07:00
0527b93432 Change TaskMessage Timeout and Deadline to int Ken Hibino 2020-06-16 21:11:54 -07:00
5dddc35d7c Add redis key for deadlines in base package Ken Hibino 2020-06-16 05:27:58 -07:00
04702ddfd2 Change ErrorHandler function signature v0.10.0.rc1 Ken Hibino 2020-07-04 05:24:47 -07:00
6705f7c27a Return Result struct to caller of Enqueue Ken Hibino 2020-07-03 05:49:52 -07:00
e27ae0d33a Replace github.com/rs/xid with github.com/google/uuid Ken Hibino 2020-07-02 06:21:20 -07:00
6cd0ab65a3 Add version command to CLI Ken Hibino 2020-06-29 13:56:53 -07:00
83c9d5ae94 Add migrate command to CLI Ken Hibino 2020-06-26 06:11:39 -07:00
7eebbf181e Update docs Ken Hibino 2020-06-24 05:42:06 -07:00
7b1770da96 Minor code cleanup Ken Hibino 2020-06-23 06:34:59 -07:00
e2c5882368 Use int64 type for Timeout and Deadline in TaskMessage Ken Hibino 2020-06-22 08:33:58 -07:00
50df107ace Clean up processor test Ken Hibino 2020-06-22 05:55:04 -07:00
9699d196e5 Add recoverer Ken Hibino 2020-06-21 07:05:57 -07:00
1c5f7a791b Add RDB.ListDeadlineExceeded Ken Hibino 2020-06-20 06:29:58 -07:00
232efe8279 Fix processor Ken Hibino 2020-06-19 06:21:25 -07:00
ef4a4a8334 Add deadline to syncRequest Ken Hibino 2020-06-19 05:51:50 -07:00
65e17a3469 Update processor to adapt for deadlines set change Ken Hibino 2020-06-19 05:34:36 -07:00
88d94a2a9d Update RDB.Requeue to remove message from deadlines set Ken Hibino 2020-06-18 12:12:29 -07:00
7433b94aac Update RDB.Dequeue to return deadline as time.Time Ken Hibino 2020-06-18 11:25:33 -07:00
08ac7793ab Update RDB.Kill to remove message from deadlines set Ken Hibino 2020-06-18 10:53:58 -07:00
02b653df72 Update RDB.Retry to remove message from deadlines set Ken Hibino 2020-06-18 10:25:01 -07:00
bee784c052 Update RDB.Done to remove message from deadlines set Ken Hibino 2020-06-18 07:10:57 -07:00
4ea58052f8 Update RDB.Dequeue to return message and deadline Ken Hibino 2020-06-18 05:45:10 -07:00
5afb4861a5 Add task message to deadlines set on dequeue Ken Hibino 2020-06-17 06:46:54 -07:00
68e6b379fc Use default timeout of 30mins if both timeout and deadline are not provided Ken Hibino 2020-06-16 21:12:50 -07:00
0e70a14899 Change TaskMessage Timeout and Deadline to int Ken Hibino 2020-06-16 21:11:54 -07:00
f01c7b8e66 Add redis key for deadlines in base package Ken Hibino 2020-06-16 05:27:58 -07:00
4e5f596910 Fix Client.Enqueue to always call enqueue Ken Hibino 2020-06-14 05:31:24 -07:00
8bf5917cd9 v0.9.4 v0.9.4 Ken Hibino 2020-06-13 06:27:28 -07:00
7f30fa2bb6 Fix requeue logic in processor Ken Hibino 2020-06-13 06:09:54 -07:00
ade6e61f51 v0.9.3 v0.9.3 Ken Hibino 2020-06-12 06:31:42 -07:00
a2abeedaa0 Fix JSON number ovewflow issue Ken Hibino 2020-06-11 20:58:27 -07:00
81bb52b08c processor: log detail err in markAsDone func lion.zhao 2020-06-10 19:51:57 +08:00
bc2a7635a0 v0.9.2 v0.9.2 Ken Hibino 2020-06-08 06:23:02 -07:00
f65d408bf9 Update docs for pause feature Ken Hibino 2020-06-08 06:15:45 -07:00
4749b4bbfc Add benchmark test to verify client enqueue performance while server is running Ken Hibino 2020-06-08 05:51:36 -07:00
06c4a1c7f8 Limit the number of tasks moved by CheckAndEnqueue to prevent a long running script Ken Hibino 2020-06-07 13:04:27 -07:00
8af4cbad51 Fix data race in test Ken Hibino 2020-06-05 21:23:28 -07:00
4e800a7f68 Update stats command to show queue paused status Ken Hibino 2020-06-05 06:42:27 -07:00
d6a5c84dc6 Add pause and unpause command to CLI Ken Hibino 2020-06-04 06:34:15 -07:00
363cfedb49 Update Dequeue operation to skip paused queues Ken Hibino 2020-06-04 05:37:17 -07:00
4595bd41c3 Add Pause and Unpause methods to rdb Ken Hibino 2020-06-03 06:44:12 -07:00
e236d55477 Fix cli build Ken Hibino 2020-06-04 06:35:50 -07:00
a38f628f3b Refactor server state management Ken Hibino 2020-05-18 20:47:35 -07:00
69ad583278 v0.9.1 v0.9.1 Ken Hibino 2020-05-29 05:42:40 -07:00
23f46dde52 Add helper functions to extract task metadata from context Ken Hibino 2020-05-28 06:28:14 -07:00
39188fe930 remove typo and redundant code lihe 2020-05-22 16:09:04 +08:00
4492ed9255 Change internal constructor signatures. Ken Hibino 2020-05-17 12:33:55 -07:00
4e3e053989 Update readme Ken Hibino 2020-05-16 10:44:39 -07:00
aef0775c05 v0.9.0 v0.9.0 Ken Hibino 2020-05-16 08:02:57 -07:00
de146993d2 Add log messages around Server.Quiet Ken Hibino 2020-05-16 08:01:39 -07:00
60cbf8dc5a Minor code cleanup Ken Hibino 2020-05-12 21:30:51 -07:00
fb38086590 Clean up log messages Ken Hibino 2020-05-11 07:02:26 -07:00