handlers

Documentation

Index

• type DMLKey
• type DumpTask
• type VastbaseEventHandler
  • func (h *VastbaseEventHandler) Close()
  • func (h *VastbaseEventHandler) ConvertColType2ColumnType(colType int) (vbType string, err error)
  • func (h *VastbaseEventHandler) ConvertDataType2ColumnType(dataType parser.DataType) (vbType string, err error)
  • func (h *VastbaseEventHandler) ConvertSourceTable2TargetTable(source *schema.Table, target *dbvendor.Table) error
  • func (h *VastbaseEventHandler) Migrate() error
  • func (h *VastbaseEventHandler) OnDDL(header *replication.EventHeader, nextPos mysql.Position, ...) error
  • func (h *VastbaseEventHandler) OnGTID(header *replication.EventHeader, gtid mysql.GTIDSet) error
  • func (h *VastbaseEventHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, set mysql.GTIDSet, ...) error
  • func (h *VastbaseEventHandler) OnRotate(header *replication.EventHeader, rotateEvent *replication.RotateEvent) error
  • func (h *VastbaseEventHandler) OnRow(e *canal.RowsEvent) error
  • func (h *VastbaseEventHandler) OnTableChanged(header *replication.EventHeader, schema string, table string) error
  • func (h *VastbaseEventHandler) OnXID(header *replication.EventHeader, nextPos mysql.Position) error
  • func (h *VastbaseEventHandler) String() string

Types

type DMLKey

type DMLKey struct {
	Schema      string
	TablePrefix string
	TableName   string
}

type DumpTask

type DumpTask struct {
	Dml  dbvendor.DMLSchema
	Args []interface{}
}

type VastbaseEventHandler

type VastbaseEventHandler struct {
	// contains filtered or unexported fields
}

func (*VastbaseEventHandler) Close

func (h *VastbaseEventHandler) Close()

func (*VastbaseEventHandler) ConvertColType2ColumnType

func (h *VastbaseEventHandler) ConvertColType2ColumnType(colType int) (vbType string, err error)

func (*VastbaseEventHandler) ConvertDataType2ColumnType

func (h *VastbaseEventHandler) ConvertDataType2ColumnType(dataType parser.DataType) (vbType string, err error)

func (*VastbaseEventHandler) ConvertSourceTable2TargetTable

func (h *VastbaseEventHandler) ConvertSourceTable2TargetTable(source *schema.Table, target *dbvendor.Table) error

func (*VastbaseEventHandler) Migrate

func (h *VastbaseEventHandler) Migrate() error

func (*VastbaseEventHandler) OnDDL

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

func (*VastbaseEventHandler) OnGTID

func (h *VastbaseEventHandler) OnGTID(header *replication.EventHeader, gtid mysql.GTIDSet) error

func (*VastbaseEventHandler) OnPosSynced

func (h *VastbaseEventHandler) OnPosSynced(header *replication.EventHeader, pos mysql.Position, set mysql.GTIDSet, force bool) error

func (*VastbaseEventHandler) OnRotate

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

func (*VastbaseEventHandler) OnRow

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

func (*VastbaseEventHandler) OnTableChanged

func (h *VastbaseEventHandler) OnTableChanged(header *replication.EventHeader, schema string, table string) error

func (*VastbaseEventHandler) OnXID

func (h *VastbaseEventHandler) OnXID(header *replication.EventHeader, nextPos mysql.Position) error

func (*VastbaseEventHandler) String

func (h *VastbaseEventHandler) String() string