path	# lines of code
dependencies.yaml	8
include/pulsar/MessageRoutingPolicy.h	23
include/pulsar/ConsumerCryptoFailureAction.h	11
include/pulsar/DeprecatedException.h	14
include/pulsar/MessageBuilder.h	42
include/pulsar/Consumer.h	85
include/pulsar/ConsumerInterceptor.h	21
include/pulsar/ConsumerEventListener.h	13
include/pulsar/c/string_map.h	16
include/pulsar/c/reader_configuration.h	41
include/pulsar/c/consumer_configuration.h	151
include/pulsar/c/result.h	58
include/pulsar/c/string_list.h	14
include/pulsar/c/reader.h	28
include/pulsar/c/message.h	46
include/pulsar/c/version.h	2
include/pulsar/c/consumer.h	71
include/pulsar/c/producer.h	29
include/pulsar/c/table_view.h	29
include/pulsar/c/message_id.h	17
include/pulsar/c/authentication.h	22
include/pulsar/c/producer_configuration.h	143
include/pulsar/c/client_configuration.h	88
include/pulsar/c/messages.h	14
include/pulsar/c/table_view_configuration.h	19
include/pulsar/c/client.h	89
include/pulsar/c/message_router.h	13
include/pulsar/KeyValue.h	24
include/pulsar/Schema.h	55
include/pulsar/ProducerInterceptor.h	19
include/pulsar/ReaderConfiguration.h	63
include/pulsar/KeySharedPolicy.h	32
include/pulsar/CompressionType.h	13
include/pulsar/FileLoggerFactory.h	13
include/pulsar/ConsumerConfiguration.h	130
include/pulsar/defines.h	16
include/pulsar/BrokerConsumerStats.h	39
include/pulsar/TypedMessage.h	21
include/pulsar/TableView.h	32
include/pulsar/Client.h	82
include/pulsar/EncryptionKeyInfo.h	26
include/pulsar/ProducerCryptoFailureAction.h	10
include/pulsar/InitialPosition.h	10
include/pulsar/Result.h	60
include/pulsar/TypedMessageBuilder.h	47
include/pulsar/DeadLetterPolicy.h	21
include/pulsar/BatchReceivePolicy.h	18
include/pulsar/Reader.h	41
include/pulsar/Authentication.h	162
include/pulsar/Message.h	75
include/pulsar/Producer.h	38
include/pulsar/TableViewConfiguration.h	11
include/pulsar/MessageId.h	56
include/pulsar/Logger.h	24
include/pulsar/ProducerConfiguration.h	109
include/pulsar/ConsumerType.h	12
include/pulsar/ClientConfiguration.h	75
include/pulsar/ProtobufNativeSchema.h	6
include/pulsar/TopicMetadata.h	11
include/pulsar/CryptoKeyReader.h	32
include/pulsar/DeadLetterPolicyBuilder.h	19
include/pulsar/ConsoleLoggerFactory.h	13
include/pulsar/MessageBatch.h	21
include/pulsar/RegexSubscriptionMode.h	11
include/pulsar/MessageIdBuilder.h	22
cmake_modules/FindClangTools.cmake	93
templates/Version.h.in	24
vcpkg-triplets/arm64-osx.cmake	7
vcpkg-triplets/x64-osx.cmake	7
pkg/rpm/SPECS/pulsar-client.spec	80
vcpkg-example/main.cc	7
build-support/dep-version.py	3
build-support/gen-pulsar-version-macro.py	9
build-support/run_clang_format.py	48
build-support/download-release-artifacts.py	44
eclipse-formatter.xml	167
LegacyFindPackages.cmake	275
perf/LegacyBuildPerf.cmake	31
perf/PerfProducer.cc	326
perf/BuildPerf.cmake	22
perf/RateLimiter.h	50
perf/PerfConsumer.cc	252
lib/ProducerInterceptors.h	27
lib/MessagesImpl.cc	31
lib/MessageId.cc	117
lib/PeriodicTask.cc	40
lib/Latch.cc	19
lib/TableViewImpl.h	44
lib/CompressionCodecSnappy.h	9
lib/BrokerConsumerStatsImpl.cc	68
lib/HTTPLookupService.h	47
lib/Consumer.cc	239
lib/SinglePartitionMessageRouter.h	21
lib/BatchMessageContainer.cc	47
lib/Schema.cc	151
lib/MessageIdImpl.h	52
lib/TopicMetadataImpl.h	13
lib/JavaStringHash.h	14
lib/ProducerConfigurationImpl.h	35
lib/ProducerInterceptors.cc	56
lib/ConsumerImplBase.h	90
lib/MessagesImpl.h	22
lib/PendingFailures.h	19
lib/MessageCrypto.cc	398
lib/PulsarScheme.h	55
lib/Url.h	28
lib/TopicName.h	60
lib/CompressionCodecLZ4.h	11
lib/c/c_Message.cc	91
lib/c/cStringMap.cc	30
lib/c/c_Client.cc	222
lib/c/c_Authentication.cc	49
lib/c/c_MessageRouter.cc	5
lib/c/c_Producer.cc	45
lib/c/c_Result.cc	3
lib/c/c_Reader.cc	51
lib/c/c_ConsumerConfiguration.cc	251
lib/c/c_TableView.cc	59
lib/c/c_structs.h	63
lib/c/c_Consumer.cc	152
lib/c/c_ClientConfiguration.cc	153
lib/c/cStringList.cc	9
lib/c/c_ReaderConfiguration.cc	71
lib/c/c_TableViewConfiguration.cc	22
lib/c/c_ProducerConfiguration.cc	178
lib/c/c_MessageId.cc	48
lib/c/c_Messages.cc	7
lib/Authentication.cc	173
lib/ClientImpl.cc	708
lib/SharedBuffer.h	170
lib/TableViewImpl.cc	131
lib/ConsumerImpl.h	283
lib/TopicName.cc	209
lib/MessageBuilder.cc	123
lib/TopicMetadataImpl.cc	5
lib/MapCache.h	84
lib/DeadLetterPolicyBuilder.cc	27
lib/NamespaceName.h	33
lib/BatchReceivePolicy.cc	29
lib/ConsumerImplBase.cc	98
lib/EncryptionKeyInfoImpl.cc	9
lib/MessageImpl.h	55
lib/ServiceURI.h	17
lib/NamedEntity.h	6
lib/Producer.cc	74
lib/BoostHash.cc	7
lib/ServiceUnitId.h	7
lib/BatchMessageAcker.h	52
lib/Base64Utils.h	30
lib/AckGroupingTrackerDisabled.h	16
lib/AsioDefines.h	12
lib/PatternMultiTopicsConsumerImpl.h	59
lib/JsonUtils.h	18
lib/CryptoKeyReader.cc	49
lib/UnAckedMessageTrackerEnabled.h	48
lib/KeyValue.cc	11
lib/ProducerConfiguration.cc	205
lib/CompressionCodecZstd.cc	39
lib/PartitionedProducerImpl.cc	403
lib/SimpleLogger.h	54
lib/CompressionCodecZLib.cc	56
lib/PartitionedProducerImpl.h	92
lib/CompressionCodecZLib.h	11
lib/MessageRouterBase.h	17
lib/TimeUtils.h	37
lib/PatternMultiTopicsConsumerImpl.cc	189
lib/BatchMessageKeyBasedContainer.h	23
lib/ConnectionPool.cc	102
lib/RetryableOperationCache.h	79
lib/UnAckedMessageTrackerDisabled.h	15
lib/BitSet.h	152
lib/RoundRobinMessageRouter.cc	49
lib/ProducerImplBase.h	29
lib/BrokerConsumerStatsImpl.h	50
lib/DeadLetterPolicyImpl.cc	12
lib/ClientConfigurationImpl.h	35
lib/BatchMessageContainerBase.cc	20
lib/LogUtils.h	66
lib/MessageCrypto.h	62
lib/LookupService.h	43
lib/ClientConnection.h	285
lib/BatchMessageContainer.h	22
lib/HandlerBase.h	92
lib/UnboundedBlockingQueue.h	116
lib/CompressionCodec.h	36
lib/AckGroupingTrackerEnabled.h	56
lib/Hash.h	12
lib/CompressionCodecLZ4.cc	26
lib/MemoryLimitController.cc	46
lib/Murmur3_32Hash.h	21
lib/TableView.cc	64
lib/Backoff.h	24
lib/Murmur3_32Hash.cc	81
lib/MultiTopicsBrokerConsumerStatsImpl.cc	119
lib/Semaphore.cc	43
lib/SinglePartitionMessageRouter.cc	27
lib/ServiceURI.cc	74
lib/Client.cc	140
lib/ResultUtils.h	32
lib/Synchronized.h	23
lib/OpSendMsg.h	74
lib/ReaderConfiguration.cc	102
lib/Backoff.cc	34
lib/RoundRobinMessageRouter.h	25
lib/UnAckedMessageTrackerInterface.h	22
lib/LookupDataResult.h	46
lib/NegativeAcksTracker.h	40
lib/ProtobufNativeSchema.cc	34
lib/ExecutorService.h	67
lib/ConsumerInterceptors.h	28
lib/DeadLetterPolicyImpl.h	10
lib/SchemaUtils.h	25
lib/CompressionCodecZstd.h	9
lib/MessageBatch.cc	31
lib/BatchReceivePolicyImpl.h	8
lib/ConsoleLoggerFactoryImpl.h	12
lib/ClientConnectionAdaptor.h	26
lib/FileLoggerFactoryImpl.h	18
lib/Commands.h	112
lib/BlockingQueue.h	141
lib/BatchMessageKeyBasedContainer.cc	88
lib/Int64SerDes.h	22
lib/Utils.h	40
lib/ClientConnection.cc	1685
lib/ClientImpl.h	134
lib/BrokerConsumerStats.cc	36
lib/EncryptionKeyInfoImpl.h	21
lib/checksum/crc32c_arm.h	35
lib/checksum/crc32c_sw.cc	53
lib/checksum/int_types.h	18
lib/checksum/ChecksumProvider.h	11
lib/checksum/crc32c_sse42.h	22
lib/checksum/ChecksumProvider.cc	34
lib/checksum/crc32c_arm.cc	132
lib/checksum/crc32c_sse42.cc	225
lib/checksum/crc32c_sw.h	5
lib/checksum/gf2.hpp	132
lib/AckGroupingTrackerDisabled.cc	18
lib/AckGroupingTracker.h	47
lib/Reader.cc	95
lib/DeprecatedException.cc	6
lib/AckGroupingTrackerEnabled.cc	135
lib/KeySharedPolicyImpl.h	10
lib/KeyValueImpl.h	24
lib/UnAckedMessageTrackerEnabled.cc	137
lib/BatchedMessageIdImpl.h	24
lib/ConsumerInterceptors.cc	65
lib/ConsumerConfigurationImpl.h	45
lib/BoostHash.h	17
lib/CompressionCodec.cc	33
lib/MessageRouterBase.cc	20
lib/Message.cc	190
lib/CompressionCodecSnappy.cc	40
lib/MessageImpl.cc	93
lib/Url.cc	69
lib/JavaStringHash.cc	15
lib/ProducerImpl.cc	834
lib/PeriodicTask.h	29
lib/HTTPLookupService.cc	353
lib/RetryableLookupService.h	68
lib/lz4/lz4.h	85
lib/lz4/lz4.cc	1146
lib/AckGroupingTracker.cc	107
lib/BinaryProtoLookupService.cc	194
lib/RetryableOperation.h	105
lib/ConnectionPool.h	51
lib/KeyValueImpl.cc	46
lib/MessageIdBuilder.cc	47
lib/LogUtils.cc	28
lib/TestUtil.h	4
lib/NamespaceName.cc	75
lib/ServiceNameResolver.h	32
lib/BatchMessageContainerBase.h	75
lib/MessageIdUtil.h	21
lib/ObjectPool.h	166
lib/ReaderImpl.cc	132
lib/ConsoleLoggerFactory.cc	8
lib/FileLoggerFactory.cc	8
lib/BinaryProtoLookupService.h	57
lib/MultiTopicsConsumerImpl.h	193
lib/ReaderConfigurationImpl.h	24
lib/SynchronizedHashMap.h	145
lib/ConsumerImpl.cc	1579
lib/EncryptionKeyInfo.cc	10
lib/NegativeAcksTracker.cc	82
lib/MultiTopicsBrokerConsumerStatsImpl.h	34
lib/BrokerConsumerStatsImplBase.h	24
lib/MessageAndCallbackBatch.h	36
lib/Latch.h	35
lib/UtilAllocator.h	49
lib/Semaphore.h	22
lib/ExecutorService.cc	109
lib/MessageAndCallbackBatch.cc	69
lib/ChunkMessageIdImpl.h	21
lib/NamedEntity.cc	20
lib/Future.h	106
lib/AsioTimer.h	9
lib/MultiTopicsConsumerImpl.cc	982
lib/KeySharedPolicy.cc	53
lib/CurlWrapper.h	132
lib/HandlerBase.cc	184
lib/stats/ConsumerStatsImpl.cc	86
lib/stats/ProducerStatsImpl.cc	100
lib/stats/ProducerStatsBase.h	16
lib/stats/ConsumerStatsBase.h	17
lib/stats/ConsumerStatsImpl.h	56
lib/stats/ProducerStatsImpl.h	63
lib/stats/ProducerStatsDisabled.h	11
lib/stats/ConsumerStatsDisabled.h	11
lib/ConsumerConfiguration.cc	235
lib/auth/AuthAthenz.cc	60
lib/auth/InitialAuthData.h	14
lib/auth/AuthBasic.h	21
lib/auth/AuthToken.h	18
lib/auth/AuthOauth2.h	68
lib/auth/athenz/ZTSClient.h	44
lib/auth/athenz/ZTSClient.cc	331
lib/auth/AuthTls.h	17
lib/auth/AuthOauth2.cc	353
lib/auth/AuthTls.cc	30
lib/auth/AuthBasic.cc	87
lib/auth/AuthToken.cc	70
lib/auth/AuthAthenz.h	20
lib/ReaderImpl.h	59
lib/Commands.cc	807
lib/ProtoApiEnums.h	114
lib/MemoryLimitController.h	22
lib/ClientConfiguration.cc	162
lib/GetLastMessageIdResponse.h	35
lib/ProducerImpl.h	143
lib/Result.cc	107
win-examples/example.cc	7
wireshark/pulsarDissector.cc	1030
proto/PulsarApi.proto	918