You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2020/04/26 12:32:36 UTC
[rocketmq-client-go] branch master updated (3423884 -> a0d9816)
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
[rocketmq-client-go] 01/01: Move the native branch to master.
Posted by di...@apache.org.
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 <li...@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(-)