Versions in this module Expand all Collapse all v1 v1.0.4 Jun 20, 2018 v1.0.3 May 5, 2018 Changes in this version + type Binlog struct + Config *app.MysqlConfig + EventIndex int64 + func NewBinlog(ctx *app.Context, opts ...BinlogOption) *Binlog + func (h *Binlog) Close() + func (h *Binlog) OnDDL(p mysql.Position, e *replication.QueryEvent) error + func (h *Binlog) OnGTID(g mysql.GTIDSet) error + func (h *Binlog) OnLeader(isLeader bool) + func (h *Binlog) OnPosSynced(p mysql.Position, b bool) error + func (h *Binlog) OnRotate(e *replication.RotateEvent) error + func (h *Binlog) OnRow(e *canal.RowsEvent) error + func (h *Binlog) OnTableChanged(schema string, table string) error + func (h *Binlog) OnXID(p mysql.Position) error + func (h *Binlog) RegisterService(s services.Service) + func (h *Binlog) SaveBinlogPosition(r []byte) + func (h *Binlog) Start() + func (h *Binlog) StartService() + func (h *Binlog) StopService(exit bool) + func (h *Binlog) String() string + type BinlogOption func(h *Binlog) + func OnEvent(f OnEventFunc) BinlogOption + func PosChange(f PosChangeFunc) BinlogOption + type OnEventFunc func(table string, data []byte) + type PosChangeFunc func(r []byte)
Go to main page