path	# lines of code
modules/init.go	7
modules/checksum.go	19
modules/compress.go	215
tunnel/mock_reader.go	96
tunnel/direct_writer.go	42
tunnel/rpc_reader.go	32
tunnel/mock_writer.go	26
tunnel/kafka_writer.go	195
tunnel/file_reader.go	111
tunnel/kafka/sync_writer.go	55
tunnel/kafka/common.go	68
tunnel/kafka/reader.go	47
tunnel/tunnel.go	160
tunnel/rpc_writer.go	64
tunnel/kafka_reader.go	66
tunnel/file_writer.go	126
tunnel/tcp_reader.go	121
tunnel/tcp_writer.go	192
oplog/txn_buffer.go	273
oplog/cmd_oplog.go	54
oplog/oplog.go	332
oplog/txn_optime.go	70
oplog/txn_meta.go	82
oplog/hasher.go	130
oplog/changestram_event.go	135
quorum/quorum.go	175
tools/mongo_id.go	47
tools/data_generator.py	90
tools/mongodb-schema.py	117
common/debug.go	5
common/release.go	3
common/sentinel.go	100
common/journal.go	51
common/community_client.go	206
common/change_stream.go	160
common/fcv.go	46
common/common.go	172
common/define.go	53
common/http.go	14
common/mix.go	223
common/metric.go	295
common/diskQueue.go	20
common/session.go	24
common/db_opertion.go	300
common/speed.go	74
common/parse.go	31
scripts/comparison.py	173
scripts/comparison_3x.py	176
scripts/hypervisor.c	210
sharding/sharding_operation_test_bak.go	28
sharding/sharding_operation.go	172
collector/batcher.go	370
collector/filter/oplog_filter.go	176
collector/filter/doc_filter.go	89
collector/filter/orphan_filter.go	218
collector/checkpoint.go	138
collector/transform/transform.go	92
collector/persister.go	230
collector/configure/configure.go	112
collector/configure/check.go	34
collector/reader/event_reader.go	135
collector/reader/oplog_reader.go	204
collector/reader/reader.go	36
collector/ckpt/ckpt_manager.go	115
collector/ckpt/ckpt_operation.go	143
collector/coordinator/extra_job.go	102
collector/coordinator/replication.go	196
collector/coordinator/full.go	186
collector/coordinator/incr.go	64
collector/coordinator/utils.go	178
collector/syncer.go	514
collector/worker.go	190
collector/write_controller.go	80
collector/docsyncer/doc_reader.go	259
collector/docsyncer/doc_executor.go	205
collector/docsyncer/metric.go	29
collector/docsyncer/doc_syncer.go	483
unit_test_common/include.go	11
unit_test_common/common.go	34
executor/db_writer_command.go	169
executor/db_writer_single.go	228
executor/executor.go	359
executor/db_writer_bulk.go	219
executor/duplicate.go	15
executor/db_writer.go	199
executor/collision_matrix.go	283
executor/combiner.go	67
executor/operation.go	205
cmd/collector/sanitize.go	399
cmd/collector/collector.go	140
cmd/receiver/receiver.go	92
receiver/configure/configure.go	12
receiver/replayer.go	98