Merge branch 'temp' into 'v8'

Update the imports to onboard dcc in monorepo

See merge request dbops/Redis!3

Author: RonninSaga

CHANGELOG.md

@@ -1,3 +1,11 @@
+## [8.11.5-grab1.0] (https://gitlab.myteksi.net/dbops/Redis/-/tree/v8) (20220-12-21)
+
+### Features
+
+* Add limiter for connections per node
+* Add dynamic poolsize
+* Add dynamic client reload
+
 ## [8.11.5](https://github.com/go-redis/redis/compare/v8.11.4...v8.11.5) (2022-03-17)
 
 

README.md

@@ -1,73 +1,27 @@
 # Redis client for Go
 
-![build workflow](https://github.com/go-redis/redis/actions/workflows/build.yml/badge.svg)
-[![PkgGoDev](https://pkg.go.dev/badge/github.com/go-redis/redis/v8)](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc)
-[![Documentation](https://img.shields.io/badge/redis-documentation-informational)](https://redis.uptrace.dev/)
-
-go-redis is brought to you by :star: [**uptrace/uptrace**](https://github.com/uptrace/uptrace).
-Uptrace is an open source and blazingly fast **distributed tracing** backend powered by
-OpenTelemetry and ClickHouse. Give it a star as well!
+This is modified version of go-redis by spiderman team in grab.
+This is developed based by the Go-Redis V8/V8.11.5
 
 ## Resources
 
-- [Discussions](https://github.com/go-redis/redis/discussions)
-- [Documentation](https://redis.uptrace.dev)
-- [Reference](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc)
-- [Examples](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#pkg-examples)
-- [RealWorld example app](https://github.com/uptrace/go-treemux-realworld-example-app)
+- [Documentation](https://godoc.org/github.com/go-redis/redis)
+- [Design](https://wiki.grab.com/display/DBOps/%5BDesign%5D+Redis+connector)
 
 Other projects you may like:
 
-- [Bun](https://bun.uptrace.dev) - fast and simple SQL client for PostgreSQL, MySQL, and SQLite.
-- [BunRouter](https://bunrouter.uptrace.dev/) - fast and flexible HTTP router for Go.
-
-## Ecosystem
-
-- [Redis Mock](https://github.com/go-redis/redismock)
-- [Distributed Locks](https://github.com/bsm/redislock)
-- [Redis Cache](https://github.com/go-redis/cache)
-- [Rate limiting](https://github.com/go-redis/redis_rate)
+- [DCC](https://wiki.grab.com/pages/viewpage.action?pageId=399488531) - new redis library in grab, wrapped with this forked go-redis
 
 ## Features
-
-- Redis 3 commands except QUIT, MONITOR, and SYNC.
-- Automatic connection pooling with
-  [circuit breaker](https://en.wikipedia.org/wiki/Circuit_breaker_design_pattern) support.
-- [Pub/Sub](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#PubSub).
-- [Transactions](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#example-Client-TxPipeline).
-- [Pipeline](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#example-Client.Pipeline) and
-  [TxPipeline](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#example-Client.TxPipeline).
-- [Scripting](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#Script).
-- [Timeouts](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#Options).
-- [Redis Sentinel](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#NewFailoverClient).
-- [Redis Cluster](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#NewClusterClient).
-- [Cluster of Redis Servers](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#example-NewClusterClient-ManualSetup)
-  without using cluster mode and Redis Sentinel.
-- [Ring](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#NewRing).
-- [Instrumentation](https://pkg.go.dev/github.com/go-redis/redis/v8?tab=doc#example-package-Instrumentation).
-
-## Installation
-
-go-redis supports 2 last Go versions and requires a Go version with
-[modules](https://github.com/golang/go/wiki/Modules) support. So make sure to initialize a Go
-module:
-
-```shell
-go mod init github.com/my/repo
-```
-
-And then install go-redis/v8 (note _v8_ in the import; omitting it is a popular mistake):
-
-```shell
-go get github.com/go-redis/redis/v8
-```
+-  support client reload the essiential configurations, especially dinamiclly change the poolsize.
+-  support per node limiter
 
 ## Quickstart
 
 ```go
 import (
     "context"
-    "github.com/go-redis/redis/v8"
+    "gitlab.myteksi.net/dbops/Redis/v8"
     "fmt"
 )
 
@@ -166,10 +120,3 @@ Lastly, run:
 go test
 ```
 
-## Contributors
-
-Thanks to all the people who already contributed!
-
-<a href="https://github.com/go-redis/redis/graphs/contributors">
-  <img src="https://contributors-img.web.app/image?repo=go-redis/redis" />
-</a>

bench_decode_test.go

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

bench_test.go

@@ -10,7 +10,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/go-redis/redis/v8"
+	"gitlab.myteksi.net/dbops/Redis/v8"
 )
 
 func benchmarkRedisClient(ctx context.Context, poolSize int) *redis.Client {
@@ -303,7 +303,7 @@ func BenchmarkRingWithContext(b *testing.B) {
 	}
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 func newClusterScenario() *clusterScenario {
 	return &clusterScenario{

cluster.go

@@ -12,11 +12,11 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/go-redis/redis/v8/internal"
-	"github.com/go-redis/redis/v8/internal/hashtag"
-	"github.com/go-redis/redis/v8/internal/pool"
-	"github.com/go-redis/redis/v8/internal/proto"
-	"github.com/go-redis/redis/v8/internal/rand"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal/hashtag"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal/pool"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal/proto"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal/rand"
 )
 
 var errClusterNoNodes = fmt.Errorf("redis: cluster has no nodes")
@@ -168,7 +168,7 @@ func (opt *ClusterOptions) clientOptions() *Options {
 	}
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type clusterNode struct {
 	Client *Client
@@ -257,7 +257,7 @@ func (n *clusterNode) SetGeneration(gen uint32) {
 	}
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type clusterNodes struct {
 	opt *ClusterOptions
@@ -424,7 +424,7 @@ func (c *clusterNodes) Random() (*clusterNode, error) {
 	return c.GetOrCreate(addrs[n])
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type clusterSlot struct {
 	start, end int
@@ -626,7 +626,7 @@ func (c *clusterState) slotNodes(slot int) []*clusterNode {
 	return nil
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type clusterStateHolder struct {
 	load func(ctx context.Context) (*clusterState, error)
@@ -686,7 +686,7 @@ func (c *clusterStateHolder) ReloadOrGet(ctx context.Context) (*clusterState, er
 	return c.Get(ctx)
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type clusterClient struct {
 	opt           *ClusterOptions
@@ -1735,7 +1735,7 @@ loop:
 	return ss
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 type cmdsMap struct {
 	mu sync.Mutex

cluster_dynamic.go

@@ -5,7 +5,7 @@ import (
 	"runtime"
 	"time"
 
-	"github.com/go-redis/redis/v8/internal"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal"
 )
 
 // NewDynamicClusterClient is similar to NewClusterClient, but it supports dynamic connection pool management

cluster_dynamic_test.go

@@ -5,9 +5,9 @@ import (
 	"log"
 	"time"
 
-	"github.com/go-redis/redis/v8"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
+	"gitlab.myteksi.net/dbops/Redis/v8"
 )
 
 var _ = Describe("Dynamic ClusterClient", func() {

cluster_test.go

@@ -12,8 +12,8 @@ import (
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 
-	"github.com/go-redis/redis/v8"
-	"github.com/go-redis/redis/v8/internal/hashtag"
+	"gitlab.myteksi.net/dbops/Redis/v8"
+	"gitlab.myteksi.net/dbops/Redis/v8/internal/hashtag"
 )
 
 type clusterScenario struct {
@@ -229,7 +229,7 @@ func slotEqual(s1, s2 redis.ClusterSlot) bool {
 	return true
 }
 
-//------------------------------------------------------------------------------
+// ------------------------------------------------------------------------------
 
 var _ = Describe("ClusterClient", func() {
 	var failover bool