refactor: standardize logging level naming and constants

- Rename `logLvl` to `logLevel` in `nsq.go` and `options.go`
- Remove custom log level constants in `options.go`

Signed-off-by: appleboy <[email protected]>

Author: appleboy

nsq.go

@@ -44,7 +44,7 @@ func NewWorker(opts ...Option) *Worker {
 		panic(err)
 	}
 
-	w.p.SetLoggerLevel(nsq.LogLevel(w.opts.logLvl))
+	w.p.SetLoggerLevel(w.opts.logLevel)
 
 	return w
 }
@@ -64,8 +64,7 @@ func (w *Worker) startConsumer() (err error) {
 			return
 		}
 
-		w.q.SetLoggerLevel(nsq.LogLevel(w.opts.logLvl))
-
+		w.q.SetLoggerLevel(w.opts.logLevel)
 		w.q.AddHandler(nsq.HandlerFunc(func(msg *nsq.Message) error {
 			if len(msg.Body) == 0 {
 				// Returning nil will automatically send a FIN command to NSQ to mark the message as processed.

options.go

@@ -9,15 +9,6 @@ import (
 	nsq "github.com/nsqio/go-nsq"
 )
 
-// Log levels (same as [nsq.LogLevel])
-const (
-	LogLevelDebug nsq.LogLevel = iota
-	LogLevelInfo
-	LogLevelWarning
-	LogLevelError
-	LogLevelMax = iota - 1 // convenience - match highest log level
-)
-
 // An Option configures a mutex.
 type Option interface {
 	Apply(*Options)
@@ -38,7 +29,7 @@ type Options struct {
 	channel     string
 	runFunc     func(context.Context, core.QueuedMessage) error
 	logger      queue.Logger
-	logLvl      nsq.LogLevel
+	logLevel    nsq.LogLevel
 }
 
 // WithAddr setup the addr of NSQ
@@ -86,7 +77,7 @@ func WithLogger(l queue.Logger) Option {
 // WithLogLevel set custom [nsq] log level
 func WithLogLevel(lvl nsq.LogLevel) Option {
 	return OptionFunc(func(o *Options) {
-		o.logLvl = lvl
+		o.logLevel = lvl
 	})
 }
 
@@ -97,8 +88,8 @@ func newOptions(opts ...Option) Options {
 		channel:     "ch",
 		maxInFlight: 1,
 
-		logger: queue.NewLogger(),
-		logLvl: LogLevelInfo,
+		logger:   queue.NewLogger(),
+		logLevel: nsq.LogLevelInfo,
 		runFunc: func(context.Context, core.QueuedMessage) error {
 			return nil
 		},