rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xuji...@apache.org
Subject [rocketmq-client-go] branch native updated (136d792 -> 049828c)
Date Tue, 09 Jul 2019 05:35:31 GMT
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%)


Mime
View raw message