binlog

Apr 1, 2021

Changes in this version

+ type BinlogDMLEvent struct

+ DML EventDML

+ DatabaseName string

+ NewColumnValues *sql.ColumnValues

+ TableName string

+ WhereColumnValues *sql.ColumnValues

+ func NewBinlogDMLEvent(databaseName, tableName string, dml EventDML) *BinlogDMLEvent

+ func (this *BinlogDMLEvent) String() string

+ type BinlogEntry struct

+ Coordinates mysql.BinlogCoordinates

+ DmlEvent *BinlogDMLEvent

+ EndLogPos uint64

+ func NewBinlogEntry(logFile string, logPos uint64) *BinlogEntry

+ func NewBinlogEntryAt(coordinates mysql.BinlogCoordinates) *BinlogEntry

+ func (this *BinlogEntry) Duplicate() *BinlogEntry

+ func (this *BinlogEntry) String() string

+ type BinlogReader interface

+ Reconnect func() error

+ StreamEvents func(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error

+ type EventDML string

+ const DeleteDML

+ const InsertDML

+ const NotDML

+ const UpdateDML

+ func ToEventDML(description string) EventDML

+ type GoMySQLReader struct

+ LastAppliedRowsEventHint mysql.BinlogCoordinates

+ func NewGoMySQLReader(migrationContext *base.MigrationContext) (binlogReader *GoMySQLReader, err error)

+ func (this *GoMySQLReader) Close() error

+ func (this *GoMySQLReader) ConnectBinlogStreamer(coordinates mysql.BinlogCoordinates) (err error)

+ func (this *GoMySQLReader) GetCurrentBinlogCoordinates() *mysql.BinlogCoordinates

+ func (this *GoMySQLReader) StreamEvents(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error