Documentation
¶
Index ¶
- func CheckSyncState(sourceDB, targetDB *sql.DB, schema string) bool
- func CloseDB(db *sql.DB) error
- func CloseDBs(dbs []*sql.DB) error
- func CreateDB(cfg DBConfig) (*sql.DB, error)
- func CreateSinkDB() (db *sql.DB, err error)
- func CreateSourceDB() (db *sql.DB, err error)
- func CreateSourceDBs() (dbs []*sql.DB, err error)
- type Config
- type DBConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckSyncState ¶
CheckSyncState check if srouceDB and targetDB has the same table and data
func CreateSinkDB ¶
CreateSinkDB return sink sql.DB for test
func CreateSourceDB ¶
CreateSourceDB return source sql.DB for test
func CreateSourceDBs ¶
CreateSourceDBs return source sql.DB for test we create two TiDB instance now in tests/run.sh, change it if needed
Types ¶
type Config ¶
type Config struct {
*flag.FlagSet `json:"-"`
LogLevel string `toml:"log-level" json:"log-level"`
WorkerCount int `toml:"worker-count" json:"worker-count"`
JobCount int `toml:"job-count" json:"job-count"`
Batch int `toml:"batch" json:"batch"`
SourceDBCfg DBConfig `toml:"source-db" json:"source-db"`
TargetDBCfg DBConfig `toml:"target-db" json:"target-db"`
// contains filtered or unexported fields
}
Config is the configuration.
Click to show internal directories.
Click to hide internal directories.