binlog

Jun 1, 2016

Changes in this version

type GoMySQLReader

+ LastAppliedRowsEventHint mysql.BinlogCoordinates

May 20, 2016

Changes in this version

type BinlogReader

+ GetCurrentBinlogCoordinates func() *mysql.BinlogCoordinates

+ Reconnect func() error

type GoMySQLReader

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

+ func (this *GoMySQLReader) Reconnect() error

May 16, 2016

Changes in this version

+ const DeleteDML

+ const ExpectEndLogPosState

+ const ExpectTokenState

+ const InsertDML

+ const InvalidState

+ const NotDML

+ const PositionalColumnAssignmentState

+ const SearchForStartPosOrStatementState

+ const UpdateDML

+ type BinlogCoordinates struct

+ LogFile string

+ LogPos int64

+ Type BinlogType

+ func ParseBinlogCoordinates(logFileLogPos string) (*BinlogCoordinates, error)

+ func (this *BinlogCoordinates) DisplayString() string

+ func (this *BinlogCoordinates) Equals(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) FileNumber() (int, int)

+ func (this *BinlogCoordinates) FileNumberDistance(other *BinlogCoordinates) int

+ func (this *BinlogCoordinates) FileSmallerThan(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) IsEmpty() bool

+ func (this *BinlogCoordinates) NextFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) PreviousFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) PreviousFileCoordinatesBy(offset int) (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) SmallerThan(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) SmallerThanOrEquals(other *BinlogCoordinates) bool

+ func (this BinlogCoordinates) String() string

+ 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 BinlogEntryState string

+ type BinlogReader interface

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

+ type BinlogType int

+ const BinaryLog

+ const RelayLog

+ type EventDML string

+ func ToEventDML(description string) EventDML

+ type GoMySQLReader struct

+ func NewGoMySQLReader(connectionConfig *mysql.ConnectionConfig) (binlogReader *GoMySQLReader, err error)

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

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

+ type MySQLBinlogReader struct

+ Basedir string

+ Datadir string

+ MySQLBinlogBinary string

+ func NewMySQLBinlogReader(basedir string, datadir string) (mySQLBinlogReader *MySQLBinlogReader)

+ func (this *MySQLBinlogReader) ReadEntries(logFile string, startPos uint64, stopPos uint64) (entries [](*BinlogEntry), err error)