Path	Lines of Code
pulsar/ack_grouping_tracker.go	205
pulsar/auth/athenz.go	211
pulsar/auth/basic.go	54
pulsar/auth/disabled.go	33
pulsar/auth/oauth2.go	159
pulsar/auth/provider.go	53
pulsar/auth/tls.go	67
pulsar/auth/token.go	84
pulsar/batcher_builder.go	21
pulsar/client.go	82
pulsar/client_impl.go	219
pulsar/consumer.go	87
pulsar/consumer_impl.go	633
pulsar/consumer_interceptor.go	23
pulsar/consumer_multitopic.go	213
pulsar/consumer_partition.go	1836
pulsar/consumer_regex.go	393
pulsar/crypto/crypto_failure_action.go	10
pulsar/crypto/crypto_key_reader.go	5
pulsar/crypto/default_crypto_Key_reader.go	25
pulsar/crypto/default_message_crypto.go	255
pulsar/crypto/encryption_key_Info.go	22
pulsar/crypto/message_crypto.go	7
pulsar/crypto/message_metadata.go	85
pulsar/default_router.go	66
pulsar/dlq_router.go	114
pulsar/encryption.go	13
pulsar/error.go	167
pulsar/helper.go	47
pulsar/impl_message.go	399
pulsar/internal/backoff.go	30
pulsar/internal/batch_builder.go	221
pulsar/internal/blocking_queue.go	127
pulsar/internal/buffer.go	146
pulsar/internal/channel_cond.go	45
pulsar/internal/checksum.go	24
pulsar/internal/client_handlers.go	38
pulsar/internal/closable.go	4
pulsar/internal/commands.go	272
pulsar/internal/compression/compression.go	15
pulsar/internal/compression/lz4.go	71
pulsar/internal/compression/noop.go	33
pulsar/internal/compression/zlib.go	49
pulsar/internal/compression/zstd.go	11
pulsar/internal/compression/zstd_cgo.go	46
pulsar/internal/compression/zstd_go.go	45
pulsar/internal/connection.go	873
pulsar/internal/connection_pool.go	125
pulsar/internal/connection_reader.go	104
pulsar/internal/crypto/consumer_decryptor.go	34
pulsar/internal/crypto/decryptor.go	7
pulsar/internal/crypto/encryptor.go	7
pulsar/internal/crypto/noop_decryptor.go	17
pulsar/internal/crypto/noop_encryptor.go	11
pulsar/internal/crypto/producer_encryptor.go	43
pulsar/internal/hash.go	17
pulsar/internal/helper.go	11
pulsar/internal/http_client.go	287
pulsar/internal/key_based_batch_builder.go	174
pulsar/internal/lookup_service.go	296
pulsar/internal/memory_limit_controller.go	111
pulsar/internal/metrics.go	533
pulsar/internal/namespace_name.go	6
pulsar/internal/pulsar_proto/PulsarApi.proto	902
pulsar/internal/pulsartracing/consumer_interceptor.go	28
pulsar/internal/pulsartracing/message_carrier_adaptors.go	47
pulsar/internal/pulsartracing/message_carrier_util.go	53
pulsar/internal/pulsartracing/producer_interceptor.go	29
pulsar/internal/pulsartracing/span-enrichment.go	27
pulsar/internal/rpc_client.go	135
pulsar/internal/semaphore.go	56
pulsar/internal/service_name_resolver.go	94
pulsar/internal/service_uri.go	172
pulsar/internal/topic_name.go	88
pulsar/internal/utils.go	58
pulsar/internal/version.go	25
pulsar/key_shared_policy.go	68
pulsar/log/log.go	28
pulsar/log/logger.go	28
pulsar/log/wrapper_logrus.go	93
pulsar/message.go	84
pulsar/negative_acks_tracker.go	104
pulsar/negative_backoff_policy.go	17
pulsar/primitiveSerDe.go	266
pulsar/producer.go	69
pulsar/producer_impl.go	277
pulsar/producer_interceptor.go	17
pulsar/producer_partition.go	1196
pulsar/reader.go	36
pulsar/reader_impl.go	184
pulsar/retry_router.go	107
pulsar/schema.go	539
pulsar/single_partition_router.go	19
pulsar/table_view.go	24
pulsar/table_view_impl.go	219
pulsar/transaction.go	25
pulsar/transaction_coordinator_client.go	167
pulsar/transaction_impl.go	183