From 8bd4cd628b7f961d1abac557803523b286496650 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Kurzeja?= Date: Thu, 16 Jul 2020 15:13:16 +0200 Subject: [PATCH] Bumped the major version to v6. (#85) --- cache/sink.go | 2 +- cache/sink_test.go | 6 +++--- channel/sink.go | 2 +- channel/sink_test.go | 6 +++--- channel/source.go | 2 +- channel/source_test.go | 4 ++-- example/benchmark/main.go | 2 +- example/branch/main.go | 2 +- example/kafka/main.go | 4 ++-- example/merge/main.go | 2 +- example/simple/main.go | 2 +- fakes_test.go | 2 +- go.mod | 2 +- kafka/encoder_test.go | 2 +- kafka/sink.go | 2 +- kafka/sink_internal_test.go | 2 +- kafka/sink_test.go | 6 +++--- kafka/source.go | 2 +- kafka/source_test.go | 4 ++-- message_test.go | 2 +- metastore_test.go | 2 +- mocks/pipe.go | 2 +- mocks/pipe_test.go | 4 ++-- mocks_test.go | 2 +- monitor_test.go | 2 +- pipe_test.go | 2 +- processor_test.go | 4 ++-- pump_test.go | 2 +- sql/sink.go | 2 +- sql/sink_test.go | 6 +++--- supervisor_test.go | 2 +- task_test.go | 2 +- topology_test.go | 2 +- 33 files changed, 46 insertions(+), 46 deletions(-) diff --git a/cache/sink.go b/cache/sink.go index 85aa51b..9e42142 100644 --- a/cache/sink.go +++ b/cache/sink.go @@ -4,7 +4,7 @@ import ( "time" "github.com/msales/pkg/v4/cache" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) // Sink represents a Cache streams sink. diff --git a/cache/sink_test.go b/cache/sink_test.go index 34ad921..a758c41 100644 --- a/cache/sink_test.go +++ b/cache/sink_test.go @@ -6,9 +6,9 @@ import ( "time" cache2 "github.com/msales/pkg/v4/cache" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/cache" - "github.com/msales/streams/v5/mocks" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/cache" + "github.com/msales/streams/v6/mocks" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/channel/sink.go b/channel/sink.go index 770e0b7..3696a76 100644 --- a/channel/sink.go +++ b/channel/sink.go @@ -1,6 +1,6 @@ package channel -import "github.com/msales/streams/v5" +import "github.com/msales/streams/v6" // Sink represents a channel sink. type Sink struct { diff --git a/channel/sink_test.go b/channel/sink_test.go index cf2f290..8d1a456 100644 --- a/channel/sink_test.go +++ b/channel/sink_test.go @@ -3,9 +3,9 @@ package channel_test import ( "testing" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/channel" - "github.com/msales/streams/v5/mocks" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/channel" + "github.com/msales/streams/v6/mocks" "github.com/stretchr/testify/assert" ) diff --git a/channel/source.go b/channel/source.go index ada7abd..58ade0d 100644 --- a/channel/source.go +++ b/channel/source.go @@ -3,7 +3,7 @@ package channel import ( "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) // Compile-time interface check. diff --git a/channel/source_test.go b/channel/source_test.go index abf2e8a..399e7ea 100644 --- a/channel/source_test.go +++ b/channel/source_test.go @@ -3,8 +3,8 @@ package channel_test import ( "testing" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/channel" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/channel" "github.com/stretchr/testify/assert" ) diff --git a/example/benchmark/main.go b/example/benchmark/main.go index bb4f13b..23fe02a 100644 --- a/example/benchmark/main.go +++ b/example/benchmark/main.go @@ -9,7 +9,7 @@ import ( "os/signal" "syscall" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) // BatchSize is the size of commit batches. diff --git a/example/branch/main.go b/example/branch/main.go index a6b0c20..0f255b3 100644 --- a/example/branch/main.go +++ b/example/branch/main.go @@ -8,7 +8,7 @@ import ( "os/signal" "syscall" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) func main() { diff --git a/example/kafka/main.go b/example/kafka/main.go index 7dd0a3f..d8cfcb7 100644 --- a/example/kafka/main.go +++ b/example/kafka/main.go @@ -10,8 +10,8 @@ import ( "syscall" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/kafka" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/kafka" ) // BatchSize is the size of commit batches. diff --git a/example/merge/main.go b/example/merge/main.go index bcf0541..e04a244 100644 --- a/example/merge/main.go +++ b/example/merge/main.go @@ -8,7 +8,7 @@ import ( "os/signal" "syscall" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) func main() { diff --git a/example/simple/main.go b/example/simple/main.go index 8b97341..b725433 100644 --- a/example/simple/main.go +++ b/example/simple/main.go @@ -8,7 +8,7 @@ import ( "os/signal" "syscall" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) func main() { diff --git a/fakes_test.go b/fakes_test.go index 06cba2a..9f08960 100644 --- a/fakes_test.go +++ b/fakes_test.go @@ -5,7 +5,7 @@ import ( "sync" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) type fakeSource struct { diff --git a/go.mod b/go.mod index e80bf21..5bc73ce 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/msales/streams/v5 +module github.com/msales/streams/v6 go 1.14 diff --git a/kafka/encoder_test.go b/kafka/encoder_test.go index 51b45f1..5f0f508 100644 --- a/kafka/encoder_test.go +++ b/kafka/encoder_test.go @@ -4,7 +4,7 @@ import ( "errors" "testing" - "github.com/msales/streams/v5/kafka" + "github.com/msales/streams/v6/kafka" "github.com/stretchr/testify/assert" ) diff --git a/kafka/sink.go b/kafka/sink.go index 45f0c6f..5f713fb 100644 --- a/kafka/sink.go +++ b/kafka/sink.go @@ -4,7 +4,7 @@ import ( "context" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) // SinkConfig represents the configuration of a Sink. diff --git a/kafka/sink_internal_test.go b/kafka/sink_internal_test.go index 2f06917..05f3a79 100644 --- a/kafka/sink_internal_test.go +++ b/kafka/sink_internal_test.go @@ -5,7 +5,7 @@ import ( "testing" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" ) diff --git a/kafka/sink_test.go b/kafka/sink_test.go index 26003e2..1a523cd 100644 --- a/kafka/sink_test.go +++ b/kafka/sink_test.go @@ -5,9 +5,9 @@ import ( "testing" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/kafka" - "github.com/msales/streams/v5/mocks" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/kafka" + "github.com/msales/streams/v6/mocks" "github.com/stretchr/testify/assert" ) diff --git a/kafka/source.go b/kafka/source.go index 2d6e7ed..a2e1509 100644 --- a/kafka/source.go +++ b/kafka/source.go @@ -6,7 +6,7 @@ import ( "time" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "golang.org/x/xerrors" ) diff --git a/kafka/source_test.go b/kafka/source_test.go index afce0a2..c417e45 100644 --- a/kafka/source_test.go +++ b/kafka/source_test.go @@ -5,8 +5,8 @@ import ( "time" "github.com/Shopify/sarama" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/kafka" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/kafka" "github.com/stretchr/testify/assert" ) diff --git a/message_test.go b/message_test.go index 8987e67..69c02c2 100644 --- a/message_test.go +++ b/message_test.go @@ -4,7 +4,7 @@ import ( "context" "testing" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" ) diff --git a/metastore_test.go b/metastore_test.go index 3a66a94..5e8543e 100644 --- a/metastore_test.go +++ b/metastore_test.go @@ -3,7 +3,7 @@ package streams_test import ( "testing" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/mocks/pipe.go b/mocks/pipe.go index 2d98cb3..cec2094 100644 --- a/mocks/pipe.go +++ b/mocks/pipe.go @@ -5,7 +5,7 @@ import ( "reflect" "testing" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) type record struct { diff --git a/mocks/pipe_test.go b/mocks/pipe_test.go index 194a634..2c2e0cc 100644 --- a/mocks/pipe_test.go +++ b/mocks/pipe_test.go @@ -3,8 +3,8 @@ package mocks_test import ( "testing" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/mocks" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/mocks" "github.com/stretchr/testify/assert" ) diff --git a/mocks_test.go b/mocks_test.go index 97acdc1..dbb49b7 100644 --- a/mocks_test.go +++ b/mocks_test.go @@ -4,7 +4,7 @@ import ( "context" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/mock" ) diff --git a/monitor_test.go b/monitor_test.go index eec21cb..66ad3cb 100644 --- a/monitor_test.go +++ b/monitor_test.go @@ -4,7 +4,7 @@ import ( "testing" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/pipe_test.go b/pipe_test.go index 80fe2b4..9556c6d 100644 --- a/pipe_test.go +++ b/pipe_test.go @@ -4,7 +4,7 @@ import ( "errors" "testing" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" ) diff --git a/processor_test.go b/processor_test.go index b0c22b8..4cd3be2 100644 --- a/processor_test.go +++ b/processor_test.go @@ -4,8 +4,8 @@ import ( "errors" "testing" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/mocks" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/mocks" "github.com/stretchr/testify/assert" ) diff --git a/pump_test.go b/pump_test.go index 380175d..17663d3 100644 --- a/pump_test.go +++ b/pump_test.go @@ -5,7 +5,7 @@ import ( "testing" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/sql/sink.go b/sql/sink.go index 2662a6e..2254da0 100644 --- a/sql/sink.go +++ b/sql/sink.go @@ -5,7 +5,7 @@ import ( "database/sql" "errors" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" ) // Transaction represents a SQL transaction handler. diff --git a/sql/sink_test.go b/sql/sink_test.go index ac5650c..fd5205e 100644 --- a/sql/sink_test.go +++ b/sql/sink_test.go @@ -7,9 +7,9 @@ import ( "testing" "github.com/DATA-DOG/go-sqlmock" - "github.com/msales/streams/v5" - "github.com/msales/streams/v5/mocks" - sqlx "github.com/msales/streams/v5/sql" + "github.com/msales/streams/v6" + "github.com/msales/streams/v6/mocks" + sqlx "github.com/msales/streams/v6/sql" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/supervisor_test.go b/supervisor_test.go index 388ca67..ba460d0 100644 --- a/supervisor_test.go +++ b/supervisor_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/task_test.go b/task_test.go index d0591ef..94c47ae 100644 --- a/task_test.go +++ b/task_test.go @@ -6,7 +6,7 @@ import ( "testing" "time" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" ) diff --git a/topology_test.go b/topology_test.go index 9ff1ad2..5f6449a 100644 --- a/topology_test.go +++ b/topology_test.go @@ -3,7 +3,7 @@ package streams_test import ( "testing" - "github.com/msales/streams/v5" + "github.com/msales/streams/v6" "github.com/stretchr/testify/assert" )