path	# lines of code
main.go	74
schema/alter_schema.go	41
schema/table_schema.go	89
schema/mysql_avro_schema_converter.go	100
log/rus.go	22
log/std.go	61
log/log.go	96
log/zap.go	40
throttle/throttle.go	46
streamer/streamer.go	229
streamer/buffer.go	205
streamer/snapshot.go	204
encoder/avro_schema.go	38
encoder/sql.go	242
encoder/z.go	12
encoder/msgpack.go	109
encoder/json.go	319
encoder/encoder.go	105
encoder/avro.go	372
snapshot/mysql.go	258
snapshot/snapshot.go	90
changelog/mysql.go	832
changelog/changelog.go	31
util/mysql.go	64
util/util.go	194
server/config.go	62
server/table_handler.go	230
server/cluster_handler.go	154
server/server.go	48
server/schema_handler.go	223
server/index.go	639
pipe/cache.go	52
pipe/hdfs.go	123
pipe/s3.go	203
pipe/sql.go	301
pipe/local.go	104
pipe/pipe.go	113
pipe/header.go	9
pipe/kafka.go	453
pipe/file.go	936
lock/lock.go	158
pool/pool.go	54
codecov.yaml	4
state/lock.go	130
state/manager.go	436
state/clusters.go	86
state/state.go	655
state/schema.go	81
metrics/process.go	34
metrics/counter.go	29
metrics/noop.go	40
metrics/tally.go	80
metrics/timer.go	20
metrics/metrics.go	182
types/format.go	17
types/input.go	4
types/types.go	18
types/const.go	7
types/schema.go	20
types/avro.go	30
shutdown/shutdown.go	62
db/gtid.go	34
db/builtin.go	60
db/resolver.go	67
db/open.go	81
config/config.go	325
config/topic.go	41
config/mysql.go	142
config/std.go	98
config/development.yaml	28
config/production.yaml	10
config/base.yaml	1