You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by xu...@apache.org on 2019/07/09 05:35:32 UTC
[rocketmq-client-go] 01/01: [ISSUE #93] More usability API
This is an automated email from the ASF dual-hosted git repository.
xujiang pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
commit 049828c7cb93728a190178daaa4bdd9ca3b1b7e8
Merge: 136d792 69b6604
Author: jonnxu <jo...@163.com>
AuthorDate: Tue Jul 9 13:35:27 2019 +0800
[ISSUE #93] More usability API
api.go | 25 ++-
{internal/consumer => consumer}/consumer.go | 231 ++++++++++++++++-----
{internal/consumer => consumer}/consumer_test.go | 0
{internal/consumer => consumer}/offset_store.go | 28 +--
primitive/options.go => consumer/option.go | 175 +++++-----------
{internal/consumer => consumer}/process_queue.go | 0
{internal/consumer => consumer}/pull_consumer.go | 42 ++--
.../consumer => consumer}/pull_consumer_test.go | 0
{internal/consumer => consumer}/push_consumer.go | 136 ++++++------
.../consumer => consumer}/push_consumer_test.go | 0
{internal/consumer => consumer}/statistics.go | 0
{primitive => consumer}/strategy.go | 31 +--
docs/Introduction.md | 2 +-
examples/consumer/interceptor/main.go | 33 +--
examples/consumer/simple/main.go | 17 +-
examples/producer/async/main.go | 36 ++--
examples/producer/interceptor/main.go | 23 +-
examples/producer/simple/main.go | 9 +-
go.mod | 1 +
go.sum | 8 +
internal/{kernel => }/client.go | 42 +++-
internal/{kernel => }/client_test.go | 2 +-
internal/{kernel => }/constants.go | 2 +-
internal/{kernel => }/model.go | 2 +-
internal/{kernel => }/mq_version.go | 2 +-
internal/{kernel => }/namesrv.go | 2 +-
internal/{kernel => }/namesrv_test.go | 2 +-
internal/{kernel => }/perm.go | 2 +-
internal/remote/future.go | 2 +-
internal/remote/remote_client_test.go | 2 +-
internal/{kernel => }/request.go | 2 +-
internal/{kernel => }/response.go | 2 +-
internal/{kernel => }/route.go | 4 +-
internal/{kernel => }/route_test.go | 2 +-
internal/{kernel => }/transaction.go | 2 +-
internal/{kernel => }/validators.go | 2 +-
primitive/consume.go | 142 -------------
primitive/ctx.go | 19 +-
primitive/interceptor.go | 37 +---
primitive/result.go | 4 +-
producer/option.go | 92 ++++++++
{internal/producer => producer}/producer.go | 96 ++++-----
{primitive => producer}/selector.go | 20 +-
{primitive => producer}/selector_test.go | 2 +-
utils/string.go | 1 -
utils/string_test.go | 2 +-
46 files changed, 667 insertions(+), 619 deletions(-)