replace apache paths

netdata · Oct 26, 2020 · 198e3b2 · 198e3b2
1 parent f9b3c0f
commit 198e3b2
Show file tree

Hide file tree

Showing 46 changed files with 74 additions and 76 deletions.
diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md
@@ -74,4 +74,4 @@ add the license at the beginning of each file. The location of the header file:
 
 ## Update dependencies
 
-Apache `pulsar-client-go` uses [Go 1.11 module](https://github.com/golang/go/wiki/Modules) to manage dependencies. To add or update a dependency, use the `go mod edit` command to change the dependency.
+Apache `pulsar-client-go` uses [Go 1.11 module](https://github.com/golang/go/wiki/Modules) to manage dependencies. To add or update a dependency, use the `go mod edit` command to change the dependency.
diff --git a/examples/consumer-listener/consumer-listener.go b/examples/consumer-listener/consumer-listener.go
@@ -21,7 +21,7 @@ import (
 	"fmt"
 	"log"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 func main() {

diff --git a/examples/consumer/consumer.go b/examples/consumer/consumer.go
@@ -22,7 +22,7 @@ import (
 	"fmt"
 	"log"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 func main() {

diff --git a/examples/producer/producer.go b/examples/producer/producer.go
@@ -22,7 +22,7 @@ import (
 	"fmt"
 	"log"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 func main() {

diff --git a/examples/reader/reader.go b/examples/reader/reader.go
@@ -22,7 +22,7 @@ import (
 	"fmt"
 	"log"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 func main() {

diff --git a/go.mod b/go.mod
@@ -1,25 +1,24 @@
-module github.com/apache/pulsar-client-go
+module github.com/netdata/pulsar-client-go
 
 go 1.13
 
 require (
 	github.com/DataDog/zstd v1.4.6-0.20200617134701-89f69fb7df32
-	github.com/apache/pulsar-client-go/oauth2 v0.0.0-20200715083626-b9f8c5cedefb
 	github.com/beefsack/go-rate v0.0.0-20180408011153-efa7637bb9b6
 	github.com/bmizerany/perks v0.0.0-20141205001514-d9a9656a3a4b
 	github.com/gogo/protobuf v1.3.1
 	github.com/inconshreveable/mousetrap v1.0.0 // indirect
 	github.com/klauspost/compress v1.10.8
-	github.com/kr/pretty v0.2.0 // indirect
+	github.com/netdata/pulsar-client-go/oauth2 v0.0.0-20200715083626-b9f8c5cedefb
 	github.com/pierrec/lz4 v2.0.5+incompatible
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.7.1
 	github.com/sirupsen/logrus v1.4.2
 	github.com/spaolacci/murmur3 v1.1.0
 	github.com/spf13/cobra v0.0.3
-	github.com/spf13/pflag v1.0.3 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/stretchr/testify v1.4.0
 	github.com/yahoo/athenz v1.8.55
 )
 
-replace github.com/apache/pulsar-client-go/oauth2 => ./oauth2
+replace github.com/netdata/pulsar-client-go/oauth2 => ./oauth2
diff --git a/go.sum b/go.sum
@@ -82,9 +82,8 @@ github.com/klauspost/compress v1.10.8/go.mod h1:aoV0uJVorq1K+umq18yTdKaF57EivdYs
 github.com/konsorten/go-windows-terminal-sequences v1.0.1 h1:mweAR1A6xJ3oS2pRaGiHgQ4OO8tzTaLawm8vnODuwDk=
 github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
 github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
+github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
-github.com/kr/pretty v0.2.0 h1:s5hAObm+yFO5uHYt5dYjxi2rXrsnmRpJx4OYvIWUaQs=
-github.com/kr/pretty v0.2.0/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
@@ -138,8 +137,8 @@ github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0b
 github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/spf13/cobra v0.0.3 h1:ZlrZ4XsMRm04Fr5pSFxBgfND2EBVa1nLpiy1stUsX/8=
 github.com/spf13/cobra v0.0.3/go.mod h1:1l0Ry5zgKvJasoi3XT1TypsSe7PqH0Sj9dhYf7v3XqQ=
-github.com/spf13/pflag v1.0.3 h1:zPAT6CGy6wXeQ7NtTnaTerfKOsV6V6F8agHXFiazDkg=
-github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
+github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
+github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.2.0 h1:Hbg2NidpLE8veEBkEZTL3CvlkUIVzuU9jDplZO54c48=

diff --git a/oauth2/auth.go b/oauth2/auth.go
@@ -21,7 +21,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 	"github.com/dgrijalva/jwt-go"
 	"golang.org/x/oauth2"
 )

diff --git a/oauth2/cache/cache.go b/oauth2/cache/cache.go
@@ -22,11 +22,11 @@ import (
 	"sync"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2"
-	"github.com/apache/pulsar-client-go/oauth2/store"
+	"github.com/netdata/pulsar-client-go/oauth2"
+	"github.com/netdata/pulsar-client-go/oauth2/store"
 
 	xoauth2 "golang.org/x/oauth2"
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 )
 
 // A CachingTokenSource is anything that can return a token, and is backed by a cache.

diff --git a/oauth2/client_credentials_flow.go b/oauth2/client_credentials_flow.go
@@ -20,7 +20,7 @@ package oauth2
 import (
 	"net/http"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 
 	"github.com/pkg/errors"
 )

diff --git a/oauth2/client_credentials_flow_test.go b/oauth2/client_credentials_flow_test.go
@@ -21,8 +21,8 @@ import (
 	"errors"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
-	"github.com/apache/pulsar-client-go/oauth2/clock/testing"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock/testing"
 
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"

diff --git a/oauth2/clock/testing/fake_clock.go b/oauth2/clock/testing/fake_clock.go
@@ -21,7 +21,7 @@ import (
 	"sync"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 )
 
 var (

diff --git a/oauth2/device_code_flow.go b/oauth2/device_code_flow.go
@@ -23,7 +23,7 @@ import (
 	"net/http"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 
 	"github.com/pkg/errors"
 )

diff --git a/oauth2/device_code_flow_test.go b/oauth2/device_code_flow_test.go
@@ -21,8 +21,8 @@ import (
 	"errors"
 	"time"
 
-	"github.com/apache/pulsar-client-go/oauth2/clock"
-	"github.com/apache/pulsar-client-go/oauth2/clock/testing"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/clock/testing"
 	"golang.org/x/oauth2"
 
 	. "github.com/onsi/ginkgo"

diff --git a/oauth2/go.mod b/oauth2/go.mod
@@ -1,4 +1,4 @@
-module github.com/apache/pulsar-client-go/oauth2
+module github.com/netdata/pulsar-client-go/oauth2
 
 go 1.13
 

diff --git a/oauth2/store/keyring.go b/oauth2/store/keyring.go
@@ -24,8 +24,8 @@ import (
 	"sync"
 
 	"github.com/99designs/keyring"
-	"github.com/apache/pulsar-client-go/oauth2"
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 )
 
 type KeyringStore struct {

diff --git a/oauth2/store/memory.go b/oauth2/store/memory.go
@@ -20,8 +20,8 @@ package store
 import (
 	"sync"
 
-	"github.com/apache/pulsar-client-go/oauth2"
-	"github.com/apache/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
 )
 
 type MemoryStore struct {

diff --git a/oauth2/store/store.go b/oauth2/store/store.go
@@ -20,7 +20,7 @@ package store
 import (
 	"errors"
 
-	"github.com/apache/pulsar-client-go/oauth2"
+	"github.com/netdata/pulsar-client-go/oauth2"
 )
 
 // ErrNoAuthenticationData indicates that stored authentication data is not available

diff --git a/perf/perf-consumer.go b/perf/perf-consumer.go
@@ -26,7 +26,7 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 // ConsumeArgs define the parameters required by consume

diff --git a/perf/perf-producer.go b/perf/perf-producer.go
@@ -28,7 +28,7 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 )
 
 // ProduceArgs define the parameters required by produce

diff --git a/perf/pulsar-perf-go.go b/perf/pulsar-perf-go.go
@@ -30,7 +30,7 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar"
+	"github.com/netdata/pulsar-client-go/pulsar"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 )
 

diff --git a/pulsar/client.go b/pulsar/client.go
@@ -21,7 +21,7 @@ import (
 	"crypto/tls"
 	"time"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal/auth"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/auth"
 )
 
 func NewClient(options ClientOptions) (Client, error) {

diff --git a/pulsar/client_impl.go b/pulsar/client_impl.go
@@ -27,9 +27,9 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
-	"github.com/apache/pulsar-client-go/pulsar/internal/auth"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/auth"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 )
 
 const (

diff --git a/pulsar/client_impl_test.go b/pulsar/client_impl_test.go
@@ -27,7 +27,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal/auth"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/auth"
 	"github.com/stretchr/testify/assert"
 )
 

diff --git a/pulsar/consumer_impl.go b/pulsar/consumer_impl.go
@@ -30,8 +30,8 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 )
 
 var (

diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -30,9 +30,9 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
-	"github.com/apache/pulsar-client-go/pulsar/internal/compression"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/compression"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 )
 
 var (

diff --git a/pulsar/consumer_partition_test.go b/pulsar/consumer_partition_test.go
@@ -20,12 +20,12 @@ package pulsar
 import (
 	"testing"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal/compression"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/compression"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
 )
 
 func TestSingleMessageIDNoAckTracker(t *testing.T) {

diff --git a/pulsar/consumer_regex.go b/pulsar/consumer_regex.go
@@ -30,7 +30,7 @@ import (
 
 	log "github.com/sirupsen/logrus"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
 )
 
 const (

diff --git a/pulsar/consumer_regex_test.go b/pulsar/consumer_regex_test.go
@@ -27,7 +27,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
 )
 
 func TestFilterTopics(t *testing.T) {

diff --git a/pulsar/consumer_test.go b/pulsar/consumer_test.go
@@ -27,7 +27,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
 	"github.com/stretchr/testify/assert"
 )
 

diff --git a/pulsar/dlq_router.go b/pulsar/dlq_router.go
@@ -22,7 +22,7 @@ import (
 	"errors"
 	"time"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/pulsar/helper.go b/pulsar/helper.go
@@ -24,8 +24,8 @@ import (
 
 	"github.com/gogo/protobuf/proto"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 )
 
 // NewUnexpectedErrMsg instantiates an ErrUnexpectedMsg error.

diff --git a/pulsar/impl_message.go b/pulsar/impl_message.go
@@ -25,7 +25,7 @@ import (
 
 	"github.com/gogo/protobuf/proto"
 
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 )
 
 type messageID struct {

diff --git a/pulsar/internal/auth/oauth2.go b/pulsar/internal/auth/oauth2.go
@@ -21,10 +21,10 @@ import (
 	"crypto/tls"
 	"fmt"
 
-	"github.com/apache/pulsar-client-go/oauth2"
-	"github.com/apache/pulsar-client-go/oauth2/cache"
-	"github.com/apache/pulsar-client-go/oauth2/clock"
-	"github.com/apache/pulsar-client-go/oauth2/store"
+	"github.com/netdata/pulsar-client-go/oauth2"
+	"github.com/netdata/pulsar-client-go/oauth2/cache"
+	"github.com/netdata/pulsar-client-go/oauth2/clock"
+	"github.com/netdata/pulsar-client-go/oauth2/store"
 )
 
 const (

diff --git a/pulsar/internal/batch_builder.go b/pulsar/internal/batch_builder.go
@@ -20,8 +20,8 @@ package internal
 import (
 	"time"
 
-	"github.com/apache/pulsar-client-go/pulsar/internal/compression"
-	pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+	"github.com/netdata/pulsar-client-go/pulsar/internal/compression"
+	pb "github.com/netdata/pulsar-client-go/pulsar/internal/pulsar_proto"
 	"github.com/gogo/protobuf/proto"
 
 	log "github.com/sirupsen/logrus"