增加注释

2 months ago · 1d3da02758
2 changed files with 1 additions and 0 deletions
--- 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()
--- a/xttbinlog/xttbinlog
+++ b/xttbinlog/xttbinlog