udts

type CSVNode struct {

	// 如果 DupAction 为 ignore或者replace,  并且需要调整列的顺序的时候使用。 以逗号分割的列名字符串。
	Columns string

	// 当加载重复数据的时候所采取的行为，有效值有 ignore - 忽略， replace - 替换， update - 更新。 默认为replace
	DupAction string

	// 数据迁移的时候是否保留原有数据， 默认为 false 不保留
	KeepExistData bool

	// 如果 DupAction 为 update, 并且在插入数据的同时想给一些列赋予特定的值的时候使用。
	SetPolicy []PolicyData

	// 数据路径
	URL string

	// 如果 DupAction 为 update, 并且不想用CSV数据完整替换原有数据的时候使用。
	UpdatePolicy []PolicyData
}

type CheckResult struct {

	//
	Config CheckResultItem

	//
	Connection CheckResultItem

	//
	Privileges CheckResultItem
}

type CheckResultItem struct {

	//
	ErrMessage string

	// 状态
	State string
}

type CheckUDTSTaskParamSource struct {

	// 数据库类型
	DataType *string `required:"false"`

	// // 任务类型，值可以是 full, incremental, full+incremental, bidirectional
	Mode *string `required:"false"`

	//
	MySQLNode *CheckUDTSTaskParamSourceMySQLNode `required:"false"`

	// 源网络类型，可以是 public,user,dedicated_line
	NWType *string `required:"false"`
}

type CheckUDTSTaskParamSourceMySQLNode struct {

	// 数据库地域，比如 cn-bj2
	DataRegion *string `required:"false"`

	// 需要迁移的 DB 名称
	Database *string `required:"false"`

	// 源数据库地址， 比如 10.9.37.200
	Host *string `required:"false"`

	// 源 MySQL 密码
	Password *string `required:"false"`

	// 源 MySQL 端口，如 3306
	Port *int `required:"false"`

	//
	QueryData []CheckUDTSTaskParamSourceMySQLNodeQueryData `required:"false"`

	// 子网 ID
	SubnetId *string `required:"false"`

	//
	SyncData *CheckUDTSTaskParamSourceMySQLNodeSyncData `required:"false"`

	// 需要迁移的 table 名
	Table *string `required:"false"`

	// 源 MySQL 用户名，如 root
	User *string `required:"false"`

	// VPC
	VPCId *string `required:"false"`
}

type CheckUDTSTaskParamSourceMySQLNodeQueryData struct {

	// 数据集成时需要迁移的 DB 名
	DBName *string `required:"false"`

	// 数据集成时迁移后的 DB 名
	NewDBName *string `required:"false"`
}

type CheckUDTSTaskParamSourceMySQLNodeSyncData struct {

	// 增量时需要指定的 binlog gtid，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogGTID *string `required:"false"`

	// 增量时需要指定的 binlog name，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogName *string `required:"false"`

	// 增量时需要指定的 binlog pos，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogPos *int `required:"false"`

	// 增量时需要指定的 serverID，不能和现有的 slave 重复，预检查时会检查该值
	ServerID *int `required:"false"`
}

type CheckUDTSTaskParamTarget struct {

	// 目标数据库类型，比如 mysql
	DataType *string `required:"false"`

	//
	MySQLNode *CheckUDTSTaskParamTargetMySQLNode `required:"false"`

	// 目标 db 网络类型，目前进支持 user
	NWType *string `required:"false"`
}

type CheckUDTSTaskParamTargetMySQLNode struct {

	// 目标数据库地域，比如 cn-bj2
	DataRegion *string `required:"false"`

	// 目标数据库地址， 比如 10.9.37.212
	Host *string `required:"false"`

	// 目标数据库密码
	Password *string `required:"false"`

	// 目标数据库端口，比如 3306
	Port *int `required:"false"`

	// 目标数据库子网 ID ,比如 subnet-zl44fktq
	SubnetId *string `required:"false"`

	// 目标数据库用户名，比如 root
	User *string `required:"false"`

	// 目标数据库 VPC,比如 uvnet-1wz5rqte
	VPCId *string `required:"false"`
}

type CheckUDTSTaskRequest struct {
	request.CommonBase

	// 重试次数，最大为 5。 默认为0
	MaxRetryCount *string `required:"true"`

	// task 名称，长度不能超过 128
	Name *string `required:"true"`

	// 废弃
	Query *string `required:"false"`

	//
	Source []CheckUDTSTaskParamSource `required:"false"`

	//
	Target *CheckUDTSTaskParamTarget `required:"false"`

	// 任务类型，值为 transfer 或 integration， transfer 时任务为 数据迁移，integration 时任务为 数据集成。
	Type *string `required:"true"`
}

type CheckUDTSTaskResponse struct {
	response.CommonBase

	// 操作名称
	Action string

	// 检查结果
	Data CheckUDTSTaskResult

	// 返回消息
	Message string

	// 返回码
	RetCode string
}

type CheckUDTSTaskResult struct {

	//
	Source CheckResult

	//
	Target CheckResult
}

type ConfigData struct {

	// 最大失败重试次数
	MaxRetryCount int

	// 任务名称
	Name string

	// Source
	Source Source

	// Target
	Target Source

	// 任务 ID
	TaskId string

	// 任务类型, full全量, incremental增量，full+incremental全量+增量。
	Type string
}

type CreateUDTSTaskParamSource struct {

	// 源端限速值，单位为  MB/s
	BandwidthLimit *int `required:"false"`

	// 数据库类型，比如 mysql
	DataType *string `required:"true"`

	// 任务类型，值可以是 full, incremental, full+incremental, bidirectional
	Mode *string `required:"true"`

	//
	MySQLNode *CreateUDTSTaskParamSourceMySQLNode `required:"false"`

	// 源网络类型，可以是 public,user,dedicated_line
	NWType *string `required:"true"`
}

type CreateUDTSTaskParamSourceMySQLNode struct {

	// 数据库地域，比如 cn-bj2
	DataRegion *string `required:"false"`

	// 需要迁移的 DB 名称
	Database *string `required:"false"`

	// 重复数据处理规则，数据集成时该参数才有效，值为 ignore或者replace
	DupAction *string `required:"false"`

	// 源数据库地址
	Host *string `required:"false"`

	// 是否保留原有数据，只有数据集成时该参数才有效
	KeepExistData *bool `required:"false"`

	// 源数据库密码
	Password *string `required:"false"`

	// 源数据库端口
	Port *int `required:"false"`

	//
	QueryData []CreateUDTSTaskParamSourceMySQLNodeQueryData `required:"false"`

	// 源数据库子网 ID，当网络类型为 user 时需要填写
	SubnetId *string `required:"false"`

	//
	SyncData *CreateUDTSTaskParamSourceMySQLNodeSyncData `required:"false"`

	// 需要迁移的 table 名
	Table *string `required:"false"`

	// 源数据库用户名
	User *string `required:"false"`

	// 源数据库 VPC ID，当网络类型为 user 时需要填写
	VPCId *string `required:"false"`
}

type CreateUDTSTaskParamSourceMySQLNodeQueryData struct {

	// 数据集成时需要迁移的 DB 名
	DBName *string `required:"false"`

	// 数据集成时迁移后的 DB 名
	NewDBName *string `required:"false"`

	//
	TableData *CreateUDTSTaskParamSourceMySQLNodeQueryDataTableData `required:"false"`

	//
	TableMaps []CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMaps `required:"false"`
}

type CreateUDTSTaskParamSourceMySQLNodeQueryDataTableData struct {

	// 暂时未使用该字段
	ExcludeTables *bool `required:"false"`

	// 暂时未使用该字段
	TableNames *string `required:"false"`
}

type CreateUDTSTaskParamSourceMySQLNodeQueryDataTableMaps struct {

	// 数据集成时迁移后的 Table 名
	NewTableName *string `required:"false"`

	// 数据集成时需要迁移的 Table 名
	TableName *string `required:"false"`
}

type CreateUDTSTaskParamSourceMySQLNodeSyncData struct {

	// 增量时需要指定的 binlog gtid，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogGTID *string `required:"false"`

	// 增量时需要指定的 binlog name，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogName *string `required:"false"`

	// 增量时需要指定的 binlog pos，可以通过 show master status 获取，或者全量+增量任务会自动设置
	BinlogPos *int `required:"false"`

	// 增量时需要指定的 serverID，不能和现有的 slave 重复，预检查时会检查该值
	ServerID *int `required:"false"`
}

type CreateUDTSTaskParamTarget struct {

	// 目标端限速，单位为 MB/s
	BandwidthLimit *string `required:"false"`

	// 目标数据库类型，比如 mysql
	DataType *string `required:"true"`

	//
	Mode *string `required:"true"`

	//
	MySQLNode *CreateUDTSTaskParamTargetMySQLNode `required:"false"`

	// 目标 db 网络类型，目前仅支持 user
	NWType *string `required:"true"`
}

type CreateUDTSTaskParamTargetMySQLNode struct {

	// 目标数据库地域，比如 cn-bj2
	DataRegion *string `required:"false"`

	// 目标数据库地址， 比如 10.9.37.212
	Host *string `required:"false"`

	// 是否在全量过程中，临时禁用目标 MySQL 产生 binlog，在目标磁盘空间不足，或者需要获取更快的迁移速度时可以使用，该参数会破坏目标 MySQL 的高可用
	NoBinlog *bool `required:"false"`

	// 目标数据库密码
	Password *string `required:"false"`

	// 目标数据库端口，比如 3306
	Port *int `required:"false"`

	// 目标数据库子网 ID ,比如 subnet-zl44fktq
	SubnetId *string `required:"false"`

	// 目标数据库用户名，比如 root
	User *string `required:"false"`

	// 目标数据库 VPC,比如 uvnet-1wz5rqte
	VPCId *string `required:"false"`
}

type CreateUDTSTaskRequest struct {
	request.CommonBase

	// 暂时未使用该字段
	IsUnidirection *string `required:"false"`

	// 重试次数，最大为 5。 默认为0
	MaxRetryCount *string `required:"false"`

	// task 名称，长度不能超过 128
	Name *string `required:"true"`

	// 暂时未使用该字段
	Query *string `required:"false"`

	// 备注信息，长度不能大于 255
	Remark *string `required:"false"`

	//
	Source []CreateUDTSTaskParamSource `required:"false"`

	//
	Target *CreateUDTSTaskParamTarget `required:"false"`

	// 任务类型，transfer(数据传输) 或 integration(数据集成)
	Type *string `required:"true"`
}

type CreateUDTSTaskResponse struct {
	response.CommonBase

	//
	Data string

	// 返回消息
	Message string
}

type GetUDTSTaskConfigureRequest struct {
	request.CommonBase

	// 任务ID
	TaskId *string `required:"true"`
}

type GetUDTSTaskConfigureResponse struct {
	response.CommonBase

	// 详细配置信息
	Data ConfigData
}

type GetUDTSTaskHistoryRequest struct {
	request.CommonBase

	// 任务短 id
	TaskId *string `required:"true"`

	// 任务类型
	Type *string `required:"false"`
}

type GetUDTSTaskHistoryResponse struct {
	response.CommonBase

	// 历史状态数据
	Data []TaskHistoryItem
}

type GetUDTSTaskStatusRequest struct {
	request.CommonBase

	// 任务ID
	TaskId *string `required:"true"`

	// 任务类型，值为 transfer 或 integration， transfer 时任务为 数据迁移，integration 时任务为 数据集成。
	Type *string `required:"false"`
}

type GetUDTSTaskStatusResponse struct {
	response.CommonBase

	// StatusData
	Data StatusData

	// 返回信息
	Message string
}

type ListDataItem struct {

	// 创建时间
	CreateTime int

	// 当前失败重试次数
	CurRetryCount int

	// 最大失败重试次数
	MaxRetryCount int

	// 任务名称
	Name string

	// 全量迁移进度信息，增量迁移时为空
	Progress Progress

	// 任务状态
	Status string

	// 任务 ID
	TaskId string

	// 任务类型, full全量, incremental增量，full+incremental全量+增量。
	Type string
}

type ListUDTSTaskRequest struct {
	request.CommonBase

	// 请求数量，默认为 20
	Limit *string `required:"false"`

	// 偏移量，默认为 0
	Offset *string `required:"false"`

	// 任务类型
	Type *string `required:"false"`
}

type ListUDTSTaskResponse struct {
	response.CommonBase

	// ListDataItem 数组
	Data []ListDataItem

	// 返回信息
	Message string
}

type MySQLNode struct {

	// DB 名字， 长度不超过63个字符
	DataBase string

	// 地域，只有当 Host 为 UCloud 用户内网地址的时候需要提供
	DataRegion string

	// 数据库地址，长度不能超过 60个字符
	Host string

	// 数据库密码，长度不起来32个字符
	Password string

	// 数据库端口，端口范围 1-65535
	Port int

	// 子网 ID, 只有当 Host 为 UCloud 用户内网地址并且源目属于不同的地域的时候需要提供。
	SubnetId string

	// 增量同步数据
	SyncData SyncData

	// 表名， 长度不超过64个字符
	Table string

	// 数据库用户名，长度不能超过 32个字符
	User string

	// VPC 资源ID, 只有当 Host 为 UCloud 用户内网地址的时候需要提供。
	VPCId string
}

type PolicyData struct {

	// 列名
	Column string

	// 与上面类型对应的值， 比如“1”， “now()”, "Nash".
	Data string

	// 可选值为 CSVData, Function, Fixed
	Type string
}

type Progress struct {

	// 已迁移条目数
	CurCount int

	// 已耗时间（单位秒）
	CurDuration int

	// 完成进度
	Percentage float64

	// 总条目数
	TotalCount int

	// 估算总耗时间（单位秒）
	TotalDuration int
}

type RedisNode struct {

	// 数据库地址，只填写主(master)地址，集群模式下，多个地址用 ; 相连
	Address string

	// 数据库所在的地域。 只有当 Host 为 UCloud 用户内网地址的时候需要提供
	DataRegion string

	// Redis2Redis全量迁移是否使用rump，默认是dump-restore
	IsRump string

	// redis密码
	Password string

	// 子网 ID, 只有当 Host 为 UCloud 用户内网地址并且源目属于不同的地域的时候需要提供
	SubnetId string

	// redis模式
	Type string

	// 数据库所在机器的 VPCId, 只有内网跨域迁移的时候需要提供
	VPCId string
}

type Source struct {

	// 设置的最大的速率，单位MB/s，公网/专线(0, 56]，用户网(0, 1024]，不填/超过默认是峰值
	BandwidthLimit int

	// 当 DataType 为csv的时候使用。
	CSVNode CSVNode

	// 源数据类型可以是 mysql, tidb, csv, oracle, udb-mysql。目的数据类型可以是 mysql, tidb, udb-mysql, udw.
	DataType string

	// 是否为专线迁移
	IsDedicatedLine bool

	// 当 DataType 为mysql的时候使用。
	MySQLNode MySQLNode

	// 网络类型
	NWType string

	// 当 DataType 为 redis 的时候使用
	RedisNode RedisNode

	// 当 DataType 为tidb的时候使用。
	TiDBNode TiDBNode

	// 当 DataType 为 udw 的时候使用。
	UDWNode UDWNode

	// 当 DataType 为 ufile 的时候使用。
	UFileNode UFileNode
}

type StartUDTSTaskRequest struct {
	request.CommonBase

	// 任务ID
	TaskId *string `required:"true"`

	// 任务类型
	Type *string `required:"false"`
}

type StartUDTSTaskResponse struct {
	response.CommonBase

	// 返回信息
	Message string
}

type StatusData struct {

	// 当前失败重试次数
	CurRetryCount int

	// 当Status为Failed时, 显示失败原因
	FailedMessage string

	// 用户设置的最大失败重试次数
	MaxRetryCount int

	// Progress 全量迁移进度信息， 当类型为增量迁移时为空
	Progress Progress

	// 任务状态, 状态有 Created:已创建,Checking:检查中,Dumping:转储中,Loading:加载中,Syncing:同步中,Synced:已同步,Done:完成,Failed:失败,Stopping:停止中,Stopped:停止,RetryPending:重试等待中,Starting:启动中,FailedUnrecoverable:异常,StoppedUnrecoverable:异常,Success:成功,Started:已启动
	Status string

	// Binlog 信息
	Sync SyncData
}

type StopUDTSTaskRequest struct {
	request.CommonBase

	// 任务 ID
	TaskId *string `required:"true"`

	// 任务类型
	Type *string `required:"false"`
}

type StopUDTSTaskResponse struct {
	response.CommonBase

	// 返回信息
	Message string
}

type SyncData struct {

	// GTID
	BinlogGTID string

	// Binlog 文件名， 长度不超过128字符
	BinlogName string

	// Binlog Pos
	BinlogPos int

	// 分配给UDTS task的server ID, 必须在MySQL集群中唯一
	ServerId int
}

type TaskHistoryItem struct {

	// 任务 ID
	AntID string

	// 任务状态
	AntState string

	// 事件时间，值为 timestamp
	CreateTime int

	// 事件时间，为可读的日期时间
	CreateTimeH string
}

type TiDBNode struct {

	// DB 名字， 长度不超过63个字符
	DataBase string

	// 地域，只有当 Host 为 UCloud 用户内网地址的时候需要提供
	DataRegion string

	// 数据库地址，长度不能超过 60个字符
	Host string

	// 数据库密码，长度不起来32个字符
	Password string

	// 数据库端口，端口范围 1-65535
	Port int

	// 子网 ID, 只有当 Host 为 UCloud 用户内网地址并且源目属于不同的地域的时候需要提供。
	SubnetId string

	// 表名， 长度不超过64个字符
	Table string

	// 数据库用户名，长度不能超过 32个字符
	User string

	// VPC 资源ID, 只有当 Host 为 UCloud 用户内网地址的时候需要提供。
	VPCId string
}

type UDTSClient struct {
	*ucloud.Client
}

type UDWNode struct {

	// DB 名字， 长度不超过63个字符
	DataBase string

	// 地域
	DataRegion string

	// 数据库地址，长度不能超过 60个字符
	Host string

	// 数据库密码，长度不起来32个字符
	Password string

	// 数据库端口，端口范围 1-65535
	Port int

	// 子网 ID, 只有当源目属于不同的地域的时候需要提供。
	SubnetId string

	// 数据库用户名，长度不能超过 32个字符
	User string

	// VPC 资源ID, 只有当 Host 为 UCloud 用户内网地址的时候需要提供。
	VPCId string
}

type UFileNode struct {

	// Bucket 名称
	BucketName string

	// 地域
	DataRegion string

	// 用户自定义域名
	DomainName string

	// 前缀，utf-8编码，默认为空字符串
	Prefix string

	// 私钥
	PrivateKey string

	// 公钥
	PublicKey string
}