util

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
  • func NewConfig() *Config
  • func (c *Config) Parse(arguments []string) error
  • func (c *Config) String() string
• type DBConfig
  • func (c *DBConfig) String() string

Functions

func CheckSyncState

func CheckSyncState(sourceDB, targetDB *sql.DB, schema string) bool

CheckSyncState check if srouceDB and targetDB has the same table and data

func CloseDB

func CloseDB(db *sql.DB) error

CloseDB close the mysql fd

func CloseDBs

func CloseDBs(dbs []*sql.DB) error

CloseDBs close the mysql fd

func CreateDB

func CreateDB(cfg DBConfig) (*sql.DB, error)

CreateDB create a mysql fd

func CreateSinkDB

func CreateSinkDB() (db *sql.DB, err error)

CreateSinkDB return sink sql.DB for test

func CreateSourceDB

func CreateSourceDB() (db *sql.DB, err error)

CreateSourceDB return source sql.DB for test

func CreateSourceDBs

func CreateSourceDBs() (dbs []*sql.DB, err error)

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.

func NewConfig

func NewConfig() *Config

NewConfig creates a new config.

func (*Config) Parse

func (c *Config) Parse(arguments []string) error

Parse parses flag definitions from the argument list.

func (*Config) String

func (c *Config) String() string

type DBConfig

type DBConfig struct {
	Host string `toml:"host" json:"host"`

	User string `toml:"user" json:"user"`

	Password string `toml:"password" json:"password"`

	Name string `toml:"name" json:"name"`

	Port int `toml:"port" json:"port"`
}

DBConfig is the DB configuration.

func (*DBConfig) String

func (c *DBConfig) String() string