sync

Documentation

Index

• func CreateEngine(dataSourceName string) (*xorm.Engine, error)
• func GetCanalConfig(username string, password string, host string, port int, database string) *canal.Config
• func GetDeleteSql(schemaName string, tableName string, pkColumnNames []string, ...) (string, []interface{}, error)
• func GetInsertSql(schemaName string, tableName string, columnNames []string, ...) (string, []interface{}, error)
• func GetPKColumnNames(columnNames []string, PKColumns []int) []string
• func GetPKColumnValues(columnValues []interface{}, PKColumns []int) []interface{}
• func GetServerId(engin *xorm.Engine) (uint32, error)
• func GetServerUUID(engin *xorm.Engine) (string, error)
• func GetUpdateSql(schemaName string, tableName string, columnNames []string, ...) (string, []interface{}, error)
• func StartBinlogSync() error
• func StartCanal(cfg *canal.Config, username string, password string, host string, port int, ...) error
• type MyEventHandler
  • func GetMyEventHandler(username string, password string, host string, port int, database string) MyEventHandler
  • func (h *MyEventHandler) OnGTID(header *replication.EventHeader, gtid mysql.GTIDSet) error
  • func (h *MyEventHandler) OnRow(e *canal.RowsEvent) error
  • func (h *MyEventHandler) String() string

Functions

func CreateEngine

func CreateEngine(dataSourceName string) (*xorm.Engine, error)

func GetCanalConfig

func GetCanalConfig(username string, password string, host string, port int, database string) *canal.Config

func GetDeleteSql

func GetDeleteSql(schemaName string, tableName string, pkColumnNames []string, pkColumnValue []interface{}) (string, []interface{}, error)

func GetInsertSql

func GetInsertSql(schemaName string, tableName string, columnNames []string, columnValue []interface{}) (string, []interface{}, error)

func GetPKColumnNames

func GetPKColumnNames(columnNames []string, PKColumns []int) []string

func GetPKColumnValues

func GetPKColumnValues(columnValues []interface{}, PKColumns []int) []interface{}

func GetServerId

func GetServerId(engin *xorm.Engine) (uint32, error)

func GetServerUUID

func GetServerUUID(engin *xorm.Engine) (string, error)

func GetUpdateSql

func GetUpdateSql(schemaName string, tableName string, columnNames []string, newColumnVal []interface{}, pkColumnNames []string, pkColumnValue []interface{}) (string, []interface{}, error)

func StartBinlogSync

func StartBinlogSync() error

func StartCanal

func StartCanal(cfg *canal.Config, username string, password string, host string, port int, database string) error

Types

type MyEventHandler

type MyEventHandler struct {
	GTID string
	canal.DummyEventHandler
	// contains filtered or unexported fields
}

func GetMyEventHandler

func GetMyEventHandler(username string, password string, host string, port int, database string) MyEventHandler

func (*MyEventHandler) OnGTID

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

func (*MyEventHandler) OnRow

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

func (*MyEventHandler) String

func (h *MyEventHandler) String() string