event

Documentation

Index

• type BaseHandler
  • func (h *BaseHandler) OnDDL(header *replication.EventHeader, _ mysql.Position, _ *replication.QueryEvent) error
  • func (h *BaseHandler) OnGTID(header *replication.EventHeader, _ mysql.GTIDSet) error
  • func (h *BaseHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, _ mysql.GTIDSet, _ bool) error
  • func (h *BaseHandler) OnRotate(header *replication.EventHeader, rotateEvent *replication.RotateEvent) error
  • func (h *BaseHandler) OnTableChanged(header *replication.EventHeader, _ string, _ string) error
  • func (h *BaseHandler) OnXID(header *replication.EventHeader, _ mysql.Position) error
• type DiscardLogHandler
  • func (h *DiscardLogHandler) Close() error
  • func (h *DiscardLogHandler) Write(_ []byte) (n int, err error)
• type FlashbackHandler
  • func (h *FlashbackHandler) OnRow(e *canal.RowsEvent) error
• type ToSqlHandler
  • func (h *ToSqlHandler) OnDDL(header *replication.EventHeader, _ mysql.Position, ...) error
  • func (h *ToSqlHandler) OnRow(e *canal.RowsEvent) error

Types

type BaseHandler

type BaseHandler struct {
	canal.DummyEventHandler
	Config *config.BinlogConfig
	Done   chan interface{}
	Out    io.Writer
	// contains filtered or unexported fields
}

func (*BaseHandler) OnDDL

func (h *BaseHandler) OnDDL(header *replication.EventHeader, _ mysql.Position, _ *replication.QueryEvent) error

func (*BaseHandler) OnGTID

func (h *BaseHandler) OnGTID(header *replication.EventHeader, _ mysql.GTIDSet) error

func (*BaseHandler) OnPosSynced

func (h *BaseHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, _ mysql.GTIDSet, _ bool) error

func (*BaseHandler) OnRotate

func (h *BaseHandler) OnRotate(header *replication.EventHeader, rotateEvent *replication.RotateEvent) error

func (*BaseHandler) OnTableChanged

func (h *BaseHandler) OnTableChanged(header *replication.EventHeader, _ string, _ string) error

func (*BaseHandler) OnXID

func (h *BaseHandler) OnXID(header *replication.EventHeader, _ mysql.Position) error

type DiscardLogHandler

type DiscardLogHandler struct {
}

func (*DiscardLogHandler) Close

func (h *DiscardLogHandler) Close() error

func (*DiscardLogHandler) Write

func (h *DiscardLogHandler) Write(_ []byte) (n int, err error)

type FlashbackHandler

type FlashbackHandler struct {
	BaseHandler
}

FlashbackHandler 闪回sql

func (*FlashbackHandler) OnRow

func (h *FlashbackHandler) OnRow(e *canal.RowsEvent) error

type ToSqlHandler

type ToSqlHandler struct {
	BaseHandler
}

ToSqlHandler 生成sql

func (*ToSqlHandler) OnDDL

func (h *ToSqlHandler) OnDDL(header *replication.EventHeader, _ mysql.Position, queryEvent *replication.QueryEvent) error

func (*ToSqlHandler) OnRow

func (h *ToSqlHandler) OnRow(e *canal.RowsEvent) error