Path	Lines of Code
bench/lib/client.go	87
bench/lib/config.go	118
bench/lib/context.go	40
bench/lib/metrics.go	112
bench/lib/types.go	6
bench/load/basic/launchWorkflow.go	306
bench/load/basic/stressWorkflow.go	66
bench/load/cancellation/workflow.go	269
bench/load/common/activities.go	20
bench/load/common/constants.go	14
bench/load/common/helpers.go	60
bench/load/concurrentexec/batchWorkflow.go	140
bench/load/concurrentexec/launchWorkflow.go	113
bench/load/cron/workflow.go	278
bench/load/signal/workflow.go	444
bench/load/timer/launchWorkflow.go	186
bench/load/timer/timerWorkflow.go	62
bench/worker.go	110
canary/batch.go	163
canary/canary.go	176
canary/cancellation.go	182
canary/client.go	107
canary/common.go	65
canary/concurrentExec.go	56
canary/config.go	69
canary/const.go	79
canary/cron.go	91
canary/crosscluster.go	124
canary/echo.go	70
canary/historyArchival.go	142
canary/localactivity.go	114
canary/metrics.go	91
canary/query.go	75
canary/reset.go	185
canary/retry.go	91
canary/runner.go	151
canary/sanity.go	83
canary/searchAttributes.go	91
canary/signal.go	120
canary/timeout.go	55
canary/visibility.go	105
canary/visibilityArchival.go	187
client/admin/interface.go	42
client/admin/interface_mock.go	557
client/clientBean.go	121
client/clientBean_mock.go	83
client/clientfactory.go	172
client/frontend/interface.go	51
client/frontend/interface_mock.go	697
client/history/client.go	975
client/history/interface.go	51
client/history/interface_mock.go	691
client/history/peerResolver.go	65
client/history/peerResolver_mock.go	75
client/matching/client.go	201
client/matching/interface.go	18
client/matching/interface_mock.go	179
client/matching/loadbalancer.go	89
client/matching/peerResolver.go	47
client/wrappers/grpc/constructor.go	48
client/wrappers/thrift/constructor.go	37
client/wrappers/timeout/timeout.go	23
cmd/bench/main.go	114
cmd/canary/main.go	107
cmd/server/cadence/cadence.go	167
cmd/server/cadence/server.go	252
cmd/server/main.go	16
cmd/tools/cassandra/main.go	12
cmd/tools/cli/main.go	17
cmd/tools/copyright/licensegen.go	215
cmd/tools/sql/main.go	13
codecov.yml	50
common/archiver/URI.go	62
common/archiver/archivalMetadata.go	158
common/archiver/archivalMetadata_mock.go	29
common/archiver/constants.go	22
common/archiver/filestore/historyArchiver.go	256
common/archiver/filestore/queryParser.go	221
common/archiver/filestore/queryParser_mock.go	31
common/archiver/filestore/util.go	97
common/archiver/filestore/visibilityArchiver.go	278
common/archiver/gcloud/connector/client.go	132
common/archiver/gcloud/connector/clientDelegate.go	113
common/archiver/gcloud/historyArchiver.go	301
common/archiver/gcloud/init.go	29
common/archiver/gcloud/queryParser.go	204
common/archiver/gcloud/queryParser_mock.go	31
common/archiver/gcloud/util.go	199
common/archiver/gcloud/visibilityArchiver.go	190
common/archiver/historyIterator.go	211
common/archiver/historyIterator_mock.go	78
common/archiver/interface.go	82
common/archiver/interface_mock.go	101
common/archiver/options.go	61
common/archiver/provider/init.go	43
common/archiver/provider/provider.go	169
common/archiver/provider/provider_mock.go	54
common/archiver/s3store/historyArchiver.go	366
common/archiver/s3store/queryParser.go	194
common/archiver/s3store/queryParser_mock.go	31
common/archiver/s3store/util.go	214
common/archiver/s3store/visibilityArchiver.go	207
common/archiver/util.go	137
common/asyncworkflow/queue/consumer/default_consumer.go	232
common/asyncworkflow/queue/consumer/errors.go	14
common/asyncworkflow/queue/interface.go	11
common/asyncworkflow/queue/interface_mock.go	44
common/asyncworkflow/queue/kafka/config.go	56
common/asyncworkflow/queue/kafka/decoder.go	23
common/asyncworkflow/queue/kafka/init.go	14
common/asyncworkflow/queue/kafka/queue.go	73
common/asyncworkflow/queue/provider.go	48
common/asyncworkflow/queue/provider/interface_mock.go	111
common/asyncworkflow/queue/provider/provider.go	55
common/asyncworkflow/queueconfigapi/handler.go	41
common/asyncworkflow/queueconfigapi/handler_mock.go	44
common/asyncworkflow/queueconfigapi/interface.go	9
common/authorization/authority_mock.go	58
common/authorization/authorizer.go	88
common/authorization/factory.go	14
common/authorization/nopAuthorizer.go	12
common/authorization/oauthAuthorizer.go	176
common/authorization/scram_client.go	29
common/backoff/cron.go	67
common/backoff/jitter.go	26
common/backoff/retry.go	149
common/backoff/retrypolicy.go	149
common/blobstore/filestore/client.go	103
common/blobstore/interface.go	36
common/blobstore/interface_mock.go	92
common/blobstore/retryableClient.go	75
common/checksum/crc.go	42
common/checksum/defs.go	19
common/client/versionChecker.go	194
common/client/versionChecker_mock.go	72
common/clock/time_source.go	73
common/cluster/metadata.go	143
common/cluster/metadataTest.go	85
common/cluster/utils.go	18
common/codec/gob/gob.go	40
common/codec/interface.go	26
common/codec/version0Thriftrw.go	41
common/collection/channelPriorityQueue.go	53
common/collection/concurrentPriorityQueue.go	38
common/collection/concurrentQueue.go	53
common/collection/concurrent_tx_map.go	171
common/collection/interface.go	36
common/collection/iterator.go	7
common/collection/ordered_map.go	124
common/collection/pagingIterator.go	64
common/collection/priorityQueue.go	45
common/collection/util.go	43
common/config/archival.go	26
common/config/authorization.go	64
common/config/cluster.go	107
common/config/config.go	324
common/config/elasticsearch.go	79
common/config/kafkaConfig.go	71
common/config/loader.go	80
common/config/log.go	69
common/config/metrics.go	120
common/config/persistence.go	150
common/config/pinot.go	9
common/config/pprof.go	48
common/config/sasl.go	9
common/config/tls.go	57
common/constants.go	136
common/convert.go	131
common/daemon.go	12
common/definition/indexedKeys.go	74
common/definition/resourceDeduplication.go	50
common/definition/workflowIdentifier.go	15
common/domain/archivalConfigStateMachine.go	165
common/domain/attrValidator.go	113
common/domain/dlqMessageHandler.go	182
common/domain/dlqMessageHandler_mock.go	82
common/domain/errors.go	14
common/domain/failover_watcher.go	171
common/domain/failover_watcher_mock.go	36
common/domain/handler.go	960
common/domain/handler_mock.go	95
common/domain/replicationTaskExecutor.go	236
common/domain/replicationTaskHandler_mock.go	31
common/domain/replication_queue.go	242
common/domain/replication_queue_mock.go	155
common/domain/transmissionTaskHandler.go	111
common/dynamicconfig/clientInterface.go	28
common/dynamicconfig/clientInterface_mock.go	152
common/dynamicconfig/cmp.go	30
common/dynamicconfig/config.go	484
common/dynamicconfig/config/testConfig.yaml	58
common/dynamicconfig/config_mock.go	50
common/dynamicconfig/configstore/config/config.go	8
common/dynamicconfig/configstore/config_store_client.go	609
common/dynamicconfig/configstore/configstore_mock.go	169
common/dynamicconfig/constants.go	2866
common/dynamicconfig/file_based_client.go	296
common/dynamicconfig/filter.go	126
common/dynamicconfig/inMemoryClient.go	103
common/dynamicconfig/nopClient.go	53
common/elasticsearch/bulk/backoff.go	28
common/elasticsearch/bulk/bulk.go	67
common/elasticsearch/bulk/bulk_delete_request.go	80
common/elasticsearch/bulk/bulk_index_request.go	104
common/elasticsearch/bulk/bulk_update_request.go	94
common/elasticsearch/client.go	294
common/elasticsearch/client/client.go	37
common/elasticsearch/client/os2/client.go	277
common/elasticsearch/client/os2/client_bulk.go	148
common/elasticsearch/client/v6/client.go	144
common/elasticsearch/client/v6/client_bulk.go	161
common/elasticsearch/client/v7/client.go	123
common/elasticsearch/client/v7/client_bulk.go	157
common/elasticsearch/common.go	33
common/elasticsearch/defs.go	27
common/elasticsearch/esql/aggregation.go	269
common/elasticsearch/esql/cadenceSpecial.go	47
common/elasticsearch/esql/cadencesql.go	42
common/elasticsearch/esql/esql.go	71
common/elasticsearch/esql/globals.go	55
common/elasticsearch/esql/having.go	173
common/elasticsearch/esql/scriptQuery.go	50
common/elasticsearch/esql/select.go	415
common/elasticsearch/interfaces.go	128
common/elasticsearch/page_token.go	52
common/elasticsearch/query/bool_query.go	85
common/elasticsearch/query/builder.go	77
common/elasticsearch/query/exists_query.go	24
common/elasticsearch/query/match_query.go	121
common/elasticsearch/query/range_query.go	59
common/elasticsearch/query/sort.go	42
common/elasticsearch/validator/queryValidator.go	157
common/elasticsearch/validator/searchAttrValidator.go	101
common/errors/domainNotActiveError.go	30
common/errors/fakeErrors.go	40
common/errors/internalFailureError.go	12
common/future/future.go	88
common/isolationgroup/defaultisolationgroupstate/state.go	188
common/isolationgroup/defaultisolationgroupstate/types.go	13
common/isolationgroup/interface.go	12
common/isolationgroup/isolation_group_mock.go	71
common/isolationgroup/isolationgroupapi/domain-api-handlers.go	23
common/isolationgroup/isolationgroupapi/global-api-handlers.go	39
common/isolationgroup/isolationgroupapi/handler.go	18
common/isolationgroup/isolationgroupapi/interface.go	11
common/isolationgroup/isolationgroupapi/isolation_handler_mock.go	64
common/isolationgroup/isolationgroupapi/mappers.go	59
common/jsonTaskTokenSerializer.go	26
common/locks/lock.go	48
common/log/interface.go	26
common/log/loggerimpl/logger.go	126
common/log/loggerimpl/options.go	7
common/log/loggerimpl/replay.go	83
common/log/loggerimpl/throttle.go	90
common/log/mockLogger.go	39
common/log/panic.go	19
common/log/tag/interface.go	67
common/log/tag/tags.go	550
common/log/tag/values.go	371
common/log/testlogger/testlogger.go	16
common/membership/hashring.go	265
common/membership/hostinfo.go	82
common/membership/peerprovider_mock.go	78
common/membership/resolver.go	146
common/membership/resolver_mock.go	121
common/messaging/ackManager.go	106
common/messaging/errors.go	5
common/messaging/interface.go	36
common/messaging/kafka/client_impl.go	130
common/messaging/kafka/consumer_impl.go	217
common/messaging/kafka/partition_ack_manager.go	62
common/messaging/kafka/producer_impl.go	106
common/messaging/metricsProducer.go	36
common/messaging/noop_producer.go	12
common/metrics/client.go	84
common/metrics/context.go	19
common/metrics/defs.go	2528
common/metrics/interfaces.go	32
common/metrics/nop.go	30
common/metrics/runtime.go	120
common/metrics/scope.go	105
common/metrics/stopwatch.go	21
common/metrics/tags.go	168
common/metrics/tally/prometheus/buckets.go	33
common/metrics/tally/statsd/reporter.go	70
common/metrics/version.go	2
common/ndc/history_resender.go	254
common/ndc/history_resender_mock.go	30
common/pagination/interface.go	34
common/pagination/iterator.go	77
common/pagination/mocks.go	146
common/pagination/writer.go	64
common/partition/context.go	24
common/partition/default-partitioner.go	89
common/partition/interface.go	5
common/partition/partitioning_mock.go	32
common/partition/types.go	2
common/peerprovider/ringpopprovider/config.go	227
common/peerprovider/ringpopprovider/provider.go	217
common/persistence/client/bean.go	250
common/persistence/client/bean_mock.go	174
common/persistence/client/factory.go	450
common/persistence/config.go	18
common/persistence/configStoreManager.go	52
common/persistence/dataManagerInterfaces_mock.go	1087
common/persistence/dataVisibilityManagerInterfaces.go	151
common/persistence/dataVisibilityManagerInterfaces_mock.go	220
common/persistence/data_manager_interfaces.go	1329
common/persistence/data_store_interfaces.go	738
common/persistence/data_store_interfaces_mock.go	346
common/persistence/domainManager.go	222
common/persistence/elasticsearch/es_visibility_metric_clients.go	279
common/persistence/elasticsearch/es_visibility_store.go	848
common/persistence/errors.go	63
common/persistence/execution_manager.go	932
common/persistence/historyManager.go	454
common/persistence/jsonHistoryTokenSerializer.go	52
common/persistence/metered.go	122
common/persistence/nosql/constants.go	8
common/persistence/nosql/factory.go	111
common/persistence/nosql/nosql_config_store.go	45
common/persistence/nosql/nosql_domain_store.go	248
common/persistence/nosql/nosql_execution_store.go	678
common/persistence/nosql/nosql_execution_store_util.go	637
common/persistence/nosql/nosql_history_store.go	308
common/persistence/nosql/nosql_queue_store.go	299
common/persistence/nosql/nosql_shard_store.go	126
common/persistence/nosql/nosql_store.go	15
common/persistence/nosql/nosql_task_store.go	342
common/persistence/nosql/nosql_test_utils.go	75
common/persistence/nosql/nosql_visibility_store.go	325
common/persistence/nosql/nosqlplugin/cassandra/admin.go	135
common/persistence/nosql/nosqlplugin/cassandra/cluster_config.go	39
common/persistence/nosql/nosqlplugin/cassandra/cluster_config_cql.go	9
common/persistence/nosql/nosqlplugin/cassandra/constants.go	50
common/persistence/nosql/nosqlplugin/cassandra/db.go	101
common/persistence/nosql/nosqlplugin/cassandra/domain.go	447
common/persistence/nosql/nosqlplugin/cassandra/domain_cql.go	108
common/persistence/nosql/nosqlplugin/cassandra/gocql/batch.go	51
common/persistence/nosql/nosqlplugin/cassandra/gocql/client.go	84
common/persistence/nosql/nosqlplugin/cassandra/gocql/consistency.go	54
common/persistence/nosql/nosqlplugin/cassandra/gocql/interface.go	70
common/persistence/nosql/nosqlplugin/cassandra/gocql/interface_mock.go	443
common/persistence/nosql/nosqlplugin/cassandra/gocql/public/client.go	59
common/persistence/nosql/nosqlplugin/cassandra/gocql/public/testBase.go	12
common/persistence/nosql/nosqlplugin/cassandra/gocql/query.go	86
common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go	112
common/persistence/nosql/nosqlplugin/cassandra/history_events.go	163
common/persistence/nosql/nosqlplugin/cassandra/history_events_cql.go	15
common/persistence/nosql/nosqlplugin/cassandra/plugin.go	79
common/persistence/nosql/nosqlplugin/cassandra/queue.go	190
common/persistence/nosql/nosqlplugin/cassandra/queue_cql.go	14
common/persistence/nosql/nosqlplugin/cassandra/shard.go	250
common/persistence/nosql/nosqlplugin/cassandra/shard_cql.go	58
common/persistence/nosql/nosqlplugin/cassandra/tasks.go	318
common/persistence/nosql/nosqlplugin/cassandra/tasks_cql.go	105
common/persistence/nosql/nosqlplugin/cassandra/visibility.go	516
common/persistence/nosql/nosqlplugin/cassandra/visibility_cql.go	121
common/persistence/nosql/nosqlplugin/cassandra/workflow.go	632
common/persistence/nosql/nosqlplugin/cassandra/workflow_cql.go	566
common/persistence/nosql/nosqlplugin/cassandra/workflow_parsing_utils.go	544
common/persistence/nosql/nosqlplugin/cassandra/workflow_utils.go	1312
common/persistence/nosql/nosqlplugin/common.go	21
common/persistence/nosql/nosqlplugin/dynamodb/admin.go	9
common/persistence/nosql/nosqlplugin/dynamodb/configStore.go	12
common/persistence/nosql/nosqlplugin/dynamodb/db.go	41
common/persistence/nosql/nosqlplugin/dynamodb/domain.go	43
common/persistence/nosql/nosqlplugin/dynamodb/events.go	20
common/persistence/nosql/nosqlplugin/dynamodb/queue.go	79
common/persistence/nosql/nosqlplugin/dynamodb/shard.go	17
common/persistence/nosql/nosqlplugin/dynamodb/task.go	48
common/persistence/nosql/nosqlplugin/dynamodb/visibility.go	37
common/persistence/nosql/nosqlplugin/dynamodb/workflow.go	109
common/persistence/nosql/nosqlplugin/errors.go	50
common/persistence/nosql/nosqlplugin/interfaces.go	171
common/persistence/nosql/nosqlplugin/interfaces_mock.go	2571
common/persistence/nosql/nosqlplugin/mongodb/admin.go	42
common/persistence/nosql/nosqlplugin/mongodb/configStore.go	44
common/persistence/nosql/nosqlplugin/mongodb/db.go	21
common/persistence/nosql/nosqlplugin/mongodb/domain.go	43
common/persistence/nosql/nosqlplugin/mongodb/error.go	14
common/persistence/nosql/nosqlplugin/mongodb/events.go	20
common/persistence/nosql/nosqlplugin/mongodb/plugin.go	43
common/persistence/nosql/nosqlplugin/mongodb/queue.go	82
common/persistence/nosql/nosqlplugin/mongodb/shard.go	19
common/persistence/nosql/nosqlplugin/mongodb/task.go	48
common/persistence/nosql/nosqlplugin/mongodb/visibility.go	37
common/persistence/nosql/nosqlplugin/mongodb/workflow.go	109
common/persistence/nosql/nosqlplugin/types.go	223
common/persistence/nosql/plugin.go	45
common/persistence/nosql/sharded_nosql_store.go	108
common/persistence/nosql/sharding_policy.go	73
common/persistence/nosql/utils.go	36
common/persistence/operationModeValidator.go	329
common/persistence/persistence-utils/history_manager_util.go	128
common/persistence/pinot/pinot_visibility_metric_clients.go	279
common/persistence/pinot/pinot_visibility_store.go	867
common/persistence/pinotResponseComparator.go	433
common/persistence/pinotVisibilityTripleManager.go	510
common/persistence/pinotiVsibilityDualManager.go	289
common/persistence/queueManager.go	77
common/persistence/retryer.go	181
common/persistence/retryer_mock.go	138
common/persistence/serialization/getters.go	1275
common/persistence/serialization/interfaces.go	337
common/persistence/serialization/interfaces_mock.go	780
common/persistence/serialization/parser.go	311
common/persistence/serialization/persistence_mapper.go	148
common/persistence/serialization/thrift_decoder.go	122
common/persistence/serialization/thrift_encoder.go	67
common/persistence/serialization/thrift_mapper.go	696
common/persistence/serialization/uuid.go	56
common/persistence/serializer.go	406
common/persistence/serializer_mock.go	287
common/persistence/shardManager.go	144
common/persistence/sql/common.go	117
common/persistence/sql/factory.go	135
common/persistence/sql/plugin.go	45
common/persistence/sql/sql_config_store.go	47
common/persistence/sql/sql_domain_store.go	385
common/persistence/sql/sql_execution_store.go	1306
common/persistence/sql/sql_execution_store_util.go	1267
common/persistence/sql/sql_history_store.go	410
common/persistence/sql/sql_queue_store.go	232
common/persistence/sql/sql_shard_store.go	249
common/persistence/sql/sql_task_store.go	526
common/persistence/sql/sql_testing_util.go	161
common/persistence/sql/sql_visibility_store.go	360
common/persistence/sql/sqldriver/connections.go	38
common/persistence/sql/sqldriver/driver.go	14
common/persistence/sql/sqldriver/interface.go	24
common/persistence/sql/sqldriver/interface_mock.go	239
common/persistence/sql/sqldriver/sharded.go	113
common/persistence/sql/sqldriver/singleton.go	68
common/persistence/sql/sqlplugin/dbSharding.go	25
common/persistence/sql/sqlplugin/interface_mock.go	4032
common/persistence/sql/sqlplugin/interfaces.go	558
common/persistence/sql/sqlplugin/mysql/admin.go	77
common/persistence/sql/sqlplugin/mysql/configstore.go	28
common/persistence/sql/sqlplugin/mysql/configstore_sql.go	5
common/persistence/sql/sqlplugin/mysql/db.go	103
common/persistence/sql/sqlplugin/mysql/domain.go	94
common/persistence/sql/sqlplugin/mysql/events.go	59
common/persistence/sql/sqlplugin/mysql/execution.go	411
common/persistence/sql/sqlplugin/mysql/execution_maps.go	334
common/persistence/sql/sqlplugin/mysql/plugin.go	197
common/persistence/sql/sqlplugin/mysql/queue.go	144
common/persistence/sql/sqlplugin/mysql/shard.go	47
common/persistence/sql/sqlplugin/mysql/task.go	160
common/persistence/sql/sqlplugin/mysql/typeconv.go	31
common/persistence/sql/sqlplugin/mysql/visibility.go	182
common/persistence/sql/sqlplugin/postgres/admin.go	81
common/persistence/sql/sqlplugin/postgres/configstore.go	32
common/persistence/sql/sqlplugin/postgres/db.go	87
common/persistence/sql/sqlplugin/postgres/domain.go	94
common/persistence/sql/sqlplugin/postgres/events.go	60
common/persistence/sql/sqlplugin/postgres/execution.go	413
common/persistence/sql/sqlplugin/postgres/execution_maps.go	341
common/persistence/sql/sqlplugin/postgres/plugin.go	135
common/persistence/sql/sqlplugin/postgres/queue.go	101
common/persistence/sql/sqlplugin/postgres/shard.go	47
common/persistence/sql/sqlplugin/postgres/task.go	161
common/persistence/sql/sqlplugin/postgres/typeconv.go	27
common/persistence/sql/sqlplugin/postgres/visibility.go	196
common/persistence/sql/workflow_state_maps.go	611
common/persistence/sql/workflow_state_non_maps.go	154
common/persistence/statsComputer.go	267
common/persistence/taskManager.go	116
common/persistence/tasks.go	276
common/persistence/versionHistory.go	418
common/persistence/visibility_dual_manager.go	289
common/persistence/visibility_single_manager.go	382
common/persistence/visibility_store_mock.go	220
common/persistence/workflowExecutionInfo.go	140
common/persistence/workflowStateCloseStatusValidator.go	133
common/persistence/wrappers/errorinjectors/utils.go	304
common/persistence/wrappers/metered/base.go	216
common/persistence/wrappers/ratelimited/errors.go	7
common/persistence/wrappers/sampled/tokenbucketfactory.go	43
common/persistence/wrappers/sampled/visibility_manager.go	238
common/pinot/generic_client_mock.go	52
common/pinot/interfaces.go	18
common/pinot/page_token.go	46
common/pinot/pinotQueryValidator.go	345
common/pinot/pinot_client.go	105
common/pinot/response_utility.go	89
common/pprof.go	6
common/quotas/collection.go	29
common/quotas/dynamicratelimiter.go	29
common/quotas/dynamicratelimiterfactory.go	16
common/quotas/fallbackdynamicratelimiterfactory.go	28
common/quotas/global/algorithm/requestweighted.go	237
common/quotas/global/doc.go	1
common/quotas/interfaces.go	18
common/quotas/limiter_mock.go	52
common/quotas/limiterfactory_mock.go	30
common/quotas/multistageratelimiter.go	30
common/quotas/permember.go	46
common/quotas/ratelimiter.go	87
common/reconciliation/constants.go	9
common/reconciliation/entity/types.go	131
common/reconciliation/fetcher/concrete.go	121
common/reconciliation/fetcher/current.go	83
common/reconciliation/fetcher/timer.go	66
common/reconciliation/fetcher/types.go	7
common/reconciliation/invariant/concreteExecutionExists.go	187
common/reconciliation/invariant/historyExists.go	155
common/reconciliation/invariant/inactiveDomainExists.go	80
common/reconciliation/invariant/invariantManager.go	89
common/reconciliation/invariant/mocks.go	86
common/reconciliation/invariant/openCurrentExecution.go	152
common/reconciliation/invariant/staleWorkflow.go	406
common/reconciliation/invariant/timerInvalid.go	121
common/reconciliation/invariant/types.go	60
common/reconciliation/invariant/util.go	118
common/reconciliation/store/blobstoreIterator.go	84
common/reconciliation/store/blobstoreWriter.go	118
common/reconciliation/store/mocks.go	86
common/reconciliation/store/types.go	46
common/resource/params.go	59
common/resource/resource.go	72
common/resource/resourceImpl.go	471
common/resource/resourceTest.go	294
common/rpc.go	47
common/rpc/dns_updater.go	119
common/rpc/factory.go	114
common/rpc/localip.go	58
common/rpc/middleware.go	165
common/rpc/outbounds.go	172
common/rpc/params.go	161
common/rpc/peer_chooser.go	32
common/rsa.go	54
common/service/config.go	25
common/service/metrics.go	20
common/service/name.go	26
common/syncmap/syncmap.go	32
common/task/fifo_task_scheduler.go	127
common/task/fifo_task_scheduler_options.go	15
common/task/interface.go	45
common/task/interface_mock.go	321
common/task/parallel_task_processor.go	193
common/task/scheduler_options.go	46
common/task/sequential_task_processor.go	141
common/task/weighted_round_robin_task_scheduler.go	248
common/task/weighted_round_robin_task_scheduler_options.go	16
common/taskTokenSerializerInterfaces.go	24
common/taskvalidator/validateworkflow.go	104
common/testing/event_generator.go	374
common/testing/generator_interface.go	45
common/testing/history_event_util.go	946
common/testing/testdatagen/fuzzer.go	11
common/testing/testdatagen/idlfuzzedtestdata/history.go	18
common/tokenbucket/tb.go	218
common/types/admin.go	390
common/types/configStore.go	17
common/types/enums.go	64
common/types/errors.go	115
common/types/health.go	5
common/types/history.go	884
common/types/mapper/proto/admin.go	1261
common/types/mapper/proto/api.go	5533
common/types/mapper/proto/errors.go	228
common/types/mapper/proto/helpers.go	141
common/types/mapper/proto/history.go	1421
common/types/mapper/proto/matching.go	460
common/types/mapper/proto/shared.go	1599
common/types/mapper/thrift/admin.go	830
common/types/mapper/thrift/configStore.go	137
common/types/mapper/thrift/errors.go	108
common/types/mapper/thrift/health.go	23
common/types/mapper/thrift/helpers.go	18
common/types/mapper/thrift/history.go	1149
common/types/mapper/thrift/matching.go	340
common/types/mapper/thrift/replicator.go	709
common/types/mapper/thrift/shared.go	6901
common/types/matching.go	450
common/types/replicator.go	767
common/types/shared.go	6303
common/util.go	794
common/util/file_util.go	91
config/base.yaml	4
config/bench/base.yaml	3
config/bench/development.yaml	12
config/canary/base.yaml	3
config/canary/development.yaml	13
config/credentials/keytest.pub	9
config/development.yaml	119
config/development_async_wf_kafka_queue.yaml	127
config/development_cross_region_cluster0.yaml	115
config/development_cross_region_cluster1.yaml	115
config/development_cross_region_cluster2.yaml	115
config/development_es_opensearch.yaml	36
config/development_es_v6.yaml	31
config/development_es_v7.yaml	32
config/development_generic_oauth.yaml	56
config/development_http_api.yaml	76
config/development_multiple_cassandra.yaml	144
config/development_multiple_mysql.yaml	59
config/development_mysql.yaml	26
config/development_oauth.yaml	52
config/development_pinot.yaml	43
config/development_postgres.yaml	26
config/development_prometheus.yaml	25
config/development_scylla.yaml	14
config/development_tls.yaml	27
config/development_xdc_cluster0.yaml	125
config/development_xdc_cluster1.yaml	125
config/development_xdc_cluster2.yaml	125
config/dynamicconfig/development.yaml	49
config/dynamicconfig/development_es.yaml	45
config/dynamicconfig/development_pinot.yaml	50
docker/buildkite/docker-compose-es7.yml	75
docker/buildkite/docker-compose-local-async-wf.yml	84
docker/buildkite/docker-compose-local-es7.yml	89
docker/buildkite/docker-compose-local.yml	277
docker/buildkite/docker-compose-opensearch2.yml	76
docker/config/bench/development.yaml	10
docker/config/canary/development.yaml	9
docker/config_template.yaml	302
docker/dev/cassandra-esv7-kafka.yml	29
docker/dev/cassandra-opensearch-kafka.yml	30
docker/dev/cassandra-pinot-kafka.yml	71
docker/dev/cassandra.yml	9
docker/dev/mongo-esv7-kafka.yml	39
docker/dev/mysql-esv7-kafka.yml	28
docker/dev/mysql.yml	8
docker/dev/postgres.yml	9
docker/docker-compose-async-wf-kafka.yml	91
docker/docker-compose-bench.yml	6
docker/docker-compose-canary.yml	8
docker/docker-compose-es-v7.yml	91
docker/docker-compose-es.yml	90
docker/docker-compose-http-api.yml	70
docker/docker-compose-multiclusters-cass-mysql-es.yaml	153
docker/docker-compose-multiclusters-es.yml	150
docker/docker-compose-multiclusters.yml	110
docker/docker-compose-mysql.yml	59
docker/docker-compose-oauth.yml	60
docker/docker-compose-pinot.yml	114
docker/docker-compose-postgres.yml	60
docker/docker-compose-scylla.yml	57
docker/docker-compose-statsd.yml	46
docker/grafana/provisioning/dashboards/default.yaml	8
docker/grafana/provisioning/datasources/default.yaml	6
docker/prometheus/prometheus.yml	13
docker/prometheus_multiclusters/prometheus.yml	17
environment/env.go	179
host/client.go	30
host/dynamicconfig.go	166
host/esutils/client_os2.go	117
host/esutils/client_v6.go	73
host/esutils/client_v7.go	73
host/esutils/interfaces.go	37
host/flag.go	14
host/integrationbase.go	256
host/membership_hashring.go	32
host/membership_resolver.go	61
host/onebox.go	822
host/pinotutils/pinotClient.go	14
host/service.go	184
host/taskpoller.go	408
host/testcluster.go	356
internal/tools/tools.go	15
proto/buf.yaml	14
proto/internal/uber/cadence/history/v1/service.proto	607
proto/internal/uber/cadence/indexer/v1/messages.proto	43
proto/internal/uber/cadence/matching/v1/service.proto	207
proto/internal/uber/cadence/shared/v1/error.proto	42
proto/internal/uber/cadence/shared/v1/history.proto	33
proto/internal/uber/cadence/shared/v1/tasklist.proto	30
proto/internal/uber/cadence/shared/v1/workflow.proto	31
proto/persistenceblobs/v1/gogo.proto	117
proto/persistenceblobs/v1/message.proto	1155
revive.toml	88
schema/cassandra/cadence/keyspace.cql	1
schema/cassandra/cadence/schema.cql	444
schema/cassandra/cadence/versioned/s0.0-0.23/data_0_23.cql	38
schema/cassandra/cadence/versioned/s0.0-0.23/schema_0_23.cql	384
schema/cassandra/cadence/versioned/v0.1/base.cql	175
schema/cassandra/cadence/versioned/v0.10/event_batch_version.cql	1
schema/cassandra/cadence/versioned/v0.10/execution_last_write_version_and_workflow_state.cql	2
schema/cassandra/cadence/versioned/v0.11/event_encoding.cql	3
schema/cassandra/cadence/versioned/v0.11/history_size.cql	1
schema/cassandra/cadence/versioned/v0.11/sync_activity.cql	1
schema/cassandra/cadence/versioned/v0.11/workflow_retry.cql	8
schema/cassandra/cadence/versioned/v0.12/add_archival_config.cql	2
schema/cassandra/cadence/versioned/v0.12/cron.cql	2
schema/cassandra/cadence/versioned/v0.12/events_v2.cql	32
schema/cassandra/cadence/versioned/v0.12/signal_count.cql	1
schema/cassandra/cadence/versioned/v0.12/system_domain_bootstrap.cql	9
schema/cassandra/cadence/versioned/v0.13/events_cache.cql	7
schema/cassandra/cadence/versioned/v0.13/reset.cql	4
schema/cassandra/cadence/versioned/v0.14/last_event_task_id.cql	1
schema/cassandra/cadence/versioned/v0.14/task_list.cql	1
schema/cassandra/cadence/versioned/v0.15/auto_reset.cql	4
schema/cassandra/cadence/versioned/v0.16/decision_scheduled_timestamp.cql	1
schema/cassandra/cadence/versioned/v0.17/search_attr.cql	1
schema/cassandra/cadence/versioned/v0.17/task_created_time.cql	1
schema/cassandra/cadence/versioned/v0.18/activity_last_failure_info.cql	2
schema/cassandra/cadence/versioned/v0.19/archival_domain_config.cql	4
schema/cassandra/cadence/versioned/v0.2/add_buffered_events.cql	6
schema/cassandra/cadence/versioned/v0.2/add_sticky_tasklist.cql	2
schema/cassandra/cadence/versioned/v0.2/add_wf_timeout.cql	1
schema/cassandra/cadence/versioned/v0.2/fail_decision_mutable_state.cql	3
schema/cassandra/cadence/versioned/v0.20/memo.cql	1
schema/cassandra/cadence/versioned/v0.21/decision_original_scheduled_timestamp.cql	1
schema/cassandra/cadence/versioned/v0.22/activity_last_failure_details.cql	1
schema/cassandra/cadence/versioned/v0.22/cluster_replication_level.cql	1
schema/cassandra/cadence/versioned/v0.22/parent_close_policy.cql	1
schema/cassandra/cadence/versioned/v0.22/request_cancel_signal_batch_event_id.cql	2
schema/cassandra/cadence/versioned/v0.23/queue.cql	8
schema/cassandra/cadence/versioned/v0.23/queue_metadata.cql	8
schema/cassandra/cadence/versioned/v0.23/system_domain.cql	29
schema/cassandra/cadence/versioned/v0.23/version_histories.cql	2
schema/cassandra/cadence/versioned/v0.24/checksum.cql	2
schema/cassandra/cadence/versioned/v0.25/replication_dlq.cql	1
schema/cassandra/cadence/versioned/v0.26/domain_dlq_id.cql	9
schema/cassandra/cadence/versioned/v0.27/domain_failover_end_time.cql	1
schema/cassandra/cadence/versioned/v0.28/previous_failover_version.cql	1
schema/cassandra/cadence/versioned/v0.28/replication_task_creation_time.cql	1
schema/cassandra/cadence/versioned/v0.28/shard_info_marker.cql	2
schema/cassandra/cadence/versioned/v0.29/processing_queue_states.cql	4
schema/cassandra/cadence/versioned/v0.3/add_client_version.cql	3
schema/cassandra/cadence/versioned/v0.3/add_last_first_event_id.cql	1
schema/cassandra/cadence/versioned/v0.30/domain_last_updated_time.cql	1
schema/cassandra/cadence/versioned/v0.31/cross_cluster_queue.cql	3
schema/cassandra/cadence/versioned/v0.32/config_store.cql	8
schema/cassandra/cadence/versioned/v0.33/child_info_domain_id.cql	1
schema/cassandra/cadence/versioned/v0.33/target_domain_ids.cql	1
schema/cassandra/cadence/versioned/v0.34/workflow_execution_first_run_id.cql	1
schema/cassandra/cadence/versioned/v0.35/partition_config.cql	2
schema/cassandra/cadence/versioned/v0.36/isolation_groups.cql	2
schema/cassandra/cadence/versioned/v0.37/async_workflow_config.cql	2
schema/cassandra/cadence/versioned/v0.4/add_signal_decision.cql	9
schema/cassandra/cadence/versioned/v0.4/add_tasklist_kind.cql	1
schema/cassandra/cadence/versioned/v0.5/add_replication_config.cql	7
schema/cassandra/cadence/versioned/v0.5/add_target_child_workflow_only_to_transfer_task.cql	1
schema/cassandra/cadence/versioned/v0.6/add_shard_cluster_ack_level.cql	2
schema/cassandra/cadence/versioned/v0.6/history_replication_task.cql	25
schema/cassandra/cadence/versioned/v0.7/buffered_replication_task.cql	8
schema/cassandra/cadence/versioned/v0.7/failover_version_persistence.cql	8
schema/cassandra/cadence/versioned/v0.7/retry_policy.cql	10
schema/cassandra/cadence/versioned/v0.8/domain_notification.cql	16
schema/cassandra/cadence/versioned/v0.9/domain_data.cql	1
schema/cassandra/cadence/versioned/v0.9/transfer_timestamp.cql	1
schema/cassandra/embed.go	3
schema/cassandra/version.go	3
schema/cassandra/visibility/keyspace.cql	1
schema/cassandra/visibility/schema.cql	80
schema/cassandra/visibility/versioned/v0.1/base.cql	35
schema/cassandra/visibility/versioned/v0.2/reduce_open_workflow_tombstones.cql	4
schema/cassandra/visibility/versioned/v0.3/sort_by_close_time.cql	20
schema/cassandra/visibility/versioned/v0.4/add_execution_time.cql	3
schema/cassandra/visibility/versioned/v0.4/add_memo.cql	6
schema/cassandra/visibility/versioned/v0.5/add_task_list.cql	3
schema/cassandra/visibility/versioned/v0.6/add_is_cron.cql	3
schema/cassandra/visibility/versioned/v0.7/add_num_clusters.cql	3
schema/cassandra/visibility/versioned/v0.8/add_update_time.cql	3
schema/cassandra/visibility/versioned/v0.9/add_shard_id.cql	3
schema/elasticsearch/embed.go	5
schema/mongodb/cadence/collectionSchema.go	12
schema/mongodb/version.go	2
schema/mysql/embed.go	3
schema/mysql/v8/cadence/database.sql	1
schema/mysql/v8/cadence/schema.sql	226
schema/mysql/v8/cadence/versioned/v0.1/base.sql	203
schema/mysql/v8/cadence/versioned/v0.2/queue.sql	11
schema/mysql/v8/cadence/versioned/v0.3/replication_tasks_dlq.sql	8
schema/mysql/v8/cadence/versioned/v0.4/blob_size.sql	18
schema/mysql/v8/cadence/versioned/v0.5/cross_cluster_table.sql	8
schema/mysql/v8/cadence/versioned/v0.6/cluster_config.sql	8
schema/mysql/v8/visibility/database.sql	1
schema/mysql/v8/visibility/schema.sql	23
schema/mysql/v8/visibility/versioned/v0.1/base.sql	17
schema/mysql/v8/visibility/versioned/v0.2/add_task_list.sql	1
schema/mysql/v8/visibility/versioned/v0.3/vs_index.sql	1
schema/mysql/v8/visibility/versioned/v0.4/add_is_cron.sql	1
schema/mysql/v8/visibility/versioned/v0.5/add_num_clusters.sql	1
schema/mysql/v8/visibility/versioned/v0.6/add_update_time.sql	1
schema/mysql/v8/visibility/versioned/v0.7/add_shard_id.sql	1
schema/mysql/version.go	3
schema/postgres/cadence/database.sql	1
schema/postgres/cadence/schema.sql	224
schema/postgres/cadence/versioned/v0.1/base.sql	189
schema/postgres/cadence/versioned/v0.2/queue.sql	11
schema/postgres/cadence/versioned/v0.3/replication_tasks_dlq.sql	8
schema/postgres/cadence/versioned/v0.4/cross_cluster_table.sql	8
schema/postgres/cadence/versioned/v0.5/cluster_config.sql	8
schema/postgres/embed.go	3
schema/postgres/version.go	3
schema/postgres/visibility/database.sql	1
schema/postgres/visibility/schema.sql	23
schema/postgres/visibility/versioned/v0.1/base.sql	17
schema/postgres/visibility/versioned/v0.2/add_task_list.sql	1
schema/postgres/visibility/versioned/v0.3/vs_index.sql	1
schema/postgres/visibility/versioned/v0.4/add_is_cron.sql	1
schema/postgres/visibility/versioned/v0.5/num_clusters.sql	1
schema/postgres/visibility/versioned/v0.6/add_update_time.sql	1
schema/postgres/visibility/versioned/v0.7/add_shard_id.sql	1
service/frontend/admin/handler.go	1510
service/frontend/admin/interface.go	43
service/frontend/admin/interface_mock.go	402
service/frontend/api/handler.go	3482
service/frontend/api/interface.go	53
service/frontend/api/interface_mock.go	492
service/frontend/api/producer_manager.go	80
service/frontend/api/producer_manager_mock.go	32
service/frontend/config/config.go	139
service/frontend/service.go	172
service/frontend/validate/errors.go	75
service/frontend/wrappers/accesscontrolled/access_controlled.go	43
service/frontend/wrappers/clusterredirection/dcRedirectionPolicy_mock.go	28
service/frontend/wrappers/clusterredirection/policy.go	157
service/frontend/wrappers/grpc/share.go	22
service/frontend/wrappers/metered/metered.go	274
service/frontend/wrappers/ratelimited/ratelimit.go	25
service/frontend/wrappers/thrift/constructor.go	37
service/history/common/type.go	15
service/history/config/config.go	525
service/history/constants/constants.go	14
service/history/decision/checker.go	724
service/history/decision/handler.go	743
service/history/decision/task_handler.go	910
service/history/engine/engineimpl/historyEngine.go	3133
service/history/engine/interface.go	60
service/history/engine/interface_mock.go	522
service/history/events/blob.go	21
service/history/events/cache.go	226
service/history/events/cache_mock.go	41
service/history/events/notifier.go	184
service/history/execution/cache.go	248
service/history/execution/checksum.go	80
service/history/execution/context.go	1207
service/history/execution/context_mock.go	262
service/history/execution/context_util.go	155
service/history/execution/history_builder.go	693
service/history/execution/integrity.go	130
service/history/execution/mutable_state.go	204
service/history/execution/mutable_state_builder.go	3873
service/history/execution/mutable_state_decision_task_manager.go	666
service/history/execution/mutable_state_decision_task_manager_mock.go	291
service/history/execution/mutable_state_mock.go	1873
service/history/execution/mutable_state_task_generator.go	898
service/history/execution/mutable_state_task_generator_mock.go	213
service/history/execution/mutable_state_task_refresher.go	386
service/history/execution/mutable_state_task_refresher_mock.go	32
service/history/execution/mutable_state_util.go	457
service/history/execution/retry.go	53
service/history/execution/state_builder.go	420
service/history/execution/state_builder_mock.go	42
service/history/execution/state_rebuilder.go	217
service/history/execution/state_rebuilder_mock.go	35
service/history/execution/timer_sequence.go	349
service/history/execution/timer_sequence_mock.go	74
service/history/execution/workflow.go	209
service/history/execution/workflow_execution_util.go	26
service/history/execution/workflow_mock.go	104
service/history/failover/coordinator.go	318
service/history/failover/coordinator_mock.go	64
service/history/failover/marker_notifier.go	81
service/history/failover/marker_notifier_mock.go	36
service/history/handler/handler.go	1704
service/history/handler/interface.go	55
service/history/handler/interface_mock.go	513
service/history/ndc/activity_replicator.go	200
service/history/ndc/activity_replicator_mock.go	32
service/history/ndc/branch_manager.go	213
service/history/ndc/branch_manager_mock.go	34
service/history/ndc/conflict_resolver.go	137
service/history/ndc/conflict_resolver_mock.go	34
service/history/ndc/events_reapplier.go	73
service/history/ndc/events_reapplier_mock.go	34
service/history/ndc/existing_workflow_transaction_manager.go	450
service/history/ndc/existing_workflow_transaction_manager_mock.go	33
service/history/ndc/history_replicator.go	602
service/history/ndc/new_workflow_transaction_mamanger_mock.go	33
service/history/ndc/new_workflow_transaction_manager.go	301
service/history/ndc/replication_task.go	311
service/history/ndc/transaction_manager.go	361
service/history/ndc/transaction_manager_mock.go	87
service/history/ndc/workflow_resetter.go	182
service/history/ndc/workflow_resetter_mock.go	34
service/history/query/query.go	108
service/history/query/registry.go	169
service/history/queue/action.go	68
service/history/queue/constants.go	6
service/history/queue/cross_cluster_queue_processor.go	133
service/history/queue/cross_cluster_queue_processor_base.go	599
service/history/queue/domain_filter.go	92
service/history/queue/interface.go	51
service/history/queue/interface_mock.go	360
service/history/queue/processing_queue.go	263
service/history/queue/processing_queue_collection.go	180
service/history/queue/processing_queue_state.go	70
service/history/queue/processor_base.go	364
service/history/queue/processor_options.go	35
service/history/queue/queue_processor_util.go	88
service/history/queue/split_policy.go	338
service/history/queue/task_allocator.go	142
service/history/queue/timer_gate.go	146
service/history/queue/timer_queue_active_processor.go	62
service/history/queue/timer_queue_failover_processor.go	87
service/history/queue/timer_queue_processor.go	401
service/history/queue/timer_queue_processor_base.go	562
service/history/queue/timer_queue_standby_processor.go	81
service/history/queue/transfer_queue_processor.go	587
service/history/queue/transfer_queue_processor_base.go	483
service/history/queue/transfer_queue_validator.go	136
service/history/replication/cache.go	80
service/history/replication/dlq_handler.go	277
service/history/replication/metrics_emitter.go	122
service/history/replication/task_ack_manager.go	94
service/history/replication/task_executor.go	254
service/history/replication/task_fetcher.go	231
service/history/replication/task_hydrator.go	249
service/history/replication/task_processor.go	564
service/history/replication/task_reader.go	71
service/history/replication/task_store.go	148
service/history/reset/resetter.go	575
service/history/reset/resetter_mock.go	33
service/history/resource/resource.go	90
service/history/resource/resourceTest.go	28
service/history/service.go	114
service/history/shard/context.go	1272
service/history/shard/contextTest.go	78
service/history/shard/context_mock.go	587
service/history/shard/controller.go	419
service/history/shard/controller_mock.go	130
service/history/task/constants.go	9
service/history/task/cross_cluster_source_task_executor.go	448
service/history/task/cross_cluster_target_task_executor.go	366
service/history/task/cross_cluster_task.go	749
service/history/task/cross_cluster_task_processor.go	403
service/history/task/event_logger.go	73
service/history/task/fetcher.go	304
service/history/task/interface.go	73
service/history/task/interface_mock.go	782
service/history/task/priority_assigner.go	96
service/history/task/processor.go	206
service/history/task/redispatcher.go	240
service/history/task/standby_task_util.go	146
service/history/task/task.go	350
service/history/task/task_util.go	416
service/history/task/timer_active_task_executor.go	684
service/history/task/timer_standby_task_executor.go	360
service/history/task/timer_task_executor_base.go	251
service/history/task/transfer_active_task_executor.go	1745
service/history/task/transfer_standby_task_executor.go	557
service/history/task/transfer_task_executor_base.go	354
service/history/testing/events_util.go	342
service/history/testing/workflow_util.go	84
service/history/workflow/context.go	54
service/history/workflow/errors.go	23
service/history/workflow/util.go	207
service/history/workflowcache/cache.go	158
service/history/workflowcache/cache_mock.go	40
service/history/wrappers/grpc/grpc_handler.go	16
service/history/wrappers/ratelimited/ratelimit.go	12
service/history/wrappers/thrift/thrift_handler.go	24
service/matching/config.go	186
service/matching/context.go	100
service/matching/db.go	158
service/matching/forwarder.go	223
service/matching/grpc_handler.go	16
service/matching/handler.go	340
service/matching/handler_mock.go	155
service/matching/liveness.go	83
service/matching/matcher.go	347
service/matching/matchingEngine.go	928
service/matching/matchingEngineInterfaces.go	17
service/matching/pollerHistory.go	81
service/matching/service.go	88
service/matching/task.go	113
service/matching/taskGC.go	56
service/matching/taskListManager.go	493
service/matching/taskReader.go	415
service/matching/taskWriter.go	221
service/matching/tasklist.go	95
service/matching/thrift_handler.go	23
service/worker/archiver/activities.go	153
service/worker/archiver/client.go	261
service/worker/archiver/client_mock.go	26
service/worker/archiver/client_worker.go	87
service/worker/archiver/handler.go	163
service/worker/archiver/handler_mock.go	20
service/worker/archiver/pump.go	105
service/worker/archiver/pump_mock.go	15
service/worker/archiver/replay_metrics_client.go	113
service/worker/archiver/util.go	70
service/worker/archiver/workflow.go	90
service/worker/asyncworkflow/async_workflow_consumer_manager.go	172
service/worker/batcher/batcher.go	58
service/worker/batcher/workflow.go	427
service/worker/esanalyzer/analyzer.go	127
service/worker/esanalyzer/domainWorkflowTypeCountWorkflow.go	159
service/worker/esanalyzer/workflow.go	173
service/worker/failovermanager/rebalance_workflow.go	86
service/worker/failovermanager/starter.go	69
service/worker/failovermanager/workflow.go	409
service/worker/indexer/esProcessor.go	265
service/worker/indexer/indexer.go	259
service/worker/parentclosepolicy/client.go	59
service/worker/parentclosepolicy/client_mock.go	19
service/worker/parentclosepolicy/processor.go	55
service/worker/parentclosepolicy/workflow.go	228
service/worker/replicator/domain_replication_processor.go	181
service/worker/replicator/replicator.go	76
service/worker/scanner/data_corruption_workflow.go	202
service/worker/scanner/executions/concrete_execution.go	167
service/worker/scanner/executions/current_execution.go	141
service/worker/scanner/executions/types.go	96
service/worker/scanner/executor/executor.go	97
service/worker/scanner/executor/runq.go	83
service/worker/scanner/history/scavenger.go	252
service/worker/scanner/scanner.go	201
service/worker/scanner/shardscanner/activities.go	374
service/worker/scanner/shardscanner/aggregators.go	482
service/worker/scanner/shardscanner/fixer.go	172
service/worker/scanner/shardscanner/fixer_workflow.go	210
service/worker/scanner/shardscanner/scanner.go	170
service/worker/scanner/shardscanner/scanner_workflow.go	181
service/worker/scanner/shardscanner/shardscannertest/workflow.go	19
service/worker/scanner/shardscanner/types.go	417
service/worker/scanner/shardscanner/workflows.go	10
service/worker/scanner/tasklist/db.go	130
service/worker/scanner/tasklist/handler.go	119
service/worker/scanner/tasklist/scavenger.go	214
service/worker/scanner/timers/timers.go	151
service/worker/scanner/workflow.go	140
service/worker/service.go	399
service/worker/workercommon/util.go	40
testflags/testflags.go	33
tools/cassandra/cqlclient.go	223
tools/cassandra/handler.go	183
tools/cassandra/main.go	196
tools/cli/admin.go	1379
tools/cli/admin_async_queue_commands.go	47
tools/cli/admin_cluster_commands.go	127
tools/cli/admin_commands.go	501
tools/cli/admin_config_store_commands.go	278
tools/cli/admin_db_clean_command.go	101
tools/cli/admin_db_decode_thrift.go	105
tools/cli/admin_db_scan_command.go	171
tools/cli/admin_dlq_commands.go	306
tools/cli/admin_elastic_search_commands.go	447
tools/cli/admin_failover_commands.go	324
tools/cli/admin_kafka_commands.go	469
tools/cli/admin_task_list_commands.go	86
tools/cli/admin_timers.go	238
tools/cli/app.go	184
tools/cli/cluster.go	13
tools/cli/cluster_commands.go	37
tools/cli/database.go	301
tools/cli/defs.go	97
tools/cli/domain.go	67
tools/cli/domain_commands.go	612
tools/cli/domain_migration_command.go	429
tools/cli/domain_utils.go	377
tools/cli/factory.go	201
tools/cli/flags.go	734
tools/cli/histogram.go	73
tools/cli/isolation-groups.go	191
tools/cli/render.go	212
tools/cli/task_list.go	39
tools/cli/task_list_commands.go	91
tools/cli/utils.go	855
tools/cli/workflow.go	539
tools/cli/workflow_batch_commands.go	237
tools/cli/workflow_commands.go	1858
tools/common/flag/flag.go	36
tools/common/schema/handler.go	108
tools/common/schema/schema_graph.go	67
tools/common/schema/setuptask.go	63
tools/common/schema/types.go	91
tools/common/schema/updatetask.go	327
tools/common/schema/util.go	34
tools/common/schema/version.go	52
tools/linter/funcorder/analyzer.go	91
tools/linter/funcorder/cmd/funcorder/main.go	8
tools/sql/clitest/connTest.go	112
tools/sql/clitest/handlerTest.go	52
tools/sql/clitest/setuptaskTest.go	44
tools/sql/clitest/updatetaskTest.go	51
tools/sql/clitest/versionTest.go	462
tools/sql/conn.go	73
tools/sql/handler.go	195
tools/sql/main.go	163