This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.
from e7b779c Fixed memory leak of connection (#165)
add 71d81b6 Topic reader implementation (#158)
No new revisions were added by this update.
Summary of changes:
.../{consumer/consumer.go => reader/reader.go} | 19 +-
pulsar/client_impl.go | 8 +-
pulsar/consumer.go | 3 +
pulsar/consumer_impl.go | 22 +-
pulsar/consumer_partition.go | 257 ++++++++++++---
pulsar/impl_message.go | 22 ++
pulsar/internal/commands.go | 2 +
pulsar/reader.go | 10 +-
pulsar/reader_impl.go | 147 +++++++++
pulsar/reader_test.go | 364 +++++++++++++++++++++
10 files changed, 789 insertions(+), 65 deletions(-)
copy examples/{consumer/consumer.go => reader/reader.go} (78%)
create mode 100644 pulsar/reader_impl.go
create mode 100644 pulsar/reader_test.go
