Rebrand as hanzoai/kv-go

Update module path from github.com/redis/go-redis/v9 to
github.com/hanzoai/kv-go/v9 for use as the Hanzo KV Go SDK.

- Update go.mod module declaration
- Update all Go imports across 260 files
- Update all submodule go.mod files (extra/*, example/*, internal/customvet)

acl_commands_test.go

@@ -3,7 +3,7 @@ package redis_test
 import (
 	"context"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 
 	. "github.com/bsm/ginkgo/v2"
 	. "github.com/bsm/gomega"

adapters.go

@@ -6,8 +6,8 @@ import (
 	"net"
 	"time"
 
-	"github.com/redis/go-redis/v9/internal/interfaces"
-	"github.com/redis/go-redis/v9/push"
+	"github.com/hanzoai/kv-go/v9/internal/interfaces"
+	"github.com/hanzoai/kv-go/v9/push"
 )
 
 // ErrInvalidCommand is returned when an invalid command is passed to ExecuteCommand.

async_handoff_integration_test.go

@@ -8,9 +8,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/redis/go-redis/v9/internal/pool"
-	"github.com/redis/go-redis/v9/logging"
-	"github.com/redis/go-redis/v9/maintnotifications"
+	"github.com/hanzoai/kv-go/v9/internal/pool"
+	"github.com/hanzoai/kv-go/v9/logging"
+	"github.com/hanzoai/kv-go/v9/maintnotifications"
 )
 
 // mockNetConn implements net.Conn for testing

bench_test.go

@@ -10,7 +10,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/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/hanzoai/kv-go/v9"
 )
 
 type bitCountExpected struct {

command.go

@@ -12,11 +12,11 @@ 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/routing"
-	"github.com/redis/go-redis/v9/internal/util"
+	"github.com/hanzoai/kv-go/v9/internal"
+	"github.com/hanzoai/kv-go/v9/internal/hscan"
+	"github.com/hanzoai/kv-go/v9/internal/proto"
+	"github.com/hanzoai/kv-go/v9/internal/routing"
+	"github.com/hanzoai/kv-go/v9/internal/util"
 )
 
 // keylessCommands contains Redis commands that have empty key specifications (9th slot empty)

command_digest_test.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"testing"
 
-	"github.com/redis/go-redis/v9/internal/proto"
+	"github.com/hanzoai/kv-go/v9/internal/proto"
 )
 
 func TestDigestCmd(t *testing.T) {

command_policy_resolver.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"strings"
 
-	"github.com/redis/go-redis/v9/internal/routing"
+	"github.com/hanzoai/kv-go/v9/internal/routing"
 )
 
 type (

command_recorder_test.go

@@ -5,7 +5,7 @@ import (
 	"strings"
 	"sync"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // commandRecorder records the last N commands executed by a Redis client.

command_test.go

@@ -4,7 +4,7 @@ import (
 	"errors"
 	"time"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/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/hanzoai/kv-go/v9/internal"
 )
 
 // KeepTTL is a Redis KEEPTTL option to keep existing TTL, it requires your redis-server version >= 6.0,

commands_test.go

@@ -11,9 +11,9 @@ 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/redis/go-redis/v9/internal/routing"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/internal/proto"
+	"github.com/hanzoai/kv-go/v9/internal/routing"
 )
 
 type TimeValue struct {

digest_test.go

@@ -7,8 +7,8 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/helper"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/helper"
 )
 
 func init() {

doctests/bf_tutorial_test.go

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

doctests/bitfield_tutorial_test.go

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

doctests/bitmap_tutorial_test.go

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

doctests/cmds_generic_test.go

@@ -8,7 +8,7 @@ import (
 	"math"
 	"time"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HIDE_END

doctests/cmds_hash_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HIDE_END

doctests/cmds_list_test.go

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

doctests/cmds_servermgmt_test.go

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

doctests/cmds_set_test.go

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

doctests/cmds_sorted_set_test.go

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

doctests/cmds_string_test.go

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

doctests/cms_tutorial_test.go

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

doctests/cuckoo_tutorial_test.go

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

doctests/geo_index_test.go

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

doctests/geo_tutorial_test.go

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

doctests/hash_tutorial_test.go

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

doctests/hll_tutorial_test.go

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

doctests/home_json_example_test.go

@@ -9,7 +9,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // STEP_END

doctests/home_prob_dts_test.go

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

doctests/json_tutorial_test.go

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

doctests/list_tutorial_test.go

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

doctests/lpush_lrange_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_LPush_and_lrange() {

doctests/pipe_trans_example_test.go

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

doctests/query_agg_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_query_agg() {

doctests/query_em_test.go

@@ -8,7 +8,7 @@ import (
 	"slices"
 	"strings"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_query_em() {

doctests/query_ft_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_query_ft() {

doctests/query_geo_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_query_geo() {

doctests/query_range_test.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_query_range() {

doctests/search_quickstart_test.go

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

doctests/set_get_test.go

@@ -6,7 +6,7 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func ExampleClient_Set_and_get() {

doctests/sets_example_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HIDE_END

doctests/ss_tutorial_test.go

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

doctests/stream_tutorial_test.go

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

doctests/string_example_test.go

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

doctests/tdigest_tutorial_test.go

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

doctests/timeseries_tut_test.go

@@ -8,7 +8,7 @@ import (
 	"math"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HIDE_END

doctests/topk_tutorial_test.go

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

doctests/vec_set_test.go

@@ -7,7 +7,7 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HIDE_END

error.go

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

error_test.go

@@ -6,8 +6,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/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/internal/proto"
 )
 
 type testTimeout struct {

error_wrapping_test.go

@@ -8,8 +8,8 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/internal/proto"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/internal/proto"
 )
 
 // TestTypedErrorsWithHookWrapping demonstrates that typed errors work correctly

example/cluster-mget/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/cluster-mget
+module github.com/hanzoai/kv-go/example/cluster-mget
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.16.0
+require github.com/hanzoai/kv-go/v9 v9.16.0
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/cluster-mget/main.go

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

example/del-keys-without-ttl/go.mod

@@ -1,11 +1,11 @@
-module github.com/redis/go-redis/example/del-keys-without-ttl
+module github.com/hanzoai/kv-go/example/del-keys-without-ttl
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
 require (
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 	go.uber.org/zap v1.24.0
 )
 

example/del-keys-without-ttl/main.go

@@ -8,7 +8,7 @@ import (
 
 	"go.uber.org/zap"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 func main() {

example/digest-optimistic-locking/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/digest-optimistic-locking
+module github.com/hanzoai/kv-go/example/digest-optimistic-locking
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.18.0-beta.2
+require github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/digest-optimistic-locking/main.go

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/helper"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/helper"
 )
 
 func main() {

example/disable-maintnotifications/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/disable-maintnotifications
+module github.com/hanzoai/kv-go/example/disable-maintnotifications
 
 go 1.23
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.7.0
+require github.com/hanzoai/kv-go/v9 v9.7.0
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/disable-maintnotifications/main.go

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/maintnotifications"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/maintnotifications"
 )
 
 func main() {
@@ -140,5 +140,5 @@ func main() {
 	fmt.Println("  - You want to minimize client-side overhead")
 	fmt.Println("  - The Redis server doesn't support CLIENT MAINT_NOTIFICATIONS")
 	fmt.Printf("\nFor more information, see:\n")
-	fmt.Println("  https://github.com/redis/go-redis/tree/master/maintnotifications")
+	fmt.Println("  https://github.com/hanzoai/kv-go/tree/master/maintnotifications")
 }

example/hll/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/hll
+module github.com/hanzoai/kv-go/example/hll
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.18.0-beta.2
+require github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/hll/main.go

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

example/hset-struct/go.mod

@@ -1,12 +1,12 @@
-module github.com/redis/go-redis/example/scan-struct
+module github.com/hanzoai/kv-go/example/scan-struct
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
 require (
 	github.com/davecgh/go-spew v1.1.1
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 )
 
 require (

example/hset-struct/main.go

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

example/lua-scripting/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/lua-scripting
+module github.com/hanzoai/kv-go/example/lua-scripting
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.18.0-beta.2
+require github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/lua-scripting/main.go

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

example/maintnotifiations-pubsub/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/pubsub
+module github.com/hanzoai/kv-go/example/pubsub
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.11.0
+require github.com/hanzoai/kv-go/v9 v9.11.0
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/maintnotifiations-pubsub/main.go

@@ -8,9 +8,9 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/redis/go-redis/v9"
-	"github.com/redis/go-redis/v9/logging"
-	"github.com/redis/go-redis/v9/maintnotifications"
+	"github.com/hanzoai/kv-go/v9"
+	"github.com/hanzoai/kv-go/v9/logging"
+	"github.com/hanzoai/kv-go/v9/maintnotifications"
 )
 
 var ctx = context.Background()

example/otel/client.go

@@ -12,11 +12,11 @@ import (
 
 	"github.com/uptrace/uptrace-go/uptrace"
 
-	"github.com/redis/go-redis/extra/redisotel/v9"
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/extra/redisotel/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
-var tracer = otel.Tracer("github.com/redis/go-redis/example/otel")
+var tracer = otel.Tracer("github.com/hanzoai/kv-go/example/otel")
 
 func main() {
 	ctx := context.Background()

example/otel/go.mod

@@ -1,18 +1,18 @@
-module github.com/redis/go-redis/example/otel
+module github.com/hanzoai/kv-go/example/otel
 
 go 1.23.0
 
 toolchain go1.24.1
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-replace github.com/redis/go-redis/extra/redisotel/v9 => ../../extra/redisotel
+replace github.com/hanzoai/kv-go/extra/redisotel/v9 => ../../extra/redisotel
 
-replace github.com/redis/go-redis/extra/rediscmd/v9 => ../../extra/rediscmd
+replace github.com/hanzoai/kv-go/extra/rediscmd/v9 => ../../extra/rediscmd
 
 require (
-	github.com/redis/go-redis/extra/redisotel/v9 v9.18.0-beta.2
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/extra/redisotel/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 	github.com/uptrace/uptrace-go v1.21.0
 	go.opentelemetry.io/otel v1.22.0
 )
@@ -25,7 +25,7 @@ require (
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
-	github.com/redis/go-redis/extra/rediscmd/v9 v9.18.0-beta.2 // indirect
+	github.com/hanzoai/kv-go/extra/rediscmd/v9 v9.18.0-beta.2 // indirect
 	go.opentelemetry.io/contrib/instrumentation/runtime v0.46.1 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.44.0 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.21.0 // indirect

example/redis-bloom/go.mod

@@ -1,10 +1,10 @@
-module github.com/redis/go-redis/example/redis-bloom
+module github.com/hanzoai/kv-go/example/redis-bloom
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-require github.com/redis/go-redis/v9 v9.18.0-beta.2
+require github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 
 require (
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect

example/redis-bloom/main.go

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

example/scan-struct/go.mod

@@ -1,12 +1,12 @@
-module github.com/redis/go-redis/example/scan-struct
+module github.com/hanzoai/kv-go/example/scan-struct
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
 require (
 	github.com/davecgh/go-spew v1.1.1
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 )
 
 require (

example/scan-struct/main.go

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

example_instrumentation_test.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"net"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 type redisHook struct{}

example_test.go

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

export_test.go

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

extra/rediscensus/go.mod

@@ -1,14 +1,14 @@
-module github.com/redis/go-redis/extra/rediscensus/v9
+module github.com/hanzoai/kv-go/extra/rediscensus/v9
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
+replace github.com/hanzoai/kv-go/extra/rediscmd/v9 => ../rediscmd
 
 require (
-	github.com/redis/go-redis/extra/rediscmd/v9 v9.18.0-beta.2
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/extra/rediscmd/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 	go.opencensus.io v0.24.0
 )
 

extra/rediscensus/rediscensus.go

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

extra/rediscmd/go.mod

@@ -1,13 +1,13 @@
-module github.com/redis/go-redis/extra/rediscmd/v9
+module github.com/hanzoai/kv-go/extra/rediscmd/v9
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
 require (
 	github.com/bsm/ginkgo/v2 v2.12.0
 	github.com/bsm/gomega v1.27.10
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 )
 
 require (

extra/rediscmd/rediscmd.go

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

extra/redisotel/config.go

@@ -3,7 +3,7 @@ package redisotel
 import (
 	"strings"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"

extra/redisotel/go.mod

@@ -1,14 +1,14 @@
-module github.com/redis/go-redis/extra/redisotel/v9
+module github.com/hanzoai/kv-go/extra/redisotel/v9
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
-replace github.com/redis/go-redis/extra/rediscmd/v9 => ../rediscmd
+replace github.com/hanzoai/kv-go/extra/rediscmd/v9 => ../rediscmd
 
 require (
-	github.com/redis/go-redis/extra/rediscmd/v9 v9.18.0-beta.2
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/extra/rediscmd/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 	go.opentelemetry.io/otel v1.22.0
 	go.opentelemetry.io/otel/metric v1.22.0
 	go.opentelemetry.io/otel/sdk v1.22.0

extra/redisotel/metrics.go

@@ -12,7 +12,7 @@ import (
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 type metricsState struct {

extra/redisotel/tracing.go

@@ -13,12 +13,12 @@ import (
 	semconv "go.opentelemetry.io/otel/semconv/v1.24.0"
 	"go.opentelemetry.io/otel/trace"
 
-	"github.com/redis/go-redis/extra/rediscmd/v9"
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/extra/rediscmd/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 const (
-	instrumName = "github.com/redis/go-redis/extra/redisotel"
+	instrumName = "github.com/hanzoai/kv-go/extra/redisotel"
 )
 
 func InstrumentTracing(rdb redis.UniversalClient, opts ...TracingOption) error {
@@ -115,7 +115,7 @@ func (th *tracingHook) ProcessHook(hook redis.ProcessHook) redis.ProcessHook {
 
 		attrs := make([]attribute.KeyValue, 0, 8)
 		if th.conf.callerEnabled {
-			fn, file, line := funcFileLine("github.com/redis/go-redis")
+			fn, file, line := funcFileLine("github.com/hanzoai/kv-go")
 			attrs = append(attrs,
 				semconv.CodeFunction(fn),
 				semconv.CodeFilepath(file),
@@ -157,7 +157,7 @@ func (th *tracingHook) ProcessPipelineHook(
 		)
 
 		if th.conf.callerEnabled {
-			fn, file, line := funcFileLine("github.com/redis/go-redis")
+			fn, file, line := funcFileLine("github.com/hanzoai/kv-go")
 			attrs = append(attrs,
 				semconv.CodeFunction(fn),
 				semconv.CodeFilepath(file),

extra/redisotel/tracing_test.go

@@ -16,7 +16,7 @@ import (
 	sdktrace "go.opentelemetry.io/otel/sdk/trace"
 	"go.opentelemetry.io/otel/trace"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 type providerFunc func(name string, opts ...trace.TracerOption) trace.TracerProvider

extra/redisprometheus/collector.go

@@ -3,7 +3,7 @@ package redisprometheus
 import (
 	"github.com/prometheus/client_golang/prometheus"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // StatGetter provides a method to get pool statistics.

extra/redisprometheus/go.mod

@@ -1,12 +1,12 @@
-module github.com/redis/go-redis/extra/redisprometheus/v9
+module github.com/hanzoai/kv-go/extra/redisprometheus/v9
 
 go 1.21
 
-replace github.com/redis/go-redis/v9 => ../..
+replace github.com/hanzoai/kv-go/v9 => ../..
 
 require (
 	github.com/prometheus/client_golang v1.14.0
-	github.com/redis/go-redis/v9 v9.18.0-beta.2
+	github.com/hanzoai/kv-go/v9 v9.18.0-beta.2
 )
 
 require (

fuzz/fuzz.go

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

generic_commands.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/redis/go-redis/v9/internal/hashtag"
+	"github.com/hanzoai/kv-go/v9/internal/hashtag"
 )
 
 type GenericCmdable interface {

go.mod

@@ -1,4 +1,4 @@
-module github.com/redis/go-redis/v9
+module github.com/hanzoai/kv-go/v9
 
 go 1.21
 
@@ -10,10 +10,7 @@ require (
 	github.com/zeebo/xxh3 v1.0.2
 )
 
-require (
-	github.com/dgryski/go-xxh3 v0.0.0-20190317160639-1675ae87ac49
-	go.uber.org/atomic v1.11.0
-)
+require go.uber.org/atomic v1.11.0
 
 require github.com/klauspost/cpuid/v2 v2.0.9 // indirect
 

go.sum

@@ -8,8 +8,6 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
-github.com/dgryski/go-xxh3 v0.0.0-20190317160639-1675ae87ac49 h1:E2VBGIi+PvI5Nl6ddS5W0RVtoJRfpRVaunUC8Q/NOJI=
-github.com/dgryski/go-xxh3 v0.0.0-20190317160639-1675ae87ac49/go.mod h1:GEXsXVlzo0o2VPFcPwTUM6ssCHA4xn4fp8sdopBufVU=
 github.com/klauspost/cpuid/v2 v2.0.9 h1:lgaqFMSdTdQYdZ04uHyN2d/eKdOMyi2YLSvlQIBFYa4=
 github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

hash_commands.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"time"
 
-	"github.com/redis/go-redis/v9/internal/hashtag"
+	"github.com/hanzoai/kv-go/v9/internal/hashtag"
 )
 
 type HashCmdable interface {

helper/helper.go

@@ -1,7 +1,7 @@
 package helper
 
 import (
-	"github.com/redis/go-redis/v9/internal/util"
+	"github.com/hanzoai/kv-go/v9/internal/util"
 	"github.com/zeebo/xxh3"
 )
 

hset_benchmark_test.go

@@ -7,7 +7,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/redis/go-redis/v9"
+	"github.com/hanzoai/kv-go/v9"
 )
 
 // HSET Benchmark Tests

internal/arg.go

@@ -5,7 +5,7 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/redis/go-redis/v9/internal/util"
+	"github.com/hanzoai/kv-go/v9/internal/util"
 )
 
 func AppendArg(b []byte, v interface{}) []byte {

internal/auth/streaming/conn_reauth_credentials_listener.go

@@ -1,8 +1,8 @@
 package streaming
 
 import (
-	"github.com/redis/go-redis/v9/auth"
-	"github.com/redis/go-redis/v9/internal/pool"
+	"github.com/hanzoai/kv-go/v9/auth"
+	"github.com/hanzoai/kv-go/v9/internal/pool"
 )
 
 // ConnReAuthCredentialsListener is a credentials listener for a specific connection

internal/auth/streaming/cred_listeners.go

@@ -3,7 +3,7 @@ package streaming
 import (
 	"sync"
 
-	"github.com/redis/go-redis/v9/auth"
+	"github.com/hanzoai/kv-go/v9/auth"
 )
 
 // CredentialsListeners is a thread-safe collection of credentials listeners

internal/auth/streaming/manager.go

@@ -4,8 +4,8 @@ import (
 	"errors"
 	"time"
 
-	"github.com/redis/go-redis/v9/auth"
-	"github.com/redis/go-redis/v9/internal/pool"
+	"github.com/hanzoai/kv-go/v9/auth"
+	"github.com/hanzoai/kv-go/v9/internal/pool"
 )
 
 // Manager coordinates streaming credentials and re-authentication for a connection pool.