Commit Graph

Select branches

Hide Pull Requests

dependabot/go_modules/github.com/spf13/cast-1.7.1

dependabot/go_modules/golang.org/x/sys-0.28.0

dependabot/go_modules/google.golang.org/protobuf-1.36.1

dependabot/go_modules/tools/github.com/gdamore/tcell/v2-2.7.4

dependabot/go_modules/tools/github.com/hibiken/asynq-0.25.1

dependabot/go_modules/tools/github.com/prometheus/client_golang-1.20.5

dependabot/go_modules/tools/github.com/spf13/cobra-1.8.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

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

#101

#102

#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

#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

#940

#941

#942

#944

#945

#946

#947

#948

#95

#950

#953

#954

#955

#956

#957

#958

#96

#962

#963

#964

#965

#966

#969

#969

#97

#970

#971

#972

#973

#973

#976

#976

#977

#978

#978

#980

#982

#984

#984

#988

#988

#989

#989

#99

#990

#991

#991

#992

#992

#995

#995

#996

#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

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