26 lines
		
	
	
		
			663 B
		
	
	
	
		
			Go
		
	
	
	
			
		
		
	
	
			26 lines
		
	
	
		
			663 B
		
	
	
	
		
			Go
		
	
	
	
| // 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
 | |
| 
 | |
| var (
 | |
| 	// Task settings
 | |
| 	Task = struct {
 | |
| 		QueueType    string
 | |
| 		QueueLength  int
 | |
| 		QueueConnStr string
 | |
| 	}{
 | |
| 		QueueType:    ChannelQueueType,
 | |
| 		QueueLength:  1000,
 | |
| 		QueueConnStr: "addrs=127.0.0.1:6379 db=0",
 | |
| 	}
 | |
| )
 | |
| 
 | |
| func newTaskService() {
 | |
| 	sec := Cfg.Section("task")
 | |
| 	Task.QueueType = sec.Key("QUEUE_TYPE").MustString(ChannelQueueType)
 | |
| 	Task.QueueLength = sec.Key("QUEUE_LENGTH").MustInt(1000)
 | |
| 	Task.QueueConnStr = sec.Key("QUEUE_CONN_STR").MustString("addrs=127.0.0.1:6379 db=0")
 | |
| }
 |