bulk_ddl

type Config struct {
	*flag.FlagSet `json:"-"`

	DBs []*DBConfig `toml:"dbs" json:"dbs"`

	ShardingDB    string `toml:"sharding-db" json:"sharding-db"`
	ShardingTable string `toml:"sharding-table" json:"sharding-table"`
	ShardingCount int    `toml:"sharding-count" json:"sharding-count"`

	DoDDL   string `toml:"do-ddl" json:"do-ddl"`
	Token   string `toml:"token" json:"token"`
	UndoDDL string `toml:"undo-ddl" json:"undo-ddl"`

	WorkerCount int `toml:"worker-count" json:"worker-count"`
	PoolSize    int `toml:"pool-size" json:"pool-size"`

	LogLevel string `toml:"log-level" json:"log-level"`

	ShardingDBs []string

	Wg     sync.WaitGroup
	WgStat sync.WaitGroup

	StatChan chan *Stat
	// contains filtered or unexported fields
}

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"`
}

type Job struct {
	Database string
	Table    string
}

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