diff options
Diffstat (limited to 'cmd/moncheck')
| -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{} |