This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 21bfeb155 [INLONG-6654][Sort] Supports s3 side-output for dirty data
(#6655)
add 12e8168da [INLONG-6611][TubeMQ] Base implementation of TubeMQ C++
Producer (#6612)
No new revisions were added by this update.
Summary of changes:
.../tubemq-client-cpp/example/CMakeLists.txt | 1 +
.../producer}/CMakeLists.txt | 3 +-
.../example/producer/test_producer.cc | 162 +++++
.../include/tubemq/tubemq_atomic.h | 4 +
.../include/tubemq/tubemq_client.h | 21 +-
.../include/tubemq/tubemq_config.h | 17 +-
.../include/tubemq/tubemq_message.h | 5 +-
.../tubemq-client-cpp/proto/BrokerService.proto | 3 +
.../tubemq-client-cpp/src/baseproducer.cc | 787 +++++++++++++++++++++
.../tubemq-client-cpp/src/baseproducer.h | 126 ++++
.../tubemq-client-cpp/src/const_config.h | 15 +
.../tubemq-client-cpp/src/meta_info.cc | 43 ++
.../tubemq-client-cpp/src/meta_info.h | 27 +
.../tubemq-client-cpp/src/partition_router.cc | 55 ++
.../src/{file_ini.h => partition_router.h} | 42 +-
.../tubemq-client-cpp/src/tubemq_client.cc | 99 ++-
.../tubemq-client-cpp/src/tubemq_config.cc | 42 +-
.../tubemq-client-cpp/src/tubemq_message.cc | 21 +-
.../tubemq-client-cpp/src/utils.cc | 35 +-
.../tubemq-client-cpp/src/utils.h | 6 +-
20 files changed, 1453 insertions(+), 61 deletions(-)
copy inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/{tests/executor_pool
=> example/producer}/CMakeLists.txt (94%)
create mode 100644
inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/example/producer/test_producer.cc
create mode 100644
inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/baseproducer.cc
create mode 100644
inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/baseproducer.h
create mode 100644
inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/partition_router.cc
copy inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/{file_ini.h =>
partition_router.h} (55%)
