diff --git a/nodebalancer/cmd/nodebalancer/configs.go b/nodebalancer/cmd/nodebalancer/configs.go index 49ffdd00..e606dc83 100644 --- a/nodebalancer/cmd/nodebalancer/configs.go +++ b/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 diff --git a/nodebalancer/cmd/nodebalancer/server.go b/nodebalancer/cmd/nodebalancer/server.go index 648fa3da..e1cbe155 100644 --- a/nodebalancer/cmd/nodebalancer/server.go +++ b/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: