statistic

Documentation

Index

• func BinlogSlaveRegister()
• func DispatchStatisticCall(bs BaseStatistic, table *schema.Table, action string, rows [][]interface{})
• type BaseStatistic
• type LogPos
• type SyncEventHandler
  • func (h *SyncEventHandler) OnRow(e *canal.RowsEvent) error
  • func (h *SyncEventHandler) String() string

Functions

func BinlogSlaveRegister

func BinlogSlaveRegister()

func DispatchStatisticCall

func DispatchStatisticCall(bs BaseStatistic, table *schema.Table, action string, rows [][]interface{})

Types

type BaseStatistic

type BaseStatistic interface {
	ActionDispatch(table *schema.Table, action string, rows [][]interface{})
	ParseMainKeys(rows [][]interface{}) ([]string, []string)
	HandlerInsert(companyCodes []string, keys []string)
	HandlerUpdate(companyCodes []string, keys []string)
	HandlerDelete(companyCodes []string, keys []string)
}

type LogPos

type LogPos struct {
	File           string
	Position       uint32
	BinLogDoDB     string
	BinLogIgnoreDB string
}

type SyncEventHandler

type SyncEventHandler struct {
	canal.DummyEventHandler
}

func (*SyncEventHandler) OnRow

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

func (*SyncEventHandler) String

func (h *SyncEventHandler) String() string