feat✨: 升级V9

Author: wenjianzhang

Diff for: consumer.go

@@ -7,7 +7,7 @@ import (
 	"sync"
 	"time"
 
-	"github.com/go-redis/redis/v8"
+	"github.com/go-redis/redis/v9"
 	"github.com/pkg/errors"
 )
 

Diff for: consumer_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/go-redis/redis/v8"
+	"github.com/go-redis/redis/v9"
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"

Diff for: go.mod

@@ -5,13 +5,13 @@ go 1.12
 require (
 	github.com/fatih/color v1.7.0 // indirect
 	github.com/git-chglog/git-chglog v0.0.0-20190611050339-63a4e637021f
-	github.com/go-redis/redis/v8 v8.11.5
+	github.com/go-redis/redis/v9 v9.0.0-rc.1
 	github.com/imdario/mergo v0.3.7 // indirect
 	github.com/mattn/go-colorable v0.1.2 // indirect
 	github.com/mattn/goveralls v0.0.2
 	github.com/pborman/uuid v1.2.0 // indirect
 	github.com/pkg/errors v0.9.1
-	github.com/stretchr/testify v1.5.1
+	github.com/stretchr/testify v1.8.0
 	github.com/tsuyoshiwada/go-gitcmd v0.0.0-20180205145712-5f1f5f9475df // indirect
 	github.com/urfave/cli v1.20.0 // indirect
 	gopkg.in/AlecAivazis/survey.v1 v1.8.5 // indirect

Diff for: producer.go

@@ -2,7 +2,7 @@ package redisqueue
 
 import (
 	"context"
-	"github.com/go-redis/redis/v8"
+	"github.com/go-redis/redis/v9"
 )
 
 // ProducerOptions provide options to configure the Producer.
@@ -81,11 +81,11 @@ func (p *Producer) Enqueue(msg *Message) error {
 		Stream: msg.Stream,
 		Values: msg.Values,
 	}
-	if p.options.ApproximateMaxLength {
-		args.MaxLenApprox = p.options.StreamMaxLength
-	} else {
-		args.MaxLen = p.options.StreamMaxLength
-	}
+	//if p.options.ApproximateMaxLength {
+	//	args.MaxLenApprox = p.options.StreamMaxLength
+	//} else {
+	args.MaxLen = p.options.StreamMaxLength
+	//}
 	id, err := p.redis.XAdd(context.TODO(), args).Result()
 	if err != nil {
 		return err

Diff for: redis.go

@@ -7,7 +7,7 @@ import (
 	"strconv"
 	"strings"
 
-	"github.com/go-redis/redis/v8"
+	"github.com/go-redis/redis/v9"
 	"github.com/pkg/errors"
 )
 

Diff for: redis_test.go

@@ -1,6 +1,7 @@
 package redisqueue
 
 import (
+	"context"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
@@ -12,14 +13,14 @@ func TestNewRedisClient(t *testing.T) {
 		options := &RedisOptions{}
 		r := newRedisClient(options)
 
-		err := r.Ping().Err()
+		err := r.Ping(context.TODO()).Err()
 		assert.NoError(tt, err)
 	})
 
 	t.Run("defaults options if it's nil", func(tt *testing.T) {
 		r := newRedisClient(nil)
 
-		err := r.Ping().Err()
+		err := r.Ping(context.TODO()).Err()
 		assert.NoError(tt, err)
 	})
 }