Closed Lincoln23 closed 3 years ago
Using the WithRetries block we override the error from s.binlogStreamer.GetEvent(ctx) since the library returns a new error if s.err is set here. We want to return the first error raised and not ErrNeedSyncAgain
WithRetries
s.binlogStreamer.GetEvent(ctx)
s.err
ErrNeedSyncAgain
260
Using the
WithRetriesblock we override the error froms.binlogStreamer.GetEvent(ctx)since the library returns a new error ifs.erris set here. We want to return the first error raised and notErrNeedSyncAgain