rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq-client-go] branch master updated (3423884 -> a0d9816)
Date Sun, 26 Apr 2020 12:32:36 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 3423884  fix typo.
     add 26011d0  Adding partial implementation of remote in native and docs  (#29)
     add 699442f  fix docs errors (#30)
     add 42878f2  Adding common API for producer and consumer (#32)
     add 4a93af0  remote codec (#33)
     add ddaab38  Partial implementation of Common Module (#36)
     add 3a34ed8  complete remote/client.go interface  and unit test (#38)
     add cb6cc2d  Adding consumer of original (#39)
     add 1a860c8  ring buffer (#40)
     add ca0b2a8  fix tcp scanner bug (#41)
     add 4bbb156  - remove RemotingClient interface (#43)
     add 93d4753  Pull Consumer (#44)
     add cc1dfb2  Add Push Consumer (#47)
     add e6de4b4  Add OffsetStore for Consumer (#49)
     add ef39b28  Native (#56)
     add 529c872  Add ClientProcessor and optimize (#52)
     add f14b760  Refactoring Producer (#58)
     add 1be6628  Removing cgo codes and fix bug (#60)
     add 96c62c6  Update documents for release 2.0.0-alpha1 (#61)
     add 5c00ac1  fix panic bugs when topic not exist (#63)
     add d3b6435  make all remote unit tests pass (#76)
     add 3011efa  Refactor directories & API (#82)
     add d347650  [ISSUE #88]use golangci to improve code quality (#83)
     add f306bd6  [ISSUE #87] use goimport to fmt import order  (#84)
     add 3a3f93b  [ISSUE #86] Add Interceptor for producer and consumer. (#85)
     add 9df5e28  [ISSUE #65] Fix message missing tag  properties  (#94)
     add 884475f  [ISSUE #95] Support multiple NameServe (#96)
     add 9cf568a  optimize options of producer
     add 900378c  optimize consumer options
     add 45cb340  add producer async method. resolve #98 (#100)
     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 979c93e  add producer async method. resolve #98
     add fb9a781  add queueSelector on producer. resolve #101
     add b62ad7a  resolve conflict
     add 2afa740  rename QueueId
     add 136d792  [ISSUE #101] Add QueueSelector in producer
     add 69b6604  Merge branch 'native' of https://github.com/apache/rocketmq-client-go into
ISSUE-93
     add 049828c  [ISSUE #93] More usability API
     add e696fd8  [ISSIUE #75] support shutdown mehtod (#97)
     add 95f5b0d  [ISSUE #108] Add producer unit test (#109)
     add e673b0e  [ISSUE #105] Add PullConsumer. resolve #105 (#106)
     add f4636b0  delete redundant assert.Nil(t, r)
     add 672836c  delete redundant assert.Nil(t, r)
     add 0aa7eaf  [ISSUE #75] Support Statistics of client (#113)
     add 6715597  [ISSUSE #75] change `Fatal(f)` method into `Error(f)` method (#110)
     add 25f4036  [ISSUE #75] Add internal/route.go unit tests (#116)
     add b0162cd  add orderly consume. resolve #114
     add 0b80814  fix order bug.
     add b95e887  [ISSUE #114] Add orderly consume
     add a133666  [ISSUE #104] Support ACL (#117)
     add 52f5a0c  [ISSUE #118]add messaage sendback. resolve #118 (#119)
     add 10b639b  add release note of 2.0.0-alpha2
     add f38894a  [ISSUE #75] Add release note for 2.0.0-alpha2
     add 8a49505  [ISSUE #122]add msg delay to send. resolve #122 (#123)
     add 86498ea  [ISSUE #128]update mockgen command line
     add 09ccdd4  add trace feature. resolve #124 (#125)
     add 40111a9  [ISSUE #131]Update CI config
     add 38184ea  [ISSUE 134] unify interceptor usage
     add 79058cc  [ISSUE #134] Unify interceptor usage
     add 5e093c8  fix ci file (#143)
     add 08cd71e  [ISSUE #139]add locker for updating data (#146)
     add 68358ec  Add transaction support. resolve #137 (#138)
     add ae7a2cf  [ISSUE #148] add consume/statistic.go unit test (#149)
     add e48203d  update defaultConsumer.client init AND add push_consumer testing (#156)
     add b7d9844  var info is nil when file not exist
     add 8b2892b  try to fix ci fail
     add 1e69007  [ISSUE #144] Fix nil pointer when file not exist
     add a85e68c  Merge pull request #1 from apache/native
     add ec51447  Merge pull request #2 from apache/native
     add 86767d6  add AllocateByAveragelyCircle; add the test of  AllocateByAveragely and
AllocateByAveragelyCircle
     add 60b9159  add new line at end of file
     add 0a9fdbc  add local offsetStore test
     add 847555a  add TestRemoteBrokerOffsetStore
     add 2f8f5ea  update strategy log level to warn
     add 03d8dd8  add example/strategy
     add 0e5f64c  add AllocateByConfig,AllocateByMachineRoom and their tests
     add ad5ddf8  update feature.md
     add 404e965  update
     add 66c9a42  travis add HOME
     add 4d71392  go fmt
     add 0f82ff9  go fmt strategy.go
     add 3b99659  Merge pull request #141 from luther-siyuan/native
     add cfb8fd1  Optimize PullConsumer API
     add 9124e47  fix make file bug
     add 691e778  [ISSUE #151] Optimize PullConsumer API
     add ac41607  add GetNamesrv round-robin strategy testing (#159)
     add b422a37  add AllocateByConsistentHash and it's test (#160)
     add 6303ecd  [ISSUE #147] Support Namespace and domain of namesrv (#161)
     add 458e156  support namesrv, resolve #162 (#163)
     add d1c602e  [ISSUE #135] Fix bufio.Scanner token too long error
     add e572801  [ISSUE #164]add UnCompress function implementation (#167)
     add 1a5c1c0   [ISSUE #170]Add ASF header for some source file (#171)
     add 1ee23b7  [ISSUE #173]fix namesrv rr bug and remove extra code.
     add 59cd47f  add ut for defaultConsumer. resolve #178 (#179)
     add a1b4211  add ctx to rmqClient & remoteClient. resolve #176 (#177)
     add 2a210ad  [ISSUE #130] Add Shutdown of PushConsumer (#172)
     add 36b0014  add broadcast consumer examples (#165)
     add 6480b41  [ISSUE #180]add tag filter example. resolve #180 (#181)
     add 63bb636  [ISSUE #190]Modify some code to be more elegant
     add 3bb7ed7  [ISSUE #188]fix consumer example & remove extra file .
     add d441d70  fix offsetSotre. fix #186 (#187)
     add 8c74e4f  Refactor MessageSelector. resolve #192 (#193)
     add 8f5a9c9  Fix the domain checker was rollback before (#196)
     add 303ae26  [ISSUE #184]Fix errors of using internal codes in the exported snippet
     add 71f76b0  [ISSUE #166] Make Access Message.Properties thread safety (#197)
     add d8d5e46  [ISSUE #185] Fix errors of comments and spelling
     add 370dbcd  [ISSUE #183] add set consumeMessageBatchMaxSize and fixed count++ skip one
message
     add 45537bf  [ISSUE #211]fix unmarhsal messageID bug (#210)
     add 7b049f5  [ISSUE #201]Change default consumer option to Clustering (#208)
     add af3805f  fix(log):modify log print function in push consumer(#215)
     add 3a507f6  doc(introduction): modify some directory error in doc/Introduction.md
     add 398e37c  fix: avoid extra err info on pushConsumer startup - register consumer before
defaultConsumer start] Closes #194
     add 2eed2fa  feat: support log level and log path - add method for Logger interface -
add method for set level and log path of default log
     add 805bfbf  fix: avoid file not found err when remove old offset file
     add 66041c9  [ISSUE #243]fix: replace consistent package (#244)
     add 77b0861  fix: support acl for trace (#240)
     add f3968f8  fix(travis): Fix travis ci error (#245)
     add 8e61430  fix: support multiple consumer&producer (#242)
     add a52192e  feat: support hashQueueSelector (#249)
     add bd44991  feat: reduce receive memory usage (#255)
     add 22b37a4  feat: graceful shutdown lockTicker (#259) (#265)
     add feb011d  fix: ConsumerGroup cannot auto create (#194) (#258)
     add d1e89b9  [ISSUE #272] Structured Log (#273)
     add b14d435  fix ci error (#275)
     add 2fc3b39  feat(protocol): unify name of request header (#284)
     add 3eb4710  fix(PushConsumer):fix the consumer subscripe with tag (#277)
     add aaf93cb  support broker addr search by default topic (#276)
     add 92dfa3b  fix(protocol): SearchOffsetByTimestamp protocol bug (#282)
     add 0a3dc7e  feat(protocol): remove extra json tag (#283)
     add e25a2aa  fix(consumer): goroutine leak when shutdown (#286)
     add 4364ebd  Add SetLogger method (#290)
     add 0e9d5b1  [ISSUE #299] offset store read missing fallthrough for _ReadMemoryThenStore
     add 28715e5  [ISSUE #293] Optimize Close of rmqClient (#303)
     add 4f00f3f  [ISSUE #294] Resolve problem print error log when producer/consumer shutdown
(#308)
     add c9b9f93  feat(consumer): advance code (#309)
     add 82bd638  [ISSUE #271] Fix bugs that can't consume multiple topics in single consumer
(#310)
     add 757420d  [ISSUE #301] Adding GET_CONSUMER_RUNNING_INFO (#311)
     add c6b08aa  fix: using atomic status for producer/consumer (#320)
     add 028214a  feat(message): remove extra code (#324)
     add bda9f6a  [ISSUE #328] message add GetProperties func (#325)
     add fdbb58a  feat(client): add mutex for rebalance (#316)
     add f9521f9  Prevent pc.prch blocking (#327)
     add 85ee94b  fix bugs of panic when decode MessageExt (#330)
     add 41f7106  fix(message): 错误的 equals实现 (#319)
     add 7b021b1  fix: lots of  incorrect impl (#322)
     add c57a000  feat(producer): support batch message send (#332)
     add 649f89b  [ISSUE #314] support name server domain (#315)
     add 3f00503  feat(core): fix concurrent read/write for broker version (#333)
     add df01296  feat(example): rename shutdown instead of shundown (#336)
     add be743f7  fix(route): update route (#339)
     add 598c979  fix: pull timeout and suspend time is not consistent with java (#350)
     add 0f2efa6  feat: more consumer option config (#363)
     add 08cdb4e  feat: rename persistent with interval (#359)
     add 9fe339c  [ISSUE #352]feat: use jsoniter to replace with json (#353)
     add 7f7a35d  [ISSUE #344] feat(client): advance timeout (#351)
     add 1fbd400  feat: use pool for header codec (#361)
     add 4c3fa1c  [ISSUE #366] feat: remove extra code (#367)
     add fad9882  feat: remote extra code for internal/utils (#370)
     add 2ace48a  [ISSUE #356] feat(consumer): redesign stat (#357)
     add 088ab71  change transaction producer about struct, interface, chan type from struct
to struct pointer (#373)
     add 33798bc  [ISSUE #371]feat: clean extra code for internal packagec (#372)
     add 7308bc9  [ISSUE #354] feat: Support PanicHandler (#355)
     add 145a42c  fix(doc): update notice and open statistic label (#378)
     add 8f76a40  feat(consumer): move updatePullFromWhichNode ahead of result check (#390)
     add 27e707e  fix: consume type compatible with protocol (#387)
     add 848a09a  merge rc1 chages to native branch (#395)
     add 8937360  fix(core): unalign field panic when atomic operation (#397)
     add 320d965  fix: lock is extra when not orderly consume (#393)
     add f9e5f75  fix(consumer): remove commit flag if slave pull (#399)
     add 4f9013e  [ISSUE #402] fix(consumer): improve retry topic support (#403)
     add 683c9ac  feat(nameserver): correct impl of UpdateTopicRouteInfo (#406)
     add adc707f  feat: support mq error (#392)
     add f2db09f  fix(strategy): change the deafult mq sort to ASC when do rebalance. (#420)
     add 089cc03  fix(consumer): use sync offset fix instead if async (#414)
     add 4f42398  fix(travisci): use archive server to avoid download rocketmq package failed
(#422)
     add 8e6f902  fix(consumer): sub info not updated when scale out queue (#418)
     add 2e05fc0  feat: reuse bytes.Buffer (#408)
     add 1ade23a  feat(producer): auto create topic for producer (#416)
     add af4067c  fix(consumer): brokerName not found when broker recover from machine crash.
(#429)
     add 2af5495  fix(producer): update name server address immediately when client start
; or end up with a failed publish (#436)
     add 2c78dae  fix(retry): can not consume the messages in the retry topic (#437)
     add 191cd4c  add WithNameServerDomain for producer opt (#438)
     add fb29389  fix(heatbeat): change consume type to avoid fastjson decode error in lower
broker version (#442)
     add 1ce9fd9  fix(producer): UpdateNameServerAddress shoule be called before producer
start, or namesrvs list will be empty, lead to a panic (#445)
     add e9d9ceb  fix: correct msgid (#449)
     add 267dca5  feat: ignore eof err (#450)
     add 9a58797  [ISSUE #462] fix the trace message was send failed. (#463)
     add be57995  modify version and readme to release 2.0.0 (#469)
     add 0897f19  [ISSUE #471] The message mode, ctype and where was wrong in the heartbeat
data
     add 17a373f  feat: support nameserver resolver (#457)
     new a0d9816  Move the native branch to master.

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:
 .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(-)
 create mode 100644 .golangci.yml
 create mode 100644 PULL_REQUEST_TEMPLATE.md
 create mode 100644 api.go
 create mode 100644 config.go
 create mode 100644 consumer/consumer.go
 create mode 100644 consumer/consumer_test.go
 create mode 100644 consumer/interceptor.go
 create mode 100644 consumer/lock.go
 create mode 100644 consumer/mock_offset_store.go
 create mode 100644 consumer/offset_store.go
 create mode 100644 consumer/offset_store_test.go
 create mode 100644 consumer/option.go
 create mode 100644 consumer/process_queue.go
 create mode 100644 consumer/pull_consumer.go
 create mode 100644 consumer/pull_consumer_test.go
 create mode 100644 consumer/push_consumer.go
 create mode 100644 consumer/push_consumer_test.go
 create mode 100644 consumer/statistics.go
 create mode 100644 consumer/statistics_test.go
 create mode 100644 consumer/strategy.go
 create mode 100644 consumer/strategy_test.go
 delete mode 100644 core/api.go
 delete mode 100644 core/api_test.go
 delete mode 100644 core/error.go
 delete mode 100644 core/error_test.go
 delete mode 100644 core/log.go
 delete mode 100644 core/log_test.go
 delete mode 100644 core/message.go
 delete mode 100644 core/message_test.go
 delete mode 100644 core/producer.go
 delete mode 100644 core/producer_test.go
 delete mode 100644 core/pull_consumer.go
 delete mode 100644 core/pull_consumer_test.go
 delete mode 100644 core/push_consumer.go
 delete mode 100644 core/push_consumer_test.go
 delete mode 100644 core/queue.go
 delete mode 100644 core/queue_selector.go
 delete mode 100644 core/queue_selector_test.go
 delete mode 100644 core/queue_test.go
 delete mode 100644 core/transaction_callback.go
 delete mode 100644 core/transaction_producer.go
 delete mode 100644 core/transaction_producer_test.go
 delete mode 100644 core/utils.go
 delete mode 100644 core/utils_test.go
 delete mode 100644 core/version.go
 delete mode 100644 core/version_test.go
 delete mode 100644 doc/Introduction.md
 create mode 100644 docs/Introduction.md
 create mode 100644 docs/client-design.gliffy
 create mode 100644 docs/feature.md
 create mode 100644 docs/images/client-design.png
 create mode 100644 docs/zh/native-design_zh.md
 create mode 100644 docs/zh/rocketmq-protocol_zh.md
 create mode 100644 errors.go
 create mode 100644 examples/consumer/acl/main.go
 create mode 100644 examples/consumer/broadcast/main.go
 create mode 100644 examples/consumer/delay/main.go
 create mode 100644 examples/consumer/interceptor/main.go
 create mode 100644 examples/consumer/namespace/main.go
 create mode 100644 examples/consumer/orderly/main.go
 create mode 100644 examples/consumer/pull/main.go
 create mode 100644 examples/consumer/retry/concurrent/main.go
 create mode 100644 examples/consumer/retry/order/main.go
 create mode 100644 examples/consumer/simple/main.go
 create mode 100644 examples/consumer/strategy/main.go
 create mode 100644 examples/consumer/tag/main.go
 create mode 100644 examples/consumer/trace/main.go
 delete mode 100644 examples/orderly_push_consumer.go
 delete mode 100644 examples/producer.go
 create mode 100644 examples/producer/acl/main.go
 create mode 100644 examples/producer/async/main.go
 create mode 100644 examples/producer/batch/main.go
 create mode 100644 examples/producer/delay/main.go
 create mode 100644 examples/producer/interceptor/main.go
 create mode 100644 examples/producer/namespace/main.go
 create mode 100644 examples/producer/simple/main.go
 create mode 100644 examples/producer/tag/main.go
 create mode 100644 examples/producer/trace/main.go
 create mode 100644 examples/producer/transaction/main.go
 delete mode 100644 examples/producer_orderly.go
 delete mode 100644 examples/push_consumer.go
 delete mode 100644 examples/transaction_producer.go
 create mode 100644 go.mod
 create mode 100644 go.sum
 create mode 100644 internal/callback.go
 create mode 100644 internal/client.go
 create mode 100644 internal/constants.go
 create mode 100644 internal/mock_client.go
 create mode 100644 internal/mock_namesrv.go
 create mode 100644 internal/model.go
 create mode 100644 internal/model_test.go
 create mode 100644 internal/mq_version.go
 create mode 100644 internal/namesrv.go
 create mode 100644 internal/namesrv_test.go
 create mode 100644 internal/perm.go
 create mode 100644 internal/remote/codec.go
 create mode 100644 internal/remote/codec_test.go
 create mode 100644 internal/remote/future.go
 create mode 100644 internal/remote/interceptor.go
 create mode 100644 internal/remote/interceptor_test.go
 create mode 100644 internal/remote/mock_remote_client.go
 create mode 100644 internal/remote/remote_client.go
 create mode 100644 internal/remote/remote_client_test.go
 rename examples/main.go => internal/remote/rpchook.go (85%)
 rename core/consumer_callback.go => internal/remote/tcp_conn.go (51%)
 create mode 100644 internal/request.go
 create mode 100644 internal/response.go
 create mode 100644 internal/route.go
 create mode 100644 internal/route_test.go
 create mode 100644 internal/trace.go
 create mode 100644 internal/trace_test.go
 create mode 100644 internal/transaction.go
 create mode 100644 internal/utils/errors.go
 create mode 100644 internal/utils/files.go
 create mode 100644 internal/utils/helper.go
 create mode 100644 internal/utils/helper_test.go
 create mode 100644 internal/utils/math.go
 create mode 100644 internal/utils/net.go
 create mode 100644 internal/utils/net_test.go
 create mode 100644 internal/utils/set.go
 create mode 100644 internal/utils/string.go
 create mode 100644 internal/validators.go
 create mode 100644 primitive/auth.go
 create mode 100644 primitive/base.go
 create mode 100644 primitive/base_test.go
 create mode 100644 primitive/ctx.go
 create mode 100644 primitive/errors.go
 create mode 100644 primitive/interceptor.go
 create mode 100644 primitive/message.go
 create mode 100644 primitive/message_test.go
 create mode 100644 primitive/nsresolver.go
 create mode 100644 primitive/nsresolver_test.go
 create mode 100644 primitive/pool.go
 create mode 100644 primitive/result.go
 create mode 100644 primitive/result_test.go
 create mode 100644 primitive/trace.go
 create mode 100644 producer/interceptor.go
 create mode 100644 producer/option.go
 create mode 100644 producer/producer.go
 create mode 100644 producer/producer_test.go
 create mode 100644 producer/selector.go
 create mode 100644 producer/selector_test.go
 create mode 100644 rlog/log.go


Mime
View raw message