rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq-client-go] 01/01: Move the native branch to master.
Date Sun, 26 Apr 2020 12:32:37 GMT
This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git

commit a0d98167c4bef988a64c5ce237f1054586befe84
Merge: 3423884 17a373f
Author: ShannonDing <libya_003@163.com>
AuthorDate: Sun Apr 26 20:31:39 2020 +0800

    Move the native branch to master.

 .gitignore                                         |    6 +-
 .golangci.yml                                      |  172 +++
 .travis.yml                                        |   43 +-
 PULL_REQUEST_TEMPLATE.md                           |   19 +
 README.md                                          |   27 +-
 api.go                                             |  138 +++
 benchmark/consumer.go                              |   94 +-
 benchmark/producer.go                              |  104 +-
 benchmark/stable.go                                |  126 +--
 config.go                                          |   17 +
 consumer/consumer.go                               | 1061 ++++++++++++++++++
 consumer/consumer_test.go                          |  170 +++
 consumer/interceptor.go                            |  109 ++
 consumer/lock.go                                   |   37 +
 consumer/mock_offset_store.go                      |   94 ++
 consumer/offset_store.go                           |  381 +++++++
 consumer/offset_store_test.go                      |  244 ++++
 consumer/option.go                                 |  276 +++++
 consumer/process_queue.go                          |  377 +++++++
 consumer/pull_consumer.go                          |  253 +++++
 consumer/pull_consumer_test.go                     |   18 +
 consumer/push_consumer.go                          | 1183 ++++++++++++++++++++
 consumer/push_consumer_test.go                     |   75 ++
 consumer/statistics.go                             |  483 ++++++++
 consumer/statistics_test.go                        |  209 ++++
 consumer/strategy.go                               |  247 ++++
 consumer/strategy_test.go                          |  483 ++++++++
 core/api.go                                        |  284 -----
 core/api_test.go                                   |  119 --
 core/error.go                                      |   80 --
 core/error_test.go                                 |   56 -
 core/log.go                                        |   71 --
 core/log_test.go                                   |   42 -
 core/message.go                                    |  147 ---
 core/message_test.go                               |   76 --
 core/producer.go                                   |  309 -----
 core/producer_test.go                              |  173 ---
 core/pull_consumer.go                              |  251 -----
 core/pull_consumer_test.go                         |   47 -
 core/push_consumer.go                              |  248 ----
 core/push_consumer_test.go                         |  113 --
 core/queue.go                                      |   31 -
 core/queue_selector.go                             |   79 --
 core/queue_selector_test.go                        |   69 --
 core/queue_test.go                                 |   31 -
 core/transaction_callback.go                       |   62 -
 core/transaction_producer.go                       |  234 ----
 core/transaction_producer_test.go                  |   77 --
 core/utils.go                                      |   28 -
 core/utils_test.go                                 |   26 -
 core/version.go                                    |   26 -
 core/version_test.go                               |   27 -
 doc/Introduction.md                                |  173 ---
 docs/Introduction.md                               |   95 ++
 docs/client-design.gliffy                          |    1 +
 docs/feature.md                                    |   73 ++
 docs/images/client-design.png                      |  Bin 0 -> 30513 bytes
 docs/zh/native-design_zh.md                        |  114 ++
 docs/zh/rocketmq-protocol_zh.md                    |  117 ++
 errors.go                                          |   29 +
 examples/consumer/acl/main.go                      |   64 ++
 examples/consumer/broadcast/main.go                |   57 +
 examples/consumer/delay/main.go                    |   60 +
 examples/consumer/interceptor/main.go              |   83 ++
 examples/consumer/namespace/main.go                |   65 ++
 examples/consumer/orderly/main.go                  |   60 +
 examples/consumer/pull/main.go                     |   71 ++
 examples/consumer/retry/concurrent/main.go         |   81 ++
 examples/consumer/retry/order/main.go              |   76 ++
 examples/consumer/simple/main.go                   |   58 +
 examples/consumer/strategy/main.go                 |   56 +
 examples/consumer/tag/main.go                      |   58 +
 examples/consumer/trace/main.go                    |   63 ++
 examples/orderly_push_consumer.go                  |   84 --
 examples/producer.go                               |   67 --
 examples/producer/acl/main.go                      |   65 ++
 examples/producer/async/main.go                    |   65 ++
 examples/producer/batch/main.go                    |   58 +
 examples/producer/delay/main.go                    |   55 +
 examples/producer/interceptor/main.go              |   74 ++
 examples/producer/namespace/main.go                |   66 ++
 examples/producer/simple/main.go                   |   61 +
 examples/producer/tag/main.go                      |   58 +
 examples/producer/trace/main.go                    |   64 ++
 examples/producer/transaction/main.go              |  106 ++
 examples/producer_orderly.go                       |   62 -
 examples/push_consumer.go                          |   78 --
 examples/transaction_producer.go                   |   80 --
 go.mod                                             |   20 +
 go.sum                                             |   63 ++
 internal/callback.go                               |   31 +
 internal/client.go                                 |  778 +++++++++++++
 internal/constants.go                              |   29 +
 internal/mock_client.go                            |  419 +++++++
 internal/mock_namesrv.go                           |  189 ++++
 internal/model.go                                  |  263 +++++
 internal/model_test.go                             |  364 ++++++
 internal/mq_version.go                             |   22 +
 internal/namesrv.go                                |  165 +++
 internal/namesrv_test.go                           |  146 +++
 internal/perm.go                                   |   58 +
 internal/remote/codec.go                           |  488 ++++++++
 internal/remote/codec_test.go                      |  368 ++++++
 internal/remote/future.go                          |   69 ++
 internal/remote/interceptor.go                     |   83 ++
 internal/remote/interceptor_test.go                |   29 +
 internal/remote/mock_remote_client.go              |  123 ++
 internal/remote/remote_client.go                   |  318 ++++++
 internal/remote/remote_client_test.go              |  372 ++++++
 examples/main.go => internal/remote/rpchook.go     |   14 +-
 .../remote/tcp_conn.go                             |   56 +-
 internal/request.go                                |  320 ++++++
 internal/response.go                               |   49 +
 internal/route.go                                  |  621 ++++++++++
 internal/route_test.go                             |   84 ++
 internal/trace.go                                  |  502 +++++++++
 internal/trace_test.go                             |  125 +++
 internal/transaction.go                            |   21 +
 internal/utils/errors.go                           |   40 +
 internal/utils/files.go                            |   89 ++
 internal/utils/helper.go                           |   42 +
 internal/utils/helper_test.go                      |   37 +
 internal/utils/math.go                             |   32 +
 internal/utils/net.go                              |   61 +
 internal/utils/net_test.go                         |   24 +
 internal/utils/set.go                              |  103 ++
 internal/utils/string.go                           |   30 +
 internal/validators.go                             |   43 +
 primitive/auth.go                                  |   28 +
 primitive/base.go                                  |  125 +++
 primitive/base_test.go                             |   64 ++
 primitive/ctx.go                                   |  172 +++
 primitive/errors.go                                |   68 ++
 primitive/interceptor.go                           |   51 +
 primitive/message.go                               |  546 +++++++++
 primitive/message_test.go                          |   38 +
 primitive/nsresolver.go                            |  219 ++++
 primitive/nsresolver_test.go                       |  133 +++
 primitive/pool.go                                  |   56 +
 primitive/result.go                                |  122 ++
 primitive/result_test.go                           |   74 ++
 primitive/trace.go                                 |   27 +
 producer/interceptor.go                            |   97 ++
 producer/option.go                                 |  144 +++
 producer/producer.go                               |  554 +++++++++
 producer/producer_test.go                          |  247 ++++
 producer/selector.go                               |  123 ++
 producer/selector_test.go                          |   78 ++
 rlog/log.go                                        |  134 +++
 149 files changed, 17950 insertions(+), 3489 deletions(-)


Mime
View raw message