Add slave nodes into cluster state only when its replication is completed

Author: lemonlinger

bench_decode_test.go

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

bench_test.go

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

bitmap_commands_test.go

@@ -3,7 +3,7 @@ package redis_test
 import (
 	. "github.com/bsm/ginkgo/v2"
 	. "github.com/bsm/gomega"
-	"github.com/redis/go-redis/v9"
+	"github.com/p1cn/go-redis/v9"
 )
 
 type bitCountExpected struct {

command.go

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

command_test.go

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

commands.go

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

commands_test.go

@@ -11,8 +11,8 @@ import (
 	. "github.com/bsm/ginkgo/v2"
 	. "github.com/bsm/gomega"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/internal/proto"
+	"github.com/p1cn/go-redis/v9"
+	"github.com/p1cn/go-redis/v9/internal/proto"
 )
 
 type TimeValue struct {

doctests/bf_tutorial_test.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/p1cn/go-redis/v9"
 )
 
 // HIDE_END

doctests/bitfield_tutorial_test.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/p1cn/go-redis/v9"
 )
 
 // HIDE_END

doctests/bitmap_tutorial_test.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/p1cn/go-redis/v9"
 )
 
 // HIDE_END