asynq

go-pkg/asynq

Fork 0

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

c2592e758e Update RDB.RemoveQueue with specific error types Ken Hibino 2021-05-09 06:48:44 -07:00
cfe0d673c9 Update rdb.List* methods with specific errors Ken Hibino 2021-05-08 11:45:30 -07:00
1c9bda3b2e Return QueueNotFoundError from DeleteAll* methods Ken Hibino 2021-05-07 16:48:36 -07:00
6b64feed38 Update RDB.RunAll* methods with task state Ken Hibino 2021-05-07 16:31:07 -07:00
8e16c426e8 Return QueueNotFoundError from ArchiveAll* methods Ken Hibino 2021-05-07 16:06:07 -07:00
e861e534bc Update tests for RDB.DeleteTask and RDB.ArchiveTask Ken Hibino 2021-05-07 06:26:16 -07:00
b42a29cb8d Update RDB.RunTask with more specific errors Ken Hibino 2021-05-05 16:31:07 -07:00
59a953eabe Update RDB.DeleteTask with task state Ken Hibino 2021-05-05 16:00:40 -07:00
2e7b6876b1 Update RDB.ArchiveAll methods with task state Ken Hibino 2021-05-03 20:07:00 -07:00
df0c635448 Update RDB.ArchiveAllPendingTasks with task state Ken Hibino 2021-05-03 16:38:13 -07:00
bf1e3c7505 Reorganize test for RDB.ArchiveTask Ken Hibino 2021-05-03 15:48:21 -07:00
31da4dd6eb Update errors package with detailed comments Ken Hibino 2021-05-02 06:58:54 -07:00
26a1a2f861 Update RDB.ArchiveTask with custom errors Ken Hibino 2021-05-02 06:47:32 -07:00
c0c7031ae6 Create internal errors package Ken Hibino 2021-05-02 06:46:48 -07:00
8c402e104a Update rdb.ArchiveTask with more specific error types Ken Hibino 2021-05-01 16:13:40 -07:00
aa2ddaf27d Rename error types Ken Hibino 2021-05-01 06:47:49 -07:00
88608e770b Add a list of canonical errors in base package Ken Hibino 2021-05-01 06:38:33 -07:00
29210e143c Update RDB.ArchiveTask with task state Ken Hibino 2021-04-28 21:24:42 -07:00
3e9fc2f972

Update README Vic Shóstak 2021-04-28 20:25:34 +03:00
011669a3e8 Update RDB.RunTask with task state Ken Hibino 2021-04-28 07:27:35 -07:00
2dd69b7fb3

Update README with a new gopher icon Vic Shóstak 2021-04-28 09:46:26 +03:00
b8cd3e307d Update RDB.Requeue with task state Ken Hibino 2021-04-26 07:13:48 -07:00
568c77e497 Update RDB.Retry, RDB.Archive with task state Ken Hibino 2021-04-26 07:10:29 -07:00
305e979af5 Update RDB.Dequeue with task state Ken Hibino 2021-04-26 07:07:12 -07:00
2f9cd9c758 Update RDB.ForwardIfReady with task state Ken Hibino 2021-04-26 06:58:33 -07:00
e4dd39d814 Update RDB.ScheduleUnique with task state Ken Hibino 2021-04-24 20:41:44 -07:00
2a1fbf6fa5 Update RDB.Schedule with task state Ken Hibino 2021-04-24 06:44:44 -07:00
f7954c2683 Update RDB.EnqueueUnique with task state Ken Hibino 2021-04-19 06:28:58 -07:00
a352ee2fa2 Update RDB.Enqueue with task state Ken Hibino 2021-04-18 07:19:19 -07:00
449766ba32 Fix ArchiveTask Ken Hibino 2021-04-05 20:57:24 -07:00
6dce3f156e WIP Ken Hibino 2021-04-04 14:53:12 -07:00
978c608124 Fix merge conflicts Ken Hibino 2021-04-04 14:09:14 -07:00
7ba05e6a78 Update WorkerInfo type Ken Hibino 2021-04-04 12:47:38 -07:00
c02409c974 Update Inspector to return TaskInfo from list methods Ken Hibino 2021-04-02 07:01:06 -07:00
5c6068c78b Update RDB.ListScheduled, ListRetry, and ListArchived to return list of TaskInfo Ken Hibino 2021-04-01 16:55:57 -07:00
f0c12cc6e3 Update RDB.ListPending and RDB.ListActive to return list of TaskInfo Ken Hibino 2021-04-01 16:11:56 -07:00
57fc8b86e2 Add GetTaskInfo method to Inspector Ken Hibino 2021-03-31 07:19:32 -07:00
da823fb26a Remove task key related code Ken Hibino 2021-03-31 06:52:10 -07:00
3f0bc6d738 Add GetTaskInfo method to RDB Ken Hibino 2021-03-31 06:44:56 -07:00
56af9f6686 Run task by qname and id Ken Hibino 2021-03-28 06:58:54 -07:00
4bb67c582d WIP: Archive task by qname and id Ken Hibino 2021-03-26 11:47:07 -07:00
9bc80c6216 Allow task deletion by queue name and task ID Ken Hibino 2021-03-26 10:43:10 -07:00
6d35d46461 Fix build Ken Hibino 2021-03-25 06:32:35 -07:00
e9636c7c19 WIP: Track task state under task key Ken Hibino 2021-03-23 16:39:15 -07:00
24e3d2e273 Change Client.Enqueue to return taskID Ken Hibino 2021-03-23 07:19:09 -07:00
12ed810cfc Define TaskInfo and TaskState Ken Hibino 2021-03-23 07:03:36 -07:00
d9481bd524 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
fdae82762c Change payload to byte slice Ken Hibino 2021-03-20 13:42:13 -07:00
353fc44419 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
dd25028027 Change Server API Ken Hibino 2021-03-23 06:20:54 -07:00
dc275c4612 Change payload to byte slice Ken Hibino 2021-03-20 13:42:13 -07:00
a0b52806c9 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
63ce9ed0f9

Update README with a new logo Vic Shóstak 2021-04-14 20:21:47 +03:00
2369f747a7

Update README.md Vic Shóstak 2021-04-14 19:18:38 +03:00
287d14ee9a

Update README.md Vic Shóstak 2021-04-14 19:14:59 +03:00
69fac4c944

Update README.md Vic Shóstak 2021-04-14 13:59:22 +03:00
96476c8e55

Update README.md Vic Shóstak 2021-04-14 13:56:52 +03:00
cb696d2fa4

Update README.md Vic Shóstak 2021-04-14 13:52:46 +03:00
1ebdba5aec

Update README.md Vic Shóstak 2021-04-14 13:51:32 +03:00
38bec36b1c

Update README.md Vic Shóstak 2021-04-14 13:49:11 +03:00
7acb9058e9

Update README.md Vic Shóstak 2021-04-14 13:42:21 +03:00
4312e4fca1

Update README.md Vic Shóstak 2021-04-14 13:28:33 +03:00
32d3f329b9 v0.17.1 v0.17.1 Ken Hibino 2021-04-04 12:51:00 -07:00
544c301a8b Fix bug in RDB.memoryUsage Ken Hibino 2021-04-04 12:49:19 -07:00
8b997d2fab v0.17.0 v0.17.0 Ken Hibino 2021-03-24 16:51:59 -07:00
901105a8d7 Add dial, read, write timeout options to RedisConnOpt Ken Hibino 2021-03-24 16:44:33 -07:00
3cb2b54e78 Add dial, read, write timeout options to RedisConnOpt Ken Hibino 2021-03-24 16:44:33 -07:00
803242945d Update changelog Ken Hibino 2021-03-22 07:28:18 -07:00
55f7267e17 Update Scheduler API to match Server API Ken Hibino 2021-03-22 06:46:41 -07:00
056d787935 Rename terminate to shutdown internally Ken Hibino 2021-03-21 07:16:09 -07:00
105084d6fb Rename ServerStatus to ServerState internally Ken Hibino 2021-03-21 06:33:01 -07:00
5af86a0903 Change Server API Ken Hibino 2021-03-20 17:16:44 -07:00
af6d9d3df7

Change payload to byte slice Ken Hibino 2021-03-20 13:42:13 -07:00
6171a6400d Fix build Ken Hibino 2021-03-20 06:54:00 -07:00
4c53446c10 Update package doc and readme Ken Hibino 2021-03-18 21:43:10 -07:00
b3b50d26a2 Update test to match the new API Ken Hibino 2021-03-17 09:07:43 -07:00
848a03dc16 Change task payload type to byte slice Ken Hibino 2021-03-17 06:41:40 -07:00
f3c848f25f Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
e425cf0fb1 Refactor redis keys and store messages in protobuf Ken Hibino 2021-03-12 16:23:08 -08:00
aaa3f1d4fd v0.16.1 v0.16.1 Ken Hibino 2021-03-20 06:27:03 -07:00
4722ca2d3d Replaced blocking KEYS XXX:* command to non-blocking SCAN XXX:* More details: https://redis.io/commands/KEYS disc 2021-03-20 11:56:17 +02:00
ed582000ad Replaced blocking KEYS XXX:* command to non-blocking SCAN XXX:* More details: https://redis.io/commands/KEYS disc 2021-03-20 11:56:17 +02:00
a396a2c43c Clean up asynqtest package Ken Hibino 2021-03-12 06:47:56 -08:00
c4de2cfbe9

Serialize structs in protobuf Ken Hibino 2021-03-11 19:07:58 -08:00
d95f487bef Simplify ListWorkers implementation Ken Hibino 2021-03-11 06:41:18 -08:00
ea456741b6 fix build Ken Hibino 2021-03-11 06:33:47 -08:00
3c7327e182 Add nil check for message encoding helpers Ken Hibino 2021-03-09 07:08:27 -08:00
e136e26b7e Add comments to proto definitions Ken Hibino 2021-03-09 06:39:01 -08:00
499d35c0fc Store SchedulerEntry and SchedulerEnqueueEvent in protobuf format Ken Hibino 2021-03-04 07:04:40 -08:00
2dc100bc43 Store ServerState in protobuf format Ken Hibino 2021-03-03 08:53:27 -08:00
9ac0475d4b Update base.DecodeMessage to take byte slice Ken Hibino 2021-03-02 22:14:55 -08:00
e408550d76 Update base.EncodeMessage to return byte slice Ken Hibino 2021-03-02 21:57:34 -08:00
4046932fde Use protobuf to encode task message Ken Hibino 2021-03-01 21:33:36 -08:00
47543b36fd Define TaskMessage in protobuf Ken Hibino 2021-03-01 21:09:45 -08:00
02a7c13014 Update RDB.Dequeue Ken Hibino 2021-02-24 11:22:05 -08:00
4c2c98db78 Fix build Ken Hibino 2021-03-08 06:14:50 -08:00
7d516e37e6 Fix inspeq package build Ken Hibino 2021-02-28 16:00:23 -08:00
6df8c9bed1 Remove debug log Ken Hibino 2021-02-28 15:20:09 -08:00
f434f62369 Update RDB.RemoveQueue Ken Hibino 2021-02-28 06:48:21 -08:00
de226f3654 Update RDB.DeleteAll methods Ken Hibino 2021-02-27 22:24:15 -08:00