diff options
author | Gibheer <gibheer+git@zero-knowledge.org> | 2019-01-07 15:50:55 +0100 |
---|---|---|
committer | Gibheer <gibheer+git@zero-knowledge.org> | 2019-01-07 15:50:55 +0100 |
commit | 3b222e06ed63050cb99020d9d74ca0f1e52959d2 (patch) | |
tree | 694fe5ba416682cceed76652d7534e746fc0e926 /cmd/moncheck/main.go | |
parent | 9ea6b0f3436651b2963572e719f534da96f48098 (diff) |
moncheck - make workers configurable
The default worker count was set to 25, which might be too much
depending on the amount of cores available. Now make the default 25 and
let people decide on how many they want to use.
Diffstat (limited to 'cmd/moncheck/main.go')
-rw-r--r-- | cmd/moncheck/main.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cmd/moncheck/main.go b/cmd/moncheck/main.go index 2c3ca27..28b177e 100644 --- a/cmd/moncheck/main.go +++ b/cmd/moncheck/main.go @@ -31,6 +31,7 @@ type ( Timeout string `json:"timeout"` Wait string `json:"wait"` Path []string `json:"path"` + Workers int `json:"workers"` } States []int @@ -43,7 +44,7 @@ func main() { if err != nil { log.Fatalf("could not read config: %s", err) } - config := Config{Timeout: "30s", Wait: "30s"} + config := Config{Timeout: "30s", Wait: "30s", Workers: 25} if err := json.Unmarshal(raw, &config); err != nil { log.Fatalf("could not parse config: %s", err) } @@ -66,7 +67,7 @@ func main() { log.Fatalf("could not open database connection: %s", err) } - for i := 0; i < 25; i++ { + for i := 0; i < config.Workers; i++ { go check(i, db, waitDuration, timeout) } wg := sync.WaitGroup{} |