diff --git a/README.md b/README.md index e01f645..e0b9f41 100644 --- a/README.md +++ b/README.md @@ -2,14 +2,14 @@ логотип go vshard router -[![Go Reference](https://pkg.go.dev/badge/github.com/KaymeKaydex/go-vshard-router.svg)](https://pkg.go.dev/github.com/KaymeKaydex/go-vshard-router) +[![Go Reference](https://pkg.go.dev/badge/github.com/tarantool/go-vshard-router.svg)](https://pkg.go.dev/github.com/tarantool/go-vshard-router) [![Actions Status][actions-badge]][actions-url] -[![Go Report Card](https://goreportcard.com/badge/github.com/KaymeKaydex/go-vshard-router)](https://goreportcard.com/report/github.com/KaymeKaydex/go-vshard-router) +[![Go Report Card](https://goreportcard.com/badge/github.com/tarantool/go-vshard-router)](https://goreportcard.com/report/github.com/tarantool/go-vshard-router) [![codecov](https://codecov.io/gh/KaymeKaydex/go-vshard-router/graph/badge.svg?token=WLRWE97IT1)](https://codecov.io/gh/KaymeKaydex/go-vshard-router) [![License](http://img.shields.io/badge/license-mit-blue.svg?style=flat-square)](https://raw.githubusercontent.com/KaymeKaydex/go-vshard-router/master/LICENSE) Translations: -- [Русский](https://github.com/KaymeKaydex/go-vshard-router/blob/main/README_ru.md) +- [Русский](https://github.com/tarantool/go-vshard-router/blob/main/README_ru.md) go-vshard-router is a library for sending requests to a sharded tarantool cluster directly, @@ -71,14 +71,14 @@ graph TD With [Go module](https://github.com/golang/go/wiki/Modules) support, simply add the following import ``` -import "github.com/KaymeKaydex/go-vshard-router" +import "github.com/tarantool/go-vshard-router" ``` to your code, and then `go [build|run|test]` will automatically fetch the necessary dependencies. Otherwise, run the following Go command to install the `go-vshard-router` package: ```sh -$ go get -u github.com/KaymeKaydex/go-vshard-router +$ go get -u github.com/tarantool/go-vshard-router ``` ### Running Go-Vshard-Router @@ -94,8 +94,8 @@ import ( "strconv" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" "github.com/google/uuid" "github.com/tarantool/go-tarantool/v2" @@ -215,5 +215,5 @@ at a load close to production ![Image alt](docs/static/not-direct.png) -[actions-badge]: https://github.com/KaymeKaydex/go-vshard-router/actions/workflows/main.yml/badge.svg -[actions-url]: https://github.com/KaymeKaydex/go-vshard-router/actions/workflows/main.yml +[actions-badge]: https://github.com/tarantool/go-vshard-router/actions/workflows/main.yml/badge.svg +[actions-url]: https://github.com/tarantool/go-vshard-router/actions/workflows/main.yml diff --git a/README_ru.md b/README_ru.md index d4648b8..3f448a0 100644 --- a/README_ru.md +++ b/README_ru.md @@ -2,13 +2,13 @@ go vshard router logo -[![Go Reference](https://pkg.go.dev/badge/github.com/KaymeKaydex/go-vshard-router.svg)](https://pkg.go.dev/github.com/KaymeKaydex/go-vshard-router) +[![Go Reference](https://pkg.go.dev/badge/github.com/tarantool/go-vshard-router.svg)](https://pkg.go.dev/github.com/tarantool/go-vshard-router) [![Actions Status][actions-badge]][actions-url] -[![Go Report Card](https://goreportcard.com/badge/github.com/KaymeKaydex/go-vshard-router)](https://goreportcard.com/report/github.com/KaymeKaydex/go-vshard-router) +[![Go Report Card](https://goreportcard.com/badge/github.com/tarantool/go-vshard-router)](https://goreportcard.com/report/github.com/tarantool/go-vshard-router) [![codecov](https://codecov.io/gh/KaymeKaydex/go-vshard-router/graph/badge.svg?token=WLRWE97IT1)](https://codecov.io/gh/KaymeKaydex/go-vshard-router) Translations: -- [English](https://github.com/KaymeKaydex/go-vshard-router/blob/main/README.md) +- [English](https://github.com/tarantool/go-vshard-router/blob/main/README.md) go-vshard-router — библиотека для отправки запросов напрямую в стораджа в шардированный кластер tarantool, без использования tarantool-router. Эта библиотека написана на основе [модуля библиотеки tarantool vhsard router](https://github.com/tarantool/vshard/blob/master/vshard/router/init.lua). go-vshard-router применяет новый подход к созданию кластера @@ -70,14 +70,14 @@ graph TD С помощью [Go module](https://github.com/golang/go/wiki/Modules) можно добавить следующий импорт ``` -import "github.com/KaymeKaydex/go-vshard-router" +import "github.com/tarantool/go-vshard-router" ``` в ваш код, а затем `go [build|run|test]` автоматически получит необходимые зависимости. В противном случае выполните следующую команду Go, чтобы установить пакет go-vshard-router: ```sh -$ go get -u github.com/KaymeKaydex/go-vshard-router +$ go get -u github.com/tarantool/go-vshard-router ``` ### Использование Go-Vshard-Router @@ -93,8 +93,8 @@ import ( "strconv" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" "github.com/google/uuid" "github.com/tarantool/go-tarantool/v2" @@ -216,5 +216,5 @@ func main() { ![Image alt](docs/static/not-direct.png) -[actions-badge]: https://github.com/KaymeKaydex/go-vshard-router/actions/workflows/main.yml/badge.svg -[actions-url]: https://github.com/KaymeKaydex/go-vshard-router/actions/workflows/main.yml \ No newline at end of file +[actions-badge]: https://github.com/tarantool/go-vshard-router/actions/workflows/main.yml/badge.svg +[actions-url]: https://github.com/tarantool/go-vshard-router/actions/workflows/main.yml \ No newline at end of file diff --git a/api.go b/api.go index 43eb03e..712d7c7 100644 --- a/api.go +++ b/api.go @@ -231,7 +231,7 @@ func (r VshardRouterCallResp) GetTyped(result []interface{}) error { // RouterCallImpl Perform shard operation function will restart operation // after wrong bucket response until timeout is reached // Deprecated: RouterCallImpl is deprecated. -// See https://github.com/KaymeKaydex/go-vshard-router/issues/110. +// See https://github.com/tarantool/go-vshard-router/issues/110. // Use Call method with RO, RW, RE, BRO, BRE modes instead. func (r *Router) RouterCallImpl(ctx context.Context, bucketID uint64, diff --git a/api_test.go b/api_test.go index 19f7f44..e8eb1ee 100644 --- a/api_test.go +++ b/api_test.go @@ -7,10 +7,10 @@ import ( "testing" "time" - mockpool "github.com/KaymeKaydex/go-vshard-router/mocks/pool" "github.com/stretchr/testify/mock" "github.com/stretchr/testify/require" "github.com/tarantool/go-tarantool/v2" + mockpool "github.com/tarantool/go-vshard-router/mocks/pool" ) var emptyRouter = &Router{ diff --git a/examples/customer/go-service/go.mod b/examples/customer/go-service/go.mod index c328477..3896fa1 100644 --- a/examples/customer/go-service/go.mod +++ b/examples/customer/go-service/go.mod @@ -3,7 +3,7 @@ module customer go 1.22.2 require ( - github.com/KaymeKaydex/go-vshard-router v0.0.9 + github.com/tarantool/go-vshard-router v0.0.9 github.com/google/uuid v1.6.0 github.com/spf13/viper v1.18.2 github.com/swaggo/swag v1.16.3 @@ -49,4 +49,4 @@ require ( gopkg.in/yaml.v3 v3.0.1 // indirect ) -replace github.com/KaymeKaydex/go-vshard-router v0.0.9 => ../../../ +replace github.com/tarantool/go-vshard-router v0.0.9 => ../../../ diff --git a/examples/customer/go-service/main.go b/examples/customer/go-service/main.go index bd879b1..425cccc 100644 --- a/examples/customer/go-service/main.go +++ b/examples/customer/go-service/main.go @@ -15,8 +15,8 @@ import ( "github.com/tarantool/go-tarantool/v2" "github.com/tarantool/go-tarantool/v2/pool" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) // @title Example customer service Swagger API diff --git a/go.mod b/go.mod index 82ae1d3..d609172 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/KaymeKaydex/go-vshard-router +module github.com/tarantool/go-vshard-router go 1.20 diff --git a/mocks/topology/topology_controller.go b/mocks/topology/topology_controller.go index 454ce17..e41a0c1 100644 --- a/mocks/topology/topology_controller.go +++ b/mocks/topology/topology_controller.go @@ -8,7 +8,7 @@ import ( uuid "github.com/google/uuid" mock "github.com/stretchr/testify/mock" - vshard_router "github.com/KaymeKaydex/go-vshard-router" + vshard_router "github.com/tarantool/go-vshard-router" ) // TopologyController is an autogenerated mock type for the TopologyController type diff --git a/providers/etcd/provider.go b/providers/etcd/provider.go index 4fb8cf8..422b376 100644 --- a/providers/etcd/provider.go +++ b/providers/etcd/provider.go @@ -5,8 +5,8 @@ import ( "fmt" "path/filepath" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" "github.com/google/uuid" + vshardrouter "github.com/tarantool/go-vshard-router" "go.etcd.io/etcd/client/v2" ) diff --git a/providers/etcd/provider_integration_test.go b/providers/etcd/provider_integration_test.go index 372a00e..84ef59c 100644 --- a/providers/etcd/provider_integration_test.go +++ b/providers/etcd/provider_integration_test.go @@ -5,7 +5,7 @@ package etcd import ( "fmt" - mocktopology "github.com/KaymeKaydex/go-vshard-router/mocks/topology" + mocktopology "github.com/tarantool/go-vshard-router/mocks/topology" "go.etcd.io/etcd/client/v2" "testing" "time" diff --git a/providers/static/provider.go b/providers/static/provider.go index 479ba97..308737e 100644 --- a/providers/static/provider.go +++ b/providers/static/provider.go @@ -6,7 +6,7 @@ import ( "github.com/google/uuid" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" + vshardrouter "github.com/tarantool/go-vshard-router" ) // Check that provider implements TopologyProvider interface diff --git a/providers/static/provider_test.go b/providers/static/provider_test.go index 575405f..47653f1 100644 --- a/providers/static/provider_test.go +++ b/providers/static/provider_test.go @@ -7,7 +7,7 @@ import ( "github.com/google/uuid" "github.com/stretchr/testify/require" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" + vshardrouter "github.com/tarantool/go-vshard-router" ) func TestNewProvider(t *testing.T) { diff --git a/providers/viper/provider.go b/providers/viper/provider.go index dbec1ce..2e6b5e4 100644 --- a/providers/viper/provider.go +++ b/providers/viper/provider.go @@ -9,7 +9,7 @@ import ( "github.com/google/uuid" srcviper "github.com/spf13/viper" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" + vshardrouter "github.com/tarantool/go-vshard-router" ) // Check that provider implements TopologyProvider interface diff --git a/providers/viper/provider_test.go b/providers/viper/provider_test.go index ace0cac..fac112f 100644 --- a/providers/viper/provider_test.go +++ b/providers/viper/provider_test.go @@ -6,7 +6,7 @@ import ( "github.com/spf13/viper" "github.com/stretchr/testify/require" - vprovider "github.com/KaymeKaydex/go-vshard-router/providers/viper" + vprovider "github.com/tarantool/go-vshard-router/providers/viper" ) func TestProvider_Close(t *testing.T) { diff --git a/providers_test.go b/providers_test.go index 47ede4b..0d16071 100644 --- a/providers_test.go +++ b/providers_test.go @@ -7,7 +7,7 @@ import ( "github.com/stretchr/testify/require" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" + vshardrouter "github.com/tarantool/go-vshard-router" ) var ( diff --git a/replicaset.go b/replicaset.go index 19203d1..8d57d6f 100644 --- a/replicaset.go +++ b/replicaset.go @@ -123,7 +123,7 @@ func bucketStatWait(future *tarantool.Future) (BucketStatInfo, error) { // link https://github.com/tarantool/vshard/blob/99ceaee014ea3a67424c2026545838e08d69b90c/vshard/replicaset.lua#L661 // Deprecated: ReplicaCall is deprecated, // because looks like it has a little bit broken interface. -// See https://github.com/KaymeKaydex/go-vshard-router/issues/42. +// See https://github.com/tarantool/go-vshard-router/issues/42. // Use CallAsync instead. func (rs *Replicaset) ReplicaCall( ctx context.Context, diff --git a/replicaset_test.go b/replicaset_test.go index 657d4fa..e1a4658 100644 --- a/replicaset_test.go +++ b/replicaset_test.go @@ -12,7 +12,7 @@ import ( "github.com/tarantool/go-tarantool/v2" "github.com/vmihailenco/msgpack/v5" - mockpool "github.com/KaymeKaydex/go-vshard-router/mocks/pool" + mockpool "github.com/tarantool/go-vshard-router/mocks/pool" ) func TestReplicasetInfo_String(t *testing.T) { diff --git a/tarantool_test.go b/tarantool_test.go index 076ae8d..7105a26 100644 --- a/tarantool_test.go +++ b/tarantool_test.go @@ -7,14 +7,14 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" - chelper "github.com/KaymeKaydex/go-vshard-router/test_helper" "github.com/google/uuid" "github.com/stretchr/testify/require" "github.com/tarantool/go-tarantool/v2" "github.com/tarantool/go-tarantool/v2/pool" "github.com/tarantool/go-tarantool/v2/test_helpers" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" + chelper "github.com/tarantool/go-vshard-router/test_helper" ) const instancesCount = 4 diff --git a/tests/tnt/call_bench_test.go b/tests/tnt/call_bench_test.go index 7b6f5d9..2be9103 100644 --- a/tests/tnt/call_bench_test.go +++ b/tests/tnt/call_bench_test.go @@ -5,12 +5,12 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/google/uuid" "github.com/stretchr/testify/require" "github.com/tarantool/go-tarantool/v2" "github.com/tarantool/go-tarantool/v2/pool" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) type Product struct { diff --git a/tests/tnt/cfgmaker.go b/tests/tnt/cfgmaker.go index 226b3ed..405e558 100644 --- a/tests/tnt/cfgmaker.go +++ b/tests/tnt/cfgmaker.go @@ -3,8 +3,8 @@ package tnt import ( "fmt" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" "github.com/google/uuid" + vshardrouter "github.com/tarantool/go-vshard-router" ) type cfgmaker struct { diff --git a/tests/tnt/concurrent_topology_test.go b/tests/tnt/concurrent_topology_test.go index 2d1a859..7e7d61d 100644 --- a/tests/tnt/concurrent_topology_test.go +++ b/tests/tnt/concurrent_topology_test.go @@ -8,8 +8,8 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" "github.com/stretchr/testify/require" + vshardrouter "github.com/tarantool/go-vshard-router" ) type concurrentTopologyProvider struct { @@ -35,7 +35,7 @@ func (c *concurrentTopologyProvider) Init(tc vshardrouter.TopologyController) er defer close(c.closed) //nolint:errcheck defer tc.AddReplicasets(ctx, removed) - // Hack until issue will be resolved: https://github.com/KaymeKaydex/go-vshard-router/issues/65 + // Hack until issue will be resolved: https://github.com/tarantool/go-vshard-router/issues/65 // A little pause to let finish NewRouter() with no err time.Sleep(2 * time.Second) diff --git a/tests/tnt/discovery_test.go b/tests/tnt/discovery_test.go index 802ce60..d327166 100644 --- a/tests/tnt/discovery_test.go +++ b/tests/tnt/discovery_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/stretchr/testify/require" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) func TestBucketDiscovery(t *testing.T) { diff --git a/tests/tnt/replicaset_test.go b/tests/tnt/replicaset_test.go index cb6b18d..a980c19 100644 --- a/tests/tnt/replicaset_test.go +++ b/tests/tnt/replicaset_test.go @@ -5,11 +5,11 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/stretchr/testify/require" "github.com/tarantool/go-tarantool/v2" "github.com/tarantool/go-tarantool/v2/pool" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) func TestReplicasetReplicaCall(t *testing.T) { diff --git a/tests/tnt/router_call_test.go b/tests/tnt/router_call_test.go index c68c57d..60c797d 100644 --- a/tests/tnt/router_call_test.go +++ b/tests/tnt/router_call_test.go @@ -5,10 +5,10 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/stretchr/testify/require" "github.com/tarantool/go-tarantool/v2/pool" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) func TestRouterCallProto(t *testing.T) { diff --git a/tests/tnt/routermap_call_test.go b/tests/tnt/routermap_call_test.go index 2808dde..f005e27 100644 --- a/tests/tnt/routermap_call_test.go +++ b/tests/tnt/routermap_call_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/stretchr/testify/require" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) func TestRouterMapCall(t *testing.T) { diff --git a/tests/tnt/tnt_test.go b/tests/tnt/tnt_test.go index 52c428c..ac9e320 100644 --- a/tests/tnt/tnt_test.go +++ b/tests/tnt/tnt_test.go @@ -8,7 +8,7 @@ import ( "strconv" "testing" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" + vshardrouter "github.com/tarantool/go-vshard-router" ) const ( diff --git a/tests/tnt/topology_test.go b/tests/tnt/topology_test.go index 7377b56..e3df5d3 100644 --- a/tests/tnt/topology_test.go +++ b/tests/tnt/topology_test.go @@ -6,9 +6,9 @@ import ( "testing" "time" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" "github.com/stretchr/testify/require" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) func TestTopology(t *testing.T) { diff --git a/topology_test.go b/topology_test.go index 2b02a8e..70f8ff8 100644 --- a/topology_test.go +++ b/topology_test.go @@ -5,9 +5,9 @@ import ( "errors" "testing" - mockpool "github.com/KaymeKaydex/go-vshard-router/mocks/pool" "github.com/google/uuid" "github.com/stretchr/testify/require" + mockpool "github.com/tarantool/go-vshard-router/mocks/pool" ) func TestRouter_Topology(t *testing.T) { diff --git a/vshard.go b/vshard.go index 86b557e..98e9773 100644 --- a/vshard.go +++ b/vshard.go @@ -20,7 +20,7 @@ var ( ErrTopologyProvider = fmt.Errorf("got error from topology provider") ) -// This data struct is instroduced by https://github.com/KaymeKaydex/go-vshard-router/issues/39. +// This data struct is instroduced by https://github.com/tarantool/go-vshard-router/issues/39. // We use an array of atomics to lock-free handling elements of routeMap. // knownBucketCount reflects a statistic over routeMap. // knownBucketCount might be inconsistent for a few mksecs, because at first we change routeMap[bucketID], diff --git a/vshard_shadow_test.go b/vshard_shadow_test.go index 3aed0b3..be83dd3 100644 --- a/vshard_shadow_test.go +++ b/vshard_shadow_test.go @@ -8,8 +8,8 @@ import ( "github.com/google/uuid" "github.com/stretchr/testify/require" - vshardrouter "github.com/KaymeKaydex/go-vshard-router" - "github.com/KaymeKaydex/go-vshard-router/providers/static" + vshardrouter "github.com/tarantool/go-vshard-router" + "github.com/tarantool/go-vshard-router/providers/static" ) type errorTopologyProvider struct{}