You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/06/17 10:28:23 UTC
[rocketmq-clients] 03/06: Merge branch 'main' into clients
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit da9da5bbd98efc81ad1eb524430374add69397eb
Merge: 515c9db 68f6fd2
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jun 17 18:26:11 2022 +0800
Merge branch 'main' into clients
.github/workflows/main.yml | 36 +
.vscode/settings.json | 17 +
cpp/.bazelignore | 2 +
cpp/.bazelrc | 138 +++
cpp/.bazelversion | 1 +
cpp/.clang-format | 28 +
cpp/.clang-tidy | 81 ++
cpp/.gitignore | 20 +
cpp/.travis.yml | 173 ++++
cpp/BUILD.bazel | 16 +
cpp/LICENSE | 201 ++++
cpp/README.md | 92 ++
cpp/WORKSPACE | 20 +
cpp/api/BUILD.bazel | 28 +
cpp/api/rocketmq/AdminServer.h | 41 +
cpp/api/rocketmq/BackoffPolicy.h | 70 ++
cpp/api/rocketmq/Configuration.h | 71 ++
cpp/api/rocketmq/ConfigurationDefaults.h | 34 +
cpp/api/rocketmq/ConsumeResult.h | 30 +
cpp/api/rocketmq/Credentials.h | 83 ++
cpp/api/rocketmq/CredentialsProvider.h | 110 ++
cpp/api/rocketmq/ErrorCategory.h | 40 +
cpp/api/rocketmq/ErrorCode.h | 183 ++++
cpp/api/rocketmq/Executor.h | 27 +
cpp/api/rocketmq/ExpressionType.h | 31 +
cpp/api/rocketmq/FilterExpression.h | 46 +
cpp/api/rocketmq/Logger.h | 72 ++
cpp/api/rocketmq/MQClientException.h | 97 ++
cpp/api/rocketmq/Message.h | 180 ++++
cpp/api/rocketmq/MessageListener.h | 28 +
cpp/api/rocketmq/Producer.h | 95 ++
cpp/api/rocketmq/PushConsumer.h | 94 ++
cpp/api/rocketmq/RocketMQ.h | 24 +
cpp/api/rocketmq/SendCallback.h | 29 +
cpp/api/rocketmq/SendReceipt.h | 33 +
cpp/api/rocketmq/SimpleConsumer.h | 111 ++
cpp/api/rocketmq/State.h | 34 +
cpp/api/rocketmq/Tracing.h | 27 +
cpp/api/rocketmq/Transaction.h | 51 +
cpp/api/rocketmq/TransactionChecker.h | 28 +
cpp/api/rocketmq/TransactionState.h | 30 +
cpp/bazel/BUILD.bazel | 16 +
cpp/bazel/curl.bzl | 201 ++++
cpp/bazel/rocketmq_deps.bzl | 170 +++
cpp/ci/build.sh | 10 +
cpp/docs/assets/BasicMode.png | Bin 0 -> 42779 bytes
cpp/docs/assets/class_diagram.png | Bin 0 -> 364206 bytes
cpp/docs/gtest.md | 8 +
cpp/docs/test_coverage.md | 15 +
cpp/examples/BUILD.bazel | 137 +++
cpp/examples/BenchmarkPushConsumer.cpp | 83 ++
cpp/examples/ExampleAsyncProducer.cpp | 113 ++
cpp/examples/ExampleFifoProducer.cpp | 99 ++
cpp/examples/ExampleFifoPushConsumer.cpp | 67 ++
cpp/examples/ExampleProducer.cpp | 94 ++
cpp/examples/ExamplePushConsumer.cpp | 50 +
cpp/examples/ExampleSimpleConsumer.cpp | 66 ++
cpp/examples/ExampleTransactionProducer.cpp | 52 +
cpp/examples/PushConsumerWithCustomExecutor.cpp | 147 +++
cpp/examples/PushConsumerWithThrottle.cpp | 88 ++
cpp/examples/SqlConsumer.cpp | 61 ++
cpp/examples/SqlProducer.cpp | 60 ++
cpp/proto/BUILD.bazel | 79 ++
cpp/proto/apache/rocketmq/v2/admin.proto | 43 +
cpp/proto/apache/rocketmq/v2/definition.proto | 444 ++++++++
cpp/proto/apache/rocketmq/v2/service.proto | 457 ++++++++
cpp/src/main/cpp/admin/AdminClient.cpp | 111 ++
cpp/src/main/cpp/admin/AdminFacade.cpp | 24 +
cpp/src/main/cpp/admin/AdminServerImpl.cpp | 119 +++
cpp/src/main/cpp/admin/AdminServiceImpl.cpp | 65 ++
cpp/src/main/cpp/admin/BUILD.bazel | 59 ++
cpp/src/main/cpp/admin/include/AdminClient.h | 45 +
cpp/src/main/cpp/admin/include/AdminServerImpl.h | 64 ++
cpp/src/main/cpp/admin/include/AdminServiceImpl.h | 37 +
cpp/src/main/cpp/admin/include/ServerCall.h | 82 ++
cpp/src/main/cpp/base/BUILD.bazel | 46 +
cpp/src/main/cpp/base/Configuration.cpp | 45 +
cpp/src/main/cpp/base/ConfigurationDefaults.cpp | 25 +
cpp/src/main/cpp/base/CredentialsProvider.cpp | 210 ++++
cpp/src/main/cpp/base/ErrorCategory.cpp | 116 +++
cpp/src/main/cpp/base/ErrorCode.cpp | 26 +
cpp/src/main/cpp/base/FilterExpression.cpp | 41 +
cpp/src/main/cpp/base/HostInfo.cpp | 77 ++
cpp/src/main/cpp/base/HttpClientImpl.cpp | 90 ++
cpp/src/main/cpp/base/Message.cpp | 89 ++
cpp/src/main/cpp/base/MessageExt.cpp | 33 +
cpp/src/main/cpp/base/MetadataConstants.cpp | 52 +
cpp/src/main/cpp/base/MixAll.cpp | 325 ++++++
cpp/src/main/cpp/base/Protocol.cpp | 153 +++
cpp/src/main/cpp/base/RateLimiter.cpp | 54 +
cpp/src/main/cpp/base/ThreadPoolImpl.cpp | 100 ++
cpp/src/main/cpp/base/TopAddressing.cpp | 76 ++
cpp/src/main/cpp/base/Tracing.cpp | 26 +
cpp/src/main/cpp/base/UniqueIdGenerator.cpp | 90 ++
cpp/src/main/cpp/base/UtilAll.cpp | 204 ++++
cpp/src/main/cpp/base/include/Histogram.h | 85 ++
cpp/src/main/cpp/base/include/HostInfo.h | 47 +
cpp/src/main/cpp/base/include/HttpClient.h | 53 +
cpp/src/main/cpp/base/include/HttpClientImpl.h | 46 +
cpp/src/main/cpp/base/include/InvocationContext.h | 105 ++
cpp/src/main/cpp/base/include/MessageExt.h | 31 +
cpp/src/main/cpp/base/include/MetadataConstants.h | 44 +
cpp/src/main/cpp/base/include/MixAll.h | 173 ++++
cpp/src/main/cpp/base/include/Protocol.h | 92 ++
cpp/src/main/cpp/base/include/RateLimiter.h | 184 ++++
cpp/src/main/cpp/base/include/RetryPolicy.h | 81 ++
.../cpp/base/include/StsCredentialsProviderImpl.h | 61 ++
cpp/src/main/cpp/base/include/SubscriptionEntry.h | 33 +
cpp/src/main/cpp/base/include/ThreadPool.h | 36 +
cpp/src/main/cpp/base/include/ThreadPoolImpl.h | 57 +
cpp/src/main/cpp/base/include/TopAddressing.h | 52 +
cpp/src/main/cpp/base/include/UniqueIdGenerator.h | 82 ++
cpp/src/main/cpp/base/include/UtilAll.h | 45 +
cpp/src/main/cpp/base/mocks/BUILD.bazel | 28 +
.../main/cpp/base/mocks/include/HttpClientMock.h | 37 +
.../cpp/base/mocks/include/MessageListenerMock.h | 34 +
cpp/src/main/cpp/base/tests/AssignmentTest.cpp | 23 +
cpp/src/main/cpp/base/tests/BUILD.bazel | 54 +
cpp/src/main/cpp/base/tests/ConfigurationTest.cpp | 54 +
cpp/src/main/cpp/base/tests/MessageBuilderTest.cpp | 56 +
cpp/src/main/cpp/base/tests/MessageQueueTest.cpp | 21 +
cpp/src/main/cpp/base/tests/MixAllTest.cpp | 27 +
cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp | 33 +
cpp/src/main/cpp/client/BUILD.bazel | 41 +
cpp/src/main/cpp/client/ClientManagerFactory.cpp | 62 ++
cpp/src/main/cpp/client/ClientManagerImpl.cpp | 1088 ++++++++++++++++++++
cpp/src/main/cpp/client/LogInterceptor.cpp | 97 ++
cpp/src/main/cpp/client/LogInterceptorFactory.cpp | 27 +
.../main/cpp/client/ReceiveMessageStreamReader.cpp | 118 +++
cpp/src/main/cpp/client/RpcClientImpl.cpp | 173 ++++
cpp/src/main/cpp/client/SessionImpl.cpp | 45 +
cpp/src/main/cpp/client/Signature.cpp | 73 ++
cpp/src/main/cpp/client/TelemetryBidiReactor.cpp | 347 +++++++
cpp/src/main/cpp/client/TlsHelper.cpp | 41 +
cpp/src/main/cpp/client/TopicAssignmentInfo.cpp | 59 ++
cpp/src/main/cpp/client/include/Client.h | 66 ++
cpp/src/main/cpp/client/include/ClientConfig.h | 66 ++
cpp/src/main/cpp/client/include/ClientManager.h | 105 ++
.../main/cpp/client/include/ClientManagerFactory.h | 57 +
.../main/cpp/client/include/ClientManagerImpl.h | 241 +++++
.../main/cpp/client/include/ConsumeMessageType.h | 31 +
.../cpp/client/include/HeartbeatDataCallback.h | 31 +
.../client/include/InsecureCertificateVerifier.h | 42 +
.../cpp/client/include/InterceptorContinuation.h | 45 +
cpp/src/main/cpp/client/include/LogInterceptor.h | 34 +
.../cpp/client/include/LogInterceptorFactory.h | 30 +
cpp/src/main/cpp/client/include/Metadata.h | 27 +
.../main/cpp/client/include/OpenSSLCompatible.h | 390 +++++++
.../cpp/client/include/ReceiveMessageCallback.h | 28 +
.../cpp/client/include/ReceiveMessageContext.h | 36 +
.../main/cpp/client/include/ReceiveMessageResult.h | 43 +
.../client/include/ReceiveMessageStreamReader.h | 63 ++
cpp/src/main/cpp/client/include/RpcClient.h | 106 ++
cpp/src/main/cpp/client/include/RpcClientImpl.h | 105 ++
.../main/cpp/client/include/SendMessageContext.h | 73 ++
cpp/src/main/cpp/client/include/Session.h | 30 +
cpp/src/main/cpp/client/include/SessionImpl.h | 45 +
cpp/src/main/cpp/client/include/Signature.h | 30 +
.../main/cpp/client/include/TelemetryBidiReactor.h | 121 +++
cpp/src/main/cpp/client/include/TlsHelper.h | 32 +
cpp/src/main/cpp/client/include/Topic.h | 64 ++
.../main/cpp/client/include/TopicAssignmentInfo.h | 59 ++
.../cpp/client/include/TopicRouteChangeCallback.h | 30 +
cpp/src/main/cpp/client/include/TopicRouteData.h | 67 ++
cpp/src/main/cpp/client/mocks/BUILD.bazel | 29 +
.../cpp/client/mocks/include/ClientManagerMock.h | 99 ++
cpp/src/main/cpp/client/mocks/include/ClientMock.h | 46 +
.../mocks/include/ReceiveMessageCallbackMock.h | 30 +
.../main/cpp/client/mocks/include/RpcClientMock.h | 79 ++
cpp/src/main/cpp/concurrent/BUILD.bazel | 37 +
cpp/src/main/cpp/concurrent/CountdownLatch.cpp | 52 +
.../main/cpp/concurrent/include/CountdownLatch.h | 51 +
cpp/src/main/cpp/log/BUILD.bazel | 29 +
cpp/src/main/cpp/log/LoggerImpl.cpp | 136 +++
cpp/src/main/cpp/log/include/LoggerImpl.h | 102 ++
cpp/src/main/cpp/remoting/BUILD.bazel | 32 +
cpp/src/main/cpp/remoting/BrokerData.cpp | 43 +
.../main/cpp/remoting/QueryRouteRequestHeader.cpp | 29 +
cpp/src/main/cpp/remoting/QueueData.cpp | 49 +
cpp/src/main/cpp/remoting/RemotingCommand.cpp | 113 ++
cpp/src/main/cpp/remoting/TopicRouteData.cpp | 46 +
cpp/src/main/cpp/remoting/include/BrokerData.h | 38 +
.../cpp/remoting/include/CommandCustomHeader.h | 33 +
cpp/src/main/cpp/remoting/include/LanguageCode.h | 41 +
.../cpp/remoting/include/QueryRouteRequestHeader.h | 46 +
cpp/src/main/cpp/remoting/include/QueueData.h | 44 +
.../main/cpp/remoting/include/RemotingCommand.h | 106 ++
.../cpp/remoting/include/RemotingCommandType.h | 31 +
cpp/src/main/cpp/remoting/include/RequestCode.h | 32 +
cpp/src/main/cpp/remoting/include/ResponseCode.h | 32 +
cpp/src/main/cpp/remoting/include/TopicRouteData.h | 44 +
cpp/src/main/cpp/remoting/include/Version.h | 31 +
.../cpp/rocketmq/AsyncReceiveMessageCallback.cpp | 116 +++
cpp/src/main/cpp/rocketmq/BUILD.bazel | 34 +
cpp/src/main/cpp/rocketmq/ClientImpl.cpp | 539 ++++++++++
.../cpp/rocketmq/ConsumeMessageServiceImpl.cpp | 150 +++
cpp/src/main/cpp/rocketmq/ConsumeTask.cpp | 182 ++++
.../cpp/rocketmq/DynamicNameServerResolver.cpp | 129 +++
.../cpp/rocketmq/MessageGroupQueueSelector.cpp | 35 +
cpp/src/main/cpp/rocketmq/NamingScheme.cpp | 89 ++
cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp | 250 +++++
cpp/src/main/cpp/rocketmq/Producer.cpp | 96 ++
cpp/src/main/cpp/rocketmq/ProducerImpl.cpp | 580 +++++++++++
cpp/src/main/cpp/rocketmq/PushConsumer.cpp | 53 +
cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp | 562 ++++++++++
cpp/src/main/cpp/rocketmq/SendContext.cpp | 118 +++
cpp/src/main/cpp/rocketmq/SimpleConsumer.cpp | 141 +++
cpp/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp | 400 +++++++
.../main/cpp/rocketmq/StaticNameServerResolver.cpp | 38 +
cpp/src/main/cpp/rocketmq/TopicPublishInfo.cpp | 125 +++
cpp/src/main/cpp/rocketmq/TransactionImpl.cpp | 48 +
.../rocketmq/include/AsyncReceiveMessageCallback.h | 52 +
cpp/src/main/cpp/rocketmq/include/ClientImpl.h | 213 ++++
.../cpp/rocketmq/include/ClientResourceBundle.h | 38 +
.../cpp/rocketmq/include/ConsumeMessageService.h | 71 ++
.../rocketmq/include/ConsumeMessageServiceImpl.h | 87 ++
cpp/src/main/cpp/rocketmq/include/ConsumeTask.h | 87 ++
cpp/src/main/cpp/rocketmq/include/Consumer.h | 45 +
.../rocketmq/include/DynamicNameServerResolver.h | 73 ++
.../rocketmq/include/MessageGroupQueueSelector.h | 36 +
.../main/cpp/rocketmq/include/NameServerResolver.h | 37 +
cpp/src/main/cpp/rocketmq/include/NamingScheme.h | 50 +
cpp/src/main/cpp/rocketmq/include/ProcessQueue.h | 71 ++
.../main/cpp/rocketmq/include/ProcessQueueImpl.h | 176 ++++
cpp/src/main/cpp/rocketmq/include/ProducerImpl.h | 166 +++
.../cpp/rocketmq/include/PublishInfoCallback.h | 28 +
.../main/cpp/rocketmq/include/PushConsumerImpl.h | 225 ++++
cpp/src/main/cpp/rocketmq/include/SendContext.h | 79 ++
.../main/cpp/rocketmq/include/SimpleConsumerImpl.h | 89 ++
.../rocketmq/include/StaticNameServerResolver.h | 53 +
.../main/cpp/rocketmq/include/TopicPublishInfo.h | 63 ++
.../main/cpp/rocketmq/include/TransactionImpl.h | 76 ++
cpp/src/main/cpp/rocketmq/mocks/BUILD.bazel | 28 +
.../mocks/include/ConsumeMessageServiceMock.h | 40 +
.../main/cpp/rocketmq/mocks/include/ConsumerMock.h | 37 +
.../mocks/include/NameServerResolverMock.h | 33 +
.../cpp/rocketmq/mocks/include/ProcessQueueMock.h | 63 ++
.../cpp/rocketmq/mocks/include/PushConsumerMock.h | 49 +
cpp/src/main/cpp/rocketmq/tests/BUILD.bazel | 38 +
.../main/cpp/rocketmq/tests/SendContextTest.cpp | 17 +
cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp | 31 +
cpp/src/main/cpp/scheduler/BUILD.bazel | 32 +
cpp/src/main/cpp/scheduler/SchedulerImpl.cpp | 195 ++++
cpp/src/main/cpp/scheduler/include/Scheduler.h | 46 +
cpp/src/main/cpp/scheduler/include/SchedulerImpl.h | 90 ++
cpp/src/main/cpp/stats/BUILD.bazel | 30 +
cpp/src/main/cpp/stats/ConsumeStats.cpp | 148 +++
cpp/src/main/cpp/stats/MetricBidiReactor.cpp | 116 +++
cpp/src/main/cpp/stats/OpencensusExporter.cpp | 190 ++++
cpp/src/main/cpp/stats/PublishStats.cpp | 56 +
cpp/src/main/cpp/stats/Tag.cpp | 41 +
cpp/src/main/cpp/stats/include/ConsumeStats.h | 87 ++
cpp/src/main/cpp/stats/include/Exporter.h | 30 +
cpp/src/main/cpp/stats/include/MetricBidiReactor.h | 78 ++
.../main/cpp/stats/include/OpencensusExporter.h | 53 +
cpp/src/main/cpp/stats/include/PublishStats.h | 49 +
cpp/src/main/cpp/stats/include/Tag.h | 35 +
cpp/src/main/cpp/stats/tests/BUILD.bazel | 28 +
cpp/src/main/cpp/stats/tests/PublishStatsTest.cpp | 157 +++
cpp/src/main/cpp/trace/BUILD.bazel | 29 +
cpp/src/main/cpp/trace/TracingUtility.cpp | 87 ++
cpp/src/main/cpp/trace/include/TracingUtility.h | 32 +
cpp/third_party/BUILD.bazel | 16 +
cpp/third_party/ThreadPool.BUILD | 11 +
cpp/third_party/asio.BUILD | 17 +
cpp/third_party/cpp_httplib.BUILD | 17 +
cpp/third_party/curl.BUILD | 35 +
cpp/third_party/filesystem.BUILD | 9 +
cpp/third_party/fmtlib.BUILD | 12 +
cpp/third_party/spdlog.BUILD | 21 +
cpp/tools/copyright.txt | 14 +
cpp/tools/coverage.sh | 17 +
cpp/tools/fix_copyright.py | 59 ++
cpp/tools/format.sh | 6 +
cpp/tools/trouble_shooting.sh | 2 +
cpp/tools/use_clang.sh | 2 +
276 files changed, 22701 insertions(+)