Path	Lines of Code
integration-tests/certs/generate.sh	50
integration-tests/pb/build.sh	6
integration-tests/pb/hello.pb.go	217
integration-tests/pb/hello.proto	33
integration-tests/pb/hi.pb.go	124
integration-tests/pb/hi.proto	25
oauth2/auth_suite_test.go	39
oauth2/authorization_tokenretriever_test.go	263
oauth2/client_credentials_flow_test.go	152
oauth2/client_credentials_provider_test.go	54
oauth2/config_tokenprovider_test.go	62
oauth2/data_url_test.go	34
oauth2/device_code_flow_test.go	176
oauth2/oidc_endpoint_provider_test.go	57
pulsar/ack_grouping_tracker_test.go	219
pulsar/auth/athenz_test.go	223
pulsar/auth/basic_test.go	42
pulsar/auth/oauth2_test.go	110
pulsar/backoff/backoff_test.go	36
pulsar/blue_green_migration_test.go	188
pulsar/client_impl_clustered_test.go	56
pulsar/client_impl_test.go	965
pulsar/client_impl_with_slog_test.go	24
pulsar/consumer_multitopic_test.go	340
pulsar/consumer_partition_test.go	175
pulsar/consumer_regex_test.go	423
pulsar/consumer_test.go	4013
pulsar/consumer_zero_queue_test.go	444
pulsar/crypto/default_crypto_key_reader_test.go	34
pulsar/crypto/default_message_crypto_test.go	105
pulsar/crypto/message_metadata_test.go	78
pulsar/default_router_bench_test.go	41
pulsar/default_router_test.go	110
pulsar/error_test.go	16
pulsar/extensible_load_manager_test.go	166
pulsar/helper_for_test.go	143
pulsar/helper_test.go	24
pulsar/impl_message_test.go	90
pulsar/internal/blocking_queue_test.go	94
pulsar/internal/buffer_test.go	15
pulsar/internal/channel_cond_test.go	35
pulsar/internal/checksum_test.go	25
pulsar/internal/client_handlers_test.go	46
pulsar/internal/commands_test.go	175
pulsar/internal/compression/compression_bench_test.go	85
pulsar/internal/compression/compression_test.go	62
pulsar/internal/hash_test.go	35
pulsar/internal/key_based_batch_builder_test.go	54
pulsar/internal/lookup_service_test.go	558
pulsar/internal/memory_limit_controller_test.go	179
pulsar/internal/namespace_name_test.go	10
pulsar/internal/pulsartracing/consumer_interceptor_test.go	78
pulsar/internal/pulsartracing/message_carrier_util_test.go	90
pulsar/internal/pulsartracing/producer_interceptor_test.go	43
pulsar/internal/retry_test.go	37
pulsar/internal/semaphore_test.go	42
pulsar/internal/service_name_resolver_test.go	105
pulsar/internal/service_uri_test.go	129
pulsar/internal/topic_name_test.go	137
pulsar/internal/utils_test.go	36
pulsar/internal/version_test.go	8
pulsar/key_shared_policy_test.go	70
pulsar/log/wrapper_slog_test.go	150
pulsar/message_chunking_test.go	456
pulsar/message_test.go	10
pulsar/negative_acks_tracker_test.go	246
pulsar/negative_backoff_policy_test.go	13
pulsar/primitiveSerDe_test.go	117
pulsar/producer_test.go	2122
pulsar/reader_clustered_test.go	51
pulsar/reader_test.go	950
pulsar/schema_def_test.go	32
pulsar/schema_test.go	463
pulsar/single_partition_router_test.go	37
pulsar/table_view_test.go	295
pulsar/transaction_disabled_test.go	13
pulsar/transaction_test.go	432
pulsaradmin/pkg/admin/admin_test.go	71
pulsaradmin/pkg/admin/auth/oauth2_test.go	97
pulsaradmin/pkg/admin/brokers_test.go	116
pulsaradmin/pkg/admin/config/api_version_test.go	12
pulsaradmin/pkg/admin/namespace_test.go	290
pulsaradmin/pkg/admin/schema_test.go	104
pulsaradmin/pkg/admin/subscription_test.go	178
pulsaradmin/pkg/admin/topic_test.go	432
pulsaradmin/pkg/rest/client_test.go	24
pulsaradmin/pkg/utils/auth_polices_test.go	43
pulsaradmin/pkg/utils/message_id_test.go	38
pulsaradmin/pkg/utils/namespace_name_test.go	37
pulsaradmin/pkg/utils/package_name_test.go	44
pulsaradmin/pkg/utils/topic_name_test.go	46
pulsaradmin/pkg/utils/utils_test.go	33
scripts/pulsar-test-service-start.sh	38
scripts/pulsar-test-service-stop.sh	10