You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2024/02/06 22:56:25 UTC
(pulsar-client-cpp) branch merlimat-patch-1 updated (fea1c2d -> 18689b6)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch merlimat-patch-1
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git
from fea1c2d Fixed workflow definition
add 4251f79 Renamed gitjhub action jobs and removed centos7 build (#25)
add 5fc6979 Generate and install pulsarStaticWithDeps into correct paths (#26)
add 94500a8 Fix README.md build path (#29)
add 4451cbd [fix] Force static libraries to be linked when LINK_STATIC is enabled (#28)
add a080faa Expose start message id inclusive configuration in C API (#27)
add 6deaaf5 Removed extra call of `find_package(OpenSSL)` (#30)
add 97d73cd Fix incorrect path in docker scripts (#32)
add 5f2b786 Enable required check status for PR validation (#33)
add d72924f Link to OpenSSL statically when LINK_STATIC is ON (#31)
add b6653d6 [docs] Fix compilation guidance on Ubuntu (#34)
add 829618d Enable required check status for unit tests job (#35)
add 782b4f8 Added option to set the method name for Basic authentication (#37)
add 176c8d7 Use Alpine 3.12 to build APKs (#39)
add 0fdcbe4 Improved the CI check completion (#40)
add aa83477 Move main to next version (#41)
add ebc4437 Fix Ubuntu and macOS build guide (#44)
add 748dad5 Removed docker-build.sh script (#46)
add 0fbe25e Fixed typos in stage-release.sh (#47)
add ce8fe5a Use parametrized job to build packages (#36)
add ba1a7e1 Updated Github actions versions to avoid deprecations (#49)
add c1a9808 Fixed validation of cluster/namespace names containing legal non-alpha characters (#52)
add 7f7653b [feat] Consumer support batch receive messages. (#21)
add 55b4bc9 [fix] Fix memory leak caused by incorrect close and destruction (#54)
add dd1481b [flaky-test] Fix very flaky tests for TEST_P (#59)
add 1b701e3 Fixed the release artifacts package file name (#57)
add 7bb6402 [flaky tests] Fix flaky ShutdownTest::testDestructor (#62)
add 872f8ab [refactor] Apply forward declaration as much as possible (#64)
add ecc1995 Stick clang-format version to 11 and add back docker-format.sh (#45)
add 7ec2ce7 Fix macOS build (#67)
add ec9271d [fix][doc] explicitly instruct clone the repo (#69)
add 1ea58e1 Add windows release artifacts (#72)
add c671ac0 [feat] Support KeyValue Schema. (#22)
add 2248adc [ci] Add macOS build workflow (#68)
add 42a425f Fix ci install deps failed. (#96)
add 93a44c8 Support linking static dependencies when building with MSVC (#73)
add 74ebc10 [refactor] Remove useless config file. (#76)
add a1ec5b9 [Build] Use Windows server 2019 to release Windows artifacts (#99)
add 2980bbe [feat] Support acknowledging a list of messages (#23)
add 94b909e [fix] Fix consumer doesn't clear incomingMessageQueue during seek (#101)
add 69e5680 [fix] Flush no batch message when call producer.flush (#98)
add efd2a1e Fix doxygen generation (#103)
add 74ef1a0 [feat] Support expiration for chunked messages (#71)
add 1f7fdb8 Fix MessageId::getDataAsString() crashed with MSVC debug config (#108)
add 5a27ba3 [feat] Support WaitForExclusive producer access mode. (#109)
add ad79bec [fix] Fix wrong behavior when removing the chunkedMessageCtx (#110)
add d396c90 [Improve][Build] Use pulsar client as a submodule for C++ projects (#115)
add 1721e00 Add MessageId::batchSize() and the MessageIdBuilder (#105)
add ac3033d Doxygen supports darkmode toggle (#119)
add 1a0ce69 [feat] Support consumer seek by timestamp and reader seek for C Api (#118)
add de94bc5 Fix getLastMessageId method dead recursion. (#117)
add 9f9314a Fix segmentation fault during the destruction of ConsumerImpl (#121)
add f0268ec [improve] Skip include debug artifact in the release and tar the windows artifacts (#124)
add 96d8705 Fix NamedEntity::checkName regression (#127)
add 85b1b53 [fix] Fix PartitionedProducerImpl::closeAsync to close sub-producers properly (#125)
add 88d1f20 [fix] Fix acknowledge MessageId list does not work when ackGroupingTimeMs is 0 (#128)
add 91a97eb Fix the broken master by the upgrade of GTest (#133)
add 34d62fa [fix] Close broker producer created after producer close (#131)
add 7a7b3aa [fix] Fix a crash when closing a connection while connecting (#136)
add 18dcdd5 Use boost::optional instead self-written Optional class (#138)
add 2018a06 Add BatchedMessageIdImpl to acknowledge batched messages (#132)
add cd0dcb1 Bumped version to 3.2.0-pre (#141)
add 39e8a88 [fix] Use sudo when executing `apt-get install` (#143)
add 44f3b52 Add CMAKE to the Homebrew installation line (#145)
add c8b98c6 [fix] Use authoritative argument correctly in BinaryProtoLookupService::findBroker (#146)
add fa3ac76 [feat] PIP 107: Introduce chunk message ID (#148)
add 97af35a fix auxv header (#152)
add 3a3e973 [fix][build] Hide non-exported symbols from the dependencies (#155)
add 5d5ed2a Format .c suffix file. (#159)
add d03ff20 [fix] Fix MessageId serialization when it's a batched message (#153)
add d04ba21 [fix] Fix log for connection disconnected expectedly (#156)
add f3fc502 The C API supports setting the log level. (#158)
add 8990b93 [feat] Add pulsar_logger_t as the configurable C logger (#162)
add a46da16 [feat] Support messages with generic types (#149)
add cedc0c1 Fix segfault caused by socket I/O on a closed io_service (#168)
add 5b26626 [fix] Fix missing schema related function definitions (#171)
add 06eab69 Support batch index acknowledgment (#151)
add 3202bcd [fix] Fix hostname verification (#126)
add 7fa3c43 Fix broken main branch caused by wrong getBitSet method (#177)
add 3e5c9c7 [feat] Reader support readeNextAsync interface. (#176)
add 9ed6a45 [feat] Support Dead Letter Topic. (#139)
add 96507ce [feat] Support auto download schema when create producer. (#157)
add dd649f5 Fix wireshark build (#182)
add 63c4245 Support the Wireshark plugin for more Wireshark distributions (#183)
add 70ccd83 [feat] Support partitioned topic reader. (#154)
add 0631e36 [fix] Avoid resource leakage of AckGroupingTracker (#185)
add 39183d3 [fix] Use ClientConfiguration::getTlsTrustCertsFilePath for the OAuth2 flow (#190)
add f69d0ce Fix deadlock when closing the partitioned producer (#187)
add c3e3e8a NegativeAcksTracker need close when consumer closed. (#188)
add 40d45aa [TableView-1] Add table view API (#189)
add 05807bd [improve] Add configuration to limit times of client's lookup redirection. (#129)
add f55b4bd Fix broken main branch that failed to build the wireshark dissector on macOS (#199)
add 86c915b [feat] Add producer interceptor (#169)
add e6b9d09 [refactor] Handle responses in methods instead of switch cases (#197)
add 92c182a [fix] Redeliver messages that can't be decrypted. (#160)
add 070e96f [improve] Refactor client version format (#206)
add 14b0451 [fix] Handle exceptions when creating timers when fd limit is reached (#203)
add 242ad77 [TableView-2] Implement all interfaces. (#196)
add b7fecc3 Fix Client::close might hang forever for a multi-topics consumer (#211)
add 81830b7 Fix testPublishEmptyValue flaky test. (#216)
add 2108d54 Fix flaky testAcknowledgeCumulativeWithPartition (#214)
add e2de5fc Fix event loop thread might exit unexpectedly (#217)
add 861b198 Use shared_ptr for topic name in message ids (#218)
add 998c73d [feat] Add consumer interceptor (#210)
add e79357e Make stats timers thread safe to use (#223)
add b4f70dc Fix TableViewTest.testCreateTableView flaky test. (#222)
add 3ae6d1f [feat] Support ExclusiveWithFencing producer access mode. (#201)
add ba52218 Fix possible crash caused by MessageId::getTopicName (#225)
add ba7f59d [feat] Add `onNegativeAcksSend` to the consumer interceptor (#220)
add 8167852 [fix] Use unique topic name in ConsumerInterceptorsTest (#231)
add 14623ca Fix flaky test ProducerTest.testWaitForExclusiveProducer (#233)
add 1f91575 Support waiting for the ACK response (#232)
add fc6dbe5 [fix][flaky] Remove zero queue case in ConsumerInterceptorTest to reduce flaky (#239)
add cb82141 Fix ack non-persistent topic will be blocked. (#240)
add d0d7e39 [feat] Support pattern subscribe non-persistent topic. (#207)
add 86d66bd [fix] Consumer batch receive will cause data loss. (#228)
add 3bb3a72 Fix typo in comment (#243)
add 5ad3f25 [feat] Support set producer access mode for C client. (#245)
add 0088a64 Fix compilation error that occurs when USE_LOG4CXX is ON (#244)
add 2f61c62 Speed up the process to start standalone for tests (#236)
add f4587d7 [feat] Support set batch index ack for C client. (#246)
add a57bb07 [cleanup] Remove useless variable `interceptors_` definition (#250)
add 713e254 Fix the static library might failed to link on Windows (#251)
add 4d659a8 [feat] Support set consumer regex subscription mode for C client. (#247)
add d2cfabd Support the base64 encoded credentials for OAuth2 authentication (#249)
add d4b4862 [C API] Support synchronous consumer batch receive (#252)
add bc57b4d PIP-254: Support configuring client version with a description suffix (#253)
add 058d099 Complete batch receive other feature of C client (#254)
add ef25a62 [Bug Fix][KeySharedPolicy] Fixed bug where KeySharedPolicy::setStickyRanges duplicated ranges. (#242)
add 8f96463 Improve the C APIs for batch receive policy and fix the wrong documents (#256)
add e3f6505 [feat] Support dead letter topic for C client. (#237)
add 1cc88bf Fix broken debian package build process (#258)
add 4063562 Support get the SchemaInfo from a topic and the schema version (#257)
add 043c88b [feat] Support end-to-end encryption in C Reader API (#262)
add 4338d45 [doc] Fix compile perf on MacOS and Ubuntu. (#263)
add 3e49fe5 [Doc] Add links to client docs and feature matrix in README.md (#264)
add 8a9b2dc Fix deadlock for negative acknowledgment (#266)
add 191a6b4 Support specifying the C++ standard for some higher dependencies (#269)
add 49d9f18 Bumped version to 3.3.0-pre (#271)
add 3e4f49a Fix batch receive for C client unit test faied. (#272)
add 4209987 [improve] AuthAthenz supports Copper Argos (#274)
add 0ab478a [consumer] Support parse broker metadata (#276)
add d883c60 add cmake-build-debug dir to gitignore (#275)
add 413461a [docs] Fix the developer guide for macOS users (#279)
add a42261b Fix flaky testConsumerEventWithoutPartition cause by the change of Pulsar 3.0 (#281)
add d03e46a Add getIndex method on Message (#277)
add 9bfed6d Fix testSchemaIncompatibility for Protobuf 3.20.0 or later (#282)
add a4ee89d Remove log4cxx dependency and its specified configuration (#283)
add 8d5a412 Close the socket gracefully on Windows (#284)
add 7cfe07c Fix ci failed on macos env. (#288)
add 0202218 Fix broker return error code confuse when not set subscription name. (#289)
add 1143a87 feat: Support message copy for C client. (#285)
add 27000ee Perfect missing tls related method definitions. (#287)
add 0ef3ddf [feat] Support configure startMessageIdInclusive for the reader (#291)
add 633f4bb Fix build failure with the Protobuf 23.3 (#290)
add 94cf3fc Fix retriable errors not handled well when creating producer or consumer (#293)
add 804f87b [fix] producer do not create when topic update partition (#295)
add 20f6fa0 Fix the buggy Future and Promise implementations (#299)
add 342aea4 Fix the test script does not work for Docker on macOS (#297)
add 51d11db feat: Support table view for C client. (#294)
add e737716 Fix the wrong backoff computation when retrying (#296)
add 0e63af9 Fix the build failure with C++20 standard (#302)
add ffee4a0 [fix] callback of send batch message is error when flush (#303)
add d1347c7 [fix][client] Memory leak during GET_LAST_MESSAGE_ID command processing. (#301)
add 1e7d259 fix: authentication refresh when command data is not available (#304)
add afb2fcb Bumped version to 3.4.0-pre (#305)
add cac5e1d Avoid copying OpSendMsg when sending messages (#308)
add 6ebea5c Avoid calling serializeSingleMessageInBatchWithPayload each time a message is added (#309)
add 2e2f90b Avoid double attempt at reconnecting (#310)
add 84ac6fb Fix the visibility compilation error for GCC <= 7 (#312)
add 787bfd0 [fix] Add the curl wrapper to avoid inconsistent curl options (#313)
add b242e1a Fix broken cpp-build-windows workflow (#316)
add ba5902a Fix broken wireshark build workflow on macOS (#318)
add b35ae1a Avoid accessing a null ClientConnection instance (#317)
add af45a54 Fix the handler instance is expired when the connection is established (#323)
add f2c580b Fix pending requests failed with ResultConnectError when disconnecting (#322)
add eea59bb [fix] Fix consumer doesn't acknowledge all chunk message Ids (#321)
add 5c77648 Fix segmentation fault when sending messages after receiving an error (#326)
add 33085eb Fix topic not shown correctly in the consumer string (#329)
add ebae92e Delay the timing of setting reconnectionPending to false to avoid double attempt at reconnecting (#328)
add a0f2d32 Fix segmentation fault caused by async_receive (#330)
add 7cefe0e Fix topic name is shown as a pointer rather than string (#331)
add 6daf7a5 Avoid blocking the message listener threads (#332)
add a01c16e Upgrade libcurl to 8.4.0 to fix CVEs (#335)
add 77e2d63 Fix possible deadlock of Future when adding a listener after completed (#334)
add 81cc562 Added support for multiple connections to each broker (#336)
add 6f115e7 Fix ProducerBusy or ConsumerBusy error when configuring multiple brokers per connection (#337)
add 47fb809 Use absolute path to find credential files in unit tests (#340)
add a8402da Fix close() returns ResultAlreadyClosed after unsubscribe or close (#338)
add bb16f24 Fix lazy partitioned producer might send duplicated messages (#342)
add 8d32fd2 Bumped version to 3.5.0-pre (#344)
add 6d47e94 Fix crash when removing connection from the pool (#347)
add c771b12 Log topic lookup result (#351)
add 7bb94f4 Fix bad_weak_ptr when close a ClientConnection during construction (#350)
add 37ea769 Fix the flush callback might be called repeatedly (#353)
add f75b39b Fix Protobuf symbols not found in libpulsarwithdeps.a when building on macOS (#354)
add 0bbc155 Gather the macOS binaries when releasing (#355)
add d209482 Fix HTTP lookup segfault when the redirect host cannot be resolved (#356)
add 751c807 Install Version.h when installing by CMakeLists (#361)
add 63d494f Add the Consumer::getConsumerName API (#360)
add 24ab12c Fix accessing destroyed objects in the callback of async_wait (#362)
add 27cba3e Fix tlsTrustCertsFilePath config is not applied for OAuth2 (#364)
add 7087a8e Expose Get/Set Listener Name in C API (#370)
add 7baa312 Integrate vcpkg to manage dependencies for all platforms (#371)
add e04686d Fix the unstable wireshark workflow on macOS (#374)
add 25ea451 [PIP-60] [Proxy-Client] Support SNI routing for Pulsar CPP client (#373)
add d1b287c Fix issue where custom logger setting is ignored (#377)
add a4b7f12 Retry on new partition producer creation failure (#378)
add f7e493b Remove the Boost.Random dependency (#380)
add 90ea369 Depend on the independent Asio instead of Boost.Asio by default (#382)
add 9ffd2ef Fix Boost source code download failure (#384)
add a1cf401 Fix `StartMessageIdInclusive` not work when reader reads from latest msg id (#386)
add 6eb228e Fix wrong TimeUtils::currentTimeMillis() implementation (#387)
add 72b7311 Fix the operation timeout is not honored for GetSchema requests (#383)
add e13bd6d [docs] Add example for how to import the library via vcpkg (#379)
add d1dd08b [feat] PIP-307 added assigned broker urls for CloseProudcer and CloseConsumer commands and handler logic (#389)
add d107d32 Pin the Pulsar version to 3.1.1 temporarily for the regression in Pulsar (#395)
add a1e2b4a Fix multi-topics consumer could receive old messages after seek (#388)
add c7e53ac Do not close the socket when the broker failed due to MetadataStoreException (#390)
add 77e0c22 Fix an unbalanced release of the producer's pending semaphore (#392)
add 1f94dd9 Disable topic level policies to make tests work (#397)
add 289c930 Fix broken main branch after Pulsar image was upgraded to 3.2.0 (#400)
add 71077b8 Fix segmenatation fault if connection is closed during handshake (#399)
add 18689b6 Merge remote-tracking branch 'apache/main' into merlimat-patch-1
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 8 +-
.clang-format | 2 +-
.github/workflows/ci-build-binary-artifacts.yaml | 317 ++--
.github/workflows/ci-pr-validation.yaml | 301 ++--
.gitignore | 9 +-
.gitmodules | 3 +
CMakeLists.txt | 392 +----
Doxyfile | 23 +-
LEGACY_BUILD.md | 250 +++
LegacyFindPackages.cmake | 308 ++++
README.md | 269 +---
.../Dockerfile.format | 22 +-
.../{copy-deps-versionfile.sh => docker-format.sh} | 17 +-
build-support/download-release-artifacts.py | 3 +
build-support/run_clang_format.py | 2 +-
.../setup-test-service-container.sh | 20 +-
build-support/stage-release.sh | 18 +-
.../start-mim-test-service-inside-container.sh | 85 +
.../start-test-service-inside-container.sh | 128 +-
cmake_modules/FindClangTools.cmake | 4 +-
dependencies.yaml | 6 +-
docker-build-centos7.sh | 39 -
docker-build.sh | 49 -
docker-format.sh | 47 -
docker-tests.sh | 88 -
docker/alpine/Dockerfile | 99 --
docker/alpine/Dockerfile-alpine-3.8 | 99 --
docker/alpine/build-alpine-image.sh | 33 -
docker/alpine/build-wheel-file-within-docker.sh | 38 -
docker/alpine/build-wheel.sh | 34 -
docker/build-client-lib.sh | 49 -
docker/centos-7/Dockerfile | 47 -
docker/push-images.sh | 46 -
docs/MainPage.md | 180 ---
examples/CMakeLists.txt | 64 +-
examples/SampleAsyncConsumerCApi.c | 2 +-
examples/SampleAsyncProducer.cc | 6 +-
examples/SampleConsumer.cc | 6 +-
examples/SampleConsumerCApi.c | 7 +-
examples/SampleConsumerListener.cc | 6 +-
examples/SampleConsumerListenerCApi.c | 9 +-
examples/SampleCustomLoggerCApi.c | 153 ++
...Consumer.cc => SampleKeyValueSchemaConsumer.cc} | 25 +-
...Producer.cc => SampleKeyValueSchemaProducer.cc} | 38 +-
examples/SampleProducer.cc | 6 +-
examples/SampleProducerCApi.c | 7 +-
examples/SampleReaderCApi.c | 8 +-
include/pulsar/Authentication.h | 15 +-
include/pulsar/BatchReceivePolicy.h | 92 ++
include/pulsar/BrokerConsumerStats.h | 8 +-
include/pulsar/Client.h | 57 +-
include/pulsar/ClientConfiguration.h | 122 +-
include/pulsar/Consumer.h | 76 +-
include/pulsar/ConsumerConfiguration.h | 165 +-
include/pulsar/ConsumerInterceptor.h | 121 ++
include/pulsar/CryptoKeyReader.h | 4 +-
...{ConsumerEventListener.h => DeadLetterPolicy.h} | 52 +-
include/pulsar/DeadLetterPolicyBuilder.h | 94 ++
include/pulsar/DeprecatedException.h | 3 +-
include/pulsar/EncryptionKeyInfo.h | 5 +-
include/pulsar/KeySharedPolicy.h | 7 +-
include/pulsar/KeyValue.h | 84 +
include/pulsar/Logger.h | 3 +-
include/pulsar/Message.h | 49 +-
include/pulsar/MessageBatch.h | 6 +-
include/pulsar/MessageBuilder.h | 19 +-
include/pulsar/MessageId.h | 22 +-
include/pulsar/MessageIdBuilder.h | 115 ++
include/pulsar/MessageRoutingPolicy.h | 3 +-
include/pulsar/Producer.h | 6 +-
include/pulsar/ProducerConfiguration.h | 33 +-
include/pulsar/ProducerInterceptor.h | 114 ++
include/pulsar/ProtobufNativeSchema.h | 2 +-
include/pulsar/Reader.h | 11 +-
include/pulsar/ReaderConfiguration.h | 29 +-
.../pulsar/RegexSubscriptionMode.h | 31 +-
include/pulsar/Result.h | 5 +-
include/pulsar/Schema.h | 37 +-
include/pulsar/TableView.h | 129 ++
.../{TopicMetadata.h => TableViewConfiguration.h} | 25 +-
.../pulsar/TypedMessage.h | 30 +-
include/pulsar/TypedMessageBuilder.h | 79 +
include/pulsar/c/client.h | 59 +-
include/pulsar/c/client_configuration.h | 30 +
include/pulsar/c/consumer.h | 68 +-
include/pulsar/c/consumer_configuration.h | 103 ++
include/pulsar/c/message.h | 11 +-
include/pulsar/c/message_id.h | 2 +-
include/pulsar/c/message_router.h | 2 +-
include/pulsar/c/{message_router.h => messages.h} | 27 +-
include/pulsar/c/producer.h | 5 +-
include/pulsar/c/producer_configuration.h | 26 +-
include/pulsar/c/reader.h | 48 +-
include/pulsar/c/reader_configuration.h | 14 +-
include/pulsar/c/table_view.h | 141 ++
.../c/{string_map.h => table_view_configuration.h} | 22 +-
lib/AckGroupingTracker.cc | 129 +-
lib/AckGroupingTracker.h | 70 +-
lib/AckGroupingTrackerDisabled.cc | 22 +-
lib/AckGroupingTrackerDisabled.h | 24 +-
lib/AckGroupingTrackerEnabled.cc | 134 +-
lib/AckGroupingTrackerEnabled.h | 60 +-
lib/{Log4CxxLogger.h => AsioDefines.h} | 29 +-
lib/{checksum/crc32c_sw.h => AsioTimer.h} | 12 +-
lib/Authentication.cc | 27 +-
lib/Backoff.cc | 14 +-
lib/Backoff.h | 13 +-
lib/Base64Utils.h | 59 +
lib/BatchAcknowledgementTracker.cc | 176 --
lib/BatchAcknowledgementTracker.h | 104 --
lib/BatchMessageAcker.h | 93 ++
lib/BatchMessageContainer.cc | 25 +-
lib/BatchMessageContainer.h | 13 +-
lib/BatchMessageContainerBase.cc | 60 +-
lib/BatchMessageContainerBase.h | 87 +-
lib/BatchMessageKeyBasedContainer.cc | 55 +-
lib/BatchMessageKeyBasedContainer.h | 12 +-
lib/BatchReceivePolicy.cc | 58 +
.../crc32c_sw.h => BatchReceivePolicyImpl.h} | 8 +-
...ultiResultCallback.h => BatchedMessageIdImpl.h} | 41 +-
lib/BinaryProtoLookupService.cc | 107 +-
lib/BinaryProtoLookupService.h | 45 +-
lib/BitSet.h | 267 +++
lib/BlockingQueue.h | 36 +-
lib/BoostHash.h | 5 +-
lib/BrokerConsumerStats.cc | 5 +-
lib/BrokerConsumerStatsImpl.cc | 3 +-
lib/BrokerConsumerStatsImpl.h | 12 +-
lib/BrokerConsumerStatsImplBase.h | 1 -
lib/CMakeLists.txt | 101 +-
...pingTrackerDisabled.cc => ChunkMessageIdImpl.h} | 41 +-
lib/Client.cc | 39 +-
lib/ClientConfiguration.cc | 68 +-
lib/ClientConfigurationImpl.h | 12 +-
lib/ClientConnection.cc | 1703 +++++++++++---------
lib/ClientConnection.h | 225 ++-
lib/ClientConnectionAdaptor.h | 61 +
lib/ClientImpl.cc | 404 +++--
lib/ClientImpl.h | 89 +-
lib/Commands.cc | 284 +++-
lib/Commands.h | 87 +-
lib/CompressionCodec.cc | 38 +-
lib/CompressionCodec.h | 9 +-
lib/CompressionCodecLZ4.cc | 3 +-
lib/CompressionCodecSnappy.cc | 2 +-
lib/CompressionCodecZLib.cc | 4 +-
lib/CompressionCodecZLib.h | 2 -
lib/ConnectionPool.cc | 116 +-
lib/ConnectionPool.h | 44 +-
lib/ConsoleLoggerFactory.cc | 3 +-
lib/ConsoleLoggerFactoryImpl.h | 3 +-
lib/Consumer.cc | 51 +-
lib/ConsumerConfiguration.cc | 62 +-
lib/ConsumerConfigurationImpl.h | 8 +
lib/ConsumerImpl.cc | 1003 ++++++++----
lib/ConsumerImpl.h | 184 ++-
lib/ConsumerImplBase.cc | 139 ++
lib/ConsumerImplBase.h | 68 +-
lib/ConsumerInterceptors.cc | 94 ++
lib/{ServiceURI.h => ConsumerInterceptors.h} | 43 +-
lib/CryptoKeyReader.cc | 9 +-
lib/CurlWrapper.h | 183 +++
lib/DeadLetterPolicyBuilder.cc | 55 +
lib/{JavaStringHash.cc => DeadLetterPolicyImpl.cc} | 26 +-
.../crc32c_sw.h => DeadLetterPolicyImpl.h} | 9 +-
lib/DeprecatedException.cc | 2 +-
lib/EncryptionKeyInfoImpl.h | 5 +-
lib/ExecutorService.cc | 70 +-
lib/ExecutorService.h | 52 +-
lib/FileLoggerFactory.cc | 3 +-
lib/FileLoggerFactoryImpl.h | 5 +-
lib/Future.h | 202 +--
lib/GetLastMessageIdResponse.h | 12 +-
lib/HTTPLookupService.cc | 346 ++--
lib/HTTPLookupService.h | 30 +-
lib/HandlerBase.cc | 174 +-
lib/HandlerBase.h | 107 +-
lib/{checksum/crc32c_sw.h => Int64SerDes.h} | 22 +-
lib/JavaStringHash.cc | 1 +
lib/JavaStringHash.h | 3 +-
lib/KeySharedPolicy.cc | 16 +-
lib/{FileLoggerFactoryImpl.h => KeyValue.cc} | 28 +-
lib/KeyValueImpl.cc | 78 +
lib/{EncryptionKeyInfoImpl.h => KeyValueImpl.h} | 41 +-
lib/Latch.h | 5 +-
lib/Log4cxxLogger.cc | 97 --
lib/LogUtils.cc | 24 +-
lib/LogUtils.h | 35 +-
lib/LookupDataResult.h | 7 +-
lib/LookupService.h | 36 +-
lib/MapCache.h | 17 +
lib/MemoryLimitController.h | 2 +-
lib/Message.cc | 50 +-
lib/MessageAndCallbackBatch.cc | 80 +-
lib/MessageAndCallbackBatch.h | 57 +-
lib/MessageBatch.cc | 6 +-
lib/MessageBuilder.cc | 24 +-
lib/MessageCrypto.cc | 22 +-
lib/MessageCrypto.h | 35 +-
lib/MessageId.cc | 56 +-
lib/MessageIdBuilder.cc | 77 +
lib/MessageIdImpl.h | 55 +-
lib/MessageIdUtil.h | 13 +-
lib/MessageImpl.cc | 41 +-
lib/MessageImpl.h | 16 +-
lib/MessageRouterBase.cc | 2 +-
lib/MessageRouterBase.h | 7 +-
lib/MessagesImpl.cc | 59 +
.../pulsar/MessageBatch.h => lib/MessagesImpl.h | 38 +-
lib/MultiTopicsBrokerConsumerStatsImpl.cc | 5 +-
lib/MultiTopicsBrokerConsumerStatsImpl.h | 9 +-
lib/MultiTopicsConsumerImpl.cc | 643 ++++++--
lib/MultiTopicsConsumerImpl.h | 104 +-
lib/Murmur3_32Hash.h | 3 +-
lib/NamedEntity.cc | 25 +-
lib/NamespaceName.cc | 10 +-
lib/NamespaceName.h | 3 +-
lib/NegativeAcksTracker.cc | 64 +-
lib/NegativeAcksTracker.h | 33 +-
lib/ObjectPool.h | 7 +-
lib/OpSendMsg.h | 94 +-
lib/PartitionedProducerImpl.cc | 167 +-
lib/PartitionedProducerImpl.h | 44 +-
lib/PatternMultiTopicsConsumerImpl.cc | 73 +-
lib/PatternMultiTopicsConsumerImpl.h | 33 +-
lib/PeriodicTask.cc | 20 +-
lib/PeriodicTask.h | 16 +-
lib/Producer.cc | 5 +-
lib/ProducerConfiguration.cc | 21 +-
lib/ProducerConfigurationImpl.h | 10 +-
lib/ProducerImpl.cc | 547 ++++---
lib/ProducerImpl.h | 116 +-
lib/ProducerImplBase.h | 3 +
lib/ProducerInterceptors.cc | 84 +
...ultiResultCallback.h => ProducerInterceptors.h} | 45 +-
lib/ProtoApiEnums.h | 161 ++
lib/ProtobufNativeSchema.cc | 24 +-
lib/Reader.cc | 10 +-
lib/ReaderConfiguration.cc | 9 +-
lib/ReaderConfigurationImpl.h | 1 +
lib/ReaderImpl.cc | 48 +-
lib/ReaderImpl.h | 32 +-
lib/Result.cc | 5 +-
lib/{checksum/crc32c_sw.h => ResultUtils.h} | 6 +-
lib/RetryableLookupService.h | 130 +-
lib/RetryableOperation.h | 140 ++
lib/RetryableOperationCache.h | 118 ++
lib/RoundRobinMessageRouter.cc | 15 +-
lib/RoundRobinMessageRouter.h | 12 +-
lib/Schema.cc | 104 +-
lib/SchemaUtils.h | 55 +
lib/Semaphore.h | 2 +-
lib/ServiceNameResolver.h | 2 +
lib/ServiceURI.cc | 1 +
lib/ServiceURI.h | 1 +
lib/SharedBuffer.h | 31 +-
lib/SimpleLogger.h | 6 +-
lib/SinglePartitionMessageRouter.cc | 2 +
lib/SinglePartitionMessageRouter.h | 6 +-
lib/SynchronizedHashMap.h | 35 +-
lib/TableView.cc | 97 ++
lib/TableViewImpl.cc | 170 ++
lib/TableViewImpl.h | 86 +
lib/TimeUtils.h | 21 +-
lib/TopicMetadataImpl.cc | 2 +-
lib/TopicMetadataImpl.h | 1 -
lib/TopicName.cc | 32 +-
lib/TopicName.h | 15 +-
lib/UnAckedMessageTrackerDisabled.h | 3 +-
lib/UnAckedMessageTrackerEnabled.cc | 54 +-
lib/UnAckedMessageTrackerEnabled.h | 40 +-
lib/UnAckedMessageTrackerInterface.h | 17 +-
lib/UnboundedBlockingQueue.h | 28 +-
lib/Url.cc | 1 -
lib/Url.h | 3 +-
lib/UtilAllocator.h | 1 +
lib/Utils.h | 38 +-
lib/auth/AuthAthenz.cc | 10 +-
lib/auth/AuthAthenz.h | 4 +-
lib/auth/AuthBasic.cc | 35 +-
lib/auth/AuthBasic.h | 8 +-
lib/auth/AuthOauth2.cc | 203 ++-
lib/auth/AuthOauth2.h | 8 +-
lib/auth/AuthTls.cc | 2 +-
lib/auth/AuthTls.h | 1 -
lib/auth/AuthToken.cc | 6 +-
lib/auth/AuthToken.h | 2 -
lib/auth/{AuthTls.h => InitialAuthData.h} | 23 +-
lib/auth/athenz/ZTSClient.cc | 222 +--
lib/auth/athenz/ZTSClient.h | 23 +-
lib/c/cStringMap.cc | 2 +-
lib/c/c_Authentication.cc | 5 +-
lib/c/c_Client.cc | 28 +
lib/c/c_ClientConfiguration.cc | 58 +-
lib/c/c_Consumer.cc | 40 +
lib/c/c_ConsumerConfiguration.cc | 93 ++
lib/c/c_Message.cc | 14 +
lib/c/c_MessageId.cc | 4 +-
lib/{TimeUtils.cc => c/c_Messages.cc} | 17 +-
lib/c/c_ProducerConfiguration.cc | 12 +-
lib/c/c_Reader.cc | 22 +-
lib/c/c_ReaderConfiguration.cc | 27 +-
lib/c/c_Result.cc | 2 +-
lib/c/c_TableView.cc | 89 +
lib/c/c_TableViewConfiguration.cc | 46 +
lib/c/c_structs.h | 16 +-
lib/checksum/ChecksumProvider.h | 2 +-
lib/checksum/crc32c_arm.cc | 1 +
lib/checksum/crc32c_sse42.cc | 3 +-
lib/checksum/crc32c_sw.cc | 1 +
lib/lz4/lz4.h | 2 +-
lib/stats/ConsumerStatsBase.h | 7 +-
lib/stats/ConsumerStatsDisabled.h | 4 +-
lib/stats/ConsumerStatsImpl.cc | 58 +-
lib/stats/ConsumerStatsImpl.h | 36 +-
lib/stats/ProducerStatsBase.h | 6 +-
lib/stats/ProducerStatsDisabled.h | 4 +-
lib/stats/ProducerStatsImpl.cc | 58 +-
lib/stats/ProducerStatsImpl.h | 33 +-
.../sign-files.sh => perf/BuildPerf.cmake | 16 +-
perf/CMakeLists.txt | 23 +-
perf/{CMakeLists.txt => LegacyBuildPerf.cmake} | 0
perf/PerfConsumer.cc | 34 +-
perf/PerfProducer.cc | 37 +-
perf/RateLimiter.h | 2 +-
pkg/apk/Dockerfile | 13 +-
pkg/deb/Dockerfile | 11 +-
pkg/deb/build-deb.sh | 3 +-
pkg/mac/build-static-library.sh | 193 +++
pkg/rpm/Dockerfile | 11 +-
pkg/rpm/SPECS/pulsar-client.spec | 4 +-
proto/PulsarApi.proto | 4 +
pulsar-test-service-start.sh | 16 +-
pulsar-test-service-stop.sh | 4 +-
run-unit-tests.sh | 52 +-
test-conf/{client-ssl.conf => client-ssl-mim.conf} | 6 +-
test-conf/cpp_credentials_file.json | 2 +
test-conf/hn-verification/broker-cert.pem | 27 +
test-conf/hn-verification/broker-key.pem | 28 +
test-conf/hn-verification/cacert.pem | 29 +
...standalone-ssl.conf => standalone-ssl-mim.conf} | 17 +-
test-conf/standalone-ssl.conf | 11 +
tests/AcknowledgeTest.cc | 383 +++++
tests/AuthBasicTest.cc | 52 +-
tests/AuthPluginTest.cc | 154 +-
tests/AuthTokenTest.cc | 16 +-
tests/BackoffTest.cc | 40 +-
tests/{TopicMetadataImplTest.cc => Base64Test.cc} | 19 +-
tests/BasicEndToEndTest.cc | 382 +++--
tests/BatchMessageTest.cc | 53 +-
...odecSnappyTest.cc => BatchReceivePolicyTest.cc} | 30 +-
tests/BitSetTest.cc | 109 ++
tests/BlockingQueueTest.cc | 26 +-
tests/BuildTests.cmake | 60 +
tests/CMakeLists.txt | 47 +-
tests/ClientDeduplicationTest.cc | 7 +-
tests/ClientTest.cc | 179 +-
tests/CompressionCodecSnappyTest.cc | 2 +-
tests/ConnectionTest.cc | 48 +
tests/ConsumerConfigurationTest.cc | 37 +-
tests/ConsumerStatsTest.cc | 17 +-
tests/ConsumerTest.cc | 667 +++++++-
tests/ConsumerTest.h | 3 +-
tests/{ConsumerTest.h => ConsumerWrapper.cc} | 19 +-
tests/ConsumerWrapper.h | 114 ++
tests/CustomLoggerTest.cc | 16 +-
tests/CustomRoutingPolicy.h | 5 +-
tests/DeadLetterPolicyTest.cc | 45 +
tests/DeadLetterQueueTest.cc | 392 +++++
tests/HashTest.cc | 11 +-
tests/HttpHelper.cc | 25 +-
tests/HttpHelper.h | 1 +
...essionCodecSnappyTest.cc => Int64SerDesTest.cc} | 34 +-
tests/InterceptorsTest.cc | 458 ++++++
tests/KeyBasedBatchingTest.cc | 7 +-
tests/KeySharedConsumerTest.cc | 10 +-
tests/KeySharedPolicyTest.cc | 33 +-
tests/KeyValueImplTest.cc | 116 ++
tests/KeyValueSchemaTest.cc | 93 ++
tests/LatchTest.cc | 6 +-
tests/{CMakeLists.txt => LegacyBuildTests.cmake} | 23 +-
tests/LoggerTest.cc | 3 +-
tests/LookupServiceTest.cc | 454 ++++--
tests/MapCacheTest.cc | 33 +-
tests/MemoryLimitControllerTest.cc | 7 +-
tests/MemoryLimitTest.cc | 14 +-
tests/MessageChunkingTest.cc | 237 ++-
tests/MessageIdTest.cc | 44 +-
tests/MessageTest.cc | 54 +-
tests/MessagesImplTest.cc | 62 +
tests/MultiTopicsConsumerTest.cc | 105 ++
tests/NamespaceNameTest.cc | 13 +-
tests/PartitionsUpdateTest.cc | 15 +-
tests/PeriodicTaskTest.cc | 6 +-
tests/ProducerConfigurationTest.cc | 1 +
tests/ProducerTest.cc | 402 ++++-
tests/PromiseTest.cc | 46 +-
tests/ProtobufNativeSchemaTest.cc | 46 +-
.../PulsarAdminHelper.h | 34 +-
tests/PulsarFriend.h | 110 +-
lib/checksum/crc32c_sw.h => tests/PulsarWrapper.h | 8 +-
tests/ReaderConfigurationTest.cc | 3 +-
tests/ReaderTest.cc | 265 ++-
tests/RetryableOperationCacheTest.cc | 135 ++
tests/RoundRobinMessageRouterTest.cc | 23 +-
tests/SchemaTest.cc | 90 +-
tests/SemaphoreTest.cc | 5 +-
tests/ServiceURITest.cc | 1 +
tests/ShutdownTest.cc | 134 ++
tests/SinglePartitionMessageRouterTest.cc | 12 +-
tests/SynchronizedHashMapTest.cc | 20 +-
lib/Synchronized.h => tests/SynchronizedQueue.h | 25 +-
tests/TableViewTest.cc | 218 +++
tests/ThreadSafeMessages.h | 75 +
tests/TopicMetadataImplTest.cc | 4 +-
tests/TopicNameTest.cc | 31 +-
tests/TypedMessageTest.cc | 136 ++
tests/UnboundedBlockingQueueTest.cc | 21 +-
tests/UrlTest.cc | 3 +-
tests/VersionTest.cc | 2 +-
tests/WaitUtils.h | 8 +-
tests/ZLibCompressionTest.cc | 3 +-
tests/ZTSClientTest.cc | 34 +-
tests/ZeroQueueSizeTest.cc | 7 +-
tests/brokermetadata/BrokerMetadataTest.cc | 96 ++
tests/brokermetadata/docker-compose.yml | 43 +
tests/c/c_BasicEndToEndTest.cc | 8 +-
.../c_ClientConfigurationTest.cc} | 24 +-
tests/c/c_ConsumerConfigurationTest.cc | 63 +-
tests/c/c_ConsumerTest.cc | 195 +++
.../c/message_router.h => tests/c/c_MessageTest.cc | 26 +-
tests/c/c_ProducerConfigurationTest.cc | 6 +-
tests/c/c_ReaderConfigurationTest.cc | 50 +
tests/c/c_SeekTest.cc | 266 +++
tests/c/c_TableViewTest.cc | 176 ++
tests/chunkdedup/ChunkDedupTest.cc | 79 +
tests/chunkdedup/docker-compose.yml | 45 +
tests/extensibleLM/ExtensibleLoadManagerTest.cc | 197 +++
tests/extensibleLM/docker-compose.yml | 150 ++
tests/main.cc | 1 -
tests/oauth2/Oauth2Test.cc | 111 ++
tests/oauth2/docker-compose.yml | 46 +
tests/unix/ConnectionFailTest.cc | 95 ++
vcpkg | 1 +
vcpkg-example/CMakeLists.txt | 18 +
vcpkg-example/README.md | 52 +
vcpkg-example/main.cc | 8 +
vcpkg-example/vcpkg.json | 11 +
vcpkg.json | 87 +-
version.txt | 2 +-
win-examples/CMakeLists.txt | 49 +
tests/PaddingDemo.proto => win-examples/example.cc | 12 +-
wireshark/CMakeLists.txt | 81 +-
wireshark/README.md | 74 +-
wireshark/pulsar-dissector-example.jpg | Bin 0 -> 876001 bytes
wireshark/pulsarDissector.cc | 31 +-
wireshark/wireshark-plugins.jpg | Bin 0 -> 271303 bytes
457 files changed, 21486 insertions(+), 7553 deletions(-)
create mode 100644 .gitmodules
create mode 100644 LEGACY_BUILD.md
create mode 100644 LegacyFindPackages.cmake
copy pkg/apk/docker-build-apk-arm64.sh => build-support/Dockerfile.format (69%)
mode change 100755 => 100644
copy build-support/{copy-deps-versionfile.sh => docker-format.sh} (71%)
rename docker/build-client-lib-within-docker.sh => build-support/setup-test-service-container.sh (65%)
create mode 100755 build-support/start-mim-test-service-inside-container.sh
delete mode 100755 docker-build-centos7.sh
delete mode 100755 docker-build.sh
delete mode 100755 docker-format.sh
delete mode 100755 docker-tests.sh
delete mode 100644 docker/alpine/Dockerfile
delete mode 100644 docker/alpine/Dockerfile-alpine-3.8
delete mode 100755 docker/alpine/build-alpine-image.sh
delete mode 100755 docker/alpine/build-wheel-file-within-docker.sh
delete mode 100755 docker/alpine/build-wheel.sh
delete mode 100755 docker/build-client-lib.sh
delete mode 100644 docker/centos-7/Dockerfile
delete mode 100755 docker/push-images.sh
delete mode 100644 docs/MainPage.md
create mode 100644 examples/SampleCustomLoggerCApi.c
copy examples/{SampleConsumer.cc => SampleKeyValueSchemaConsumer.cc} (60%)
copy examples/{SampleAsyncProducer.cc => SampleKeyValueSchemaProducer.cc} (55%)
create mode 100644 include/pulsar/BatchReceivePolicy.h
create mode 100644 include/pulsar/ConsumerInterceptor.h
copy include/pulsar/{ConsumerEventListener.h => DeadLetterPolicy.h} (51%)
create mode 100644 include/pulsar/DeadLetterPolicyBuilder.h
create mode 100644 include/pulsar/KeyValue.h
create mode 100644 include/pulsar/MessageIdBuilder.h
create mode 100644 include/pulsar/ProducerInterceptor.h
copy lib/Hash.h => include/pulsar/RegexSubscriptionMode.h (68%)
create mode 100644 include/pulsar/TableView.h
copy include/pulsar/{TopicMetadata.h => TableViewConfiguration.h} (61%)
copy lib/PendingFailures.h => include/pulsar/TypedMessage.h (61%)
create mode 100644 include/pulsar/TypedMessageBuilder.h
copy include/pulsar/c/{message_router.h => messages.h} (57%)
create mode 100644 include/pulsar/c/table_view.h
copy include/pulsar/c/{string_map.h => table_view_configuration.h} (51%)
rename lib/{Log4CxxLogger.h => AsioDefines.h} (65%)
copy lib/{checksum/crc32c_sw.h => AsioTimer.h} (80%)
create mode 100644 lib/Base64Utils.h
delete mode 100644 lib/BatchAcknowledgementTracker.cc
delete mode 100644 lib/BatchAcknowledgementTracker.h
create mode 100644 lib/BatchMessageAcker.h
create mode 100644 lib/BatchReceivePolicy.cc
copy lib/{checksum/crc32c_sw.h => BatchReceivePolicyImpl.h} (89%)
copy lib/{MultiResultCallback.h => BatchedMessageIdImpl.h} (50%)
create mode 100644 lib/BitSet.h
copy lib/{AckGroupingTrackerDisabled.cc => ChunkMessageIdImpl.h} (53%)
create mode 100644 lib/ClientConnectionAdaptor.h
create mode 100644 lib/ConsumerImplBase.cc
create mode 100644 lib/ConsumerInterceptors.cc
copy lib/{ServiceURI.h => ConsumerInterceptors.h} (51%)
create mode 100644 lib/CurlWrapper.h
create mode 100644 lib/DeadLetterPolicyBuilder.cc
copy lib/{JavaStringHash.cc => DeadLetterPolicyImpl.cc} (58%)
copy lib/{checksum/crc32c_sw.h => DeadLetterPolicyImpl.h} (82%)
copy lib/{checksum/crc32c_sw.h => Int64SerDes.h} (57%)
copy lib/{FileLoggerFactoryImpl.h => KeyValue.cc} (61%)
create mode 100644 lib/KeyValueImpl.cc
copy lib/{EncryptionKeyInfoImpl.h => KeyValueImpl.h} (56%)
delete mode 100644 lib/Log4cxxLogger.cc
create mode 100644 lib/MessageIdBuilder.cc
create mode 100644 lib/MessagesImpl.cc
copy include/pulsar/MessageBatch.h => lib/MessagesImpl.h (61%)
create mode 100644 lib/ProducerInterceptors.cc
rename lib/{MultiResultCallback.h => ProducerInterceptors.h} (52%)
create mode 100644 lib/ProtoApiEnums.h
copy lib/{checksum/crc32c_sw.h => ResultUtils.h} (85%)
create mode 100644 lib/RetryableOperation.h
create mode 100644 lib/RetryableOperationCache.h
create mode 100644 lib/SchemaUtils.h
create mode 100644 lib/TableView.cc
create mode 100644 lib/TableViewImpl.cc
create mode 100644 lib/TableViewImpl.h
copy lib/auth/{AuthTls.h => InitialAuthData.h} (64%)
rename lib/{TimeUtils.cc => c/c_Messages.cc} (71%)
create mode 100644 lib/c/c_TableView.cc
create mode 100644 lib/c/c_TableViewConfiguration.cc
copy build-support/sign-files.sh => perf/BuildPerf.cmake (77%)
mode change 100755 => 100644
copy perf/{CMakeLists.txt => LegacyBuildPerf.cmake} (100%)
create mode 100755 pkg/mac/build-static-library.sh
copy test-conf/{client-ssl.conf => client-ssl-mim.conf} (87%)
create mode 100644 test-conf/hn-verification/broker-cert.pem
create mode 100644 test-conf/hn-verification/broker-key.pem
create mode 100644 test-conf/hn-verification/cacert.pem
copy test-conf/{standalone-ssl.conf => standalone-ssl-mim.conf} (95%)
create mode 100644 tests/AcknowledgeTest.cc
copy tests/{TopicMetadataImplTest.cc => Base64Test.cc} (63%)
copy tests/{CompressionCodecSnappyTest.cc => BatchReceivePolicyTest.cc} (55%)
create mode 100644 tests/BitSetTest.cc
create mode 100644 tests/BuildTests.cmake
create mode 100644 tests/ConnectionTest.cc
copy tests/{ConsumerTest.h => ConsumerWrapper.cc} (70%)
create mode 100644 tests/ConsumerWrapper.h
create mode 100644 tests/DeadLetterPolicyTest.cc
create mode 100644 tests/DeadLetterQueueTest.cc
copy tests/{CompressionCodecSnappyTest.cc => Int64SerDesTest.cc} (56%)
create mode 100644 tests/InterceptorsTest.cc
create mode 100644 tests/KeyValueImplTest.cc
create mode 100644 tests/KeyValueSchemaTest.cc
copy tests/{CMakeLists.txt => LegacyBuildTests.cmake} (66%)
create mode 100644 tests/MessagesImplTest.cc
create mode 100644 tests/MultiTopicsConsumerTest.cc
copy lib/FileLoggerFactoryImpl.h => tests/PulsarAdminHelper.h (59%)
copy lib/checksum/crc32c_sw.h => tests/PulsarWrapper.h (80%)
create mode 100644 tests/RetryableOperationCacheTest.cc
create mode 100644 tests/ShutdownTest.cc
copy lib/Synchronized.h => tests/SynchronizedQueue.h (68%)
create mode 100644 tests/TableViewTest.cc
create mode 100644 tests/ThreadSafeMessages.h
create mode 100644 tests/TypedMessageTest.cc
create mode 100644 tests/brokermetadata/BrokerMetadataTest.cc
create mode 100644 tests/brokermetadata/docker-compose.yml
copy tests/{CompressionCodecSnappyTest.cc => c/c_ClientConfigurationTest.cc} (54%)
create mode 100644 tests/c/c_ConsumerTest.cc
copy include/pulsar/c/message_router.h => tests/c/c_MessageTest.cc (63%)
create mode 100644 tests/c/c_ReaderConfigurationTest.cc
create mode 100644 tests/c/c_SeekTest.cc
create mode 100644 tests/c/c_TableViewTest.cc
create mode 100644 tests/chunkdedup/ChunkDedupTest.cc
create mode 100644 tests/chunkdedup/docker-compose.yml
create mode 100644 tests/extensibleLM/ExtensibleLoadManagerTest.cc
create mode 100644 tests/extensibleLM/docker-compose.yml
create mode 100644 tests/oauth2/Oauth2Test.cc
create mode 100644 tests/oauth2/docker-compose.yml
create mode 100644 tests/unix/ConnectionFailTest.cc
create mode 160000 vcpkg
create mode 100644 vcpkg-example/CMakeLists.txt
create mode 100644 vcpkg-example/README.md
create mode 100644 vcpkg-example/main.cc
create mode 100644 vcpkg-example/vcpkg.json
create mode 100644 win-examples/CMakeLists.txt
copy tests/PaddingDemo.proto => win-examples/example.cc (84%)
create mode 100755 wireshark/pulsar-dissector-example.jpg
create mode 100755 wireshark/wireshark-plugins.jpg