This is an automated email from the ASF dual-hosted git repository.
xujiang pushed a change to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git.
from 136d792 [ISSUE #101] Add QueueSelector in producer
add 9cf568a optimize options of producer
add 900378c optimize consumer options
add f0edc27 Merge branch 'native' of https://github.com/apache/rocketmq-client-go into
ISSUE-93
add d45a252 fix errors
add 4e80b49 remove kernel package
add 8f19aca fix according disscussion
add 69b6604 Merge branch 'native' of https://github.com/apache/rocketmq-client-go into
ISSUE-93
new 049828c [ISSUE #93] More usability API
The 1 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:
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(-)
rename {internal/consumer => consumer}/consumer.go (74%)
rename {internal/consumer => consumer}/consumer_test.go (100%)
rename {internal/consumer => consumer}/offset_store.go (91%)
rename primitive/options.go => consumer/option.go (51%)
rename {internal/consumer => consumer}/process_queue.go (100%)
rename {internal/consumer => consumer}/pull_consumer.go (81%)
rename {internal/consumer => consumer}/pull_consumer_test.go (100%)
rename {internal/consumer => consumer}/push_consumer.go (86%)
rename {internal/consumer => consumer}/push_consumer_test.go (100%)
rename {internal/consumer => consumer}/statistics.go (100%)
rename {primitive => consumer}/strategy.go (82%)
rename internal/{kernel => }/client.go (93%)
rename internal/{kernel => }/client_test.go (98%)
rename internal/{kernel => }/constants.go (98%)
rename internal/{kernel => }/model.go (99%)
rename internal/{kernel => }/mq_version.go (97%)
rename internal/{kernel => }/namesrv.go (99%)
rename internal/{kernel => }/namesrv_test.go (99%)
rename internal/{kernel => }/perm.go (98%)
rename internal/{kernel => }/request.go (99%)
rename internal/{kernel => }/response.go (98%)
rename internal/{kernel => }/route.go (99%)
rename internal/{kernel => }/route_test.go (98%)
rename internal/{kernel => }/transaction.go (97%)
rename internal/{kernel => }/validators.go (98%)
delete mode 100644 primitive/consume.go
create mode 100644 producer/option.go
rename {internal/producer => producer}/producer.go (75%)
rename {primitive => producer}/selector.go (77%)
rename {primitive => producer}/selector_test.go (98%)
|