(gset gomysql.GTIDSet)
| 432 | } |
| 433 | |
| 434 | func (b *BinlogReader) handleEventGSet(gset gomysql.GTIDSet) { |
| 435 | if gset == nil { |
| 436 | return |
| 437 | } |
| 438 | |
| 439 | b.currentCoord.GtidSet = gset.String() |
| 440 | b.CurrentGtidSetMutex.Lock() |
| 441 | b.CurrentGtidSet = gset.(*gomysql.MysqlGTIDSet) |
| 442 | b.CurrentGtidSetMutex.Unlock() |
| 443 | if b.targetGtid != nil { |
| 444 | if b.CurrentGtidSetContains(b.targetGtid) { |
| 445 | b.onMeetTarget() |
| 446 | } |
| 447 | } |
| 448 | } |
| 449 | |
| 450 | func (b *BinlogReader) handleEvent(ev *replication.BinlogEvent, entriesChannel chan<- *common.EntryContext) error { |
| 451 | switch ev.Header.EventType { |
no test coverage detected