Method onMeetTarget

driver/mysql/binlog/binlog_reader.go:1830–1833

()

}

func (b *BinlogReader) onMeetTarget() {
	b.logger.Info("onMeetTarget", "target", b.targetGtid.String(), "current", b.CurrentGtidSet.String())
	_ = b.Close()
}

func (b *BinlogReader) handleRowsEvent(ev *replication.BinlogEvent, rowsEvent *replication.RowsEvent,
	entriesChannel chan<- *common.EntryContext) (err error) {