refactor: refactor cluster initialization and update related tests

- Remove the `enable` parameter from the `WithCluster` function and set `w.cluster` to `true` by default
- Update the test `TestRedisCluster` to call `WithCluster()` without parameters

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

Author: appleboy

options.go

@@ -60,9 +60,9 @@ func WithDB(db int) Option {
 }
 
 // WithCluster redis cluster
-func WithCluster(enable bool) Option {
+func WithCluster() Option {
 	return func(w *options) {
-		w.cluster = enable
+		w.cluster = true
 	}
 }
 

redis_test.go

@@ -188,7 +188,7 @@ func TestRedisCluster(t *testing.T) {
 	w := NewWorker(
 		WithAddr(strings.Join(hosts, ",")),
 		WithStreamName("testCluster"),
-		WithCluster(true),
+		WithCluster(),
 		WithRunFunc(func(ctx context.Context, m core.QueuedMessage) error {
 			time.Sleep(500 * time.Millisecond)
 			return nil