added error support in worker - app exists on error;

cmd/main.go

@@ -40,25 +40,25 @@ func runApp() {
 			Aliases: []string{"w", "work"},
 			Usage:   "Runs worker",
 			Action: func(ctx *cli.Context) error {
-				return worker.Init()
+				return worker.InitWorker()
 			},
 		},
 		{
 			Name:  "all",
 			Usage: "Runs worker and server",
 			Action: func(ctx *cli.Context) error {
 				var wg sync.WaitGroup
-				wg.Add(2)
 
 				go func() {
 					defer wg.Done()
 					log.Fatal(routing.InitRouter())
 				}()
 				go func() {
 					defer wg.Done()
-					log.Fatal(worker.Init())
+					log.Fatal(worker.InitWorker())
 				}()
 
+				wg.Add(2)
 				wg.Wait()
 
 				return nil

pkg/worker/main.go

@@ -1,32 +1,43 @@
 package worker
 
 import (
-	"bufio"
 	"fmt"
+	"math/rand"
 	"os"
 	"time"
 )
 
-const prefix = "[WORKER]"
+const loggerPrefix = "[WORKER]"
 
-func info(format string, args ...interface{}) {
-	prefixedFormat := fmt.Sprintf("%s %s \n", prefix, format)
-	fmt.Fprintf(os.Stdout, prefixedFormat, args...)
+var random *rand.Rand
+
+func init() {
+	s1 := rand.NewSource(time.Now().UnixNano())
+	random = rand.New(s1)
+}
+
+func info(baseFormat string, args ...interface{}) {
+	format := fmt.Sprintf("%s %s \n", loggerPrefix, baseFormat)
+	fmt.Fprintf(os.Stdout, format, args...)
 }
 
-// Init -
-func Init() error {
+// InitWorker -
+func InitWorker() error {
 	info("Starting ...")
+	workerErr := make(chan error)
+	defer close(workerErr)
 
 	go func() {
 		for {
-			time.Sleep(time.Second * 10)
-			info("tick")
+			time.Sleep(time.Second * 5)
+			randomNumber := random.Intn(100)
+			if randomNumber > 90 {
+				workerErr <- fmt.Errorf("random number is '%d' so above 90", randomNumber)
+				continue
+			}
+			info("tick %d", randomNumber)
 		}
 	}()
 
-	info("Press 'Enter' to exit ...")
-	bufio.NewReader(os.Stdin).ReadBytes('\n')
-
-	return nil
+	return <-workerErr
 }