Merge pull request #999 from moonstream-to/nb-healthcheck-interfal-env

Env for healthcheck interval for nb

nodebalancer/cmd/nodebalancer/configs.go

@@ -38,7 +38,7 @@ var (
 
 	NB_CONNECTION_RETRIES          = 2
 	NB_CONNECTION_RETRIES_INTERVAL = time.Millisecond * 10
-	NB_HEALTH_CHECK_INTERVAL       = time.Millisecond * 5000
+	NB_HEALTH_CHECK_INTERVAL       = os.Getenv("NB_HEALTH_CHECK_INTERVAL")
 	NB_HEALTH_CHECK_CALL_TIMEOUT   = time.Second * 2
 
 	NB_CACHE_CLEANING_INTERVAL          = time.Second * 10

nodebalancer/cmd/nodebalancer/server.go

@@ -12,6 +12,7 @@ import (
 	"net/http/httputil"
 	"net/url"
 	"os"
+	"strconv"
 	"strings"
 	"time"
 
@@ -28,7 +29,11 @@ var (
 
 // initHealthCheck runs a routine for check status of the nodes every 5 seconds
 func initHealthCheck(debug bool) {
-	t := time.NewTicker(NB_HEALTH_CHECK_INTERVAL)
+	healthCheckInterval, convErr := strconv.Atoi(NB_HEALTH_CHECK_INTERVAL)
+	if convErr != nil {
+		healthCheckInterval = 5
+	}
+	t := time.NewTicker(time.Second * time.Duration(healthCheckInterval))
 	for {
 		select {
 		case <-t.C: