Skip to content

Commit a4ad4af

Browse files
committed
add config for issue indexer type
1 parent e2fbf78 commit a4ad4af

File tree

2 files changed

+15
-7
lines changed

2 files changed

+15
-7
lines changed

models/issue_indexer.go

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,15 +21,21 @@ var (
2121

2222
// InitIssueIndexer initialize issue indexer
2323
func InitIssueIndexer() error {
24-
issueIndexer = issues.NewBleveIndexer(setting.Indexer.IssuePath)
25-
exist, err := issueIndexer.Init()
26-
if err != nil {
27-
return err
28-
}
29-
if !exist {
30-
go populateIssueIndexer()
24+
switch setting.Indexer.IssueType {
25+
case "bleve":
26+
issueIndexer = issues.NewBleveIndexer(setting.Indexer.IssuePath)
27+
exist, err := issueIndexer.Init()
28+
if err != nil {
29+
return err
30+
}
31+
if !exist {
32+
go populateIssueIndexer()
33+
}
34+
default:
35+
return fmt.Errorf("unknow issue indexer type: %s", setting.Indexer.IssueType)
3136
}
3237

38+
var err error
3339
switch setting.Indexer.IssueIndexerQueueType {
3440
case setting.LedisLocalQueueType:
3541
issueIndexerUpdateQueue, err = issues.NewLedisLocalQueue(

modules/setting/setting.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ var (
187187

188188
// Indexer settings
189189
Indexer = struct {
190+
IssueType string
190191
IssuePath string
191192
RepoIndexerEnabled bool
192193
RepoPath string
@@ -197,6 +198,7 @@ var (
197198
IssueIndexerQueueDBIndex int
198199
IssueIndexerQueueBatchNumber int
199200
}{
201+
IssueType: "bleve",
200202
IssuePath: "indexers/issues.bleve",
201203
IssueIndexerQueueType: LedisLocalQueueType,
202204
IssueIndexerQueueDir: "indexers/issues.queue",

0 commit comments

Comments
 (0)