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

Mono Color

• 985018e1b5 Rename rdb Remove to Done Ken Hibino 2019-12-04 06:33:05 -08:00
• 39f177dabf Change rdb Dequeue signature Ken Hibino 2019-12-04 06:25:58 -08:00
• d4e442d04f Extract rdb to internal package Ken Hibino 2019-12-03 21:01:26 -08:00
• 593f2b0482 Add command "asynqmon" for monitoring Ken Hibino 2019-12-03 20:02:29 -08:00
• 319d157d47 Change inspector's list methods to return specific task type for each queue Ken Hibino 2019-12-02 07:09:43 -08:00
• 28dae0fdd3 Add task types specific to each queue Ken Hibino 2019-12-02 06:55:04 -08:00
• 5446f877ce Add List* methods to Inspector Ken Hibino 2019-12-01 15:01:26 -08:00
• 9c2d2a612d Create Inspector Ken Hibino 2019-12-01 07:59:52 -08:00
• 57838600ef Rename to RedisConfig Ken Hibino 2019-12-03 19:43:01 -08:00
• 4afb3a2401
  Merge pull request #5 from hibiken/api/handler Ken Hibino 2019-12-02 20:49:43 -08:00
• b0a54cd2b2 Change Background API to take Handler interface Ken Hibino 2019-12-02 20:42:21 -08:00
• 1a996e0d40 Update readme Ken Hibino 2019-12-01 19:03:31 -08:00
• 1a97d4ba98
  Add MIT License Ken Hibino 2019-11-30 10:21:25 -08:00
• b9cb95b1e1 Add readme Ken Hibino 2019-11-30 09:38:46 -08:00
• d31532c8f5 Add .travis.yml Ken Hibino 2019-11-30 07:36:43 -08:00
• 8eb6f04ef4 Move test helpers to asynq_test.go Ken Hibino 2019-11-29 20:53:29 -08:00
• ad1291e0a1 Add test for background to verify no goroutine leaks Ken Hibino 2019-11-29 20:49:18 -08:00
• 09662432c8 Update todos Ken Hibino 2019-11-29 20:16:39 -08:00
• 634af38e3a Add test for client Ken Hibino 2019-11-29 17:40:31 -08:00
• d53e5d3350 Add test for processor Ken Hibino 2019-11-29 12:48:54 -08:00
• eed375b138 Add test for poller Ken Hibino 2019-11-29 08:00:43 -08:00
• facdadd7b0 Change shutdown message to use info level logging Ken Hibino 2019-11-29 07:14:28 -08:00
• bdbee31b86 Add test for retry task logic Ken Hibino 2019-11-28 11:22:42 -08:00
• da0bfa1519 Add test for (*rdb).kill Ken Hibino 2019-11-28 07:47:12 -08:00
• 481d3c6b77 Refactor rdb tests Ken Hibino 2019-11-28 07:17:07 -08:00
• e5e3fee742 Add test for (*rdb).remove Ken Hibino 2019-11-28 06:50:05 -08:00
• 1617278d86 Rename (*rdb).lrem to (*rdb).remove Ken Hibino 2019-11-27 20:05:31 -08:00
• efaceb8a03 Clean up error messages from rdb methods Ken Hibino 2019-11-27 19:43:33 -08:00
• c9a8f5fabd Minor cleanup Ken Hibino 2019-11-27 19:36:56 -08:00
• 0db4b8a34f fix:Remove task from in_progress when worker goroutine finishes Ken Hibino 2019-11-27 14:26:04 -08:00
• 871162cd67
  Merge pull request #3 from hibiken/feature/recover Ken Hibino 2019-11-27 14:05:39 -08:00
• d4f136ebc9 Protect handler call against panic Ken Hibino 2019-11-27 14:03:04 -08:00
• 47e2a57d05 Rename (*rdb).zadd to (*rdb).schedule Ken Hibino 2019-11-27 07:16:16 -08:00
• fab2dcb56e Change newRDB signature Ken Hibino 2019-11-27 06:41:54 -08:00
• e6b1230c36 Update log messages on shutdown Ken Hibino 2019-11-27 06:33:04 -08:00
• 60132f3208 Minor cleanup Ken Hibino 2019-11-27 06:21:57 -08:00
• d35d345e2d
  Merge pull request #2 from hibiken/feature/lua Ken Hibino 2019-11-26 10:19:26 -08:00
• 97b96f6992 Use lua script to implement (*rdb).moveAll Ken Hibino 2019-11-26 10:09:42 -08:00
• 4fd82c5975 Refactor (*rdb).moveAll test Ken Hibino 2019-11-26 09:57:53 -08:00
• d2a6cc127d Use (*rdb).forward in poller Ken Hibino 2019-11-26 06:52:58 -08:00
• cff5e67018 Refactor (*rdb).forward test Ken Hibino 2019-11-26 06:38:11 -08:00
• 810c40bd54 Refactor dequeue test Ken Hibino 2019-11-25 20:57:53 -08:00
• 199dcf8fdb Use pipeline for enqueue Ken Hibino 2019-11-25 20:10:35 -08:00
• faa9b6ee22 Rename (*rdb).push to enqueue Ken Hibino 2019-11-25 19:58:24 -08:00
• 737de898eb Refactor rdb_test.go Ken Hibino 2019-11-25 18:55:17 -08:00
• 4aa5078dc4 Add (*rdb).forward method using lua script Ken Hibino 2019-11-25 07:09:39 -08:00
• f91004e6aa Add DB field to RedisOpt to specify redis db index Ken Hibino 2019-11-24 18:41:55 -08:00
• d5c2b9b995 Follow the convention of declaring variable immediately after its guard mutex Ken Hibino 2019-11-23 20:18:39 -08:00
• 5eaf606a0d fix: Nil out handler reference after all workers have finished Ken Hibino 2019-11-23 17:09:57 -08:00
• ac3190a0d5 Update comments Ken Hibino 2019-11-23 16:44:22 -08:00
• be3b774b51 Simplify Background API Ken Hibino 2019-11-23 15:44:42 -08:00
• e19c45cff3 Rename Launcher to Background Ken Hibino 2019-11-23 15:22:43 -08:00
• 847d724985
  Merge pull request #1 from hibiken/feature/simple_rescue Ken Hibino 2019-11-23 15:15:46 -08:00
• fd80126a67 Add logic to restore unfinished tasks back into the default queue if there are any uncompleted tasks Ken Hibino 2019-11-23 15:09:50 -08:00
• 4a327933bd Use command BRPUSHLPOP to move from queue to in_progress in redis Ken Hibino 2019-11-23 08:43:41 -08:00
• 76ceb282a9 Change the direction of list push/pop operations Ken Hibino 2019-11-23 08:24:16 -08:00
• 3fa867b190 Remove per task heartbeat Ken Hibino 2019-11-23 08:21:32 -08:00
• 2e0af11ca0 Add heartbeat goroutine to write heartbeat data to redis for active worker Ken Hibino 2019-11-22 06:43:42 -08:00
• 80f477212d Add ID field to taskMessage Ken Hibino 2019-11-22 06:16:43 -08:00
• 67a9e8aa00 Track in-progress tasks with redis SET Ken Hibino 2019-11-21 21:45:27 -08:00
• c84287d7ab Minor fixes Ken Hibino 2019-11-21 20:22:55 -08:00
• 66930970f9 Move retry related logic to its own file Ken Hibino 2019-11-20 20:38:49 -08:00
• 3dddcfbb14 Minor cleanup Ken Hibino 2019-11-20 20:27:01 -08:00
• 2dd5f2c5ab Rename manager to processor Ken Hibino 2019-11-20 20:08:03 -08:00
• dd0b0b358c Add tests for type rdb Ken Hibino 2019-11-20 07:01:24 -08:00
• e9069bfb47 Move client and launcher to its own files Ken Hibino 2019-11-19 21:19:46 -08:00
• 85a04cbabb Extract redis logic to type rdb Ken Hibino 2019-11-19 19:44:41 -08:00
• 4c5b6081de Update todo comments Ken Hibino 2019-11-19 07:47:21 -08:00
• eb6a5032f6 Make Launcher thread safe Ken Hibino 2019-11-19 07:46:04 -08:00
• e238d3835d Gracefully shutdown all scheduled goroutines on (*Launcher).Stop Ken Hibino 2019-11-19 07:38:09 -08:00
• 195fd893be Extract manager to its own type Ken Hibino 2019-11-19 06:48:54 -08:00
• 8d22d1f6fb Change (*poller).start to use time.Sleep instead of ticker Ken Hibino 2019-11-19 06:20:59 -08:00
• 89c54fb47d Rename Workers to Launcher Ken Hibino 2019-11-19 06:19:22 -08:00
• 4485b6e3a9 Extract polling logic to poller type Ken Hibino 2019-11-18 21:23:49 -08:00
• 3daef02632 Fix bug around releasing semaphore token Ken Hibino 2019-11-18 07:42:26 -08:00
• c6f482d4f8 Make Run method stateful Ken Hibino 2019-11-17 21:21:32 -08:00
• 62db9863fb Send retry exhausted tasks to "dead" zset Ken Hibino 2019-11-17 21:13:41 -08:00
• 6252cc02e0 Implement exponential backoff retry Ken Hibino 2019-11-17 18:44:40 -08:00
• 22e2a6f433 Add retry logic Ken Hibino 2019-11-17 15:36:33 -08:00
• e75756937e Change internal representation of task data written to redis Ken Hibino 2019-11-17 13:25:01 -08:00
• d2d0d1fde5 Change package APIs Ken Hibino 2019-11-16 14:45:51 -08:00
• f4d59bece7 Add support for multiple queues Ken Hibino 2019-11-16 08:20:23 -08:00
• 95023bd3b5 Extract a push logic to a function Ken Hibino 2019-11-16 07:51:53 -08:00
• bda718bcaa Refactor enqueue logic for scheduled tasks Ken Hibino 2019-11-16 07:39:42 -08:00
• e362e0daca Add workers Ken Hibino 2019-11-15 07:21:25 -08:00
• 6d65ebfb35 Initial commit Ken Hibino 2019-11-14 21:07:19 -08:00