feat: add support for setting and using username in Redis connections

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

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

Author: appleboy

options.go

@@ -17,6 +17,7 @@ type options struct {
 	addr             string
 	db               int
 	connectionString string
+	username         string
 	password         string
 	streamName       string
 	cluster          bool
@@ -84,6 +85,14 @@ func WithConsumer(name string) Option {
 	}
 }
 
+// WithUsername redis username
+// This is only used for redis cluster
+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

@@ -51,11 +51,13 @@ 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,
 			})
 		} else {
 			options := &redis.Options{
 				Addr:     w.opts.addr,
+				Username: w.opts.username,
 				Password: w.opts.password,
 				DB:       w.opts.db,
 			}