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

44c657bec6 Rate limit error logs Ken Hibino 2020-01-22 06:28:47 -08:00
19d62063d1 Rate limit error logs Ken Hibino 2020-01-22 06:28:47 -08:00
db8e9d05c3 Add custom logger Ken Hibino 2020-01-21 07:17:41 -08:00
21c4dcd1ce Add custom logger Ken Hibino 2020-01-21 07:17:41 -08:00
b02e4e6b09 [ci skip] Update readme Ken Hibino 2020-01-20 15:17:41 -08:00
f43c51ce8b v0.2.0 v0.2.0 Ken Hibino 2020-01-19 15:28:24 -08:00
04983dc00f [ci skip] Clarify terminology around 'state' and 'queue' Ken Hibino 2020-01-19 15:21:51 -08:00
9e872a4cb4 Change asynqmon history command to take no arguments Ken Hibino 2020-01-19 15:04:52 -08:00
7c61e7dd59 [ci skip] Clarify terminology around 'state' and 'queue' Ken Hibino 2020-01-19 15:21:51 -08:00
e94dabac7d Change asynqmon history command to take no arguments Ken Hibino 2020-01-19 15:04:52 -08:00
959c9fd01a [ci skip] Allow config file to set default values for flags Ken Hibino 2020-01-19 08:40:51 -08:00
15da08dbc0 [ci skip] Allow config file to set default values for flags Ken Hibino 2020-01-19 08:40:51 -08:00
d37f2a09ab [ci skip] Add readme for asynqmon tool Ken Hibino 2020-01-18 20:31:22 -08:00
0f7045d5c2 [ci skip] Add readme for asynqmon tool Ken Hibino 2020-01-18 20:31:22 -08:00
207a6d2d1a Fix benchmark tests Ken Hibino 2020-01-18 10:17:39 -08:00
c29200b1fc Add syncer to retry failed redis commands Ken Hibino 2020-01-18 07:32:06 -08:00
80a65c129a Fix benchmark tests Ken Hibino 2020-01-18 10:17:39 -08:00
7b3d08473a Add syncer to retry failed redis commands Ken Hibino 2020-01-18 07:32:06 -08:00
5c806676de [ci skip] Add link to gitter chat room Ken Hibino 2020-01-16 21:35:03 -08:00
fd8eb51440 [ci skip] Add badges to readme Ken Hibino 2020-01-16 21:13:34 -08:00
f66a65d6ca Fix tests Ken Hibino 2020-01-16 21:01:27 -08:00
d1f516d8f1 [ci skip] Update changelog Ken Hibino 2020-01-16 20:54:36 -08:00
0c2591ad7e [ci skip] Update docs Ken Hibino 2020-01-16 19:50:45 -08:00
43d7591250 Remove redis.Client type from asynq package API Ken Hibino 2020-01-14 21:19:06 -08:00
17c95bdf96 Fix tests Ken Hibino 2020-01-16 21:01:27 -08:00
3a59fd954c [ci skip] Update changelog Ken Hibino 2020-01-16 20:54:36 -08:00
ab56f46b3c [ci skip] Update docs Ken Hibino 2020-01-16 19:50:45 -08:00
dec9317ebb Remove redis.Client type from asynq package API Ken Hibino 2020-01-14 21:19:06 -08:00
cb2ebf18ac [performance] Skip the overhead of json decoding when scheduling to one queue Ken Hibino 2020-01-14 07:26:41 -08:00
5a6f737589 [performance] Use BRPOPLPUSH if one queue is used Ken Hibino 2020-01-14 06:29:05 -08:00
8fd4e66514 [performance] Skip the overhead of json decoding when scheduling to one queue Ken Hibino 2020-01-14 07:26:41 -08:00
ceac54b483 [performance] Use BRPOPLPUSH if one queue is used Ken Hibino 2020-01-14 06:29:05 -08:00
f0251be5d2 [ci skip] Update changelog Ken Hibino 2020-01-14 06:05:21 -08:00
858b0325bd Add rmq command to asynqmon Ken Hibino 2020-01-13 07:03:07 -08:00
874d8e8843 Add RDB.RemoveQueue method Ken Hibino 2020-01-13 06:50:03 -08:00
f71b80dab7 Add rmq command to asynqmon Ken Hibino 2020-01-13 07:03:07 -08:00
1fa1ab931c Add RDB.RemoveQueue method Ken Hibino 2020-01-13 06:50:03 -08:00
84eef4ed0b Add strict-priority option Ken Hibino 2020-01-12 07:46:51 -08:00
d59717f91d Add strict-priority option Ken Hibino 2020-01-12 07:46:51 -08:00
97316d6766 Fix flaky tests Ken Hibino 2020-01-11 10:02:13 -08:00
2631672575 Allow filtering results of asynqmon ls enqueued by providing queue name Ken Hibino 2020-01-10 21:32:15 -08:00
cf78a12866 Add "Queue" column to the output of asynqmon ls Ken Hibino 2020-01-10 07:06:26 -08:00
c5b215e3b9 Update RDB.ListEnqueued to list tasks from all queues Ken Hibino 2020-01-10 06:56:51 -08:00
2ff847d520 Include each queue counts in stats command output Ken Hibino 2020-01-09 20:29:10 -08:00
89843ac565 Change RDB.CurrentStats to be multi-queue aware Ken Hibino 2020-01-09 07:01:44 -08:00
67f381269a Maintain a set of queue names in redis set Ken Hibino 2020-01-09 06:21:43 -08:00
390eb13149 Remove stale field in processor struct Ken Hibino 2020-01-08 20:50:22 -08:00
718336ff44 Update RDB.Enqueue* methods to be multi queue aware Ken Hibino 2020-01-08 07:16:21 -08:00
aede018e21 Fix flaky tests Ken Hibino 2020-01-11 10:02:13 -08:00
d4c70038d5 Allow filtering results of asynqmon ls enqueued by providing queue name Ken Hibino 2020-01-10 21:32:15 -08:00
f96aee3832 Add "Queue" column to the output of asynqmon ls Ken Hibino 2020-01-10 07:06:26 -08:00
f1e5768259 Update RDB.ListEnqueued to list tasks from all queues Ken Hibino 2020-01-10 06:56:51 -08:00
8735718c20 Include each queue counts in stats command output Ken Hibino 2020-01-09 20:29:10 -08:00
70f1320e6e Change RDB.CurrentStats to be multi-queue aware Ken Hibino 2020-01-09 07:01:44 -08:00
5d431bc247 Maintain a set of queue names in redis set Ken Hibino 2020-01-09 06:21:43 -08:00
d5970d9501 Remove stale field in processor struct Ken Hibino 2020-01-08 20:50:22 -08:00
f5cf6a7720 Update RDB.Enqueue* methods to be multi queue aware Ken Hibino 2020-01-08 07:16:21 -08:00
8ff5c5101e [ci skip] Update changelog Ken Hibino 2020-01-07 21:53:38 -08:00
4f5d115b3e [ci skip] Upgrade github.com/google/go-cmp to v0.4.0 Ken Hibino 2020-01-07 21:22:19 -08:00
24bb45b36b [ci skip] Normalize queue priority numbers Ken Hibino 2020-01-07 21:17:01 -08:00
8d9a2d1313 Update processor to query queues based on priority Ken Hibino 2020-01-07 07:03:39 -08:00
53d0902808 Change RDB.Dequeue to query multiple queues Ken Hibino 2020-01-07 06:28:34 -08:00
2af9eb2c88 Delete stale code Ken Hibino 2020-01-06 21:30:27 -08:00
28d698c24e Update CheckAndEnqueue to enqueue tasks to specified queue Ken Hibino 2020-01-06 21:27:51 -08:00
1d99d99692 Update comment Ken Hibino 2020-01-06 07:21:14 -08:00
03cb6eef09 Add Queues field to Config Ken Hibino 2020-01-06 07:15:59 -08:00
ca78b92078 Add Queue option to allow user to specify queue from client Ken Hibino 2020-01-06 06:53:40 -08:00
25b359a795 [ci skip] Update changelog Ken Hibino 2020-01-07 21:53:38 -08:00
d5d4114240 [ci skip] Upgrade github.com/google/go-cmp to v0.4.0 Ken Hibino 2020-01-07 21:22:19 -08:00
fb66f0977a [ci skip] Normalize queue priority numbers Ken Hibino 2020-01-07 21:17:01 -08:00
25a93737df Update processor to query queues based on priority Ken Hibino 2020-01-07 07:03:39 -08:00
d7ae925b39 Change RDB.Dequeue to query multiple queues Ken Hibino 2020-01-07 06:28:34 -08:00
79a2205b1d Delete stale code Ken Hibino 2020-01-06 21:30:27 -08:00
889a35af97 Update CheckAndEnqueue to enqueue tasks to specified queue Ken Hibino 2020-01-06 21:27:51 -08:00
8e79be6f5b Update comment Ken Hibino 2020-01-06 07:21:14 -08:00
48572dd433 Add Queues field to Config Ken Hibino 2020-01-06 07:15:59 -08:00
cdc6e520c4 Add Queue option to allow user to specify queue from client Ken Hibino 2020-01-06 06:53:40 -08:00
29ad70c36a [ci skip] Update readme Ken Hibino 2020-01-05 09:06:23 -08:00
00b03e1287 Add test for payload key not exist Ken Hibino 2020-01-05 08:50:43 -08:00
f3a23b9b12 Make Task type immutable Ken Hibino 2020-01-04 13:13:46 -08:00
82abe0e4c4 [ci skip] Update readme Ken Hibino 2020-01-05 09:06:23 -08:00
a4adfe355a Add test for payload key not exist Ken Hibino 2020-01-05 08:50:43 -08:00
c1ef571d16 Make Task type immutable Ken Hibino 2020-01-04 13:13:46 -08:00
899566e661 [ci skip] Add changelog v0.1.0 Ken Hibino 2020-01-04 13:24:09 -08:00
187679711e [ci skip] Add changelog Ken Hibino 2020-01-04 13:24:09 -08:00
294a695b98 Add history command to asynqmon tool Ken Hibino 2020-01-04 09:41:05 -08:00
c5f424440f Add history command to asynqmon tool Ken Hibino 2020-01-04 09:41:05 -08:00
606b0fae64 Rename Client Process method to Schedule Ken Hibino 2020-01-03 20:24:18 -08:00
8a8fdb0fa3 Rename Client Process method to Schedule Ken Hibino 2020-01-03 20:24:18 -08:00
9256fb6023 Update package doc Ken Hibino 2020-01-02 19:47:04 -08:00
c62833540c Add license comment to all src files Ken Hibino 2020-01-02 18:13:16 -08:00
9c0233c388 Update todos Ken Hibino 2020-01-02 18:04:36 -08:00
fc5b65ddae Add a function to return a list of queues to query Ken Hibino 2020-01-01 18:19:55 -08:00
6de80f9f04 Change dequeue method to use lua script Ken Hibino 2020-01-01 14:57:31 -08:00
5c42bdc4c4 Change (*RDB).Dequeue to query multiple queues in order Ken Hibino 2020-01-01 13:42:24 -08:00
eb191c07d1 Export (High|Low)PriorityQueue constant from base pkg Ken Hibino 2020-01-01 12:12:49 -08:00
2e95166f39 Remove Queue field and Priority field to base.TaskMessage Ken Hibino 2020-01-01 07:48:21 -08:00
31a18d783e Add Priority type in base package Ken Hibino 2020-01-01 07:41:22 -08:00
09ee8df5a0 Add end-to-end benchmark tests Ken Hibino 2019-12-31 12:36:46 -08:00
1dd875adb9 Add end-to-end benchmark tests Ken Hibino 2019-12-31 12:36:46 -08:00