feat: add support for configuring Redis connection with username (#30)

* 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]>

* ci: update Go version to 1.20 and adjust GitHub Actions accordingly

- Remove support for Go 1.18 and 1.19 in GitHub Actions workflow
- Update Go version in `go.mod` from 1.18 to 1.20

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

---------

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

Author: appleboy

.github/workflows/go.yml

@@ -22,7 +22,7 @@ jobs:
     strategy:
       matrix:
         os: [ubuntu-latest]
-        go: [1.18, 1.19, "1.20", 1.21, 1.22, 1.23]
+        go: ["1.20", 1.21, 1.22, 1.23]
         include:
           - os: ubuntu-latest
             go-build: ~/.cache/go-build

go.mod

@@ -1,6 +1,6 @@
 module github.com/golang-queue/redisdb
 
-go 1.18
+go 1.20
 
 require (
 	github.com/golang-queue/queue v0.1.4-0.20221210024521-cb8720b0c721

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,
 		})