Skip to content

Commit

Permalink
Update comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Dec 17, 2024
1 parent 1d5f545 commit 1bb69fa
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sources/mysql/streaming/offset.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func (p *Position) UpdatePosition(ts time.Time, evt *replication.BinlogEvent) er
p.Pos = evt.Header.LogPos
p.UnixTs = ts.Unix()

// If the event is a GTID event, let's set the GTID Set.
// If the event is a [*replication.GTIDEvent], then let's parse it and grab the next GTID set
if gtidEvent, ok := evt.Event.(*replication.GTIDEvent); ok {
set, err := gtidEvent.GTIDNext()
if err != nil {
Expand Down

0 comments on commit 1bb69fa

Please sign in to comment.