You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2019/08/05 01:35:32 UTC
[pulsar-client-go] branch master updated (987d2f0 -> 9c79c0b)
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.
from 987d2f0 Merge pull request #37 from wolfstudy/xiaolong/fix-zlib-compress
new a5bde62 Impl consumer logic for go client
new b2e59ef fix messageID and Seek logic
new b26016e Add test case for consumer
new 3a1e41c fix a little
new 26b421e fix dead lock of UnackedMessageTracker
new faa0e18 Fix unsubscribe logic
new b6982c5 Fix an issue where partition topic could not be created correctly
new f04ca7b Support multi partition receive logic
new 81540a2 support unsubscribe logic in consumer
new 7f0eba1 add unsubscribe test and handler channel logic of closing
new f172fb2 Impl consumer logic for go client
new c577157 fix messageID and Seek logic
new fee4fd1 Add test case for consumer
new 96cd5c4 fix a little
new b1ac841 fix dead lock of UnackedMessageTracker
new 6edeab9 Fix unsubscribe logic
new bbfffce Fix an issue where partition topic could not be created correctly
new 9aced0f Support multi partition receive logic
new 3c5b583 support unsubscribe logic in consumer
new a56277e fix conflict
new 9da5a04 support ack timeout logic
new 7f80cc7 add unack messages tracker uint test
new 9c64136 Update README.md
new 6e743dc Merge pull request #1 from wty4427300/master
new a5d1d98 remove godoc and add in other pull request
new a042223 support consumer listener logic
new 003037c Add some unit test for consumer and add IsNil func
new 54f8ee2 add key_shared test case for consumer
new f77a470 add partition topic test case for consumer
new 7148b47 add ack timeout test case for consumer
new 1a7fda0 Merge master and fix conflict
new 059e15d code format for consumer
new ad1e9be code format
new 0a9a70b Merge master code and fix conflict
new 0db5c44 Fix gofmt and add some comments
new 1c148de fix comments
new 836438a remove openjdk-8-jre-headless
new 66ffac1 fix ci error
new a430e71 comments openjdk-8-jre-headless
new d72134f fix java install errr in dokcer image
new 69adade add some depend for openjdk-8
new cb24d11 fix a little
new d97be18 install jdk8 for docker image
new 33a2899 fix ci error
new 4c90011 fix compression test error
new f525579 Merge master code and fix conflict
new 9c79c0b Merge pull request #16 from wolfstudy/xiaolong/consumer-impl
The 114 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
examples/consumer-listener/consumer-listener.go | 64 ++
examples/consumer/consumer.go | 62 ++
.../producer/producer.go | 59 +-
go.mod | 6 +
go.sum | 15 +
pkg/compression/lz4.go | 3 +-
pkg/pb/PulsarApi.pb.go | 1032 +++++++++++++-------
pulsar/consumer.go | 9 +-
pulsar/consumer_test.go | 341 +++++++
pulsar/error.go | 4 +-
pulsar/impl_client.go | 8 +-
pulsar/impl_consumer.go | 256 +++++
pulsar/impl_message.go | 61 +-
pulsar/impl_partition_consumer.go | 688 +++++++++++++
pulsar/impl_partition_producer.go | 7 +-
pulsar/impl_producer.go | 39 +-
pulsar/internal/checksum.go | 23 +-
pulsar/internal/{hash_test.go => checksum_test.go} | 53 +-
pulsar/internal/commands.go | 137 ++-
pulsar/internal/connection.go | 52 +-
pulsar/internal/lookup_service_test.go | 6 +
pulsar/internal/rpc_client.go | 15 +
pulsar/message.go | 2 +-
pulsar/unackMsgTracker_test.go | 64 ++
pulsar/unackedMsgTracker.go | 213 ++++
util/error.go | 50 +
pulsar/internal/closable.go => util/util.go | 16 +-
pulsar/internal/closable.go => util/util_test.go | 15 +-
28 files changed, 2835 insertions(+), 465 deletions(-)
create mode 100644 examples/consumer-listener/consumer-listener.go
create mode 100644 examples/consumer/consumer.go
copy perf/pulsar-perf-go.go => examples/producer/producer.go (55%)
create mode 100644 pulsar/consumer_test.go
create mode 100644 pulsar/impl_consumer.go
create mode 100644 pulsar/impl_partition_consumer.go
copy pulsar/internal/{hash_test.go => checksum_test.go} (55%)
create mode 100644 pulsar/unackMsgTracker_test.go
create mode 100644 pulsar/unackedMsgTracker.go
create mode 100644 util/error.go
copy pulsar/internal/closable.go => util/util.go (78%)
copy pulsar/internal/closable.go => util/util_test.go (77%)