rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xuji...@apache.org
Subject [rocketmq-client-go] 01/01: [ISSUE #93] More usability API
Date Tue, 09 Jul 2019 05:35:32 GMT
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 <jonnxu@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(-)


Mime
View raw message