Skip to content

Commit

Permalink
Bumped the major version to v6. (#85)
Browse files Browse the repository at this point in the history
  • Loading branch information
@michalkurzeja
michalkurzeja authored Jul 16, 2020
1 parent b2e62e3 commit 8bd4cd6
Show file tree
Hide file tree
Showing 33 changed files with 46 additions and 46 deletions.
2 changes: 1 addition & 1 deletion cache/sink.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
6 changes: 3 additions & 3 deletions cache/sink_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion channel/sink.go
View file
Original file line number Diff line number Diff line change
@@ -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 {
Expand Down
6 changes: 3 additions & 3 deletions channel/sink_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion channel/source.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package channel
import (
"time"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

// Compile-time interface check.
Expand Down
4 changes: 2 additions & 2 deletions channel/source_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion example/benchmark/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion example/branch/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"os/signal"
"syscall"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

func main() {
Expand Down
4 changes: 2 additions & 2 deletions example/kafka/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion example/merge/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"os/signal"
"syscall"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

func main() {
Expand Down
2 changes: 1 addition & 1 deletion example/simple/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"os/signal"
"syscall"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

func main() {
Expand Down
2 changes: 1 addition & 1 deletion fakes_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"sync"
"time"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

type fakeSource struct {
Expand Down
2 changes: 1 addition & 1 deletion go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/msales/streams/v5
module github.com/msales/streams/v6

go 1.14

Expand Down
2 changes: 1 addition & 1 deletion kafka/encoder_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"errors"
"testing"

"github.com/msales/streams/v5/kafka"
"github.com/msales/streams/v6/kafka"
"github.com/stretchr/testify/assert"
)

Expand Down
2 changes: 1 addition & 1 deletion kafka/sink.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion kafka/sink_internal_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
6 changes: 3 additions & 3 deletions kafka/sink_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion kafka/source.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"time"

"github.com/Shopify/sarama"
"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
"golang.org/x/xerrors"
)

Expand Down
4 changes: 2 additions & 2 deletions kafka/source_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion message_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"context"
"testing"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
"github.com/stretchr/testify/assert"
)

Expand Down
2 changes: 1 addition & 1 deletion metastore_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion mocks/pipe.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"reflect"
"testing"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

type record struct {
Expand Down
4 changes: 2 additions & 2 deletions mocks/pipe_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion mocks_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"context"
"time"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
"github.com/stretchr/testify/mock"
)

Expand Down
2 changes: 1 addition & 1 deletion monitor_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion pipe_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"errors"
"testing"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
"github.com/stretchr/testify/assert"
)

Expand Down
4 changes: 2 additions & 2 deletions processor_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)

Expand Down
2 changes: 1 addition & 1 deletion pump_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion sql/sink.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"database/sql"
"errors"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
)

// Transaction represents a SQL transaction handler.
Expand Down
6 changes: 3 additions & 3 deletions sql/sink_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion supervisor_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion task_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
)
Expand Down
2 changes: 1 addition & 1 deletion topology_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package streams_test
import (
"testing"

"github.com/msales/streams/v5"
"github.com/msales/streams/v6"
"github.com/stretchr/testify/assert"
)

Expand Down

0 comments on commit 8bd4cd6

Please sign in to comment.