feat: add support for configuring Redis connection with username

- Add `username` field to the `options` struct
- Add `WithUsername` function to set the `username` option
- Include `username` in the `NewWorker` function for Redis connection configuration

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

Author: appleboy

options.go

@@ -16,6 +16,7 @@ type options struct {
 	addr             string
 	db               int
 	connectionString string
+	username         string
 	password         string
 	channelName      string
 	channelSize      int
@@ -66,6 +67,13 @@ func WithChannelSize(size int) Option {
 	}
 }
 
+// WithUsername redis username
+func WithUsername(username string) Option {
+	return func(w *options) {
+		w.username = username
+	}
+}
+
 // WithPassword redis password
 func WithPassword(passwd string) Option {
 	return func(w *options) {

redis.go

@@ -42,6 +42,7 @@ func NewWorker(opts ...Option) *Worker {
 
 	options := &redis.Options{
 		Addr:     w.opts.addr,
+		Username: w.opts.username,
 		Password: w.opts.password,
 		DB:       w.opts.db,
 	}
@@ -58,6 +59,7 @@ func NewWorker(opts ...Option) *Worker {
 	if w.opts.cluster {
 		w.rdb = redis.NewClusterClient(&redis.ClusterOptions{
 			Addrs:    strings.Split(w.opts.addr, ","),
+			Username: w.opts.username,
 			Password: w.opts.password,
 		})
 	}
@@ -66,6 +68,7 @@ func NewWorker(opts ...Option) *Worker {
 		w.rdb = redis.NewFailoverClient(&redis.FailoverOptions{
 			MasterName:    w.opts.masterName,
 			SentinelAddrs: strings.Split(w.opts.addr, ","),
+			Username:      w.opts.username,
 			Password:      w.opts.password,
 			DB:            w.opts.db,
 		})