Path	Lines of Code
api/api_test.go	59
api/ares_suite_test.go	12
api/common/ares_suite_test.go	12
api/common/request_test.go	49
api/data_handler_test.go	55
api/debug_handler_test.go	935
api/enum_handler_test.go	85
api/health_handler_test.go	40
api/panic_handler_test.go	28
api/query_handler_test.go	338
api/schema_handler_test.go	191
api/sql_query_handler_test.go	124
broker/broker_schema_mutator_test.go	71
broker/broker_suite_test.go	12
broker/common/mocks/BlockingPlanNode.go	47
broker/common/mocks/MergeNode.go	57
broker/common/mocks/QueryExecutor.go	17
broker/common/mocks/StreamingPlanNode.go	16
broker/handler_test.go	14
broker/query_compiler_test.go	731
broker/query_plan_agg_test.go	553
broker/query_plan_non_agg_test.go	237
broker/result_merge_test.go	456
broker/util/assignment_test.go	55
broker/util/broker_suite_test.go	12
cgoutils/ares_suite_test.go	12
cgoutils/memory_test.go	75
client/ares_suite_test.go	12
client/connector_test.go	271
client/mocks/Connector.go	26
cluster/ares_suite_test.go	12
cluster/shard/ares_suite_test.go	12
cluster/shard/mocks/ShardSet.go	30
cluster/shard/shardset_test.go	18
cluster/topology/ares_suite_test.go	12
cluster/topology/dynamic_test.go	187
cluster/topology/healthtracking_dynamic_test.go	82
cluster/topology/host_test.go	23
cluster/topology/map_test.go	59
cluster/topology/mocks/DynamicOptions.go	139
cluster/topology/mocks/DynamicTopology.go	56
cluster/topology/mocks/HealthTrackingDynamicTopoloy.go	59
cluster/topology/mocks/Host.go	35
cluster/topology/mocks/HostShardSet.go	31
cluster/topology/mocks/Initializer.go	40
cluster/topology/mocks/Map.go	99
cluster/topology/mocks/MapProvider.go	24
cluster/topology/mocks/MapWatch.go	33
cluster/topology/mocks/StaticOptions.go	87
cluster/topology/mocks/Topology.go	39
cluster/topology/options_test.go	56
cluster/topology/static_test.go	39
controller/client/controller_client_suite_test.go	10
controller/client/controller_test.go	216
controller/client/mocks/ControllerClient.go	165
controller/handlers/assignment_test.go	97
controller/handlers/config_test.go	159
controller/handlers/membership_test.go	125
controller/handlers/namespace_test.go	56
controller/handlers/placement_test.go	244
controller/handlers/schema_test.go	141
controller/mutators/common/job_config_validator_test.go	44
controller/mutators/etcd/assignment_mutator_test.go	100
controller/mutators/etcd/enum_mutator_test.go	92
controller/mutators/etcd/job_mutator_test.go	132
controller/mutators/etcd/membership_mutator_test.go	71
controller/mutators/etcd/namespace_mutator_test.go	46
controller/mutators/etcd/placement_mutator_test.go	205
controller/mutators/etcd/schema_mutator_test.go	197
controller/mutators/etcd/subscriber_mutator_test.go	50
controller/mutators/mocks/EnumMutator.go	41
controller/mutators/mocks/EnumReader.go	23
controller/mutators/mocks/IngestionAssignmentMutator.go	88
controller/mutators/mocks/JobMutator.go	88
controller/mutators/mocks/MembershipMutator.go	76
controller/mutators/mocks/NamespaceMutator.go	33
controller/mutators/mocks/SubscriberMutator.go	58
controller/mutators/mocks/TableSchemaMutator.go	88
controller/tasks/etcd/ingestion_assignment_test.go	270
controller/tasks/etcd/leader_elector_test.go	31
controller/ui/src/App.test.js	6
datanode/ares_suite_test.go	12
datanode/bootstrap/ares_suite_test.go	12
datanode/bootstrap/bootstrap_details_test.go	40
datanode/bootstrap/bootstrap_server_bm_test.go	120
datanode/bootstrap/bootstrap_server_test.go	257
datanode/bootstrap/mocks/Bootstrapable.go	18
datanode/bootstrap_manager_test.go	81
datanode/client/datanode_client_suite_test.go	10
datanode/client/mocks/DataNodeQueryClient.go	44
datanode/client/mocks/Peer.go	32
datanode/client/mocks/PeerSource.go	19
datanode/client/query_client_test.go	91
datanode/datanode_test.go	151
datanode/peer_source_test.go	69
diskstore/ares_suite_test.go	12
diskstore/diskstore_util_test.go	53
diskstore/local_diskstore_test.go	539
diskstore/mocks/DiskStore.go	263
integration/ares_suite_test.go	48
integration/integration_test.go	65
memstore/archive_store_test.go	241
memstore/archiving_test.go	336
memstore/ares_suite_test.go	12
memstore/backfill_manager_test.go	77
memstore/backfill_test.go	380
memstore/batchstats_test.go	35
memstore/bootstrap_test.go	360
memstore/common/ares_suite_test.go	12
memstore/common/data_type_test.go	480
memstore/common/data_value_test.go	450
memstore/common/mocks/BootStrapToken.go	18
memstore/common/mocks/EnumUpdater.go	15
memstore/common/mocks/HostMemoryManager.go	42
memstore/common/mocks/ListVectorParty.go	27
memstore/common/mocks/LiveVectorParty.go	203
memstore/common/mocks/PrimaryKey.go	116
memstore/common/mocks/TableSchemaReader.go	48
memstore/common/mocks/VectorParty.go	161
memstore/common/primary_key_test.go	34
memstore/common/upsert_batch_builder_test.go	249
memstore/common/upsert_batch_header_test.go	72
memstore/common/upsert_batch_test.go	544
memstore/cuckoo_index_test.go	358
memstore/host_memory_manager_test.go	810
memstore/ingestion_test.go	585
memstore/job_manager_test.go	416
memstore/json_marshaller_test.go	309
memstore/list/archive_vector_party_test.go	246
memstore/list/ares_suite_test.go	12
memstore/list/live_vector_party_test.go	176
memstore/list/memory_pool_test.go	180
memstore/list/slab_test.go	276
memstore/list/test_factory.go	74
memstore/list/test_factory_test.go	54
memstore/live_store_test.go	188
memstore/live_vector_party_test.go	139
memstore/memstore_test.go	86
memstore/merge_arrayvp_test.go	191
memstore/merge_test.go	495
memstore/mocks/BatchReader.go	26
memstore/mocks/Job.go	46
memstore/mocks/MemStore.go	191
memstore/mocks/RedoLogBrowser.go	73
memstore/mocks/Scheduler.go	119
memstore/mocks/sortedColumnIterator.go	87
memstore/purge_test.go	117
memstore/recovery_test.go	185
memstore/redo_log_browser_test.go	68
memstore/scheduler_test.go	73
memstore/schema_test.go	488
memstore/snapshot_manager_test.go	100
memstore/snapshot_test.go	212
memstore/table_shard_test.go	68
memstore/test_factory.go	156
memstore/test_factory_test.go	108
memstore/tests/test_factory_base.go	230
memstore/vector_party_serializer_test.go	245
memstore/vector_party_test.go	281
memstore/vectors/vector_test.go	390
metastore/ares_suite_test.go	12
metastore/common/ares_suite_test.go	12
metastore/common/model_test.go	36
metastore/disk_metastore_test.go	687
metastore/mocks/TableSchemaMutator.go	112
metastore/mocks/TableSchemaReader.go	42
metastore/mocks/TableSchemaValidator.go	22
metastore/mocks/TableSchemaWatchable.go	58
metastore/mocks/metastore.go	492
metastore/schema_fetch_test.go	154
metastore/validator_test.go	743
query/aql_compiler_test.go	3981
query/aql_context_test.go	15
query/aql_postprocessor_test.go	597
query/aql_processor_array_test.go	496
query/aql_processor_test.go	2079
query/ares_suite_test.go	13
query/common/aql_query_result_test.go	51
query/common/ares_suite_test.go	12
query/common/dim_util_test.go	34
query/common/dimval_test.go	178
query/common/hll_test.go	261
query/common/time_filter_test.go	163
query/device_allocator_test.go	41
query/device_manager_test.go	255
query/expr/ast_test.go	27
query/expr/parser_test.go	381
query/expr/scanner_test.go	177
query/expr/token_test.go	16
query/hll_test.go	236
query/sql/ares_suite_test.go	13
query/sql/sql_parser_test.go	544
query/stats_test.go	152
query/time_bucketizer_test.go	286
redolog/composite_redolog_manager_test.go	165
redolog/file_redolog_manager_test.go	374
redolog/kafka_redolog_manager_test.go	86
redolog/mocks/RedologManager.go	110
redolog/redolog_manager_master_test.go	134
redolog/redolog_suite_test.go	12
subscriber/common/consumer/consumer_suite_test.go	10
subscriber/common/consumer/kafka/kafka_suite_test.go	10
subscriber/common/consumer/kafka/kafka_test.go	140
subscriber/common/job/controller_test.go	335
subscriber/common/job/driver_test.go	211
subscriber/common/job/job_suite_test.go	10
subscriber/common/job/processor_test.go	17
subscriber/common/job/streaming_processor_test.go	311
subscriber/common/message/json_decoder_test.go	40
subscriber/common/message/message_decoder_test.go	62
subscriber/common/message/message_parser_test.go	69
subscriber/common/message/message_suite_test.go	10
subscriber/common/message/test_config/hp_config/schemas/hp-api-test_topic/test_topic.1.avsc	13
subscriber/common/rules/job_config_test.go	87
subscriber/common/rules/rules_suite_test.go	10
subscriber/common/rules/transformation_test.go	24
subscriber/common/sink/ares_database_test.go	75
subscriber/common/sink/kafka_test.go	163
subscriber/common/sink/sink_suite_test.go	10
subscriber/common/sink/sink_test.go	135
subscriber/common/tools/batcher_test.go	61
subscriber/common/tools/tools_suite_test.go	10
subscriber/common/tools/util_test.go	23
subscriber/config/config_suite_test.go	10
subscriber/config/service_config_test.go	91
subscriber/config/test.yaml	48
utils/ares_suite_test.go	12
utils/consistenthasing/consistenthasing_test.go	24
utils/env_test.go	32
utils/error_test.go	31
utils/hash_test.go	60
utils/hll_test.go	24
utils/http_test.go	58
utils/memory_test.go	62
utils/metrics_test.go	88
utils/mocks/ReadCloser.go	31
utils/mocks/WriteSyncCloser.go	41
utils/mocks/file_info.go	69
utils/mocks/file_system.go	119
utils/reflection_test.go	23
utils/serialization_test.go	235
utils/slices_test.go	21
utils/stream_serialization_test.go	240
utils/table_writer_test.go	79
utils/test_utils.go	18
utils/time_test.go	53
utils/uuid_test.go	23