From 32bfda0e0097f74472ab9bb5f5b7eeb61df2dc26 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aitor=20P=C3=A9rez=20Cedres?= Date: Mon, 17 Jul 2023 18:18:16 +0100 Subject: [PATCH] Update module to v2 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Aitor Pérez Cedres --- go.mod | 2 +- internal/publish_test.go | 4 ++-- internal/sub_batch_publish_test.go | 6 +++--- internal/subscribe.go | 2 +- internal/subscribe_test.go | 2 +- main.go | 10 +++++----- pkg/common/types.go | 2 +- pkg/e2e/end_to_end_test.go | 6 +++--- pkg/raw/client.go | 4 ++-- pkg/raw/client_dial_test.go | 2 +- pkg/raw/client_test.go | 4 ++-- pkg/raw/client_types.go | 4 ++-- pkg/raw/client_types_test.go | 2 +- pkg/raw/mock_conn_test.go | 2 +- pkg/raw/publishing_message.go | 4 ++-- pkg/raw/stream_suite_test.go | 4 ++-- pkg/raw/test_helpers.go | 2 +- pkg/stream/environment.go | 2 +- pkg/stream/environment_configuration_test.go | 2 +- pkg/stream/environment_test.go | 4 ++-- pkg/stream/locator.go | 2 +- pkg/stream/locator_test.go | 2 +- pkg/stream/mock_raw_client_test.go | 4 ++-- pkg/stream/test_helpers.go | 2 +- pkg/stream/util.go | 2 +- 25 files changed, 41 insertions(+), 41 deletions(-) diff --git a/go.mod b/go.mod index 1d65d4f1..4a29a2ee 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/gsantomaggio/rabbitmq-stream-go-client +module github.com/rabbitmq/rabbitmq-stream-go-client/v2 go 1.19 diff --git a/internal/publish_test.go b/internal/publish_test.go index abbfc4dc..c2c6a4e8 100644 --- a/internal/publish_test.go +++ b/internal/publish_test.go @@ -4,10 +4,10 @@ import ( "bufio" "bytes" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/codecs/amqp" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/codecs/amqp" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" ) var _ = Describe("Create", func() { diff --git a/internal/sub_batch_publish_test.go b/internal/sub_batch_publish_test.go index 376de89e..90c03673 100644 --- a/internal/sub_batch_publish_test.go +++ b/internal/sub_batch_publish_test.go @@ -4,11 +4,11 @@ import ( "bufio" "bytes" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/codecs/amqp" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/codecs/amqp" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" ) var _ = Describe("Create", func() { diff --git a/internal/subscribe.go b/internal/subscribe.go index c8e440e8..7d2d3e0c 100644 --- a/internal/subscribe.go +++ b/internal/subscribe.go @@ -3,7 +3,7 @@ package internal import ( "bufio" "bytes" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" ) // SubscribeRequest is the command to subscribe to a stream diff --git a/internal/subscribe_test.go b/internal/subscribe_test.go index 8f530289..24defe49 100644 --- a/internal/subscribe_test.go +++ b/internal/subscribe_test.go @@ -3,9 +3,9 @@ package internal import ( "bufio" "bytes" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" ) var _ = Describe("Subscribe", func() { diff --git a/main.go b/main.go index 23f6aad0..63318750 100644 --- a/main.go +++ b/main.go @@ -4,11 +4,11 @@ import ( "bufio" "context" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/codecs/amqp" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/stream" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/codecs/amqp" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/stream" "golang.org/x/exp/slog" "os" "time" diff --git a/pkg/common/types.go b/pkg/common/types.go index 5fa1f26b..e4c91c25 100644 --- a/pkg/common/types.go +++ b/pkg/common/types.go @@ -4,7 +4,7 @@ import ( "bytes" "compress/gzip" "encoding" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" "io" ) diff --git a/pkg/e2e/end_to_end_test.go b/pkg/e2e/end_to_end_test.go index 281ea274..cf2b5de6 100644 --- a/pkg/e2e/end_to_end_test.go +++ b/pkg/e2e/end_to_end_test.go @@ -7,12 +7,12 @@ import ( "context" "encoding/binary" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" "github.com/onsi/gomega/gmeasure" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "io" "os" diff --git a/pkg/raw/client.go b/pkg/raw/client.go index 3eb8f0a5..fd9a1d1d 100644 --- a/pkg/raw/client.go +++ b/pkg/raw/client.go @@ -5,8 +5,8 @@ import ( "context" "errors" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/internal" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/internal" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" "golang.org/x/exp/slog" "io" "math" diff --git a/pkg/raw/client_dial_test.go b/pkg/raw/client_dial_test.go index 1bf57ca0..c7d370e9 100644 --- a/pkg/raw/client_dial_test.go +++ b/pkg/raw/client_dial_test.go @@ -8,7 +8,7 @@ import ( "path/filepath" "time" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" ) var _ = Describe("ClientDial", func() { diff --git a/pkg/raw/client_test.go b/pkg/raw/client_test.go index 99c05316..18ea1955 100644 --- a/pkg/raw/client_test.go +++ b/pkg/raw/client_test.go @@ -8,10 +8,10 @@ import ( "time" "github.com/golang/mock/gomock" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/constants" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/constants" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" ) const ( diff --git a/pkg/raw/client_types.go b/pkg/raw/client_types.go index ee693788..068efb9d 100644 --- a/pkg/raw/client_types.go +++ b/pkg/raw/client_types.go @@ -4,8 +4,8 @@ import ( "context" "crypto/tls" "errors" - "github.com/gsantomaggio/rabbitmq-stream-go-client/internal" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/internal" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" "net" "time" ) diff --git a/pkg/raw/client_types_test.go b/pkg/raw/client_types_test.go index 5ae1f644..e7dd8f73 100644 --- a/pkg/raw/client_types_test.go +++ b/pkg/raw/client_types_test.go @@ -1,10 +1,10 @@ package raw_test import ( - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" . "github.com/onsi/gomega/gstruct" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" ) var _ = Describe("ClientTypes", func() { diff --git a/pkg/raw/mock_conn_test.go b/pkg/raw/mock_conn_test.go index 3b2783a3..cc22347c 100644 --- a/pkg/raw/mock_conn_test.go +++ b/pkg/raw/mock_conn_test.go @@ -5,10 +5,10 @@ package raw_test import ( + ginkgo "github.com/onsi/ginkgo/v2" net "net" reflect "reflect" time "time" - ginkgo "github.com/onsi/ginkgo/v2" gomock "github.com/golang/mock/gomock" ) diff --git a/pkg/raw/publishing_message.go b/pkg/raw/publishing_message.go index 0ac757fb..4c42e7b7 100644 --- a/pkg/raw/publishing_message.go +++ b/pkg/raw/publishing_message.go @@ -1,8 +1,8 @@ package raw import ( - "github.com/gsantomaggio/rabbitmq-stream-go-client/internal" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/internal" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" "io" ) diff --git a/pkg/raw/stream_suite_test.go b/pkg/raw/stream_suite_test.go index d2a858a9..07b64b1b 100644 --- a/pkg/raw/stream_suite_test.go +++ b/pkg/raw/stream_suite_test.go @@ -5,7 +5,7 @@ import ( "context" "encoding/binary" "errors" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "io" "net" @@ -13,9 +13,9 @@ import ( "testing" "time" - "github.com/gsantomaggio/rabbitmq-stream-go-client/internal" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/internal" ) var logger *slog.Logger diff --git a/pkg/raw/test_helpers.go b/pkg/raw/test_helpers.go index 381e0468..9d8b3fbd 100644 --- a/pkg/raw/test_helpers.go +++ b/pkg/raw/test_helpers.go @@ -4,7 +4,7 @@ package raw import ( "context" - "github.com/gsantomaggio/rabbitmq-stream-go-client/internal" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/internal" ) // StartFrameListener starts reading the Connection socket. It receives frames diff --git a/pkg/stream/environment.go b/pkg/stream/environment.go index 51e72b12..e0c8906b 100644 --- a/pkg/stream/environment.go +++ b/pkg/stream/environment.go @@ -3,7 +3,7 @@ package stream import ( "context" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "math/rand" "time" diff --git a/pkg/stream/environment_configuration_test.go b/pkg/stream/environment_configuration_test.go index 06e53f5e..460d0b58 100644 --- a/pkg/stream/environment_configuration_test.go +++ b/pkg/stream/environment_configuration_test.go @@ -1,9 +1,9 @@ package stream_test import ( - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/stream" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/stream" ) var _ = Describe("EnvironmentConfiguration", func() { diff --git a/pkg/stream/environment_test.go b/pkg/stream/environment_test.go index f63520d2..6d16a729 100644 --- a/pkg/stream/environment_test.go +++ b/pkg/stream/environment_test.go @@ -4,11 +4,11 @@ import ( "context" "errors" "github.com/golang/mock/gomock" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/stream" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" "github.com/onsi/gomega/gbytes" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/stream" "golang.org/x/exp/slog" "reflect" "sync" diff --git a/pkg/stream/locator.go b/pkg/stream/locator.go index 38a6b238..4eb8208f 100644 --- a/pkg/stream/locator.go +++ b/pkg/stream/locator.go @@ -2,7 +2,7 @@ package stream import ( "context" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "golang.org/x/mod/semver" "net" diff --git a/pkg/stream/locator_test.go b/pkg/stream/locator_test.go index 9dacdf3b..f79c176d 100644 --- a/pkg/stream/locator_test.go +++ b/pkg/stream/locator_test.go @@ -3,9 +3,9 @@ package stream import ( "context" "errors" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" . "github.com/onsi/ginkgo/v2" . "github.com/onsi/gomega" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "time" ) diff --git a/pkg/stream/mock_raw_client_test.go b/pkg/stream/mock_raw_client_test.go index f7101e8d..aebfa678 100644 --- a/pkg/stream/mock_raw_client_test.go +++ b/pkg/stream/mock_raw_client_test.go @@ -9,8 +9,8 @@ import ( reflect "reflect" gomock "github.com/golang/mock/gomock" - common "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/common" - raw "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + common "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/common" + raw "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" ) // MockRawClient is a mock of Clienter interface. diff --git a/pkg/stream/test_helpers.go b/pkg/stream/test_helpers.go index 4c29c799..27246dc5 100644 --- a/pkg/stream/test_helpers.go +++ b/pkg/stream/test_helpers.go @@ -4,7 +4,7 @@ package stream import ( "context" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" "golang.org/x/exp/slog" "time" ) diff --git a/pkg/stream/util.go b/pkg/stream/util.go index 9ae1e487..84f82ddd 100644 --- a/pkg/stream/util.go +++ b/pkg/stream/util.go @@ -4,7 +4,7 @@ import ( "context" "errors" "fmt" - "github.com/gsantomaggio/rabbitmq-stream-go-client/pkg/raw" + "github.com/rabbitmq/rabbitmq-stream-go-client/v2/pkg/raw" ) const (