2016-05-13 15:43:17 +02:00
|
|
|
package config
|
|
|
|
|
|
|
|
import (
|
|
|
|
"os"
|
|
|
|
"strconv"
|
2016-05-16 07:57:30 +02:00
|
|
|
|
|
|
|
"github.com/vmware/harbor/utils/log"
|
2016-05-13 15:43:17 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
const defaultMaxWorkers int = 10
|
|
|
|
|
|
|
|
var maxJobWorkers int
|
|
|
|
var localRegURL string
|
|
|
|
|
|
|
|
func init() {
|
|
|
|
maxWorkersEnv := os.Getenv("MAX_JOB_WORKERS")
|
|
|
|
maxWorkers64, err := strconv.ParseInt(maxWorkersEnv, 10, 32)
|
|
|
|
maxJobWorkers = int(maxWorkers64)
|
|
|
|
if err != nil {
|
|
|
|
log.Warningf("Failed to parse max works setting, error: %v, the default value: %d will be used", err, defaultMaxWorkers)
|
|
|
|
maxJobWorkers = defaultMaxWorkers
|
|
|
|
}
|
|
|
|
|
2016-05-16 07:57:30 +02:00
|
|
|
localRegURL = os.Getenv("LOCAL_REGISTRY_URL")
|
2016-05-13 15:43:17 +02:00
|
|
|
if len(localRegURL) == 0 {
|
|
|
|
localRegURL = "http://registry:5000/"
|
|
|
|
}
|
|
|
|
|
|
|
|
log.Debugf("config: maxJobWorkers: %d", maxJobWorkers)
|
|
|
|
log.Debugf("config: localRegURL: %s", localRegURL)
|
|
|
|
}
|
|
|
|
|
|
|
|
func MaxJobWorkers() int {
|
|
|
|
return maxJobWorkers
|
|
|
|
}
|
|
|
|
|
|
|
|
func LocalRegURL() string {
|
|
|
|
return localRegURL
|
|
|
|
}
|