You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/14 16:34:06 UTC
[pulsar-client-go] 29/38: Renamed to pulsar-client-go
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
commit dfd7550791033554fd5f2d3f55ccc2fb76749756
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Sun May 5 16:36:29 2019 -0700
Renamed to pulsar-client-go
---
perf/perf-consumer.go | 2 +-
perf/perf-producer.go | 2 +-
pulsar/impl/batch_builder.go | 4 ++--
pulsar/impl/commands.go | 2 +-
pulsar/impl/connection.go | 2 +-
pulsar/impl/connection_reader.go | 2 +-
pulsar/impl/lookup_service.go | 2 +-
pulsar/impl/lookup_service_test.go | 2 +-
pulsar/impl/rpc_client.go | 2 +-
pulsar/impl_client.go | 4 ++--
pulsar/impl_message.go | 2 +-
pulsar/impl_partition_producer.go | 6 +++---
pulsar/impl_producer.go | 2 +-
pulsar/producer_test.go | 2 +-
14 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/perf/perf-consumer.go b/perf/perf-consumer.go
index e6fdf77..ee315ba 100644
--- a/perf/perf-consumer.go
+++ b/perf/perf-consumer.go
@@ -22,7 +22,7 @@ package main
import (
"context"
"encoding/json"
- "pulsar-client-go-native/pulsar"
+ "pulsar-client-go/pulsar"
"github.com/spf13/cobra"
log "github.com/sirupsen/logrus"
"sync/atomic"
diff --git a/perf/perf-producer.go b/perf/perf-producer.go
index c40af30..e8fd76f 100644
--- a/perf/perf-producer.go
+++ b/perf/perf-producer.go
@@ -26,7 +26,7 @@ import (
"github.com/bmizerany/perks/quantile"
"github.com/spf13/cobra"
log "github.com/sirupsen/logrus"
- "pulsar-client-go-native/pulsar"
+ "pulsar-client-go/pulsar"
"time"
)
diff --git a/pulsar/impl/batch_builder.go b/pulsar/impl/batch_builder.go
index 0619154..6675d8d 100644
--- a/pulsar/impl/batch_builder.go
+++ b/pulsar/impl/batch_builder.go
@@ -3,8 +3,8 @@ package impl
import (
"github.com/golang/protobuf/proto"
log "github.com/sirupsen/logrus"
- "pulsar-client-go-native/pulsar/impl/compression"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ "pulsar-client-go/pulsar/impl/compression"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
"time"
)
diff --git a/pulsar/impl/commands.go b/pulsar/impl/commands.go
index c2db791..7a55a89 100644
--- a/pulsar/impl/commands.go
+++ b/pulsar/impl/commands.go
@@ -3,7 +3,7 @@ package impl
import (
"github.com/golang/protobuf/proto"
log "github.com/sirupsen/logrus"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
)
const MaxFrameSize = 5 * 1024 * 1024
diff --git a/pulsar/impl/connection.go b/pulsar/impl/connection.go
index 580a821..75ad6e3 100644
--- a/pulsar/impl/connection.go
+++ b/pulsar/impl/connection.go
@@ -6,7 +6,7 @@ import (
log "github.com/sirupsen/logrus"
"net"
"net/url"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
"sync"
"sync/atomic"
"time"
diff --git a/pulsar/impl/connection_reader.go b/pulsar/impl/connection_reader.go
index 3b45dc4..8277507 100644
--- a/pulsar/impl/connection_reader.go
+++ b/pulsar/impl/connection_reader.go
@@ -5,7 +5,7 @@ import (
"github.com/golang/protobuf/proto"
"github.com/pkg/errors"
"io"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
)
type connectionReader struct {
diff --git a/pulsar/impl/lookup_service.go b/pulsar/impl/lookup_service.go
index 3dfe758..ce1360e 100644
--- a/pulsar/impl/lookup_service.go
+++ b/pulsar/impl/lookup_service.go
@@ -6,7 +6,7 @@ import (
"github.com/golang/protobuf/proto"
log "github.com/sirupsen/logrus"
"net/url"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
)
type LookupResult struct {
diff --git a/pulsar/impl/lookup_service_test.go b/pulsar/impl/lookup_service_test.go
index 7e18198..62f0ea7 100644
--- a/pulsar/impl/lookup_service_test.go
+++ b/pulsar/impl/lookup_service_test.go
@@ -4,7 +4,7 @@ import (
"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/assert"
"net/url"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
"testing"
)
diff --git a/pulsar/impl/rpc_client.go b/pulsar/impl/rpc_client.go
index 706b9a1..137d6f0 100644
--- a/pulsar/impl/rpc_client.go
+++ b/pulsar/impl/rpc_client.go
@@ -3,7 +3,7 @@ package impl
import (
"github.com/golang/protobuf/proto"
"net/url"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
"sync"
"sync/atomic"
)
diff --git a/pulsar/impl_client.go b/pulsar/impl_client.go
index a1f6e10..f688208 100644
--- a/pulsar/impl_client.go
+++ b/pulsar/impl_client.go
@@ -4,8 +4,8 @@ import (
"fmt"
log "github.com/sirupsen/logrus"
"net/url"
- "pulsar-client-go-native/pulsar/impl"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ "pulsar-client-go/pulsar/impl"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
)
type client struct {
diff --git a/pulsar/impl_message.go b/pulsar/impl_message.go
index 5d54678..651bab3 100644
--- a/pulsar/impl_message.go
+++ b/pulsar/impl_message.go
@@ -2,7 +2,7 @@ package pulsar
import (
"github.com/golang/protobuf/proto"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
)
type messageId struct {
diff --git a/pulsar/impl_partition_producer.go b/pulsar/impl_partition_producer.go
index 78f14af..9e8800c 100644
--- a/pulsar/impl_partition_producer.go
+++ b/pulsar/impl_partition_producer.go
@@ -4,9 +4,9 @@ import (
"context"
"github.com/golang/protobuf/proto"
log "github.com/sirupsen/logrus"
- "pulsar-client-go-native/pulsar/impl"
- "pulsar-client-go-native/pulsar/impl/util"
- pb "pulsar-client-go-native/pulsar/pulsar_proto"
+ "pulsar-client-go/pulsar/impl"
+ "pulsar-client-go/pulsar/impl/util"
+ pb "pulsar-client-go/pulsar/pulsar_proto"
"sync"
"sync/atomic"
"time"
diff --git a/pulsar/impl_producer.go b/pulsar/impl_producer.go
index aec4eb5..f1b5509 100644
--- a/pulsar/impl_producer.go
+++ b/pulsar/impl_producer.go
@@ -2,7 +2,7 @@ package pulsar
import (
"context"
- "pulsar-client-go-native/pulsar/impl"
+ "pulsar-client-go/pulsar/impl"
)
type producer struct {
diff --git a/pulsar/producer_test.go b/pulsar/producer_test.go
index f7455ce..1408170 100644
--- a/pulsar/producer_test.go
+++ b/pulsar/producer_test.go
@@ -4,7 +4,7 @@ import (
"context"
log "github.com/sirupsen/logrus"
"github.com/stretchr/testify/assert"
- "pulsar-client-go-native/pulsar/impl/util"
+ "pulsar-client-go/pulsar/impl/util"
"sync"
"testing"
"time"