Skip to content

Commit

Permalink
Merge pull request #5 from k6io/feat/rename-k6-go-modules
Browse files Browse the repository at this point in the history
Rename k6 Go modules to go.k6.io
  • Loading branch information
Ivan Mirić authored May 11, 2021
2 parents 44692ab + bfee833 commit fbd4ce3
Show file tree
Hide file tree
Showing 10 changed files with 316 additions and 47 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
# xk6-output-kafka
Is extracted the original [kafka output](https://k6.io/docs/results-visualization/apache-kafka) from [k6](https://github.com/loadimpact/k6) so it can be used with [xk6](https://github.com/k6io/xk6).
Is extracted the original [kafka output](https://k6.io/docs/results-visualization/apache-kafka) from [k6](https://github.com/k6io/k6) so it can be used with [xk6](https://github.com/k6io/xk6).

</div>

Expand Down
8 changes: 4 additions & 4 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@ require (
github.com/influxdata/influxdb1-client v0.0.0-20190402204710-8ff2fc3824fc
github.com/kelseyhightower/envconfig v1.4.0
github.com/kubernetes/helm v2.9.0+incompatible
github.com/loadimpact/k6 v0.31.1
github.com/mitchellh/mapstructure v0.0.0-20180220230111-00c29f56e238
github.com/sirupsen/logrus v1.6.0
github.com/stretchr/testify v1.2.2
github.com/mitchellh/mapstructure v1.1.2
github.com/sirupsen/logrus v1.8.1
github.com/stretchr/testify v1.7.0
go.k6.io/k6 v0.31.2-0.20210511090412-61f464b99a2d
gopkg.in/guregu/null.v3 v3.3.0
)
331 changes: 300 additions & 31 deletions go.sum

Large diffs are not rendered by default.

4 changes: 2 additions & 2 deletions pkg/kafka/collector.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ import (
"github.com/Shopify/sarama"
"github.com/sirupsen/logrus"

"github.com/loadimpact/k6/output"
"github.com/loadimpact/k6/stats"
"go.k6.io/k6/output"
"go.k6.io/k6/stats"
)

// Collector implements the lib.Collector interface and should be used only for testing
Expand Down
6 changes: 3 additions & 3 deletions pkg/kafka/collector_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,9 +30,9 @@ import (
"github.com/stretchr/testify/require"
"gopkg.in/guregu/null.v3"

"github.com/loadimpact/k6/lib/testutils"
"github.com/loadimpact/k6/output"
"github.com/loadimpact/k6/stats"
"go.k6.io/k6/lib/testutils"
"go.k6.io/k6/output"
"go.k6.io/k6/stats"
)

func TestRun(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion pkg/kafka/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import (
"github.com/mitchellh/mapstructure"
"gopkg.in/guregu/null.v3"

"github.com/loadimpact/k6/lib/types"
"go.k6.io/k6/lib/types"
)

// Config is the config for the kafka collector
Expand Down
2 changes: 1 addition & 1 deletion pkg/kafka/config_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ import (
"github.com/stretchr/testify/require"
"gopkg.in/guregu/null.v3"

"github.com/loadimpact/k6/lib/types"
"go.k6.io/k6/lib/types"
)

func TestConfigParseArg(t *testing.T) {
Expand Down
4 changes: 2 additions & 2 deletions pkg/kafka/format_influxdb.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ import (
"strings"

client "github.com/influxdata/influxdb1-client/v2"
"github.com/loadimpact/k6/lib/types"
"github.com/loadimpact/k6/stats"
"go.k6.io/k6/lib/types"
"go.k6.io/k6/stats"
"github.com/mitchellh/mapstructure"
"github.com/sirupsen/logrus"
)
Expand Down
2 changes: 1 addition & 1 deletion pkg/kafka/format_json.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ package kafka
import (
"time"

"github.com/loadimpact/k6/stats"
"go.k6.io/k6/stats"
)

// wrapSample is used to package a metric sample in a way that's nice to export
Expand Down
2 changes: 1 addition & 1 deletion register.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ package kafka

import (
"github.com/k6io/xk6-output-kafka/pkg/kafka"
"github.com/loadimpact/k6/output"
"go.k6.io/k6/output"
)

func init() {
Expand Down

0 comments on commit fbd4ce3

Please sign in to comment.