mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

chore: v9

This commit is contained in:
Vladimir Mihailenco 2022-06-04 17:39:21 +03:00
parent a8e56a2961
commit a18fad5bd3
66 changed files with 107 additions and 114 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -63,13 +63,13 @@ module:
go mod init github.com/my/repo go mod init github.com/my/repo
``` ```
And then install go-redis/v8 (note _v8_ in the import; omitting it is a popular mistake): If you are using **Redis 6**, install go-redis/**v8**:
```shell ```shell
go get github.com/go-redis/redis/v8 go get github.com/go-redis/redis/v8
``` ```
If you need **Redis 7** support, install go-redis/v9: If you are using **Redis 7**, install **go-redis/v9**:
```shell ```shell
go get github.com/go-redis/redis/v9 go get github.com/go-redis/redis/v9

2
bench_decode_test.go
View File

@ -8,7 +8,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
var ctx = context.TODO() var ctx = context.TODO()

2
bench_test.go
View File

@ -10,7 +10,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func benchmarkRedisClient(ctx context.Context, poolSize int) *redis.Client { func benchmarkRedisClient(ctx context.Context, poolSize int) *redis.Client {

10
cluster.go
View File

@ -12,11 +12,11 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/hashtag" "github.com/go-redis/redis/v9/internal/hashtag"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
var errClusterNoNodes = fmt.Errorf("redis: cluster has no nodes") var errClusterNoNodes = fmt.Errorf("redis: cluster has no nodes")

4
cluster_test.go
View File

@ -12,8 +12,8 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
"github.com/go-redis/redis/v8/internal/hashtag" "github.com/go-redis/redis/v9/internal/hashtag"
) )
type clusterScenario struct { type clusterScenario struct {

8
command.go
View File

@ -7,10 +7,10 @@ import (
"strconv" "strconv"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/hscan" "github.com/go-redis/redis/v9/internal/hscan"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
"github.com/go-redis/redis/v8/internal/util" "github.com/go-redis/redis/v9/internal/util"
) )
type Cmder interface { type Cmder interface {

2
command_test.go
View File

@ -4,7 +4,7 @@ import (
"errors" "errors"
"time" "time"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"

2
commands.go
View File

@ -6,7 +6,7 @@ import (
"io" "io"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
) )
// KeepTTL is a Redis KEEPTTL option to keep existing TTL, it requires your redis-server version >= 6.0, // KeepTTL is a Redis KEEPTTL option to keep existing TTL, it requires your redis-server version >= 6.0,

4
commands_test.go
View File

@ -10,8 +10,8 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
var _ = Describe("Commands", func() { var _ = Describe("Commands", func() {

4
error.go
View File

@ -6,8 +6,8 @@ import (
"net" "net"
"strings" "strings"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
// ErrClosed performs any operation on the closed client will return this error. // ErrClosed performs any operation on the closed client will return this error.

4
example/del-keys-without-ttl/go.mod
View File

@ -2,6 +2,6 @@ module github.com/go-redis/redis/example/del-keys-without-ttl
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require github.com/go-redis/redis/v8 v8.11.5 require github.com/go-redis/redis/v9 v8.11.5

2
example/del-keys-without-ttl/main.go
View File

@ -5,7 +5,7 @@ import (
"fmt" "fmt"
"sync" "sync"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func main() { func main() {

4
example/hll/go.mod
View File

@ -2,6 +2,6 @@ module github.com/go-redis/redis/example/hll
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require github.com/go-redis/redis/v8 v8.11.5 require github.com/go-redis/redis/v9 v8.11.5

2
example/hll/main.go
View File

@ -4,7 +4,7 @@ import (
"context" "context"
"fmt" "fmt"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func main() { func main() {

4
example/lua-scripting/go.mod
View File

@ -2,6 +2,6 @@ module github.com/go-redis/redis/example/redis-bloom
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require github.com/go-redis/redis/v8 v8.11.5 require github.com/go-redis/redis/v9 v8.11.5

2
example/lua-scripting/main.go
View File

@ -4,7 +4,7 @@ import (
"context" "context"
"fmt" "fmt"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func main() { func main() {

8
example/otel/go.mod
View File

@ -2,15 +2,13 @@ module github.com/go-redis/redis/example/otel
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
replace github.com/go-redis/redis/extra/redisotel/v8 => ../../extra/redisotel replace github.com/go-redis/redis/extra/redisotel/v9 => ../../extra/redisotel
replace github.com/go-redis/redis/extra/rediscmd/v8 => ../../extra/rediscmd replace github.com/go-redis/redis/extra/rediscmd/v9 => ../../extra/rediscmd
require ( require (
github.com/go-redis/redis/extra/redisotel/v8 v8.11.5
github.com/go-redis/redis/v8 v8.11.5
github.com/uptrace/opentelemetry-go-extra/otelplay v0.1.10 github.com/uptrace/opentelemetry-go-extra/otelplay v0.1.10
go.opentelemetry.io/otel v1.5.0 go.opentelemetry.io/otel v1.5.0
go.opentelemetry.io/otel/exporters/jaeger v1.5.0 // indirect go.opentelemetry.io/otel/exporters/jaeger v1.5.0 // indirect

4
example/otel/main.go
View File

@ -10,8 +10,8 @@ import (
"go.opentelemetry.io/otel/codes" "go.opentelemetry.io/otel/codes"
semconv "go.opentelemetry.io/otel/semconv/v1.7.0" semconv "go.opentelemetry.io/otel/semconv/v1.7.0"
"github.com/go-redis/redis/extra/redisotel/v8" "github.com/go-redis/redis/extra/redisotel/v9"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var tracer = otel.Tracer("redisexample") var tracer = otel.Tracer("redisexample")

4
example/redis-bloom/go.mod
View File

@ -2,6 +2,6 @@ module github.com/go-redis/redis/example/redis-bloom
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require github.com/go-redis/redis/v8 v8.11.5 require github.com/go-redis/redis/v9 v8.11.5

2
example/redis-bloom/main.go
View File

@ -5,7 +5,7 @@ import (
"fmt" "fmt"
"math/rand" "math/rand"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func main() { func main() {

4
example/scan-struct/go.mod
View File

@ -2,9 +2,9 @@ module github.com/go-redis/redis/example/scan-struct
go 1.14 go 1.14
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require ( require (
github.com/davecgh/go-spew v1.1.1 github.com/davecgh/go-spew v1.1.1
github.com/go-redis/redis/v8 v8.11.5 github.com/go-redis/redis/v9 v8.11.5
) )

2
example/scan-struct/main.go
View File

@ -5,7 +5,7 @@ import (
"github.com/davecgh/go-spew/spew" "github.com/davecgh/go-spew/spew"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
type Model struct { type Model struct {

2
example_instrumentation_test.go
View File

@ -4,7 +4,7 @@ import (
"context" "context"
"fmt" "fmt"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
type redisHook struct{} type redisHook struct{}

2
example_test.go
View File

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

6
export_test.go
View File

@ -6,9 +6,9 @@ import (
"net" "net"
"strings" "strings"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/hashtag" "github.com/go-redis/redis/v9/internal/hashtag"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
) )
func (c *baseClient) Pool() pool.Pooler { func (c *baseClient) Pool() pool.Pooler {

8
extra/rediscensus/go.mod
View File

@ -1,14 +1,12 @@
module github.com/go-redis/redis/extra/rediscensus/v8 module github.com/go-redis/redis/extra/rediscensus/v9
go 1.15 go 1.15
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
replace github.com/go-redis/redis/extra/rediscmd/v8 => ../rediscmd replace github.com/go-redis/redis/extra/rediscmd/v9 => ../rediscmd
require ( require (
github.com/go-redis/redis/extra/rediscmd/v8 v8.11.5
github.com/go-redis/redis/v8 v8.11.5
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
go.opencensus.io v0.23.0 go.opencensus.io v0.23.0
) )

4
extra/rediscensus/rediscensus.go
View File

@ -5,8 +5,8 @@ import (
"go.opencensus.io/trace" "go.opencensus.io/trace"
"github.com/go-redis/redis/extra/rediscmd/v8" "github.com/go-redis/redis/extra/rediscmd/v9"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
type TracingHook struct{} type TracingHook struct{}

5
extra/rediscmd/go.mod
View File

@ -1,11 +1,10 @@
module github.com/go-redis/redis/extra/rediscmd/v8 module github.com/go-redis/redis/extra/rediscmd/v9
go 1.15 go 1.15
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
require ( require (
github.com/go-redis/redis/v8 v8.11.5
github.com/onsi/ginkgo v1.16.5 github.com/onsi/ginkgo v1.16.5
github.com/onsi/gomega v1.18.1 github.com/onsi/gomega v1.18.1
) )

2
extra/rediscmd/rediscmd.go
View File

@ -7,7 +7,7 @@ import (
"strings" "strings"
"time" "time"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func CmdString(cmd redis.Cmder) string { func CmdString(cmd redis.Cmder) string {

6
extra/redisotel/README.md
View File

@ -3,7 +3,7 @@
## Installation ## Installation
```bash ```bash
go get github.com/go-redis/redis/extra/redisotel/v8 go get github.com/go-redis/redis/extra/redisotel/v9
``` ```
## Usage ## Usage
@ -12,8 +12,8 @@ Tracing is enabled by adding a hook:
```go ```go
import ( import (
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
"github.com/go-redis/redis/extra/redisotel" "github.com/go-redis/redis/extra/redisotel/v9"
) )
rdb := rdb.NewClient(&rdb.Options{...}) rdb := rdb.NewClient(&rdb.Options{...})

8
extra/redisotel/go.mod
View File

@ -1,14 +1,12 @@
module github.com/go-redis/redis/extra/redisotel/v8 module github.com/go-redis/redis/extra/redisotel/v9
go 1.15 go 1.15
replace github.com/go-redis/redis/v8 => ../.. replace github.com/go-redis/redis/v9 => ../..
replace github.com/go-redis/redis/extra/rediscmd/v8 => ../rediscmd replace github.com/go-redis/redis/extra/rediscmd/v9 => ../rediscmd
require ( require (
github.com/go-redis/redis/extra/rediscmd/v8 v8.11.5
github.com/go-redis/redis/v8 v8.11.5
go.opentelemetry.io/otel v1.5.0 go.opentelemetry.io/otel v1.5.0
go.opentelemetry.io/otel/sdk v1.4.1 go.opentelemetry.io/otel/sdk v1.4.1
go.opentelemetry.io/otel/trace v1.5.0 go.opentelemetry.io/otel/trace v1.5.0

4
extra/redisotel/redisotel.go
View File

@ -9,8 +9,8 @@ import (
semconv "go.opentelemetry.io/otel/semconv/v1.7.0" semconv "go.opentelemetry.io/otel/semconv/v1.7.0"
"go.opentelemetry.io/otel/trace" "go.opentelemetry.io/otel/trace"
"github.com/go-redis/redis/extra/rediscmd/v8" "github.com/go-redis/redis/extra/rediscmd/v9"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
const ( const (

4
extra/redisotel/redisotel_test.go
View File

@ -10,8 +10,8 @@ import (
sdktrace "go.opentelemetry.io/otel/sdk/trace" sdktrace "go.opentelemetry.io/otel/sdk/trace"
"go.opentelemetry.io/otel/trace" "go.opentelemetry.io/otel/trace"
"github.com/go-redis/redis/extra/redisotel/v8" "github.com/go-redis/redis/extra/redisotel/v9"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
func TestNew(t *testing.T) { func TestNew(t *testing.T) {

2
fuzz/fuzz.go
View File

@ -7,7 +7,7 @@ import (
"context" "context"
"time" "time"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var ( var (

2
go.mod
View File

@ -1,4 +1,4 @@
module github.com/go-redis/redis/v8 module github.com/go-redis/redis/v9
go 1.17 go 1.17

2
internal/hashtag/hashtag.go
View File

@ -3,7 +3,7 @@ package hashtag
import ( import (
"strings" "strings"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
const slotNumber = 16384 const slotNumber = 16384

2
internal/hashtag/hashtag_test.go
View File

@ -6,7 +6,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
func TestGinkgoSuite(t *testing.T) { func TestGinkgoSuite(t *testing.T) {

2
internal/internal.go
View File

@ -3,7 +3,7 @@ package internal
import ( import (
"time" "time"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
func RetryBackoff(retry int, minBackoff, maxBackoff time.Duration) time.Duration { func RetryBackoff(retry int, minBackoff, maxBackoff time.Duration) time.Duration {

2
internal/pool/bench_test.go
View File

@ -6,7 +6,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
) )
type poolGetPutBenchmark struct { type poolGetPutBenchmark struct {

2
internal/pool/conn.go
View File

@ -7,7 +7,7 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
var noDeadline = time.Time{} var noDeadline = time.Time{}

2
internal/pool/pool.go
View File

@ -8,7 +8,7 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
) )
var ( var (

2
internal/pool/pool_test.go
View File

@ -10,7 +10,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
) )
var _ = Describe("ConnPool", func() { var _ = Describe("ConnPool", func() {

2
internal/proto/reader.go
View File

@ -9,7 +9,7 @@ import (
"math/big" "math/big"
"strconv" "strconv"
"github.com/go-redis/redis/v8/internal/util" "github.com/go-redis/redis/v9/internal/util"
) )
// redis resp protocol data type. // redis resp protocol data type.

2
internal/proto/reader_test.go
View File

@ -5,7 +5,7 @@ import (
"io" "io"
"testing" "testing"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
func BenchmarkReader_ParseReply_Status(b *testing.B) { func BenchmarkReader_ParseReply_Status(b *testing.B) {

2
internal/proto/scan.go
View File

@ -7,7 +7,7 @@ import (
"reflect" "reflect"
"time" "time"
"github.com/go-redis/redis/v8/internal/util" "github.com/go-redis/redis/v9/internal/util"
) )
// Scan parses bytes `b` to `v` with appropriate type. // Scan parses bytes `b` to `v` with appropriate type.

2
internal/proto/scan_test.go
View File

@ -6,7 +6,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
type testScanSliceStruct struct { type testScanSliceStruct struct {

2
internal/proto/writer.go
View File

@ -8,7 +8,7 @@ import (
"strconv" "strconv"
"time" "time"
"github.com/go-redis/redis/v8/internal/util" "github.com/go-redis/redis/v9/internal/util"
) )
type writer interface { type writer interface {

2
internal/proto/writer_test.go
View File

@ -11,7 +11,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
type MyType struct{} type MyType struct{}

2
internal/util.go
View File

@ -4,7 +4,7 @@ import (
"context" "context"
"time" "time"
"github.com/go-redis/redis/v8/internal/util" "github.com/go-redis/redis/v9/internal/util"
) )
func Sleep(ctx context.Context, dur time.Duration) error { func Sleep(ctx context.Context, dur time.Duration) error {

2
iterator_test.go
View File

@ -6,7 +6,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("ScanIterator", func() { var _ = Describe("ScanIterator", func() {

2
main_test.go
View File

@ -15,7 +15,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
const ( const (

2
options.go
View File

@ -13,7 +13,7 @@ import (
"strings" "strings"
"time" "time"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
) )
// Limiter is the interface of a rate limiter or a circuit breaker. // Limiter is the interface of a rate limiter or a circuit breaker.

2
pipeline_test.go
View File

@ -6,7 +6,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("pipelining", func() { var _ = Describe("pipelining", func() {

2
pool_test.go
View File

@ -7,7 +7,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("pool", func() { var _ = Describe("pool", func() {

6
pubsub.go
View File

@ -7,9 +7,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
// PubSub implements Pub/Sub commands as described in // PubSub implements Pub/Sub commands as described in

2
pubsub_test.go
View File

@ -9,7 +9,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("PubSub", func() { var _ = Describe("PubSub", func() {

2
race_test.go
View File

@ -13,7 +13,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("races", func() { var _ = Describe("races", func() {

6
redis.go
View File

@ -7,9 +7,9 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
// Nil reply returned by Redis when key does not exist. // Nil reply returned by Redis when key does not exist.

2
redis_test.go
View File

@ -11,7 +11,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
type redisHookError struct { type redisHookError struct {

8
ring.go
View File

@ -14,10 +14,10 @@ import (
"github.com/cespare/xxhash/v2" "github.com/cespare/xxhash/v2"
rendezvous "github.com/dgryski/go-rendezvous" //nolint rendezvous "github.com/dgryski/go-rendezvous" //nolint
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/hashtag" "github.com/go-redis/redis/v9/internal/hashtag"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
var errRingShardsDown = errors.New("redis: all ring shards are down") var errRingShardsDown = errors.New("redis: all ring shards are down")

2
ring_test.go
View File

@ -12,7 +12,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("Redis Ring", func() { var _ = Describe("Redis Ring", func() {

6
sentinel.go
View File

@ -9,9 +9,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/go-redis/redis/v8/internal" "github.com/go-redis/redis/v9/internal"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/rand" "github.com/go-redis/redis/v9/internal/rand"
) )
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------

2
sentinel_test.go
View File

@ -6,7 +6,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("Sentinel", func() { var _ = Describe("Sentinel", func() {

4
tx.go
View File

@ -3,8 +3,8 @@ package redis
import ( import (
"context" "context"
"github.com/go-redis/redis/v8/internal/pool" "github.com/go-redis/redis/v9/internal/pool"
"github.com/go-redis/redis/v8/internal/proto" "github.com/go-redis/redis/v9/internal/proto"
) )
// TxFailedErr transaction redis failed. // TxFailedErr transaction redis failed.

2
tx_test.go
View File

@ -8,7 +8,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("Tx", func() { var _ = Describe("Tx", func() {

2
universal_test.go
View File

@ -4,7 +4,7 @@ import (
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v9"
) )
var _ = Describe("UniversalClient", func() { var _ = Describe("UniversalClient", func() {