diff --git a/xttbinlog/syncer/data_syncer.go b/xttbinlog/syncer/data_syncer.go index a3b673c..a6480c0 100644 --- a/xttbinlog/syncer/data_syncer.go +++ b/xttbinlog/syncer/data_syncer.go @@ -91,6 +91,7 @@ func (ds *DataSyncer) Start() error { return ds.canal.RunFrom(startPos) } +// positionSaver 定期保存当前位置 func (ds *DataSyncer) positionSaver() { ticker := time.NewTicker(5 * time.Second) defer ticker.Stop() diff --git a/xttbinlog/xttbinlog b/xttbinlog/xttbinlog new file mode 100644 index 0000000..1ed5843 Binary files /dev/null and b/xttbinlog/xttbinlog differ