asynq

go-pkg/asynq

Fork 0

mirror of https://github.com/hibiken/asynq.git synced 2025-04-21 16:20:18 +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/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

#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

669c7995c4 Run CI builds using go v1.15.x Ken Hibino 2020-09-02 06:27:11 -07:00
7ed9091516 Run CI builds using go v1.15.x Ken Hibino 2020-09-02 06:27:11 -07:00
3c3b0e395a

Merge 278cbdcd034b392e3529e8b81c0c78817680d8d8 into 6d6a30137988203a5bf136b29caa1c7aaf31d797 xbt5843740 2020-09-02 04:55:45 +00:00
278cbdcd03

Update README.md xbt5843740 2020-09-02 12:55:38 +08: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
6d5ea0a1df Update changelog Ken Hibino 2020-07-28 22:45:22 -07:00
63c3a122df Fix history command Ken Hibino 2020-07-28 22:00:54 -07:00
6ff08a1767 Add Pause and Unpause queue methods to Inspector Ken Hibino 2020-07-28 21:56:48 -07:00
b2ed2fa97b Add healthchecker to check broker connection Ken Hibino 2020-07-25 18:49:27 -07:00
2f1eff387d Add healthchecker to check broker connection Ken Hibino 2020-07-25 18:49:27 -07:00
5c87cb3ed1 Fix flaky test Ken Hibino 2020-07-26 13:16:13 -07:00
a7764dc631 Minor comment fix Ken Hibino 2020-07-26 07:01:19 -07:00
93f15fb969 Add Inspector type Ken Hibino 2020-07-13 06:29:41 -07:00
764478b341 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
15f3afcdcc Do not start worker goroutine for task already exceeded its deadline Ken Hibino 2020-07-05 16:55:33 -07:00
890f757171 Invoke error handler when ctx.Done channel is closed Ken Hibino 2020-07-04 06:31:56 -07:00
04702ddfd2 Change ErrorHandler function signature v0.10.0.rc1 Ken Hibino 2020-07-04 05:24:47 -07:00
53511e0225 Change ErrorHandler function signature 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
e4dab12498 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
5a24eaeb12 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
7b1542fbef 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
61656b5b39 Add migrate command to CLI Ken Hibino 2020-06-26 06:11:39 -07:00
14cc9fbca2 Update docs Ken Hibino 2020-06-24 05:42:06 -07:00
bf37fe4d0a Minor code cleanup Ken Hibino 2020-06-23 06:34:59 -07:00
fb88618bff Use int64 type for Timeout and Deadline in TaskMessage Ken Hibino 2020-06-22 08:33:58 -07:00
55b78e7558 Clean up processor test Ken Hibino 2020-06-22 05:55:04 -07:00
c9c82b3e8b Add recoverer Ken Hibino 2020-06-21 07:05:57 -07:00
50b5584767 Add RDB.ListDeadlineExceeded Ken Hibino 2020-06-20 06:29:58 -07:00
6e81d65688 Fix processor Ken Hibino 2020-06-19 06:21:25 -07:00
f5f761413c Add deadline to syncRequest Ken Hibino 2020-06-19 05:51:50 -07:00
5de05e5473 Update processor to adapt for deadlines set change Ken Hibino 2020-06-19 05:34:36 -07:00
889e8010f4 Update RDB.Requeue to remove message from deadlines set Ken Hibino 2020-06-18 12:12:29 -07:00
d334a664b8 Update RDB.Dequeue to return deadline as time.Time Ken Hibino 2020-06-18 11:25:33 -07:00
c1a358418a Update RDB.Kill to remove message from deadlines set Ken Hibino 2020-06-18 10:53:58 -07:00
ee31ea2e9c Update RDB.Retry to remove message from deadlines set Ken Hibino 2020-06-18 10:25:01 -07:00
cf3ccdfa92 Update RDB.Done to remove message from deadlines set Ken Hibino 2020-06-18 07:10:57 -07:00
d98fc7c419 Update RDB.Dequeue to return message and deadline Ken Hibino 2020-06-18 05:45:10 -07:00
5587601b81 Add task message to deadlines set on dequeue Ken Hibino 2020-06-17 06:46:54 -07:00
9d471e3aa2 Use default timeout of 30mins if both timeout and deadline are not provided Ken Hibino 2020-06-16 21:12:50 -07:00
7fddba8f10 Change TaskMessage Timeout and Deadline to int Ken Hibino 2020-06-16 21:11:54 -07:00
825b29b7f3 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
7beab35c61 Fix Client.Enqueue to always call enqueue Ken Hibino 2020-06-14 05:31:24 -07:00