aboutsummaryrefslogtreecommitdiff
path: root/cmd/moncheck/main.go
diff options
context:
space:
mode:
authorGibheer <gibheer+git@zero-knowledge.org>2019-01-07 15:50:55 +0100
committerGibheer <gibheer+git@zero-knowledge.org>2019-01-07 15:50:55 +0100
commit3b222e06ed63050cb99020d9d74ca0f1e52959d2 (patch)
tree694fe5ba416682cceed76652d7534e746fc0e926 /cmd/moncheck/main.go
parent9ea6b0f3436651b2963572e719f534da96f48098 (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.go5
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{}