Update worker config name

cmd/gogstash.go

@@ -41,9 +41,9 @@ func gogstash(
 		return err
 	}
 
-	// use worker mode when user need more than one workers
-	if conf.Workers > 1 && !workerMode {
-		return startWorkers(ctx, conf.Workers)
+	// use worker mode when user need more than one worker
+	if conf.Worker > 1 && !workerMode {
+		return startWorkers(ctx, conf.Worker)
 	}
 
 	if err = conf.Start(ctx); err != nil {

cmd/worker_unix.go

@@ -49,7 +49,7 @@ func waitWorkers(ctx context.Context, pids []int, args []string, attr *syscall.P
 	}
 }
 
-func startWorkers(ctx context.Context, workers int) error {
+func startWorkers(ctx context.Context, workerNum int) error {
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()
 
@@ -59,8 +59,8 @@ func startWorkers(ctx context.Context, workers int) error {
 	}
 	args := append([]string{os.Args[0], WorkerModule.Use}, os.Args[1:]...)
 
-	pids := make([]int, workers)
-	for i := 0; i < workers; i++ {
+	pids := make([]int, workerNum)
+	for i := 0; i < workerNum; i++ {
 		pid, err := startWorker(args, attr)
 		if err != nil {
 			return err

cmd/worker_windows.go

@@ -53,7 +53,7 @@ func waitWorkers(ctx context.Context, pids []int, handles []uintptr, args []stri
 	}
 }
 
-func startWorkers(ctx context.Context, workers int) error {
+func startWorkers(ctx context.Context, workerNum int) error {
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()
 
@@ -63,9 +63,9 @@ func startWorkers(ctx context.Context, workers int) error {
 	}
 	args := append([]string{os.Args[0], WorkerModule.Use}, os.Args[1:]...)
 
-	pids := make([]int, workers)
-	handles := make([]uintptr, workers)
-	for i := 0; i < workers; i++ {
+	pids := make([]int, workerNum)
+	handles := make([]uintptr, workerNum)
+	for i := 0; i < workerNum; i++ {
 		pid, handle, err := startWorker(args, attr)
 		if err != nil {
 			return err

config/config.go

@@ -14,7 +14,7 @@ import (
 	"github.com/tsaikd/gogstash/config/goglog"
 	"github.com/tsaikd/gogstash/config/logevent"
 	"golang.org/x/sync/errgroup"
-	"gopkg.in/yaml.v2"
+	yaml "gopkg.in/yaml.v2"
 )
 
 // errors
@@ -34,8 +34,8 @@ type Config struct {
 	// channel size: chInFilter, chFilterOut, chOutDebug
 	ChannelSize int `json:"chsize,omitempty" yaml:"chsize"`
 
-	// workers number, defaults to 1
-	Workers int `json:"workers,omitempty" yaml:"workers"`
+	// worker number, defaults to 1
+	Worker int `json:"worker,omitempty" yaml:"worker"`
 
 	// enable debug channel, used for testing
 	DebugChannel bool `json:"debugch,omitempty" yaml:"debugch"`
@@ -49,7 +49,7 @@ type Config struct {
 
 var defaultConfig = Config{
 	ChannelSize: 100,
-	Workers:     1,
+	Worker:      1,
 }
 
 // MsgChan message channel type
@@ -101,8 +101,8 @@ func initConfig(config *Config) {
 	if config.ChannelSize < 1 {
 		config.ChannelSize = defaultConfig.ChannelSize
 	}
-	if config.Workers < 1 {
-		config.Workers = defaultConfig.Workers
+	if config.Worker < 1 {
+		config.Worker = defaultConfig.Worker
 	}
 
 	config.chInFilter = make(MsgChan, config.ChannelSize)