mybinlog

type BinlogParser struct{}

type MyDumper struct {
	// mysqldump execution path, like mysqldump or /usr/bin/mysqldump, etc...
	ExecutionPath string

	Addr     string
	User     string
	Password string
	Protocol string

	// Will override Databases
	Tables  []string
	TableDB string

	Databases []string

	Where   string
	Charset string

	IgnoreTables map[string][]string

	ExtraOptions []string

	ErrOut io.Writer
	// contains filtered or unexported fields
}

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

type QueryRequest struct {
	DBServer   string
	Query      string
	Parameters []interface{}
	Pos        mysql.Position
}

type Rule struct {
	DB    string `toml:"db"`
	Table string `toml:"table"`

	ToDBServer string `toml:"to_dbserver"`
	ToDB       string `toml:"to_db"`

	RawKey string `toml:"keys"`

	PKColumnIds []int
	//build unique where condition base on PKColumns
	WherePK string

	// // MySQL table information
	TableInfo *schema.Table
}

type SimpleCanalDBConfig struct {
	Addr     string `toml:"address"`
	User     string `toml:"user"`
	Password string `toml:"password"`
}