asynq

go-pkg/asynq

Fork 0

mirror of https://github.com/hibiken/asynq.git synced 2025-06-07 15:22:55 +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

0cc486a975 Fix data race in syncer test Ken Hibino 2020-02-16 21:09:16 -08:00
906f231e6c Fix data race in subscriber test Ken Hibino 2020-02-16 14:42:21 -08:00
39f237899b Clean up heartbeater test Ken Hibino 2020-02-16 09:45:44 -08:00
3d9a222bb3 Use sync.WaitGroup for shutdown Ken Hibino 2020-02-15 23:14:30 -08:00
2bcaea52ce Make heartbeater goroutine a monitor goroutine for process info. Ken Hibino 2020-02-15 21:59:06 -08:00
0856ef32e0 v0.4.0 v0.4.0 Ken Hibino 2020-02-13 06:25:27 -08:00
70efb7b455 [ci skip] Update changelog Ken Hibino 2020-02-13 06:17:47 -08:00
d33ca98648 Use int as priority value type. Ken Hibino 2020-02-12 22:23:25 -08:00
bf31fcc3ec [ci skip] Update readme and changelog Ken Hibino 2020-02-12 18:11:59 -08:00
cd55a0e316 Add cancel command to asynqmon cli Ken Hibino 2020-02-12 17:33:41 -08:00
6685827147 Add redis pubsub subscriber for cancelation Ken Hibino 2020-02-12 17:12:09 -08:00
133bb6c2c6 Update docs for context and timeout Ken Hibino 2020-02-11 21:59:46 -08:00
39459b4412 Allow user to specify timeout per task Ken Hibino 2020-02-11 21:53:59 -08:00
6e14062325 Send cancellation signal to all in-progress handlers on shutdown Ken Hibino 2020-02-11 07:40:45 -08:00
1b41c721b4 Change Handler interface to take context.Context Ken Hibino 2020-02-11 07:06:52 -08:00
79a04e52a3 [cip skip] Add link to intro video in readme Ken Hibino 2020-02-09 10:59:32 -08:00
d9327cf24b Avoid creating script struct on every rdb method invocation Ken Hibino 2020-02-08 11:06:14 -08:00
7e33c9ebe0 [ci skip] Add contribution doc Ken Hibino 2020-02-08 09:34:14 -08:00
a6b79eb7a0 [ci skip] Update readme Ken Hibino 2020-02-07 06:45:36 -08:00
7af69c8d3c [ci skip] Fix comments Ken Hibino 2020-02-06 20:46:59 -08:00
6dd4c688f4 [ci skip] Update readme Ken Hibino 2020-02-05 21:58:05 -08:00
024cfa9fe6 Update output text for task's next retry value Ken Hibino 2020-02-05 21:43:24 -08:00
461a6f2587 v0.3.0 v0.3.0 Ken Hibino 2020-02-04 06:29:57 -08:00
ba9b42f428 Clean up cli description text Ken Hibino 2020-02-04 06:16:29 -08:00
3744072e9b Sort processes by host and pid in ps output Ken Hibino 2020-02-03 06:44:17 -08:00
eadfd5f8b4 [ci skip] Update changelog Ken Hibino 2020-02-02 20:59:00 -08:00
96f06ac89b Add ps command to asynqmon Ken Hibino 2020-02-01 22:22:48 -08:00
d03fa34eaf Add hearbeater Ken Hibino 2020-01-31 06:48:58 -08:00
489e695433 [ci skip] Change font used in demo.gif Ken Hibino 2020-01-30 21:47:08 -08:00
9ae4be8184 Run and compare benchmarks after successful ci-build Ken Hibino 2020-01-30 20:37:28 -08:00
36af486303 [ci skip] Add prettier gif for demo Ken Hibino 2020-01-29 21:23:40 -08:00
a46eb97e6f [ci skip] Shorten readme Ken Hibino 2020-01-26 19:58:48 -08:00
c934ef115b v0.2.2 v0.2.2 Ken Hibino 2020-01-26 16:07:44 -08:00
6fbaa2ed6c (fix): RestoreUnfinished to select correct queue Ken Hibino 2020-01-26 13:55:23 -08:00
166497748b (fix): Requeue to select correct queue Ken Hibino 2020-01-26 13:41:06 -08:00
31123fd42a Paginate tasks with asynqmon ls command Ken Hibino 2020-01-24 07:19:58 -08:00
3ed155b45b [ci skip] Update readme Ken Hibino 2020-01-23 06:33:34 -08:00
58d2ed94e7 [ci skip] Fix typo Ken Hibino 2020-01-23 06:05:18 -08:00
e253211a60 v0.2.1 v0.2.1 Ken Hibino 2020-01-22 06:45:16 -08:00
44c657bec6 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
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
959c9fd01a [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
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
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
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
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
84eef4ed0b 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
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
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
899566e661 [ci skip] Add changelog v0.1.0 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
606b0fae64 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
09ee8df5a0 Add end-to-end benchmark tests Ken Hibino 2019-12-31 12:36:46 -08:00
4376dc1e9d Add benchmark tests for rdb Ken Hibino 2019-12-30 20:10:34 -08:00
b7c0c5d3aa Handle mutated task in RDB's Done, Retry, Kill methods Ken Hibino 2019-12-30 09:22:25 -08:00
ade97befbc Minor cleanup Ken Hibino 2019-12-30 07:10:13 -08:00
22b21df884 Allow user to specify retry delay duration Ken Hibino 2019-12-29 17:43:19 -08:00
9af14d9a6d Add Config type to configure background processing behavior Ken Hibino 2019-12-29 16:55:51 -08:00
fc71857c7c Change NewBackground API to take *redis.Client Ken Hibino 2019-12-29 14:50:46 -08:00
62624cb0d8 Change NewClient API to take *redis.Client Ken Hibino 2019-12-29 13:42:49 -08:00
ae0c2f9ca5 Use asynqtest helpers in asynq package tests Ken Hibino 2019-12-29 09:41:00 -08:00
807729d36a Create internal asynqtest package for test helpers Ken Hibino 2019-12-28 20:12:14 -08:00
fef5ae6d3f Rename poller to scheduler Ken Hibino 2019-12-28 13:33:24 -08:00