feat: add TLS configuration options and functions to options struct

- Add TLS configuration option to `options` struct
- Introduce `WithTLS` function to configure TLS with a minimum version of 1.2
- Introduce `WithSkipTLSVerify` function to allow skipping TLS certificate verification
- Update `NewWorker` function to use TLS configuration from options

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

Author: appleboy

options.go

@@ -2,6 +2,7 @@ package redisdb
 
 import (
 	"context"
+	"crypto/tls"
 	"time"
 
 	"github.com/golang-queue/queue"
@@ -25,6 +26,7 @@ type options struct {
 	consumer         string
 	maxLength        int64
 	blockTime        time.Duration
+	tls              *tls.Config
 }
 
 // WithAddr setup the addr of redis
@@ -121,6 +123,34 @@ func WithLogger(l queue.Logger) Option {
 	}
 }
 
+// WithTLS returns an Option that configures the use of TLS for the connection.
+// It sets the minimum TLS version to TLS 1.2.
+func WithTLS() Option {
+	return func(w *options) {
+		w.tls = &tls.Config{
+			MinVersion: tls.VersionTLS12,
+		}
+	}
+}
+
+// WithSkipTLSVerify returns an Option that configures the TLS settings to skip
+// verification of the server's certificate. This is useful for connecting to
+// servers with self-signed certificates or when certificate verification is
+// not required. Use this option with caution as it makes the connection
+// susceptible to man-in-the-middle attacks.
+func WithSkipTLSVerify() Option {
+	return func(w *options) {
+		if w.tls == nil {
+			w.tls = &tls.Config{
+				InsecureSkipVerify: true, //nolint: gosec
+
+			}
+			return
+		}
+		w.tls.InsecureSkipVerify = true
+	}
+}
+
 func newOptions(opts ...Option) options {
 	defaultOpts := options{
 		addr:       "127.0.0.1:6379",

redis.go

@@ -50,16 +50,18 @@ func NewWorker(opts ...Option) *Worker {
 	} else if w.opts.addr != "" {
 		if w.opts.cluster {
 			w.rdb = redis.NewClusterClient(&redis.ClusterOptions{
-				Addrs:    strings.Split(w.opts.addr, ","),
-				Username: w.opts.username,
-				Password: w.opts.password,
+				Addrs:     strings.Split(w.opts.addr, ","),
+				Username:  w.opts.username,
+				Password:  w.opts.password,
+				TLSConfig: w.opts.tls,
 			})
 		} else {
 			options := &redis.Options{
-				Addr:     w.opts.addr,
-				Username: w.opts.username,
-				Password: w.opts.password,
-				DB:       w.opts.db,
+				Addr:      w.opts.addr,
+				Username:  w.opts.username,
+				Password:  w.opts.password,
+				DB:        w.opts.db,
+				TLSConfig: w.opts.tls,
 			}
 			w.rdb = redis.NewClient(options)
 		}