2019-02-19 17:39:39 +03:00
// Copyright 2019 The Gitea Authors. All rights reserved.
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.
package setting
import (
"path"
"path/filepath"
)
// enumerates all the indexer queue types
const (
LevelQueueType = "levelqueue"
ChannelQueueType = "channel"
2019-04-08 12:05:15 +03:00
RedisQueueType = "redis"
2019-02-19 17:39:39 +03:00
)
var (
// Indexer settings
Indexer = struct {
2019-04-08 12:05:15 +03:00
IssueType string
IssuePath string
RepoIndexerEnabled bool
RepoPath string
UpdateQueueLength int
MaxIndexerFileSize int64
IssueQueueType string
IssueQueueDir string
IssueQueueConnStr string
IssueQueueBatchNumber int
2019-02-19 17:39:39 +03:00
} {
2019-04-08 12:05:15 +03:00
IssueType : "bleve" ,
IssuePath : "indexers/issues.bleve" ,
IssueQueueType : LevelQueueType ,
IssueQueueDir : "indexers/issues.queue" ,
IssueQueueConnStr : "" ,
IssueQueueBatchNumber : 20 ,
2019-02-19 17:39:39 +03:00
}
)
func newIndexerService ( ) {
sec := Cfg . Section ( "indexer" )
2019-02-21 08:01:28 +03:00
Indexer . IssueType = sec . Key ( "ISSUE_INDEXER_TYPE" ) . MustString ( "bleve" )
2019-02-19 17:39:39 +03:00
Indexer . IssuePath = sec . Key ( "ISSUE_INDEXER_PATH" ) . MustString ( path . Join ( AppDataPath , "indexers/issues.bleve" ) )
if ! filepath . IsAbs ( Indexer . IssuePath ) {
Indexer . IssuePath = path . Join ( AppWorkPath , Indexer . IssuePath )
}
Indexer . RepoIndexerEnabled = sec . Key ( "REPO_INDEXER_ENABLED" ) . MustBool ( false )
Indexer . RepoPath = sec . Key ( "REPO_INDEXER_PATH" ) . MustString ( path . Join ( AppDataPath , "indexers/repos.bleve" ) )
if ! filepath . IsAbs ( Indexer . RepoPath ) {
Indexer . RepoPath = path . Join ( AppWorkPath , Indexer . RepoPath )
}
Indexer . UpdateQueueLength = sec . Key ( "UPDATE_BUFFER_LEN" ) . MustInt ( 20 )
Indexer . MaxIndexerFileSize = sec . Key ( "MAX_FILE_SIZE" ) . MustInt64 ( 1024 * 1024 )
2019-04-08 12:05:15 +03:00
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 )
2019-02-19 17:39:39 +03:00
}