diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml new file mode 100644 index 00000000..b62db843 --- /dev/null +++ b/.github/workflows/build.yml @@ -0,0 +1,59 @@ +name: Go Modules Test + +on: [push] + +jobs: + prepare-matrix: + runs-on: ubuntu-latest + outputs: + matrix: ${{ steps.set-matrix.outputs.matrix }} + steps: + - uses: actions/checkout@v4 + - id: set-matrix + run: | + echo "matrix=$(find . -maxdepth 2 -type f -name 'go.mod' | xargs -n 1 dirname | sort -u | { echo "e2e"; cat; } | jq -R -s -c 'split("\n")[:-1]')" >> $GITHUB_OUTPUT + + build: + needs: prepare-matrix + runs-on: ubuntu-latest + strategy: + fail-fast: false + matrix: + module: ${{fromJson(needs.prepare-matrix.outputs.matrix)}} + steps: + - name: Checkout code + uses: actions/checkout@v4 + + - name: Set up Go + uses: actions/setup-go@v5 + with: + go-version: '1.21.0' + + - name: Test Module + run: | + module_path=${{ matrix.module }} + if [ "$module_path" == "." ]; then + list=$(go list ./...) + echo "Test Packages: $list" + for n in {1..5}; do + ./dockertest.sh -skip 'Integration' $list && break + done + elif [ "$module_path" == "e2e" ]; then + list=$(go list ./...) + echo "Test Packages: $list" + for n in {1..5}; do + ./dockertest.sh -run 'Integration' $list && break + done + else + cd $module_path + list=$(go list ./...) + echo "Test Packages: $list" + for n in {1..5}; do + ../dockertest.sh $list && break + done + fi + + - uses: codecov/codecov-action@v4 + with: + token: ${{ secrets.CODECOV_TOKEN }} + verbose: true diff --git a/README.md b/README.md index 42b98fef..045c64e2 100644 --- a/README.md +++ b/README.md @@ -1,9 +1,9 @@ # valkey-go -[![Go Reference](https://pkg.go.dev/badge/github.com/rueian/valkey-go.svg)](https://pkg.go.dev/github.com/rueian/valkey-go) -[![CircleCI](https://dl.circleci.com/status-badge/img/gh/rueian/valkey-go/tree/main.svg?style=shield)](https://dl.circleci.com/status-badge/redirect/gh/rueian/valkey-go/tree/main) -[![Go Report Card](https://goreportcard.com/badge/github.com/rueian/valkey-go)](https://goreportcard.com/report/github.com/rueian/valkey-go) -[![codecov](https://codecov.io/gh/rueian/valkey-go/branch/main/graph/badge.svg?token=934zeTPaTc)](https://codecov.io/gh/rueian/valkey-go) +[![Go Reference](https://pkg.go.dev/badge/github.com/valkey-io/valkey-go.svg)](https://pkg.go.dev/github.com/valkey-io/valkey-go) +[![CircleCI](https://dl.circleci.com/status-badge/img/gh/valkey-io/valkey-go/tree/main.svg?style=shield)](https://dl.circleci.com/status-badge/redirect/gh/valkey-io/valkey-go/tree/main) +[![Go Report Card](https://goreportcard.com/badge/github.com/valkey-io/valkey-go)](https://goreportcard.com/report/github.com/valkey-io/valkey-go) +[![codecov](https://codecov.io/gh/valkey-io/valkey-go/branch/main/graph/badge.svg?token=26SfMHyUJ3)](https://codecov.io/gh/valkey-io/valkey-go) A fast Golang Valkey client that does auto pipelining and supports server-assisted client-side caching. @@ -31,7 +31,7 @@ package main import ( "context" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func main() { @@ -49,7 +49,7 @@ func main() { } ``` -Checkout more examples: [Command Response Cheatsheet](https://github.com/rueian/valkey-go#command-response-cheatsheet) +Checkout more examples: [Command Response Cheatsheet](https://github.com/valkey-io/valkey-go#command-response-cheatsheet) ## Developer Friendly Command Builder @@ -181,7 +181,7 @@ Otherwise, their client-side cache will not be invalidated by valkey. ### Client Side Caching with Cache Aside Pattern Cache-Aside is a widely used caching strategy. -[valkeyaside](https://github.com/rueian/valkey-go/blob/main/valkeyaside/README.md) can help you cache data into your client-side cache backed by Valkey. For example: +[valkeyaside](https://github.com/valkey-io/valkey-go/blob/main/valkeyaside/README.md) can help you cache data into your client-side cache backed by Valkey. For example: ```go client, err := valkeyaside.NewClient(valkeyaside.ClientOption{ @@ -200,7 +200,7 @@ val, err := client.Get(context.Background(), time.Minute, "mykey", func(ctx cont // ... ``` -Please refer to the full example at [valkeyaside](https://github.com/rueian/valkey-go/blob/main/valkeyaside/README.md). +Please refer to the full example at [valkeyaside](https://github.com/valkey-io/valkey-go/blob/main/valkeyaside/README.md). ### Disable Client Side Caching @@ -539,7 +539,7 @@ if err := valkey.DecodeSliceOfJSON(client.Do(ctx, client.B().Mget().Key("user1") ## Contributing -Contributions are welcome, including [issues](https://github.com/rueian/valkey-go/issues), [pull requests](https://github.com/rueian/valkey-go/pulls), and [discussions](https://github.com/rueian/valkey-go/discussions). +Contributions are welcome, including [issues](https://github.com/valkey-io/valkey-go/issues), [pull requests](https://github.com/valkey-io/valkey-go/pulls), and [discussions](https://github.com/valkey-io/valkey-go/discussions). Contributions mean a lot to us and help us improve this library and the community! ### Generate command builders diff --git a/client.go b/client.go index 447b2439..5db625c8 100644 --- a/client.go +++ b/client.go @@ -6,7 +6,7 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) type singleClient struct { diff --git a/cluster.go b/cluster.go index 81106f33..408409f4 100644 --- a/cluster.go +++ b/cluster.go @@ -13,8 +13,8 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go/internal/cmds" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/util" ) // ErrNoSlot indicates that there is no valkey node owns the key slot. diff --git a/cmds.go b/cmds.go index b702156f..c24255ee 100644 --- a/cmds.go +++ b/cmds.go @@ -1,6 +1,6 @@ package valkey -import "github.com/rueian/valkey-go/internal/cmds" +import "github.com/valkey-io/valkey-go/internal/cmds" // Builder represents a command builder. It should only be created from the client.B() method. type Builder = cmds.Builder diff --git a/go.mod b/go.mod index da3a1bc3..2b11c36c 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/rueian/valkey-go +module github.com/valkey-io/valkey-go go 1.20 diff --git a/helper.go b/helper.go index 8fa6b509..1b7a57ab 100644 --- a/helper.go +++ b/helper.go @@ -5,8 +5,8 @@ import ( "errors" "time" - intl "github.com/rueian/valkey-go/internal/cmds" - "github.com/rueian/valkey-go/internal/util" + intl "github.com/valkey-io/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/util" ) type mgetcachecmds struct { diff --git a/lru.go b/lru.go index 15b2f19b..f4f0aa8d 100644 --- a/lru.go +++ b/lru.go @@ -8,7 +8,7 @@ import ( "time" "unsafe" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) const ( diff --git a/lru_test.go b/lru_test.go index 000fa865..4cb327fb 100644 --- a/lru_test.go +++ b/lru_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) const PTTL = 50 diff --git a/lua.go b/lua.go index bbab773f..857110b1 100644 --- a/lua.go +++ b/lua.go @@ -7,7 +7,7 @@ import ( "runtime" "sync/atomic" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go/internal/util" ) // NewLuaScript creates a Lua instance whose Lua.Exec uses EVALSHA and EVAL. diff --git a/lua_test.go b/lua_test.go index bd3e598e..af333977 100644 --- a/lua_test.go +++ b/lua_test.go @@ -10,7 +10,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) func TestNewLuaScriptOnePass(t *testing.T) { diff --git a/message.go b/message.go index 12c07228..32d39efb 100644 --- a/message.go +++ b/message.go @@ -9,7 +9,7 @@ import ( "time" "unsafe" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go/internal/util" ) const messageStructSize = int(unsafe.Sizeof(ValkeyMessage{})) diff --git a/mock/README.md b/mock/README.md index c35b456b..19dea5a5 100644 --- a/mock/README.md +++ b/mock/README.md @@ -17,7 +17,7 @@ import ( "testing" "go.uber.org/mock/gomock" - "github.com/rueian/valkey-go/mock" + "github.com/valkey-io/valkey-go/mock" ) func TestWithValkey(t *testing.T) { @@ -53,7 +53,7 @@ import ( "testing" "go.uber.org/mock/gomock" - "github.com/rueian/valkey-go/mock" + "github.com/valkey-io/valkey-go/mock" ) func TestWithValkeyReceive(t *testing.T) { diff --git a/mock/client.go b/mock/client.go index a27abd10..8f0f75ee 100644 --- a/mock/client.go +++ b/mock/client.go @@ -5,8 +5,8 @@ import ( "reflect" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/internal/cmds" "go.uber.org/mock/gomock" ) diff --git a/mock/client_test.go b/mock/client_test.go index fd96a32a..e9f95ed4 100644 --- a/mock/client_test.go +++ b/mock/client_test.go @@ -7,7 +7,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" "go.uber.org/mock/gomock" ) diff --git a/mock/go.mod b/mock/go.mod index 5ce2ed4f..a622bec5 100644 --- a/mock/go.mod +++ b/mock/go.mod @@ -1,11 +1,11 @@ -module github.com/rueian/valkey-go/mock +module github.com/valkey-io/valkey-go/mock go 1.20 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 go.uber.org/mock v0.3.0 ) diff --git a/mock/match.go b/mock/match.go index c58b5f74..573d2ae6 100644 --- a/mock/match.go +++ b/mock/match.go @@ -4,7 +4,7 @@ import ( "fmt" "strings" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" "go.uber.org/mock/gomock" ) diff --git a/mock/match_test.go b/mock/match_test.go index eb8b4fb4..d11e017b 100644 --- a/mock/match_test.go +++ b/mock/match_test.go @@ -5,8 +5,8 @@ import ( "strings" "testing" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/internal/cmds" "go.uber.org/mock/gomock" ) diff --git a/mock/result.go b/mock/result.go index ae08be21..083f5e4c 100644 --- a/mock/result.go +++ b/mock/result.go @@ -11,7 +11,7 @@ import ( "time" "unsafe" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func Result(val valkey.ValkeyMessage) valkey.ValkeyResult { diff --git a/mock/result_test.go b/mock/result_test.go index a79bf79b..9849b374 100644 --- a/mock/result_test.go +++ b/mock/result_test.go @@ -8,7 +8,7 @@ import ( "strings" "testing" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func TestValkeyString(t *testing.T) { diff --git a/mux.go b/mux.go index dc4c735a..51d70934 100644 --- a/mux.go +++ b/mux.go @@ -9,8 +9,8 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go/internal/cmds" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/util" ) type connFn func(dst string, opt *ClientOption) conn diff --git a/mux_test.go b/mux_test.go index 2378fa73..9af85713 100644 --- a/mux_test.go +++ b/mux_test.go @@ -13,7 +13,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) func setupMux(wires []*mockWire) (conn *mux, checkClean func(t *testing.T)) { diff --git a/om/README.md b/om/README.md index 90d990aa..e1ce4881 100644 --- a/om/README.md +++ b/om/README.md @@ -10,8 +10,8 @@ import ( "fmt" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/om" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/om" ) type Example struct { diff --git a/om/conv.go b/om/conv.go index 976ae5b7..a348ba87 100644 --- a/om/conv.go +++ b/om/conv.go @@ -7,7 +7,7 @@ import ( "strconv" "unsafe" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func newHashConvFactory(t reflect.Type, schema schema) *hashConvFactory { diff --git a/om/cursor.go b/om/cursor.go index 6dd75ab7..2aeb4f09 100644 --- a/om/cursor.go +++ b/om/cursor.go @@ -4,7 +4,7 @@ import ( "context" "errors" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var EndOfCursor = errors.New("end of cursor") diff --git a/om/cursor_test.go b/om/cursor_test.go index 528611a2..fdfdd597 100644 --- a/om/cursor_test.go +++ b/om/cursor_test.go @@ -5,7 +5,7 @@ import ( "strconv" "testing" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) type Book struct { diff --git a/om/go.mod b/om/go.mod index 64f2e6f0..d96f46fb 100644 --- a/om/go.mod +++ b/om/go.mod @@ -1,12 +1,12 @@ -module github.com/rueian/valkey-go/om +module github.com/valkey-io/valkey-go/om go 1.20 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( github.com/oklog/ulid/v2 v2.1.0 - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 ) require golang.org/x/sys v0.19.0 // indirect diff --git a/om/hash.go b/om/hash.go index 44ec7e15..e6b51160 100644 --- a/om/hash.go +++ b/om/hash.go @@ -6,7 +6,7 @@ import ( "strconv" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) // NewHashRepository creates an HashRepository. diff --git a/om/hash_test.go b/om/hash_test.go index b93a501d..104d2e15 100644 --- a/om/hash_test.go +++ b/om/hash_test.go @@ -10,7 +10,7 @@ import ( "time" "github.com/oklog/ulid/v2" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) type HashTestStruct struct { diff --git a/om/json.go b/om/json.go index 94b9746c..2f2cfbb3 100644 --- a/om/json.go +++ b/om/json.go @@ -8,7 +8,7 @@ import ( "strings" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) // NewJSONRepository creates an JSONRepository. diff --git a/om/json_test.go b/om/json_test.go index c206440d..ba19c4f0 100644 --- a/om/json_test.go +++ b/om/json_test.go @@ -7,7 +7,7 @@ import ( "time" "github.com/oklog/ulid/v2" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) type JSONTestStruct struct { diff --git a/om/repo.go b/om/repo.go index da0548f8..b59f3357 100644 --- a/om/repo.go +++ b/om/repo.go @@ -5,8 +5,8 @@ import ( "errors" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/internal/cmds" ) type ( diff --git a/om/repo_test.go b/om/repo_test.go index f2329082..908bb0dc 100644 --- a/om/repo_test.go +++ b/om/repo_test.go @@ -3,7 +3,7 @@ package om import ( "testing" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func setup(t *testing.T) valkey.Client { diff --git a/pipe.go b/pipe.go index 9348eefc..994d651b 100644 --- a/pipe.go +++ b/pipe.go @@ -16,8 +16,8 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go/internal/cmds" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/util" ) const LibName = "valkey" diff --git a/pipe_test.go b/pipe_test.go index 6189639a..72639501 100644 --- a/pipe_test.go +++ b/pipe_test.go @@ -16,7 +16,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) type valkeyExpect struct { diff --git a/ring_test.go b/ring_test.go index 13f33c76..1d98e8e8 100644 --- a/ring_test.go +++ b/ring_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) //gocyclo:ignore diff --git a/sentinel.go b/sentinel.go index 8a4dd902..fef65abf 100644 --- a/sentinel.go +++ b/sentinel.go @@ -14,7 +14,7 @@ import ( "math/rand" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) func newSentinelClient(opt *ClientOption, connFn connFn) (client *sentinelClient, err error) { diff --git a/sentinel_test.go b/sentinel_test.go index 0d5a7a7f..eb559754 100644 --- a/sentinel_test.go +++ b/sentinel_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/cmds" ) //gocyclo:ignore diff --git a/valkeyaside/README.md b/valkeyaside/README.md index 6573c033..a0be3126 100644 --- a/valkeyaside/README.md +++ b/valkeyaside/README.md @@ -12,7 +12,7 @@ And if using a locking mechanism, how to get notified when a lock is released? I Thankfully, the above issues can be addressed better with the client-side caching along with the following additional benefits: * Avoiding unnecessary network round trips. Valkey will proactively invalidate the client-side cache. -* Avoiding Cache Stampede by locking keys with the client-side caching, the same technique used in [valkeylock](https://github.com/rueian/valkey-go/tree/main/valkeylock). Only the first cache missed call can update the cache and others will wait for notifications. +* Avoiding Cache Stampede by locking keys with the client-side caching, the same technique used in [valkeylock](https://github.com/valkey-io/valkey-go/tree/main/valkeylock). Only the first cache missed call can update the cache and others will wait for notifications. ## Example @@ -24,8 +24,8 @@ import ( "database/sql" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeyaside" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeyaside" ) func main() { diff --git a/valkeyaside/aside.go b/valkeyaside/aside.go index 85673b98..585b252d 100644 --- a/valkeyaside/aside.go +++ b/valkeyaside/aside.go @@ -8,7 +8,7 @@ import ( "time" "github.com/oklog/ulid/v2" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) type ClientOption struct { diff --git a/valkeyaside/aside_test.go b/valkeyaside/aside_test.go index d5a39f15..210a35e4 100644 --- a/valkeyaside/aside_test.go +++ b/valkeyaside/aside_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var addr = []string{"127.0.0.1:6379"} diff --git a/valkeyaside/go.mod b/valkeyaside/go.mod index 565291e5..618d793a 100644 --- a/valkeyaside/go.mod +++ b/valkeyaside/go.mod @@ -1,12 +1,12 @@ -module github.com/rueian/valkey-go/valkeyaside +module github.com/valkey-io/valkey-go/valkeyaside go 1.20 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( github.com/oklog/ulid/v2 v2.1.0 - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 ) require golang.org/x/sys v0.19.0 // indirect diff --git a/valkeycompat/README.md b/valkeycompat/README.md index fc5057fc..eb7cd4b5 100644 --- a/valkeycompat/README.md +++ b/valkeycompat/README.md @@ -20,8 +20,8 @@ package main import ( "context" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeycompat" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeycompat" ) func main() { diff --git a/valkeycompat/adapter.go b/valkeycompat/adapter.go index 19cb34bb..930718fc 100644 --- a/valkeycompat/adapter.go +++ b/valkeycompat/adapter.go @@ -38,9 +38,9 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/internal/cmds" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/internal/cmds" + "github.com/valkey-io/valkey-go/internal/util" ) const KeepTTL = -1 diff --git a/valkeycompat/adapter_test.go b/valkeycompat/adapter_test.go index 45e06785..ed7b0843 100644 --- a/valkeycompat/adapter_test.go +++ b/valkeycompat/adapter_test.go @@ -39,7 +39,7 @@ import ( . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) type TimeValue struct { diff --git a/valkeycompat/command.go b/valkeycompat/command.go index 0967bdde..72c2f1e3 100644 --- a/valkeycompat/command.go +++ b/valkeycompat/command.go @@ -34,8 +34,8 @@ import ( "strconv" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/internal/util" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/internal/util" ) type baseCmd[T any] struct { diff --git a/valkeycompat/go.mod b/valkeycompat/go.mod index d42f3e62..86185606 100644 --- a/valkeycompat/go.mod +++ b/valkeycompat/go.mod @@ -1,13 +1,13 @@ -module github.com/rueian/valkey-go/valkeycompat +module github.com/valkey-io/valkey-go/valkeycompat go 1.20 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( github.com/onsi/ginkgo/v2 v2.15.0 github.com/onsi/gomega v1.31.1 - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 ) require ( diff --git a/valkeyhook/README.md b/valkeyhook/README.md index 1bc376e2..85f66159 100644 --- a/valkeyhook/README.md +++ b/valkeyhook/README.md @@ -13,8 +13,8 @@ import ( "context" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeyhook" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeyhook" ) type hook struct{} diff --git a/valkeyhook/go.mod b/valkeyhook/go.mod index 88cd3d34..395d2c2e 100644 --- a/valkeyhook/go.mod +++ b/valkeyhook/go.mod @@ -1,15 +1,15 @@ -module github.com/rueian/valkey-go/valkeyhook +module github.com/valkey-io/valkey-go/valkeyhook go 1.20 replace ( - github.com/rueian/valkey-go => ../ - github.com/rueian/valkey-go/mock => ../mock + github.com/valkey-io/valkey-go => ../ + github.com/valkey-io/valkey-go/mock => ../mock ) require ( - github.com/rueian/valkey-go v1.0.35 - github.com/rueian/valkey-go/mock v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 + github.com/valkey-io/valkey-go/mock v1.0.35 go.uber.org/mock v0.4.0 ) diff --git a/valkeyhook/hook.go b/valkeyhook/hook.go index bc3c3304..5fbbf950 100644 --- a/valkeyhook/hook.go +++ b/valkeyhook/hook.go @@ -5,7 +5,7 @@ import ( "time" "unsafe" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var _ valkey.Client = (*hookclient)(nil) diff --git a/valkeyhook/hook_test.go b/valkeyhook/hook_test.go index 576ea4cd..0b001286 100644 --- a/valkeyhook/hook_test.go +++ b/valkeyhook/hook_test.go @@ -7,8 +7,8 @@ import ( "testing" "time" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/mock" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/mock" "go.uber.org/mock/gomock" ) diff --git a/valkeylock/README.md b/valkeylock/README.md index 61adca81..acb74bec 100644 --- a/valkeylock/README.md +++ b/valkeylock/README.md @@ -7,8 +7,8 @@ package main import ( "context" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeylock" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeylock" ) func main() { diff --git a/valkeylock/lock.go b/valkeylock/lock.go index d7d49715..423f220e 100644 --- a/valkeylock/lock.go +++ b/valkeylock/lock.go @@ -11,7 +11,7 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var sources sync.Pool diff --git a/valkeylock/lock_test.go b/valkeylock/lock_test.go index 635d9556..83b05803 100644 --- a/valkeylock/lock_test.go +++ b/valkeylock/lock_test.go @@ -9,7 +9,7 @@ import ( "testing" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var address = []string{"127.0.0.1:6379"} diff --git a/valkeyotel/README.md b/valkeyotel/README.md index bf2d990d..755602bf 100644 --- a/valkeyotel/README.md +++ b/valkeyotel/README.md @@ -15,8 +15,8 @@ Client side caching metrics: package main import ( - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeyotel" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeyotel" ) func main() { diff --git a/valkeyotel/go.mod b/valkeyotel/go.mod index 90bfe6db..31e0d69c 100644 --- a/valkeyotel/go.mod +++ b/valkeyotel/go.mod @@ -1,11 +1,11 @@ -module github.com/rueian/valkey-go/valkeyotel +module github.com/valkey-io/valkey-go/valkeyotel go 1.20 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 go.opentelemetry.io/otel v1.24.0 go.opentelemetry.io/otel/metric v1.24.0 go.opentelemetry.io/otel/sdk v1.24.0 diff --git a/valkeyotel/metrics.go b/valkeyotel/metrics.go index 51107fac..d65570fc 100644 --- a/valkeyotel/metrics.go +++ b/valkeyotel/metrics.go @@ -7,7 +7,7 @@ import ( "sync/atomic" "time" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" "go.opentelemetry.io/otel" "go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/metric" diff --git a/valkeyotel/metrics_test.go b/valkeyotel/metrics_test.go index 8532917a..7ae1b07f 100644 --- a/valkeyotel/metrics_test.go +++ b/valkeyotel/metrics_test.go @@ -11,7 +11,7 @@ import ( "go.opentelemetry.io/otel/sdk/metric" "go.opentelemetry.io/otel/sdk/metric/metricdata" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func TestNewClient(t *testing.T) { diff --git a/valkeyotel/trace.go b/valkeyotel/trace.go index 2001e681..b9497862 100644 --- a/valkeyotel/trace.go +++ b/valkeyotel/trace.go @@ -10,11 +10,11 @@ import ( "go.opentelemetry.io/otel/metric" "go.opentelemetry.io/otel/trace" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var ( - name = "github.com/rueian/valkey-go" + name = "github.com/valkey-io/valkey-go" kind = trace.WithSpanKind(trace.SpanKindClient) dbattr = attribute.String("db.system", "valkey") dbstmt = attribute.Key("db.statement") diff --git a/valkeyotel/trace_test.go b/valkeyotel/trace_test.go index bd1fd905..b8e23c57 100644 --- a/valkeyotel/trace_test.go +++ b/valkeyotel/trace_test.go @@ -19,7 +19,7 @@ import ( metricapi "go.opentelemetry.io/otel/metric" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var ( diff --git a/valkeyprob/README.md b/valkeyprob/README.md index ea21baed..661b8aa4 100644 --- a/valkeyprob/README.md +++ b/valkeyprob/README.md @@ -20,8 +20,8 @@ import ( "context" "fmt" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeyprob" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeyprob" ) func main() { @@ -74,8 +74,8 @@ import ( "context" "fmt" - "github.com/rueian/valkey-go" - "github.com/rueian/valkey-go/valkeyprob" + "github.com/valkey-io/valkey-go" + "github.com/valkey-io/valkey-go/valkeyprob" ) func main() { diff --git a/valkeyprob/bloomfilter.go b/valkeyprob/bloomfilter.go index 4681f102..019e670f 100644 --- a/valkeyprob/bloomfilter.go +++ b/valkeyprob/bloomfilter.go @@ -6,7 +6,7 @@ import ( "math" "strconv" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) const ( diff --git a/valkeyprob/bloomfilter_test.go b/valkeyprob/bloomfilter_test.go index d6ff0a3b..03dd0cd0 100644 --- a/valkeyprob/bloomfilter_test.go +++ b/valkeyprob/bloomfilter_test.go @@ -7,7 +7,7 @@ import ( "strconv" "testing" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var address = []string{"127.0.0.1:7001", "127.0.0.1:7002", "127.0.0.1:7003"} diff --git a/valkeyprob/countingbloomfilter.go b/valkeyprob/countingbloomfilter.go index 2ccb65a6..babe6f36 100644 --- a/valkeyprob/countingbloomfilter.go +++ b/valkeyprob/countingbloomfilter.go @@ -6,7 +6,7 @@ import ( "math" "strconv" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) var ( diff --git a/valkeyprob/countingbloomfilter_test.go b/valkeyprob/countingbloomfilter_test.go index 34655cb5..933240b8 100644 --- a/valkeyprob/countingbloomfilter_test.go +++ b/valkeyprob/countingbloomfilter_test.go @@ -7,7 +7,7 @@ import ( "strconv" "testing" - "github.com/rueian/valkey-go" + "github.com/valkey-io/valkey-go" ) func TestNewCountingBloomFilter(t *testing.T) { diff --git a/valkeyprob/go.mod b/valkeyprob/go.mod index 0679ce6a..4c591fe4 100644 --- a/valkeyprob/go.mod +++ b/valkeyprob/go.mod @@ -1,11 +1,11 @@ -module github.com/rueian/valkey-go/valkeyprob +module github.com/valkey-io/valkey-go/valkeyprob go 1.20.0 -replace github.com/rueian/valkey-go => ../ +replace github.com/valkey-io/valkey-go => ../ require ( - github.com/rueian/valkey-go v1.0.35 + github.com/valkey-io/valkey-go v1.0.35 github.com/twmb/murmur3 v1.1.8 )