From e7d7dcb0901b32bed90061e7bc8ae1d2e3c75654 Mon Sep 17 00:00:00 2001
From: Lunny Xiao <xiaolunwen@gmail.com>
Date: Mon, 8 Apr 2019 17:05:15 +0800
Subject: Issue indexer queue redis support (#6218)

* add redis queue

* finished indexer redis queue

* add redis vendor

* fix vet

* Update docs/content/doc/advanced/config-cheat-sheet.en-us.md

Co-Authored-By: lunny <xiaolunwen@gmail.com>

* switch to go mod

* Update required changes for new logging func signatures
---
 modules/setting/indexer.go | 38 +++++++++++++++++++++-----------------
 1 file changed, 21 insertions(+), 17 deletions(-)

(limited to 'modules/setting')

diff --git a/modules/setting/indexer.go b/modules/setting/indexer.go
index 0e09ed2b86..36fd4a020b 100644
--- a/modules/setting/indexer.go
+++ b/modules/setting/indexer.go
@@ -13,26 +13,29 @@ import (
 const (
 	LevelQueueType   = "levelqueue"
 	ChannelQueueType = "channel"
+	RedisQueueType   = "redis"
 )
 
 var (
 	// Indexer settings
 	Indexer = struct {
-		IssueType                    string
-		IssuePath                    string
-		RepoIndexerEnabled           bool
-		RepoPath                     string
-		UpdateQueueLength            int
-		MaxIndexerFileSize           int64
-		IssueIndexerQueueType        string
-		IssueIndexerQueueDir         string
-		IssueIndexerQueueBatchNumber int
+		IssueType             string
+		IssuePath             string
+		RepoIndexerEnabled    bool
+		RepoPath              string
+		UpdateQueueLength     int
+		MaxIndexerFileSize    int64
+		IssueQueueType        string
+		IssueQueueDir         string
+		IssueQueueConnStr     string
+		IssueQueueBatchNumber int
 	}{
-		IssueType:                    "bleve",
-		IssuePath:                    "indexers/issues.bleve",
-		IssueIndexerQueueType:        LevelQueueType,
-		IssueIndexerQueueDir:         "indexers/issues.queue",
-		IssueIndexerQueueBatchNumber: 20,
+		IssueType:             "bleve",
+		IssuePath:             "indexers/issues.bleve",
+		IssueQueueType:        LevelQueueType,
+		IssueQueueDir:         "indexers/issues.queue",
+		IssueQueueConnStr:     "",
+		IssueQueueBatchNumber: 20,
 	}
 )
 
@@ -50,7 +53,8 @@ func newIndexerService() {
 	}
 	Indexer.UpdateQueueLength = sec.Key("UPDATE_BUFFER_LEN").MustInt(20)
 	Indexer.MaxIndexerFileSize = sec.Key("MAX_FILE_SIZE").MustInt64(1024 * 1024)
-	Indexer.IssueIndexerQueueType = sec.Key("ISSUE_INDEXER_QUEUE_TYPE").MustString(LevelQueueType)
-	Indexer.IssueIndexerQueueDir = sec.Key("ISSUE_INDEXER_QUEUE_DIR").MustString(path.Join(AppDataPath, "indexers/issues.queue"))
-	Indexer.IssueIndexerQueueBatchNumber = sec.Key("ISSUE_INDEXER_QUEUE_BATCH_NUMBER").MustInt(20)
+	Indexer.IssueQueueType = sec.Key("ISSUE_INDEXER_QUEUE_TYPE").MustString(LevelQueueType)
+	Indexer.IssueQueueDir = sec.Key("ISSUE_INDEXER_QUEUE_DIR").MustString(path.Join(AppDataPath, "indexers/issues.queue"))
+	Indexer.IssueQueueConnStr = sec.Key("ISSUE_INDEXER_QUEUE_CONN_STR").MustString(path.Join(AppDataPath, ""))
+	Indexer.IssueQueueBatchNumber = sec.Key("ISSUE_INDEXER_QUEUE_BATCH_NUMBER").MustInt(20)
 }
-- 
cgit v1.2.3