You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2020/09/09 10:20:26 UTC
[pulsar] branch master updated (7154185 -> e7c4074)
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7154185 Fix comment: pulsar.Client.create_producer() (#7972)
add e7c4074 [C++] Support key based batching (#7996)
No new revisions were added by this update.
Summary of changes:
pulsar-client-cpp/include/pulsar/Message.h | 2 +-
.../include/pulsar/ProducerConfiguration.h | 32 +++-
pulsar-client-cpp/lib/BatchMessageContainer.cc | 201 +++++----------------
pulsar-client-cpp/lib/BatchMessageContainer.h | 115 ++----------
pulsar-client-cpp/lib/BatchMessageContainerBase.cc | 82 +++++++++
pulsar-client-cpp/lib/BatchMessageContainerBase.h | 167 +++++++++++++++++
.../lib/BatchMessageKeyBasedContainer.cc | 129 +++++++++++++
.../lib/BatchMessageKeyBasedContainer.h | 62 +++++++
pulsar-client-cpp/lib/ClientConnection.cc | 7 +-
pulsar-client-cpp/lib/ClientConnection.h | 5 +-
pulsar-client-cpp/lib/Commands.cc | 30 ++-
pulsar-client-cpp/lib/Commands.h | 4 +-
pulsar-client-cpp/lib/ConsumerImpl.cc | 2 +-
pulsar-client-cpp/lib/MessageAndCallbackBatch.cc | 66 +++++++
pulsar-client-cpp/lib/MessageAndCallbackBatch.h | 82 +++++++++
pulsar-client-cpp/lib/MessageCrypto.cc | 4 +-
pulsar-client-cpp/lib/MessageCrypto.h | 4 +-
.../pulsar/MessageBatch.h => lib/OpSendMsg.h} | 49 ++---
.../lib/{BoostHash.h => PendingFailures.h} | 31 ++--
pulsar-client-cpp/lib/ProducerConfiguration.cc | 17 +-
pulsar-client-cpp/lib/ProducerConfigurationImpl.h | 2 +
pulsar-client-cpp/lib/ProducerImpl.cc | 197 ++++++++++++--------
pulsar-client-cpp/lib/ProducerImpl.h | 32 +---
pulsar-client-cpp/tests/BatchMessageTest.cc | 3 +
pulsar-client-cpp/tests/KeyBasedBatchingTest.cc | 178 ++++++++++++++++++
pulsar-client-cpp/tests/KeySharedConsumerTest.cc | 45 ++++-
26 files changed, 1130 insertions(+), 418 deletions(-)
create mode 100644 pulsar-client-cpp/lib/BatchMessageContainerBase.cc
create mode 100644 pulsar-client-cpp/lib/BatchMessageContainerBase.h
create mode 100644 pulsar-client-cpp/lib/BatchMessageKeyBasedContainer.cc
create mode 100644 pulsar-client-cpp/lib/BatchMessageKeyBasedContainer.h
create mode 100644 pulsar-client-cpp/lib/MessageAndCallbackBatch.cc
create mode 100644 pulsar-client-cpp/lib/MessageAndCallbackBatch.h
copy pulsar-client-cpp/{include/pulsar/MessageBatch.h => lib/OpSendMsg.h} (56%)
copy pulsar-client-cpp/lib/{BoostHash.h => PendingFailures.h} (66%)
create mode 100644 pulsar-client-cpp/tests/KeyBasedBatchingTest.cc