Versions in this module Expand all Collapse all v0 v0.1.0 Mar 16, 2023 Changes in this version + const DefaultCheckProgressInterval + const DefaultMysqlConnectionTimeout + const DefaultMysqlReadTimeout + const DefaultMysqlWriteTimeout + var SaramaVersion = sarama.V3_3_1_0 + func AbsInt(x int) int + func CloseMysqlConnection(db *sql.DB) error + func ConfigToStruct(source core.StringMap, target interface{}) error + func CreateMysqlConnection(host string, port uint16, user string, password string) (db1 *sql.DB, err error) + func FullTableName(db string, table string) string + func GenerateRandomServerID() uint32 + func GenerateSqlAndArgs(event *core.DBChangeEvent, keyColumns []string) (sqlString string, sqlArgs []interface{}) + func GetArrayFromConfig(config core.StringMap, path string) ([]interface{}, error) + func GetConfigArrayFromConfig(config core.StringMap, path string) ([]core.StringMap, error) + func GetConfigFromConfig(config core.StringMap, path string) (core.StringMap, error) + func GetFNV64aHash(text string) int + func GetIntFromConfig(config core.StringMap, path string) (int, error) + func GetStringFromConfig(config core.StringMap, path string) (string, error) + func GetTypeName(v interface{}) string + func IntervalCheckTicker(intervalMS int64) *time.Ticker + func IsMultipleStatements(sqlString string) bool + func IsNil(v interface{}) bool + func LoadColumnTypes(db string, table string, cols []string, conn *sql.DB) ([]*sql.ColumnType, error) + func LookupDNS(host string) ([]string, error) + func NewBatchDataPointers(columnTypes []*sql.ColumnType, size int) [][]interface + func ReadDataFromPointers(pointers []interface{}) []interface + func ScanRowsWithDataPointers(rows *sql.Rows, columnTypes []*sql.ColumnType, vPtrs []interface{}) ([]interface{}, error) + func ScanType(columnType *sql.ColumnType) reflect.Type + func SignalQuit() chan os.Signal + type DDLInfo struct + DB string + Node ast.StmtNode + Table string + func ExtractFromDDL(schema []byte, stmt ast.StmtNode) []*DDLInfo