Path	Lines of Code
pulsar/ack_grouping_tracker.go	217
pulsar/auth/athenz.go	213
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	83
pulsar/backoff/backoff.go	41
pulsar/batcher_builder.go	21
pulsar/client.go	85
pulsar/client_impl.go	215
pulsar/consumer.go	108
pulsar/consumer_impl.go	715
pulsar/consumer_interceptor.go	23
pulsar/consumer_multitopic.go	274
pulsar/consumer_partition.go	2101
pulsar/consumer_regex.go	419
pulsar/consumer_zero_queue.go	227
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	135
pulsar/encryption.go	13
pulsar/error.go	170
pulsar/helper.go	47
pulsar/impl_message.go	439
pulsar/internal/batch_builder.go	228
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	53
pulsar/internal/compression/zstd_go.go	45
pulsar/internal/connection.go	910
pulsar/internal/connection_pool.go	139
pulsar/internal/connection_reader.go	101
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	292
pulsar/internal/key_based_batch_builder.go	159
pulsar/internal/lookup_service.go	301
pulsar/internal/memory_limit_controller.go	111
pulsar/internal/metrics.go	533
pulsar/internal/namespace_name.go	6
pulsar/internal/pulsar_proto/PulsarApi.proto	922
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/retry.go	37
pulsar/internal/rpc_client.go	208
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/log/wrapper_slog.go	69
pulsar/message.go	88
pulsar/negative_acks_tracker.go	104
pulsar/negative_backoff_policy.go	17
pulsar/primitiveSerDe.go	266
pulsar/producer.go	71
pulsar/producer_impl.go	280
pulsar/producer_interceptor.go	17
pulsar/producer_partition.go	1424
pulsar/reader.go	37
pulsar/reader_impl.go	175
pulsar/retry_router.go	117
pulsar/schema.go	523
pulsar/single_partition_router.go	19
pulsar/table_view.go	24
pulsar/table_view_impl.go	223
pulsar/transaction.go	25
pulsar/transaction_coordinator_client.go	362
pulsar/transaction_impl.go	197