Skip to content

Commit

Permalink
added env var for worker sleep time;
Browse files Browse the repository at this point in the history
  • Loading branch information
jacekk committed Aug 17, 2019
1 parent 2af4597 commit e0b09be
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 1 deletion.
1 change: 1 addition & 0 deletions dist.env
Original file line number Diff line number Diff line change
Expand Up @@ -2,3 +2,4 @@ ALLOW_ORIGINS=*
GIN_MODE=release # change to `debug` on local
PROXY_CONFIG_PATH=./storage/proxy-config.dist.json
SERVER_PORT=8080
WORKER_SLEEP_SECONDS=600
13 changes: 12 additions & 1 deletion pkg/worker/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,14 @@ import (
"fmt"
"math/rand"
"os"
"strconv"
"time"

"github.com/pkg/errors"
)

const loggerPrefix = "[WORKER]"
const sleepVarName = "WORKER_SLEEP_SECONDS"

var random *rand.Rand

Expand All @@ -27,9 +31,16 @@ func InitWorker() error {
workerErr := make(chan error)
defer close(workerErr)

sleepTime, err := strconv.Atoi(os.Getenv(sleepVarName))
if err != nil {
return errors.Wrapf(err, "failed to parsed '%s' ", sleepVarName)
}

info("Will run every %d seconds", sleepTime)

go func() {
for {
time.Sleep(time.Second * 5)
time.Sleep(time.Second * time.Duration(sleepTime))
randomNumber := random.Intn(100)
if randomNumber > 90 {
workerErr <- fmt.Errorf("random number is '%d' so above 90", randomNumber)
Expand Down

0 comments on commit e0b09be

Please sign in to comment.