asynq

go-pkg/asynq

Fork 0

mirror of https://github.com/hibiken/asynq.git synced 2025-04-22 08:40:22 +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

9eac55c922 Misc cleanup Ken Hibino 2021-05-19 16:39:02 -07:00
cb35603119 Update WorkerInfo and remove unnecessary types Ken Hibino 2021-05-19 16:23:38 -07:00
87e82dd665 Update Inspector.List*Task methods to return ErrQueueNotFound Ken Hibino 2021-05-19 05:59:30 -07:00
bab489a2a1 Update Inspector.ListArchivedTasks Ken Hibino 2021-05-18 21:06:53 -07:00
c28b40daef Add LastFailedAt to TaskInfo Ken Hibino 2021-05-18 21:03:04 -07:00
95bd979c06 Record last_failed_at time on Retry or Archive event Ken Hibino 2021-05-18 21:00:53 -07:00
776a495f25 Add LastFailedAt field to TaskMessage Ken Hibino 2021-05-18 20:50:00 -07:00
77e8eef1f1 Update List methods (expect for ListArchived) Ken Hibino 2021-05-18 19:13:52 -07:00
043088b379 Move inspeq package content to asynq package Ken Hibino 2021-05-18 18:45:15 -07:00
6bfe641a2e Replace ArchiveTaskByKey with ArchiveTask in Inspector Ken Hibino 2021-05-18 16:27:16 -07:00
5a7a38d2f1 Replace DeleteTaskByKey with DeleteTask in Inspector Ken Hibino 2021-05-17 16:37:30 -07:00
976d39676e Replace RunTaskByKey with RunTask in Inspector Ken Hibino 2021-05-16 07:32:47 -07:00
7eee841d63 Update Client.Enqueue to return TaskInfo Ken Hibino 2021-05-15 06:43:18 -07:00
7ee8bbb5e4 Define TaskInfo type Ken Hibino 2021-05-13 19:41:17 -07:00
f0aefb0430 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
45b2ed2e80 Fix error in readme Ken Hibino 2021-06-14 12:31:09 -07:00
a79a82dcd9 Fix CLI build Ken Hibino 2021-06-14 12:20:44 -07:00
dc3eaa66ad Change TaskInfo to use public fields instead of methods Ken Hibino 2021-06-14 07:31:39 -07:00
832bcb3785 Fix lua script for redis-cluster mode Ken Hibino 2021-06-13 15:03:46 -07:00
48256265af Use md5 to generate checksum for unique key Ken Hibino 2021-06-09 06:46:21 -07:00
3557ce780d (fix): Clear unique lock when task is deleted via Inspector Ken Hibino 2021-06-09 06:06:43 -07:00
31d6ec31c1 Minor typos fixed Aurken Bilbao 2021-06-08 17:53:45 +02:00
04ad1ddbc3 Fix recoverer test Ken Hibino 2021-06-03 06:58:07 -07:00
e3b293193a Update ProcessorRetry test Ken Hibino 2021-06-03 06:33:21 -07:00
5b58444821 Format payload bytes in CLI output Ken Hibino 2021-06-02 06:37:46 -07:00
bf5e6b2190 Rename cli subcommand to not to use dash Ken Hibino 2021-05-24 16:14:36 -07:00
25e6360e14 Add task inspect command Ken Hibino 2021-05-24 16:14:20 -07:00
44d15e46bf Add String method to TaskState Ken Hibino 2021-05-24 16:11:02 -07:00
e1a33c6b5e Minor fix in queue command Ken Hibino 2021-05-23 20:46:22 -07:00
2e57764dff Fix asynq CLI build Ken Hibino 2021-05-23 11:19:29 -07:00
28cd7d3633 Add Inspector.GetTaskInfo Ken Hibino 2021-05-22 18:30:44 -07:00
f834edbc66 Fix lua scripts for redis cluster Ken Hibino 2021-05-22 17:46:23 -07:00
802ee2665c Define RDB.GetTaskInfo Ken Hibino 2021-05-22 13:03:12 -07:00
8ae62c4e1d Rename Inspector.CurrentStats to GetQueueInfo Ken Hibino 2021-05-22 12:13:19 -07:00
2e719fd7ba Rename Inspector.CancelActiveTask to CancelProcessing Ken Hibino 2021-05-20 16:59:43 -07:00
afb18225bc Make NodeCluster fields read-only Ken Hibino 2021-05-19 16:48:38 -07:00
88ea30e23f Misc cleanup Ken Hibino 2021-05-19 16:39:02 -07:00
3a14f43179 Update WorkerInfo and remove unnecessary types Ken Hibino 2021-05-19 16:23:38 -07:00
ffa59f75a0 Update Inspector.List*Task methods to return ErrQueueNotFound Ken Hibino 2021-05-19 05:59:30 -07:00
2046d7edc4 Update Inspector.ListArchivedTasks Ken Hibino 2021-05-18 21:06:53 -07:00
ffa1c92aa9 Add LastFailedAt to TaskInfo Ken Hibino 2021-05-18 21:03:04 -07:00
704fc5753b Record last_failed_at time on Retry or Archive event Ken Hibino 2021-05-18 21:00:53 -07:00
4e24bb50c7 Add LastFailedAt field to TaskMessage Ken Hibino 2021-05-18 20:50:00 -07:00
ad1abe5f8c Update List methods (expect for ListArchived) Ken Hibino 2021-05-18 19:13:52 -07:00
ca047c474d Move inspeq package content to asynq package Ken Hibino 2021-05-18 18:45:15 -07:00
a8a636ec4a Replace ArchiveTaskByKey with ArchiveTask in Inspector Ken Hibino 2021-05-18 16:27:16 -07:00
95f8b1f4ee Replace DeleteTaskByKey with DeleteTask in Inspector Ken Hibino 2021-05-17 16:37:30 -07:00
55a8ef036e Replace RunTaskByKey with RunTask in Inspector Ken Hibino 2021-05-16 07:32:47 -07:00
c2998b7f57 Update Client.Enqueue to return TaskInfo Ken Hibino 2021-05-15 06:43:18 -07:00
2b064aa6a7 Define TaskInfo type Ken Hibino 2021-05-13 19:41:17 -07:00
5e89a2c2e8 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
30723edcaf Add TaskState type to base package Ken Hibino 2021-05-11 20:43:01 -07:00
9e5f39fa3a Fix build Ken Hibino 2021-05-10 21:19:57 -07:00
252af60672 Update RDB methods with new errors package Ken Hibino 2021-05-10 09:16:13 -07:00
f0964038c0 Update RDB.Dequeue with new errors package Ken Hibino 2021-05-10 06:04:42 -07:00
5a661fcf05 Minor fixes Ken Hibino 2021-05-09 19:20:54 -07:00
7948cb5dbf Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors Ken Hibino 2021-05-09 07:39:01 -07:00
59ba0525a0 Add errors.RedisCommandError type Ken Hibino 2021-05-09 07:15:09 -07:00
6ccb0ab5c4 Update RDB.CurrentStats and RDB.HistoricalStats with specific errors Ken Hibino 2021-05-09 07:05:10 -07:00
3db8eff01b Update RDB.RemoveQueue with specific error types Ken Hibino 2021-05-09 06:48:44 -07:00
95a6942b4e Update rdb.List* methods with specific errors Ken Hibino 2021-05-08 11:45:30 -07:00
ba30b8b940 Return QueueNotFoundError from DeleteAll* methods Ken Hibino 2021-05-07 16:48:36 -07:00
bfd7dd57d2 Update RDB.RunAll* methods with task state Ken Hibino 2021-05-07 16:31:07 -07:00
2a30fcb6ea Return QueueNotFoundError from ArchiveAll* methods Ken Hibino 2021-05-07 16:06:07 -07:00
b440702039 Update tests for RDB.DeleteTask and RDB.ArchiveTask Ken Hibino 2021-05-07 06:26:16 -07:00
b6aa10e4ff Update RDB.RunTask with more specific errors Ken Hibino 2021-05-05 16:31:07 -07:00
213f5326e1 Update RDB.DeleteTask with task state Ken Hibino 2021-05-05 16:00:40 -07:00
020c09ce18 Update RDB.ArchiveAll methods with task state Ken Hibino 2021-05-03 20:07:00 -07:00
cf98807307 Update RDB.ArchiveAllPendingTasks with task state Ken Hibino 2021-05-03 16:38:13 -07:00
b0b1ece480 Reorganize test for RDB.ArchiveTask Ken Hibino 2021-05-03 15:48:21 -07:00
8a5d5a4332 Update errors package with detailed comments Ken Hibino 2021-05-02 06:58:54 -07:00
25173cd505 Update RDB.ArchiveTask with custom errors Ken Hibino 2021-05-02 06:47:32 -07:00
4693ffec05 Create internal errors package Ken Hibino 2021-05-02 06:46:48 -07:00
3fbf3dab76 Update rdb.ArchiveTask with more specific error types Ken Hibino 2021-05-01 16:13:40 -07:00
4d2ff9e375 Rename error types Ken Hibino 2021-05-01 06:47:49 -07:00
d45fc45b01 Add a list of canonical errors in base package Ken Hibino 2021-05-01 06:38:33 -07:00
2a509ecd4f Update RDB.ArchiveTask with task state Ken Hibino 2021-04-28 21:24:42 -07:00
69aa071632 Update RDB.RunTask with task state Ken Hibino 2021-04-28 07:27:35 -07:00
4f7f7e91de Update RDB.Requeue with task state Ken Hibino 2021-04-26 07:13:48 -07:00
08e6dc08d5 Update RDB.Retry, RDB.Archive with task state Ken Hibino 2021-04-26 07:10:29 -07:00
a5a28a0a40 Update RDB.Dequeue with task state Ken Hibino 2021-04-26 07:07:12 -07:00
a647cd7225 Update RDB.ForwardIfReady with task state Ken Hibino 2021-04-26 06:58:33 -07:00
df4e5c8d45 Update RDB.ScheduleUnique with task state Ken Hibino 2021-04-24 20:41:44 -07:00
eb40c8a2b4 Update RDB.Schedule with task state Ken Hibino 2021-04-24 06:44:44 -07:00
691bc7db81 Update RDB.EnqueueUnique with task state Ken Hibino 2021-04-19 06:28:58 -07:00
bf512f4ec2 Update RDB.Enqueue with task state Ken Hibino 2021-04-18 07:19:19 -07:00
d6e7e0df05 Change Server API Ken Hibino 2021-03-23 06:20:54 -07:00
585e7fdd53 Change payload to byte slice Ken Hibino 2021-03-20 13:42:13 -07:00
5f61566284 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
2516c4baba v0.17.2 v0.17.2 Ken Hibino 2021-06-06 06:51:30 -07:00
ebe482a65c Free uniqueness lock when task is deleted Ken Hibino 2021-06-06 06:35:36 -07:00
7f716abcf2 Free uniqueness lock when task is deleted Ken Hibino 2021-06-06 06:35:36 -07:00
4ecbc7064e Add TaskState type to base package Ken Hibino 2021-05-11 20:43:01 -07:00
bb83551581 Fix build Ken Hibino 2021-05-10 21:19:57 -07:00
1981ac3279 Update RDB methods with new errors package Ken Hibino 2021-05-10 09:16:13 -07:00
9e056b7c96 Update RDB.Dequeue with new errors package Ken Hibino 2021-05-10 06:04:42 -07:00
793c0129a9 Minor fixes Ken Hibino 2021-05-09 19:20:54 -07:00
e3455b633c Update RDB.EnqueueUnique and RDB.ScheduleUnique with specific errors Ken Hibino 2021-05-09 07:39:01 -07:00
8bec07ef51 Add errors.RedisCommandError type Ken Hibino 2021-05-09 07:15:09 -07:00
c6a47f8797 Update RDB.CurrentStats and RDB.HistoricalStats with specific errors Ken Hibino 2021-05-09 07:05:10 -07:00