Path	Lines of Code
bench/lib/config_test.go	32
canary/workflow_test.go	104
client/history/client_test.go	833
client/history/peerResolver_test.go	52
client/matching/loadbalancer_test.go	219
client/matching/peerResolver_test.go	56
client/wrappers/errorinjectors/errorinjectors_test.go	88
client/wrappers/metered/metered_test.go	117
client/wrappers/retryable/wrappers_test.go	40
client/wrappers/timeout/history_generated_test.go	105
cmd/server/cadence/cadence_test.go	29
cmd/server/cadence/server_test.go	68
common/archiver/URI_test.go	120
common/archiver/filestore/historyArchiver_test.go	555
common/archiver/filestore/queryParser_test.go	306
common/archiver/filestore/util_test.go	176
common/archiver/filestore/visibilityArchiver_test.go	512
common/archiver/gcloud/connector/client_test.go	265
common/archiver/gcloud/connector/mocks/BucketHandleWrapper.go	52
common/archiver/gcloud/connector/mocks/Client.go	102
common/archiver/gcloud/connector/mocks/GcloudStorageClient.go	20
common/archiver/gcloud/connector/mocks/ObjectHandleWrapper.go	58
common/archiver/gcloud/connector/mocks/ObjectIteratorWrapper.go	26
common/archiver/gcloud/connector/mocks/ReaderWrapper.go	31
common/archiver/gcloud/connector/mocks/WriterWrapper.go	41
common/archiver/gcloud/util_test.go	189
common/archiver/gcloud/visibilityArchiver_test.go	270
common/archiver/historyIterator_test.go	628
common/archiver/s3store/historyArchiver_test.go	677
common/archiver/s3store/mocks/S3API_generate.go	1
common/archiver/s3store/mocks/s3_api_mock.go	7246
common/archiver/s3store/queryParser_test.go	231
common/archiver/s3store/visibilityArchiver_test.go	533
common/archiver/util_test.go	117
common/asyncworkflow/queue/consumer/default_consumer_test.go	286
common/asyncworkflow/queue/kafka/config_test.go	58
common/asyncworkflow/queue/kafka/decoder_test.go	52
common/asyncworkflow/queue/kafka/queue_test.go	199
common/asyncworkflow/queue/provider/provider_test.go	92
common/asyncworkflow/queue/provider_test.go	132
common/asyncworkflow/queueconfigapi/handler_test.go	148
common/authorization/authorizer_test.go	66
common/authorization/factory_test.go	66
common/backoff/cron_test.go	116
common/backoff/jitter_test.go	55
common/backoff/retry_test.go	243
common/backoff/retrypolicy_test.go	208
common/blobstore/filestore/client_test.go	113
common/checksum/crc_test.go	47
common/checksum/ctc_benchmark_test.go	23
common/client/versionChecker_test.go	404
common/cluster/metadata_test.go	863
common/codec/gob/gob_test.go	44
common/codec/version0Thriftrw_test.go	86
common/collection/channelPriorityQueue_test.go	44
common/collection/concurrentQueue_test.go	79
common/collection/concurrent_tx_map_test.go	189
common/collection/ordered_map_test.go	79
common/collection/pagingIterator_test.go	127
common/collection/priorityQueue_test.go	104
common/config/archival_test.go	117
common/config/authorization_test.go	82
common/config/cluster_test.go	170
common/config/config_test.go	328
common/config/elasticsearch_test.go	70
common/config/loader_test.go	92
common/config/log_test.go	37
common/config/metrics_test.go	58
common/convert_test.go	19
common/definition/resourceDeduplication_test.go	36
common/domain/archivalConfigStateMachine_test.go	412
common/domain/attrValidator_test.go	238
common/domain/dlqMessageHandler_test.go	289
common/domain/failover_watcher_test.go	199
common/domain/handler_MasterCluster_test.go	958
common/domain/handler_NotMasterCluster_test.go	738
common/domain/handler_test.go	738
common/domain/replicationTaskExecutor_integration_test.go	798
common/domain/replicationTaskExecutor_test.go	434
common/domain/replication_queue_test.go	565
common/domain/transmissionTaskHandler_test.go	372
common/dynamicconfig/cmp_test.go	59
common/dynamicconfig/config_benchmark_test.go	15
common/dynamicconfig/config_test.go	209
common/dynamicconfig/configstore/config_store_client_test.go	848
common/dynamicconfig/constants_test.go	324
common/dynamicconfig/file_based_client_test.go	291
common/elasticsearch/bulk/mocks/GenericBulkProcessor.go	52
common/elasticsearch/bulk/mocks/GenericBulkableRequest.go	33
common/elasticsearch/client/os2/client_test.go	534
common/elasticsearch/client/v6/client_bulk_test.go	362
common/elasticsearch/client/v6/client_test.go	439
common/elasticsearch/client/v7/client_bulk_test.go	359
common/elasticsearch/client/v7/client_test.go	439
common/elasticsearch/esql/esql_test.go	243
common/elasticsearch/mocks/GenericClient.go	165
common/elasticsearch/query/bool_query_test.go	22
common/elasticsearch/query/builder_test.go	44
common/elasticsearch/query/exists_query_test.go	21
common/elasticsearch/query/match_query_test.go	37
common/elasticsearch/query/range_query_test.go	21
common/elasticsearch/query/sort_test.go	21
common/elasticsearch/validator/queryValidator_test.go	119
common/elasticsearch/validator/searchAttrValidator_test.go	85
common/future/future_test.go	132
common/isolationgroup/defaultisolationgroupstate/state_test.go	652
common/isolationgroup/isolationgroupapi/domain-api-handlers_test.go	194
common/isolationgroup/isolationgroupapi/global-api-handlers_test.go	102
common/locks/lock_test.go	48
common/log/loggerimpl/logger_bench_test.go	91
common/log/loggerimpl/logger_test.go	167
common/membership/hashring_test.go	221
common/membership/hostinfo_test.go	27
common/membership/resolver_test.go	85
common/messaging/ackManager_test.go	51
common/messaging/kafka/client_impl_test.go	120
common/messaging/kafka/consumer_impl_test.go	160
common/messaging/kafka/partition_ack_manager_test.go	72
common/messaging/kafka/producer_impl_test.go	64
common/messaging/mocks/message_mock.go	57
common/metrics/context_test.go	20
common/metrics/defs_test.go	89
common/metrics/mocks/Client.go	54
common/metrics/mocks/Scope.go	55
common/metrics/tally/statsd/reporter_test.go	31
common/mocks/ExecutionManager.go	464
common/mocks/ExecutionManagerFactory.go	29
common/mocks/HistoryV2Manager.go	158
common/mocks/KafkaProducer.go	30
common/mocks/MessagingClient.go	21
common/mocks/MetadataManager.go	124
common/mocks/ShardManager.go	60
common/mocks/TaskManager.go	219
common/mocks/VisibilityManager.go	280
common/ndc/history_resender_test.go	340
common/pagination/iterator_test.go	95
common/pagination/writerIterator_test.go	93
common/pagination/writer_test.go	107
common/partition/context_test.go	12
common/partition/default-partitioner_test.go	178
common/peerprovider/ringpopprovider/config_test.go	261
common/peerprovider/ringpopprovider/provider_test.go	85
common/persistence/data_manager_interfaces_test.go	190
common/persistence/data_store_interfaces_test.go	147
common/persistence/elasticsearch/decodeBench_test.go	82
common/persistence/elasticsearch/es_visibility_store_test.go	868
common/persistence/execution_manager_test.go	477
common/persistence/nosql/nosql_execution_store_test.go	893
common/persistence/nosql/nosql_execution_store_util_test.go	605
common/persistence/nosql/nosql_queue_store_test.go	33
common/persistence/nosql/nosqlplugin/cassandra/db_test.go	243
common/persistence/nosql/nosqlplugin/cassandra/gocql/batch_test.go	46
common/persistence/nosql/nosqlplugin/cassandra/gocql/client_test.go	58
common/persistence/nosql/nosqlplugin/cassandra/shard_test.go	452
common/persistence/nosql/nosqlplugin/cassandra/tasks_test.go	984
common/persistence/nosql/nosqlplugin/cassandra/tests/cassandra_persistence_test.go	71
common/persistence/nosql/nosqlplugin/cassandra/tests/cassandra_tool_cqlclient_test.go	45
common/persistence/nosql/nosqlplugin/cassandra/tests/cassandra_tool_setupTask_test.go	43
common/persistence/nosql/nosqlplugin/cassandra/tests/cassandra_tool_updateTask_test.go	59
common/persistence/nosql/nosqlplugin/cassandra/tests/cassandra_tool_version_test.go	148
common/persistence/nosql/nosqlplugin/cassandra/tests/utils.go	55
common/persistence/nosql/nosqlplugin/cassandra/workflow_test.go	2069
common/persistence/nosql/nosqlplugin/cassandra/workflow_utils_test.go	2321
common/persistence/nosql/nosqlplugin/dynamodb/tests/dynamodb_persistence_test.go	17
common/persistence/nosql/nosqlplugin/mongodb/tests/mongodb_persistence_test.go	30
common/persistence/nosql/sharded_nosql_store_test.go	181
common/persistence/nosql/sharding_policy_test.go	136
common/persistence/operationModeValidator_test.go	368
common/persistence/persistence-tests/configStorePersistenceTest.go	118
common/persistence/persistence-tests/dbVisibilityPersistenceTest.go	752
common/persistence/persistence-tests/executionManagerTest.go	5108
common/persistence/persistence-tests/executionManagerTestForEventsV2.go	358
common/persistence/persistence-tests/historyV2PersistenceTest.go	685
common/persistence/persistence-tests/matchingPersistenceTest.go	536
common/persistence/persistence-tests/metadataPersistenceV2Test.go	1210
common/persistence/persistence-tests/persistenceTestBase.go	1783
common/persistence/persistence-tests/queuePersistenceTest.go	152
common/persistence/persistence-tests/shardPersistenceTest.go	350
common/persistence/persistence-tests/shared_test.go	25
common/persistence/persistence-tests/testcluster/interfaces.go	9
common/persistence/persistence-tests/visibilitySamplingClient_test.go	232
common/persistence/pinot/pinot_visibility_metric_clients_test.go	1125
common/persistence/pinot/pinot_visibility_store_test.go	1755
common/persistence/pinotResponseComparator_test.go	497
common/persistence/pinotVisibilityTripleManager_test.go	36
common/persistence/serialization/getters_fixtures_test.go	703
common/persistence/serialization/getters_test.go	335
common/persistence/serialization/parser_test.go	334
common/persistence/serialization/persistence_mapper_test.go	123
common/persistence/serialization/thrift_mapper_test.go	470
common/persistence/serializer_test.go	441
common/persistence/sql/common_test.go	244
common/persistence/sql/factory_test.go	181
common/persistence/sql/main_test.go	9
common/persistence/sql/plugin_test.go	39
common/persistence/sql/sql_config_store_test.go	142
common/persistence/sql/sql_domain_store_test.go	831
common/persistence/sql/sql_execution_store_test.go	3568
common/persistence/sql/sql_execution_store_util_test.go	2241
common/persistence/sql/sql_history_store_test.go	1003
common/persistence/sql/sql_queue_store_test.go	781
common/persistence/sql/sql_shard_store_test.go	565
common/persistence/sql/sql_task_store_test.go	1173
common/persistence/sql/sqlplugin/mysql/configstore_test.go	121
common/persistence/sql/sqlplugin/mysql/dsn_test.go	118
common/persistence/sql/sqlplugin/mysql/mysql_persistence_test.go	89
common/persistence/sql/sqlplugin/postgres/plugin_test.go	34
common/persistence/sql/sqlplugin/postgres/postgres_persistence_test.go	80
common/persistence/sql/workflow_state_non_maps_test.go	146
common/persistence/statsComputer_test.go	134
common/persistence/tasks_test.go	108
common/persistence/versionHistory_test.go	575
common/persistence/visibility_dual_manager_test.go	524
common/persistence/visibility_single_manager_test.go	899
common/persistence/workflowStateCloseStatusValidator_test.go	151
common/persistence/wrappers/errorinjectors/injectors_test.go	259
common/persistence/wrappers/metered/metered_test.go	254
common/persistence/wrappers/ratelimited/utils_test.go	29
common/persistence/wrappers/ratelimited/wrappers_test.go	250
common/persistence/wrappers/sampled/tokenbucketfactory_test.go	14
common/persistence/wrappers/sampled/visibility_manager_test.go	223
common/pinot/page_token_test.go	28
common/pinot/pinotQueryValidator_test.go	275
common/pinot/pinot_client_test.go	359
common/pinot/response_utility_test.go	108
common/quotas/fallbackdynamicratelimiterfactory_test.go	26
common/quotas/global/algorithm/requestweighted_test.go	676
common/quotas/limiter_test.go	112
common/quotas/permember_test.go	34
common/reconciliation/entity/types_test.go	159
common/reconciliation/fetcher/concrete_test.go	75
common/reconciliation/fetcher/current_test.go	74
common/reconciliation/fetcher/timer_test.go	142
common/reconciliation/invariant/concreteExecutionExists_test.go	137
common/reconciliation/invariant/historyExists_test.go	116
common/reconciliation/invariant/inactiveDomainExists_test.go	54
common/reconciliation/invariant/invariantManager_test.go	617
common/reconciliation/invariant/openCurrentExecution_test.go	155
common/reconciliation/invariant/staleWorkflow_test.go	361
common/reconciliation/invariant/test_util.go	71
common/reconciliation/invariant/timerInvalid_test.go	263
common/reconciliation/invariant/util_test.go	178
common/reconciliation/store/blobstorewriter_test.go	58
common/reconciliation/store/writerIterator_test.go	141
common/resource/resource_test.go	11
common/rpc/localip_test.go	77
common/rpc/middleware_test.go	313
common/rpc/outbounds_test.go	156
common/rpc/params_test.go	54
common/rpc/peer_chooser_test.go	43
common/service/name_test.go	15
common/syncmap/syncmap_test.go	56
common/task/fifo_task_scheduler_test.go	89
common/task/parallel_task_processor_test.go	250
common/task/scheduler_options_test.go	57
common/task/sequential_task_processor_test.go	237
common/task/weighted_round_robin_task_scheduler_test.go	313
common/taskvalidator/validateworkflow_test.go	73
common/testing/history_event_test.go	96
common/tokenbucket/tb_test.go	220
common/types/admin_test.go	142
common/types/mapper/proto/admin_test.go	803
common/types/mapper/proto/api_test.go	1041
common/types/mapper/proto/enum_test.go	386
common/types/mapper/proto/errors_test.go	32
common/types/mapper/proto/helpers_test.go	16
common/types/mapper/proto/history_test.go	335
common/types/mapper/proto/matching_test.go	92
common/types/mapper/proto/shared_test.go	262
common/types/mapper/thrift/admin_test.go	689
common/types/mapper/thrift/config_store_test.go	175
common/types/mapper/thrift/errors_test.go	29
common/types/mapper/thrift/helpers_test.go	24
common/types/mapper/thrift/history_test.go	568
common/types/mapper/thrift/matching_test.go	303
common/types/mapper/thrift/shared_test.go	2849
common/types/shared_test.go	243
common/util/file_util_test.go	139
common/util_test.go	1401
environment/env_test.go	539
host/activity_test.go	1173
host/archival_test.go	302
host/async_wf_test.go	161
host/cancel_workflow_test.go	452
host/client_integration_test.go	427
host/continue_as_new_test.go	417
host/decision_test.go	794
host/elastic_search_test.go	1038
host/integration_test.go	3712
host/ndc/integration_test.go	2281
host/ndc/replication_integration_test.go	107
host/ndc/test_suites.go	44
host/pinot_test.go	961
host/query_workflow_test.go	1144
host/reset_workflow_test.go	341
host/retry_policy_workflow_test.go	155
host/signal_workflow_test.go	1400
host/size_limit_test.go	160
host/test_suites.go	29
host/xdc/elasticsearch_test.go	299
scripts/run_cass_and_test.sh	18
service/frontend/admin/handler_test.go	1003
service/frontend/api/handler_test.go	1988
service/frontend/api/producer_manager_test.go	204
service/frontend/wrappers/accesscontrolled/access_controlled_test.go	65
service/frontend/wrappers/clusterredirection/api_test.go	700
service/frontend/wrappers/clusterredirection/policy_test.go	286
service/frontend/wrappers/metered/metered_test.go	62
service/frontend/wrappers/thrift/admin_handler_test.go	127
service/frontend/wrappers/thrift/api_handler_test.go	241
service/history/constants/test_constants.go	111
service/history/decision/checker_test.go	652
service/history/decision/handler_test.go	108
service/history/engine/engineimpl/historyEngine2_test.go	1411
service/history/engine/engineimpl/historyEngine3_eventsv2_test.go	385
service/history/engine/engineimpl/historyEngine_test.go	4572
service/history/events/blob_test.go	23
service/history/events/cache_test.go	184
service/history/events/notifier_test.go	106
service/history/execution/cache_test.go	157
service/history/execution/context_test.go	1074
service/history/execution/history_builder_test.go	1439
service/history/execution/mutable_state_builder_add_continue_as_new_event_test.go	343
service/history/execution/mutable_state_builder_test.go	1656
service/history/execution/mutable_state_decision_task_manager_test.go	44
service/history/execution/mutable_state_task_generator_test.go	839
service/history/execution/mutable_state_util_test.go	232
service/history/execution/retry_test.go	201
service/history/execution/state_builder_test.go	1376
service/history/execution/state_rebuilder_test.go	325
service/history/execution/timer_sequence_test.go	1013
service/history/execution/workflow_test.go	376
service/history/failover/coordinator_test.go	394
service/history/failover/marker_notifier_test.go	130
service/history/handler/handler_test.go	277
service/history/ndc/activity_replicator_test.go	1144
service/history/ndc/branch_manager_test.go	303
service/history/ndc/conflict_resolver_test.go	208
service/history/ndc/events_reapplier_test.go	187
service/history/ndc/existing_workflow_transaction_manager_test.go	567
service/history/ndc/new_workflow_transaction_manager_test.go	358
service/history/ndc/replication_task_test.go	53
service/history/ndc/transaction_manager_test.go	416
service/history/ndc/workflow_resetter_test.go	212
service/history/query/query_test.go	194
service/history/query/registry_test.go	200
service/history/queue/cross_cluster_queue_processor_base_test.go	676
service/history/queue/domain_filter_test.go	175
service/history/queue/processing_queue_collection_test.go	785
service/history/queue/processing_queue_test.go	1068
service/history/queue/processor_base_test.go	352
service/history/queue/queue_processor_util_test.go	189
service/history/queue/split_policy_test.go	658
service/history/queue/timer_gate_test.go	364
service/history/queue/timer_queue_processor_base_test.go	810
service/history/queue/transfer_queue_processor_base_test.go	496
service/history/queue/transfer_queue_validator_test.go	188
service/history/replication/cache_test.go	76
service/history/replication/dlq_handler_test.go	184
service/history/replication/metrics_emitter_test.go	82
service/history/replication/task_ack_manager_test.go	242
service/history/replication/task_executor_test.go	216
service/history/replication/task_fetcher_test.go	106
service/history/replication/task_hydrator_test.go	770
service/history/replication/task_processor_test.go	268
service/history/replication/task_reader_test.go	148
service/history/replication/task_store_test.go	129
service/history/reset/resetter_test.go	630
service/history/shard/context_test.go	258
service/history/shard/controller_test.go	571
service/history/task/cross_cluster_source_task_executor_test.go	1134
service/history/task/cross_cluster_target_task_executor_test.go	584
service/history/task/cross_cluster_task_processor_test.go	265
service/history/task/cross_cluster_task_test.go	927
service/history/task/event_logger_test.go	54
service/history/task/fetcher_test.go	188
service/history/task/priority_assigner_test.go	221
service/history/task/processor_test.go	166
service/history/task/redispatcher_test.go	149
service/history/task/task_test.go	242
service/history/task/timer_active_task_executor_test.go	1040
service/history/task/timer_standby_task_executor_test.go	668
service/history/task/timer_task_executor_base_test.go	160
service/history/task/transfer_active_task_executor_test.go	1773
service/history/task/transfer_standby_task_executor_test.go	703
service/history/workflow/util_test.go	150
service/history/workflowcache/cache_test.go	243
service/history/wrappers/ratelimited/handler_generated_test.go	107
service/history/wrappers/ratelimited/ratelimit_test.go	69
service/history/wrappers/thrift/thrift_handler_test.go	278
service/matching/forwarder_test.go	300
service/matching/liveness_test.go	79
service/matching/matcher_test.go	533
service/matching/matchingEngine_test.go	1795
service/matching/taskListManager_test.go	377
service/matching/tasklist_test.go	100
service/matching/thrift_handler_test.go	84
service/worker/archiver/activities_test.go	368
service/worker/archiver/client_test.go	390
service/worker/archiver/handler_test.go	187
service/worker/archiver/pump_test.go	236
service/worker/archiver/util_test.go	108
service/worker/archiver/workflow_test.go	114
service/worker/asyncworkflow/async_workflow_consumer_manager_test.go	310
service/worker/esanalyzer/analyzer_test.go	292
service/worker/failovermanager/rebalance_workflow_test.go	267
service/worker/failovermanager/workflow_test.go	551
service/worker/indexer/esProcessor_test.go	335
service/worker/replicator/domain_replication_processor_test.go	193
service/worker/scanner/data_corruption_workflow_test.go	110
service/worker/scanner/executions/concrete_execution_test.go	196
service/worker/scanner/executions/current_test.go	196
service/worker/scanner/executions/workflows_test.go	1
service/worker/scanner/executor/executor_test.go	71
service/worker/scanner/history/scavenger_test.go	426
service/worker/scanner/scanner_test.go	19
service/worker/scanner/shardscanner/activities_test.go	451
service/worker/scanner/shardscanner/aggregators_test.go	631
service/worker/scanner/shardscanner/fixer_test.go	736
service/worker/scanner/shardscanner/fixer_workflow_test.go	111
service/worker/scanner/shardscanner/scanner_test.go	484
service/worker/scanner/shardscanner/scanner_workflow_test.go	251
service/worker/scanner/shardscanner/shardscannertest/workflow_test.go	424
service/worker/scanner/shardscanner/types_test.go	15
service/worker/scanner/tasklist/mocks_test.go	122
service/worker/scanner/tasklist/scavenger_test.go	206
service/worker/scanner/timers/timers_test.go	208
service/worker/scanner/workflow_test.go	54
tools/cassandra/handler_test.go	27
tools/cli/admin_cluster_commands_test.go	98
tools/cli/admin_db_decode_thrift_test.go	210
tools/cli/app_test.go	832
tools/cli/isolation_groups_test.go	148
tools/cli/render_test.go	161
tools/cli/utils_test.go	98
tools/common/flag/flag_test.go	56
tools/common/schema/handler_test.go	84
tools/common/schema/schema_graph_test.go	70
tools/common/schema/test/dbtest.go	106
tools/common/schema/test/setuptest.go	93
tools/common/schema/test/updatetest.go	174
tools/common/schema/updatetask_test.go	292
tools/common/schema/version_test.go	85
tools/sql/clitest/cli_test.go	27