Versions in this module Expand all Collapse all v1 v1.0.3 Dec 26, 2018 v1.0.2 Oct 13, 2018 v1.0.1 Sep 17, 2018 v1.0.0 Sep 3, 2018 Changes in this version + type Binlog struct + func NewBinlog(log *xlog.Log, conf *config.BinlogConfig) *Binlog + func (bin *Binlog) Close() + func (bin *Binlog) CloseSQLWorker(sqlworker *SQLWorker) + func (bin *Binlog) Init() error + func (bin *Binlog) LastGTID() int64 + func (bin *Binlog) LogEvent(typ string, schema string, sql string) + func (bin *Binlog) NewSQLWorker(ts int64) (*SQLWorker, error) + func (bin *Binlog) RelayInfos() []RelayInfo + type Event struct + EndLogPos int64 + LogName string + Pos int64 + Query string + Schema string + Timestamp uint64 + Type string + Version uint16 + type IOWorker struct + func NewIOWorker(log *xlog.Log, conf *config.BinlogConfig) *IOWorker + func (io *IOWorker) Close() + func (io *IOWorker) GTID() int64 + func (io *IOWorker) Init() error + func (io *IOWorker) LogEvent(typ string, schema string, query string) + type Info struct + func NewInfo(log *xlog.Log, conf *config.BinlogConfig, fileName string) *Info + func (inf *Info) Close() + func (inf *Info) Init() error + func (inf *Info) ReadTs() (int64, error) + func (inf *Info) Sync(binlog string, ts int64) error + type RelayInfo struct + ID int64 + LastWriteGTID int64 + RelayGTID int64 + RelayPosition int64 + Relaybin string + SecondBehinds int64 + StartGTID int64 + type SQLWorker struct + func NewSQLWorker(log *xlog.Log, conf *config.BinlogConfig, ts int64) *SQLWorker + func (sql *SQLWorker) Init() error + func (sql *SQLWorker) NextEvent() (*Event, error) + func (sql *SQLWorker) RelayGTID() int64 + func (sql *SQLWorker) RelayName() string + func (sql *SQLWorker) RelayPosition() int64 + func (sql *SQLWorker) SeekGTID() int64
Go to main page