model

package
v0.1.60 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 19, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ActionBaseResp added in v0.1.58

type ActionBaseResp struct {

	// 错误码。
	ErrorCode string `json:"error_code"`

	// 错误描述。
	ErrorMsg string `json:"error_msg"`

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 操作结果。
	Status string `json:"status"`
}

ActionBaseResp 操作任务响应体。

func (ActionBaseResp) String added in v0.1.58

func (o ActionBaseResp) String() string

type ActionParams

type ActionParams struct {

	// 测试连接数据库信息。
	Endpoints *[]JobEndpointInfo `json:"endpoints,omitempty"`

	// 预检查模式。
	PrecheckMode *string `json:"precheck_mode,omitempty"`

	SkipPrecheckInfo *SkipPreCheckInfo `json:"skip_precheck_info,omitempty"`

	// 任务暂停模式。
	PauseMode *string `json:"pause_mode,omitempty"`

	// 任务定时启动时间。
	StartTime *string `json:"start_time,omitempty"`

	CompareTaskParam *CompareTaskParams `json:"compare_task_param,omitempty"`

	// 再编辑任务启动时取值true。
	IsSyncReEdit *bool `json:"is_sync_re_edit,omitempty"`

	// 强制结束时取值为true。
	ForceDelete *bool `json:"force_delete,omitempty"`
}

ActionParams 操作任务动作参数。

func (ActionParams) String

func (o ActionParams) String() string

type ActionReq

type ActionReq struct {

	// 任务ID (对比任务相关操作,多任务场景传父任务详情返回的master_job_id),批量操作时必填
	JobId *string `json:"job_id,omitempty"`

	// 操作任务动作名称。取值: - network:测试连接源库/目标库。 - precheck:执行预检查。 - start:启动任务。 - stop:暂停任务。 - restart:重试任务。 - reset:重置任务。 - terminate:结束任务。 - skip_precheck:跳过预检查。 - create_compare:创建对比任务。 - cancel_compare:取消对比任务。
	ActionName ActionReqActionName `json:"action_name"`

	ActionParams *ActionParams `json:"action_params,omitempty"`
}

ActionReq 测试连接、预检查、启动、暂停、续传、重置、对比、结束等操作任务请求体。

func (ActionReq) String

func (o ActionReq) String() string

type ActionReqActionName

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

func (ActionReqActionName) MarshalJSON

func (c ActionReqActionName) MarshalJSON() ([]byte, error)

func (*ActionReqActionName) UnmarshalJSON

func (c *ActionReqActionName) UnmarshalJSON(b []byte) error

func (ActionReqActionName) Value

func (c ActionReqActionName) Value() string

type ActionReqActionNameEnum

type ActionReqActionNameEnum struct {
	NETWORK        ActionReqActionName
	PRECHECK       ActionReqActionName
	START          ActionReqActionName
	STOP           ActionReqActionName
	RESTART        ActionReqActionName
	RESET          ActionReqActionName
	TERMINATE      ActionReqActionName
	SKIP_PRECHECK  ActionReqActionName
	CREATE_COMPARE ActionReqActionName
	CANCEL_COMPARE ActionReqActionName
}

func GetActionReqActionNameEnum

func GetActionReqActionNameEnum() ActionReqActionNameEnum

type AddColumnInfo added in v0.1.58

type AddColumnInfo struct {

	// 列类型
	ColumnType *string `json:"column_type,omitempty"`

	// 列名称
	ColumnName *string `json:"column_name,omitempty"`

	// 列填充值
	ColumnValue *string `json:"column_value,omitempty"`

	// 填充列的数据类型
	DataType *string `json:"data_type,omitempty"`
}

func (AddColumnInfo) String added in v0.1.58

func (o AddColumnInfo) String() string

type AlarmNotifyConfig

type AlarmNotifyConfig struct {

	// 异常告警是否通知用户。
	AlarmToUser bool `json:"alarm_to_user"`

	// SMN主题URN。
	TopicUrn *string `json:"topic_urn,omitempty"`

	// 时延阈值(单位为s)。取值: - 最小值:1 - 最大值:3600 - 缺省值:0 - 说明: 1.源数据库和目标数据库之间的同步有时会存在一个时间差,称为时延,单位为秒。 2.时延阈值设置是指时延超过一定的值并持续6分钟后,DRS可以发送通知给指定收件人。(初次进入增量迁移阶段,会有较多数据等待同步,存在较大的时延,属于正常情况,不在此功能的监控范围之内。) 3.只有全量+增量的任务支持此选项。
	DelayTime *int64 `json:"delay_time,omitempty"`

	// RPO时延阈值(单位为s)。取值: - 最小值:1 - 最大值:3600 - 缺省值:0 - 说明: RPO时延阈值设置是业务数据库与DRS实例间同步的时延超过一定的值并持续6分钟后,DRS可以发送通知给指定收件人。(初次进入增量灾备阶段,会有较多数据等待同步,存在较大的时延,属于正常情况,不在此功能的监控范围之内。)
	RpoDelay *int64 `json:"rpo_delay,omitempty"`

	// RTO时延阈值(s)。取值: - 最小值:1 - 最大值:3600 - 缺省值:0 - 说明: RTO时延阈值设置是DRS实例与灾备数据库间同步的时延超过一定的值并持续6分钟后,DRS可以发送通知给指定收件人。
	RtoDelay *int64 `json:"rto_delay,omitempty"`
}

AlarmNotifyConfig 异常通知信息设置信息体。配置该参数时,代表当任务状态异常时,系统将发送通知给指定的SMN Topic。

func (AlarmNotifyConfig) String

func (o AlarmNotifyConfig) String() string

type ApiHttpNullResp added in v0.1.58

type ApiHttpNullResp struct {
}

ApiHttpNullResp 空响应体。

func (ApiHttpNullResp) String added in v0.1.58

func (o ApiHttpNullResp) String() string

type AsyncActionBaseResp

type AsyncActionBaseResp struct {

	// 异步操作任务响应查询ID。
	QueryId string `json:"query_id"`
}

AsyncActionBaseResp 异步操作任务基础响应体。

func (AsyncActionBaseResp) String

func (o AsyncActionBaseResp) String() string

type AsyncActionResp

type AsyncActionResp struct {

	// 异步操作任务响应查询ID。
	QueryId string `json:"query_id"`

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`
}

AsyncActionResp 异步操作任务响应体。

func (AsyncActionResp) String

func (o AsyncActionResp) String() string

type AsyncCommitJobResp

type AsyncCommitJobResp struct {

	// 批量异步任务ID。
	AsyncJobId string `json:"async_job_id"`

	// 批量异步任务状态。
	Status string `json:"status"`

	// 提交指定ID批量异步任务结果信息。
	Msg string `json:"msg"`
}

AsyncCommitJobResp 提交异步任务响应体。

func (AsyncCommitJobResp) String

func (o AsyncCommitJobResp) String() string

type AsyncCreateJobReq

type AsyncCreateJobReq struct {
	BaseInfo *JobBaseInfo `json:"base_info"`

	// 创建任务数据库信息体。
	SourceEndpoint []JobEndpointInfo `json:"source_endpoint"`

	// 创建任务数据库信息体。
	TargetEndpoint []JobEndpointInfo `json:"target_endpoint"`

	AlarmNotify *AlarmNotifyConfig `json:"alarm_notify,omitempty"`

	// 限速信息体。 - 限速:自定义的最大迁移速度,迁移过程中的迁移速度将不会超过该速度。 - 不限速:对迁移速度不进行限制,通常会最大化使用源数据库的出口带宽。该流速模式同时会对源数据库造成读消耗,消耗取决于源数据库的出口带宽。比如:源数据库的出口带宽为100MB/s,假设高速模式使用了80%带宽,则迁移对源数据库将造成80MB/s的读操作IO消耗。
	SpeedLimit *[]SpeedLimitInfo `json:"speed_limit,omitempty"`

	UserMigration *UserMigrationInfo `json:"user_migration,omitempty"`

	PolicyConfig *PolicyConfig `json:"policy_config"`

	DbObject *DbObject `json:"db_object"`

	DbParam *DbParamInfo `json:"db_param,omitempty"`

	TuningParams *TuningParamInfo `json:"tuning_params,omitempty"`

	PeriodOrder *PeriodOrderInfo `json:"period_order,omitempty"`

	NodeInfo *JobNodeInfo `json:"node_info"`
}

AsyncCreateJobReq 异步创建任务请求体。

func (AsyncCreateJobReq) String

func (o AsyncCreateJobReq) String() string

type AsyncCreateJobResp

type AsyncCreateJobResp struct {

	// 批量异步创建的任务ID。
	AsyncJobId string `json:"async_job_id"`
}

AsyncCreateJobResp 创建异步任务响应体。

func (AsyncCreateJobResp) String

func (o AsyncCreateJobResp) String() string

type AsyncJobResp

type AsyncJobResp struct {

	// 批量异步创建的任务ID。
	AsyncJobId string `json:"async_job_id"`

	// 批量异步创建的任务状态。取值: - ASYNC_JOB_VALIDATING:批量异步任务参数校验中。 - ASYNC_JOB_VALIDATE_FAILED:批量异步任务参数校验失败。 - AUTO_PARAM_VALIDATE_SUCCESS:批量异步任务参数校验成功。 - COMMIT_SUCCESS:批量异步任务提交成功。
	Status AsyncJobRespStatus `json:"status"`

	// 批量异步创建的任务的租户名。
	DomainName string `json:"domain_name"`

	// 批量异步创建的任务的用户名。
	UserName string `json:"user_name"`

	// 批量异步创建的任务的创建时间。
	CreateTime string `json:"create_time"`
}

AsyncJobResp 批量异步创建任务响应体。

func (AsyncJobResp) String

func (o AsyncJobResp) String() string

type AsyncJobRespStatus

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

func (AsyncJobRespStatus) MarshalJSON

func (c AsyncJobRespStatus) MarshalJSON() ([]byte, error)

func (*AsyncJobRespStatus) UnmarshalJSON

func (c *AsyncJobRespStatus) UnmarshalJSON(b []byte) error

func (AsyncJobRespStatus) Value

func (c AsyncJobRespStatus) Value() string

type AsyncJobRespStatusEnum

type AsyncJobRespStatusEnum struct {
	ASYNC_JOB_VALIDATING        AsyncJobRespStatus
	ASYNC_JOB_VALIDATE_FAILED   AsyncJobRespStatus
	AUTO_PARAM_VALIDATE_SUCCESS AsyncJobRespStatus
	COMMIT_SUCCESS              AsyncJobRespStatus
}

func GetAsyncJobRespStatusEnum

func GetAsyncJobRespStatusEnum() AsyncJobRespStatusEnum

type AsyncUpdateJobResp

type AsyncUpdateJobResp struct {

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 操作结果。
	Status string `json:"status"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误描述。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

AsyncUpdateJobResp 更新异步任务响应体。

func (AsyncUpdateJobResp) String

func (o AsyncUpdateJobResp) String() string

type BaseEndpoint

type BaseEndpoint struct {

	// 数据库信息ID。
	Id *string `json:"id,omitempty"`

	// 数据库场景类型。取值: - oracle:云下自建Oracle数据库。 - ecs_oracle:华为云ECS自建Oracle数据库。 - cloud_gaussdbv5:华为云数据库GaussDB分布式。 - mysql:他云/本地自建MySQL数据库。 - ecs_mysql:华为云ECS自建MySQL数据库。 - cloud_mysql:华为云数据库RDS for MySQL。
	EndpointName BaseEndpointEndpointName `json:"endpoint_name"`

	// 数据库IP。 约束: - 数据库为自建MongoDB时,数据库IP与端口之间用“:”英文冒号拼接,多个值之间请用“,”英文逗号隔开,最多支持填写3个IP地址或域名。 - 数据库为DDS实例时,数据库IP与端口之间用“:”英文冒号拼接,多个IP端口之间请用“,”英文逗号分隔。 示例: - MySQL:192.168.0.10 - MongoDB:192.168.0.10:8080,192.168.0.11:8080,192.168.0.12:8080 - DDS:192.168.205.130:8635,192.168.250.64:8635
	Ip *string `json:"ip,omitempty"`

	// 数据库端口。  约束:输入范围为1-65535之间的整数。
	DbPort *string `json:"db_port,omitempty"`

	// 数据库用户名。
	DbUser string `json:"db_user"`

	// 数据库密码。
	DbPassword string `json:"db_password"`

	// 华为云数据库实例ID。
	InstanceId *string `json:"instance_id,omitempty"`

	// 华为云数据库实例名称。
	InstanceName *string `json:"instance_name,omitempty"`

	// 指定数据库名称。例如: - oracle:serviceName.orcl。
	DbName *string `json:"db_name,omitempty"`

	// 物理源库信息。
	SourceSharding *[]BaseEndpoint `json:"source_sharding,omitempty"`
}

BaseEndpoint 数据库基本信息体。

func (BaseEndpoint) String

func (o BaseEndpoint) String() string

type BaseEndpointConfig

type BaseEndpointConfig struct {

	// 目标实例是否设置为为只读。 - MySQL迁移和灾备,且job_direction为up时设置有效。(灾备场景下,单主灾备且本云为备为必填且为true,不填默认设置为true)。
	IsTargetReadonly *bool `json:"is_target_readonly,omitempty"`
}

BaseEndpointConfig 数据库基本设置信息体,当源库或者目标库在特定场景下需要额外设置时填写。例如: - 实时迁移入云场景:云数据库(RDS for MySQL)、云数据库 GaussDB(for MySQL) 主备版作为目标库(target_endpoint)时,需要设置“只读”或者“读写”(is_target_readonly)。 - 实时迁移入云场景:分布式数据库中间件DDM作为目标库,源库为MySQL分库分表时,需要设置“端数据库实例个数”。 - 实时迁移入云场景:MongoDB作为源库时,需要设置“源数据库实例类型”为非集群、集群或者集群(MongoDB 4.0+),并且实例类型为“集群”时,还需要设置“源端分片个数”(source_shard_num)。 - 实时灾备场景:单主灾备且本云为备时,云数据库(RDS for MySQL)、云数据库 GaussDB(for MySQL) 主备版、分布式数据库中间件DDM、文档数据库服务DDS等作为目标库(target_endpoint)时,需要设置“只读”或者“读写”(is_target_readonly)。 - 实时灾备场景:云数据库GaussDB(for Cassandra) 灾备时,需要设置“是否迁移TTL”,如果参数为true时,还需要设置TTL列名。

func (BaseEndpointConfig) String

func (o BaseEndpointConfig) String() string

type BaseEndpointEndpointName

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

func (BaseEndpointEndpointName) MarshalJSON

func (c BaseEndpointEndpointName) MarshalJSON() ([]byte, error)

func (*BaseEndpointEndpointName) UnmarshalJSON

func (c *BaseEndpointEndpointName) UnmarshalJSON(b []byte) error

func (BaseEndpointEndpointName) Value

func (c BaseEndpointEndpointName) Value() string

type BaseEndpointEndpointNameEnum

type BaseEndpointEndpointNameEnum struct {
	ORACLE          BaseEndpointEndpointName
	ECS_ORACLE      BaseEndpointEndpointName
	CLOUD_GAUSSDBV5 BaseEndpointEndpointName
	MYSQL           BaseEndpointEndpointName
	ECS_MYSQL       BaseEndpointEndpointName
	CLOUD_MYSQL     BaseEndpointEndpointName
}

func GetBaseEndpointEndpointNameEnum

func GetBaseEndpointEndpointNameEnum() BaseEndpointEndpointNameEnum

type BaseResp

type BaseResp struct {

	// 列表中的项目总数,与分页无关。
	TotalCount int32 `json:"total_count"`
}

BaseResp 基础响应体。

func (BaseResp) String

func (o BaseResp) String() string

type BatchAsyncCreateJobReq

type BatchAsyncCreateJobReq struct {

	// 异步创建任务请求体。
	Jobs []AsyncCreateJobReq `json:"jobs"`
}

BatchAsyncCreateJobReq 批量异步创建任务请求体。

func (BatchAsyncCreateJobReq) String

func (o BatchAsyncCreateJobReq) String() string

type BatchAsyncUpdateJobReq

type BatchAsyncUpdateJobReq struct {

	// 批量更新指定ID异步任务请求体。
	Jobs []UpdateJobReq `json:"jobs"`
}

BatchAsyncUpdateJobReq 批量更新指定ID异步任务请求体。

func (BatchAsyncUpdateJobReq) String

func (o BatchAsyncUpdateJobReq) String() string

type BatchCreateJobsAsyncRequest

type BatchCreateJobsAsyncRequest struct {

	// 请求语言类型。
	XLanguage *BatchCreateJobsAsyncRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchAsyncCreateJobReq `json:"body,omitempty"`
}

BatchCreateJobsAsyncRequest Request Object

func (BatchCreateJobsAsyncRequest) String

type BatchCreateJobsAsyncRequestXLanguage

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

func (BatchCreateJobsAsyncRequestXLanguage) MarshalJSON

func (c BatchCreateJobsAsyncRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchCreateJobsAsyncRequestXLanguage) UnmarshalJSON

func (c *BatchCreateJobsAsyncRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchCreateJobsAsyncRequestXLanguage) Value

type BatchCreateJobsAsyncRequestXLanguageEnum

type BatchCreateJobsAsyncRequestXLanguageEnum struct {
	EN_US BatchCreateJobsAsyncRequestXLanguage
	ZH_CN BatchCreateJobsAsyncRequestXLanguage
}

func GetBatchCreateJobsAsyncRequestXLanguageEnum

func GetBatchCreateJobsAsyncRequestXLanguageEnum() BatchCreateJobsAsyncRequestXLanguageEnum

type BatchCreateJobsAsyncResponse

type BatchCreateJobsAsyncResponse struct {
	Job            *AsyncCreateJobResp `json:"job,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

BatchCreateJobsAsyncResponse Response Object

func (BatchCreateJobsAsyncResponse) String

type BatchDealResourceTagReq added in v0.1.58

type BatchDealResourceTagReq struct {

	// 操作标识(区分大小写): - 创建时为“create” - 删除时为“delete”
	Action BatchDealResourceTagReqAction `json:"action"`

	// 标签列表。最多添加10个标签。
	Tags []BatchResourceTag `json:"tags"`
}

BatchDealResourceTagReq 批量添加或删除资源标签请求体。

func (BatchDealResourceTagReq) String added in v0.1.58

func (o BatchDealResourceTagReq) String() string

type BatchDealResourceTagReqAction added in v0.1.58

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

func (BatchDealResourceTagReqAction) MarshalJSON added in v0.1.58

func (c BatchDealResourceTagReqAction) MarshalJSON() ([]byte, error)

func (*BatchDealResourceTagReqAction) UnmarshalJSON added in v0.1.58

func (c *BatchDealResourceTagReqAction) UnmarshalJSON(b []byte) error

func (BatchDealResourceTagReqAction) Value added in v0.1.58

type BatchDealResourceTagReqActionEnum added in v0.1.58

type BatchDealResourceTagReqActionEnum struct {
	CREATE BatchDealResourceTagReqAction
	DELETE BatchDealResourceTagReqAction
}

func GetBatchDealResourceTagReqActionEnum added in v0.1.58

func GetBatchDealResourceTagReqActionEnum() BatchDealResourceTagReqActionEnum

type BatchDeleteJobReq

type BatchDeleteJobReq struct {

	// 批量删除任务请求体。
	Jobs []string `json:"jobs"`
}

BatchDeleteJobReq 批量删除任务请求体。

func (BatchDeleteJobReq) String

func (o BatchDeleteJobReq) String() string

type BatchDeleteJobsByIdRequest

type BatchDeleteJobsByIdRequest struct {

	// 请求语言类型。
	XLanguage *BatchDeleteJobsByIdRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchDeleteJobReq `json:"body,omitempty"`
}

BatchDeleteJobsByIdRequest Request Object

func (BatchDeleteJobsByIdRequest) String

type BatchDeleteJobsByIdRequestXLanguage

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

func (BatchDeleteJobsByIdRequestXLanguage) MarshalJSON

func (c BatchDeleteJobsByIdRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchDeleteJobsByIdRequestXLanguage) UnmarshalJSON

func (c *BatchDeleteJobsByIdRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchDeleteJobsByIdRequestXLanguage) Value

type BatchDeleteJobsByIdRequestXLanguageEnum

type BatchDeleteJobsByIdRequestXLanguageEnum struct {
	EN_US BatchDeleteJobsByIdRequestXLanguage
	ZH_CN BatchDeleteJobsByIdRequestXLanguage
}

func GetBatchDeleteJobsByIdRequestXLanguageEnum

func GetBatchDeleteJobsByIdRequestXLanguageEnum() BatchDeleteJobsByIdRequestXLanguageEnum

type BatchDeleteJobsByIdResponse

type BatchDeleteJobsByIdResponse struct {

	// 批量删除任务响应体。
	Jobs           *[]DeleteJobResp `json:"jobs,omitempty"`
	HttpStatusCode int              `json:"-"`
}

BatchDeleteJobsByIdResponse Response Object

func (BatchDeleteJobsByIdResponse) String

type BatchExecuteJobActionsRequest

type BatchExecuteJobActionsRequest struct {

	// 请求语言类型。
	XLanguage *BatchExecuteJobActionsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchJobActionReq `json:"body,omitempty"`
}

BatchExecuteJobActionsRequest Request Object

func (BatchExecuteJobActionsRequest) String

type BatchExecuteJobActionsRequestXLanguage

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

func (BatchExecuteJobActionsRequestXLanguage) MarshalJSON

func (c BatchExecuteJobActionsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchExecuteJobActionsRequestXLanguage) UnmarshalJSON

func (c *BatchExecuteJobActionsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchExecuteJobActionsRequestXLanguage) Value

type BatchExecuteJobActionsRequestXLanguageEnum

type BatchExecuteJobActionsRequestXLanguageEnum struct {
	EN_US BatchExecuteJobActionsRequestXLanguage
	ZH_CN BatchExecuteJobActionsRequestXLanguage
}

func GetBatchExecuteJobActionsRequestXLanguageEnum

func GetBatchExecuteJobActionsRequestXLanguageEnum() BatchExecuteJobActionsRequestXLanguageEnum

type BatchExecuteJobActionsResponse

type BatchExecuteJobActionsResponse struct {

	// 批量异步操作任务响应体。
	Jobs           *[]AsyncActionResp `json:"jobs,omitempty"`
	HttpStatusCode int                `json:"-"`
}

BatchExecuteJobActionsResponse Response Object

func (BatchExecuteJobActionsResponse) String

type BatchJobActionReq

type BatchJobActionReq struct {

	// 批量操作任务请求体。
	Jobs []ActionReq `json:"jobs"`
}

BatchJobActionReq 批量操作任务请求体,支持测试连接、预检查、启动、暂停、续传、重置、对比、结束等操作。

func (BatchJobActionReq) String

func (o BatchJobActionReq) String() string

type BatchResourceTag added in v0.1.58

type BatchResourceTag struct {

	// 标签键。 - 长度为1-128个unicode字符。 - 可以包含任何语种字母、数字、空格和_.:=+-@,但首尾不能含有空格,不能以_sys_开头。
	Key string `json:"key"`

	// 标签值,删除标签时非必填。 - 最大长度255个unicode字符。 - 可以包含任何语种字母、数字、空格和_.:=+-@。
	Value *string `json:"value,omitempty"`
}

BatchResourceTag 标签信息体

func (BatchResourceTag) String added in v0.1.58

func (o BatchResourceTag) String() string

type BatchStopJobActionReq added in v0.1.58

type BatchStopJobActionReq struct {

	// 批量结束任务请求体。
	Jobs []StopJobActionInfo `json:"jobs"`
}

BatchStopJobActionReq 批量结束任务请求体。

func (BatchStopJobActionReq) String added in v0.1.58

func (o BatchStopJobActionReq) String() string

type BatchStopJobsActionRequest added in v0.1.58

type BatchStopJobsActionRequest struct {

	// 请求语言类型。
	XLanguage *BatchStopJobsActionRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchStopJobActionReq `json:"body,omitempty"`
}

BatchStopJobsActionRequest Request Object

func (BatchStopJobsActionRequest) String added in v0.1.58

type BatchStopJobsActionRequestXLanguage added in v0.1.58

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

func (BatchStopJobsActionRequestXLanguage) MarshalJSON added in v0.1.58

func (c BatchStopJobsActionRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchStopJobsActionRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *BatchStopJobsActionRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchStopJobsActionRequestXLanguage) Value added in v0.1.58

type BatchStopJobsActionRequestXLanguageEnum added in v0.1.58

type BatchStopJobsActionRequestXLanguageEnum struct {
	EN_US BatchStopJobsActionRequestXLanguage
	ZH_CN BatchStopJobsActionRequestXLanguage
}

func GetBatchStopJobsActionRequestXLanguageEnum added in v0.1.58

func GetBatchStopJobsActionRequestXLanguageEnum() BatchStopJobsActionRequestXLanguageEnum

type BatchStopJobsActionResponse added in v0.1.58

type BatchStopJobsActionResponse struct {

	// 批量操作任务响应体。
	Jobs           *[]ActionBaseResp `json:"jobs,omitempty"`
	HttpStatusCode int               `json:"-"`
}

BatchStopJobsActionResponse Response Object

func (BatchStopJobsActionResponse) String added in v0.1.58

type BatchTagActionRequest added in v0.1.58

type BatchTagActionRequest struct {

	// 资源类型。 - migration:实时迁移 - sync:实时同步 - cloudDataGuard:实时灾备 - subscription:数据订阅 - backupMigration:备份迁移 - replay:仿真回放
	ResourceType string `json:"resource_type"`

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *BatchTagActionRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchDealResourceTagReq `json:"body,omitempty"`
}

BatchTagActionRequest Request Object

func (BatchTagActionRequest) String added in v0.1.58

func (o BatchTagActionRequest) String() string

type BatchTagActionRequestXLanguage added in v0.1.58

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

func (BatchTagActionRequestXLanguage) MarshalJSON added in v0.1.58

func (c BatchTagActionRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchTagActionRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *BatchTagActionRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchTagActionRequestXLanguage) Value added in v0.1.58

type BatchTagActionRequestXLanguageEnum added in v0.1.58

type BatchTagActionRequestXLanguageEnum struct {
	EN_US BatchTagActionRequestXLanguage
	ZH_CN BatchTagActionRequestXLanguage
}

func GetBatchTagActionRequestXLanguageEnum added in v0.1.58

func GetBatchTagActionRequestXLanguageEnum() BatchTagActionRequestXLanguageEnum

type BatchTagActionResponse added in v0.1.58

type BatchTagActionResponse struct {
	HttpStatusCode int `json:"-"`
}

BatchTagActionResponse Response Object

func (BatchTagActionResponse) String added in v0.1.58

func (o BatchTagActionResponse) String() string

type CheckDataFilterRequest added in v0.1.58

type CheckDataFilterRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *CheckDataFilterRequestXLanguage `json:"X-Language,omitempty"`

	Body *DataProcessReq `json:"body,omitempty"`
}

CheckDataFilterRequest Request Object

func (CheckDataFilterRequest) String added in v0.1.58

func (o CheckDataFilterRequest) String() string

type CheckDataFilterRequestXLanguage added in v0.1.58

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

func (CheckDataFilterRequestXLanguage) MarshalJSON added in v0.1.58

func (c CheckDataFilterRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CheckDataFilterRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *CheckDataFilterRequestXLanguage) UnmarshalJSON(b []byte) error

func (CheckDataFilterRequestXLanguage) Value added in v0.1.58

type CheckDataFilterRequestXLanguageEnum added in v0.1.58

type CheckDataFilterRequestXLanguageEnum struct {
	EN_US CheckDataFilterRequestXLanguage
	ZH_CN CheckDataFilterRequestXLanguage
}

func GetCheckDataFilterRequestXLanguageEnum added in v0.1.58

func GetCheckDataFilterRequestXLanguageEnum() CheckDataFilterRequestXLanguageEnum

type CheckDataFilterResponse added in v0.1.58

type CheckDataFilterResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *CheckDataFilterResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                            `json:"-"`
}

CheckDataFilterResponse Response Object

func (CheckDataFilterResponse) String added in v0.1.58

func (o CheckDataFilterResponse) String() string

type CheckDataFilterResponseStatus added in v0.1.58

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

func (CheckDataFilterResponseStatus) MarshalJSON added in v0.1.58

func (c CheckDataFilterResponseStatus) MarshalJSON() ([]byte, error)

func (*CheckDataFilterResponseStatus) UnmarshalJSON added in v0.1.58

func (c *CheckDataFilterResponseStatus) UnmarshalJSON(b []byte) error

func (CheckDataFilterResponseStatus) Value added in v0.1.58

type CheckDataFilterResponseStatusEnum added in v0.1.58

type CheckDataFilterResponseStatusEnum struct {
	PENDING CheckDataFilterResponseStatus
	FAILED  CheckDataFilterResponseStatus
	SUCCESS CheckDataFilterResponseStatus
}

func GetCheckDataFilterResponseStatusEnum added in v0.1.58

func GetCheckDataFilterResponseStatusEnum() CheckDataFilterResponseStatusEnum

type CheckJobNameReq added in v0.1.49

type CheckJobNameReq struct {

	// - 迁移、同步、灾备、订阅任务名称,名称在4位到50位之间,必须以字母开头,可以包含字母、数字、中划线或下划线,不能包含其他特殊字符,任务名称不能重复。 - 备份迁移任务名称,名称在4位到80位之间,必须以字母开头,可以包含字母、数字、中划线或下划线,不能包含其他特殊字符,任务名称不能重复。
	Name string `json:"name"`

	// 任务类型。 - trans - subscription - offline
	Type CheckJobNameReqType `json:"type"`
}

CheckJobNameReq 校验任务名称请求体。

func (CheckJobNameReq) String added in v0.1.49

func (o CheckJobNameReq) String() string

type CheckJobNameReqType added in v0.1.49

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

func (CheckJobNameReqType) MarshalJSON added in v0.1.49

func (c CheckJobNameReqType) MarshalJSON() ([]byte, error)

func (*CheckJobNameReqType) UnmarshalJSON added in v0.1.49

func (c *CheckJobNameReqType) UnmarshalJSON(b []byte) error

func (CheckJobNameReqType) Value added in v0.1.49

func (c CheckJobNameReqType) Value() string

type CheckJobNameReqTypeEnum added in v0.1.49

type CheckJobNameReqTypeEnum struct {
	TRANS        CheckJobNameReqType
	SUBSCRIPTION CheckJobNameReqType
	OFFLINE      CheckJobNameReqType
}

func GetCheckJobNameReqTypeEnum added in v0.1.49

func GetCheckJobNameReqTypeEnum() CheckJobNameReqTypeEnum

type ChildrenJobListResp

type ChildrenJobListResp struct {

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 任务状态。取值: - CREATING:创建中。 - CREATE_FAILED:创建失败。 - CONFIGURATION:配置中。 - STARTJOBING:启动中。 - WAITING_FOR_START:等待启动中。 - START_JOB_FAILED:任务启动失败。 - FULL_TRANSFER_STARTED:全量迁移中 灾备场景为初始化。 - FULL_TRANSFER_FAILED:全量迁移失败 灾备场景为初始化失败。 - FULL_TRANSFER_COMPLETE:全量迁移完成 灾备场景为初始化完成。 - INCRE_TRANSFER_STARTED:增量迁移中 灾备场景为灾备中。 - INCRE_TRANSFER_FAILED:增量迁移失败 灾备场景为灾备异常。 - RELEASE_RESOURCE_STARTED:结束任务中。 - RELEASE_RESOURCE_FAILED:结束任务失败。 - RELEASE_RESOURCE_COMPLETE:已结束。 - CHANGE_JOB_STARTED:任务变更中。 - CHANGE_JOB_FAILED:任务变更失败。 - CHILD_TRANSFER_STARTING:子任务启动中。 - CHILD_TRANSFER_STARTED:子任务迁移中。 - CHILD_TRANSFER_COMPLETE:子任务迁移完成。 - CHILD_TRANSFER_FAILED:子任务迁移失败。 - RELEASE_CHILD_TRANSFER_STARTED:子任务结束中。 - RELEASE_CHILD_TRANSFER_COMPLETE:子任务已结束。
	Status ChildrenJobListRespStatus `json:"status"`

	// 任务描述。
	Description string `json:"description"`

	// 任务创建时间。
	CreateTime string `json:"create_time"`

	// 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。
	EngineType ChildrenJobListRespEngineType `json:"engine_type"`

	// 网络类型。取值: - eip:公网网络。 - vpc:VPC网络,灾备场景不支持选择VPC网络。 - vpn:VPN、专线网络。
	NetType ChildrenJobListRespNetType `json:"net_type"`

	// 计费模式。取值: - period:包周期。 - on_demand:按需。
	ChargingMode ChildrenJobListRespChargingMode `json:"charging_mode"`

	// 是否计费。
	BillingTag bool `json:"billing_tag"`

	// 任务方向。取值: - up:入云 ,灾备场景时对应本云为备。 - down:出云,灾备场景时对应本云为主。 - non-dbs:自建。
	JobDirection ChildrenJobListRespJobDirection `json:"job_direction"`

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType ChildrenJobListRespJobType `json:"job_type"`

	// 任务模式。取值: - FULL_TRANS :全量。 - FULL_INCR_TRANS:全量+增量。 - INCR_TRANS:增量。
	TaskType ChildrenJobListRespTaskType `json:"task_type"`

	// 企业项目ID。
	EnterpriseProjectId string `json:"enterprise_project_id"`

	// 任务模式。取值: - single:单任务。 - sync_child:同步子任务。 - multi_to_single:多对一任务。
	JobMode ChildrenJobListRespJobMode `json:"job_mode"`

	// 任务角色。取值: - parent:父任务。 - child:子任务。 - master:主任务。 - slave:备任务。
	JobModeRole ChildrenJobListRespJobModeRole `json:"job_mode_role"`

	// 是否跨AZ任务。
	IsMultiAz bool `json:"is_multi_az"`

	// 任务节点角色。
	NodeRole string `json:"node_role"`

	// 是否新框架。
	NodeNewFramework bool `json:"node_new_framework"`

	JobAction *JobActions `json:"job_action"`
}

ChildrenJobListResp 子任务列表响应体。

func (ChildrenJobListResp) String

func (o ChildrenJobListResp) String() string

type ChildrenJobListRespChargingMode

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

func (ChildrenJobListRespChargingMode) MarshalJSON

func (c ChildrenJobListRespChargingMode) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespChargingMode) UnmarshalJSON

func (c *ChildrenJobListRespChargingMode) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespChargingMode) Value

type ChildrenJobListRespChargingModeEnum

type ChildrenJobListRespChargingModeEnum struct {
	PERIOD    ChildrenJobListRespChargingMode
	ON_DEMAND ChildrenJobListRespChargingMode
}

func GetChildrenJobListRespChargingModeEnum

func GetChildrenJobListRespChargingModeEnum() ChildrenJobListRespChargingModeEnum

type ChildrenJobListRespEngineType

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

func (ChildrenJobListRespEngineType) MarshalJSON

func (c ChildrenJobListRespEngineType) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespEngineType) UnmarshalJSON

func (c *ChildrenJobListRespEngineType) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespEngineType) Value

type ChildrenJobListRespEngineTypeEnum

type ChildrenJobListRespEngineTypeEnum struct {
	ORACLE_TO_GAUSSDBV5 ChildrenJobListRespEngineType
}

func GetChildrenJobListRespEngineTypeEnum

func GetChildrenJobListRespEngineTypeEnum() ChildrenJobListRespEngineTypeEnum

type ChildrenJobListRespJobDirection

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

func (ChildrenJobListRespJobDirection) MarshalJSON

func (c ChildrenJobListRespJobDirection) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespJobDirection) UnmarshalJSON

func (c *ChildrenJobListRespJobDirection) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespJobDirection) Value

type ChildrenJobListRespJobMode

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

func (ChildrenJobListRespJobMode) MarshalJSON

func (c ChildrenJobListRespJobMode) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespJobMode) UnmarshalJSON

func (c *ChildrenJobListRespJobMode) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespJobMode) Value

type ChildrenJobListRespJobModeEnum

type ChildrenJobListRespJobModeEnum struct {
	SINGLE          ChildrenJobListRespJobMode
	SYNC_CHILD      ChildrenJobListRespJobMode
	MULTI_TO_SINGLE ChildrenJobListRespJobMode
}

func GetChildrenJobListRespJobModeEnum

func GetChildrenJobListRespJobModeEnum() ChildrenJobListRespJobModeEnum

type ChildrenJobListRespJobModeRole

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

func (ChildrenJobListRespJobModeRole) MarshalJSON

func (c ChildrenJobListRespJobModeRole) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespJobModeRole) UnmarshalJSON

func (c *ChildrenJobListRespJobModeRole) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespJobModeRole) Value

type ChildrenJobListRespJobType

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

func (ChildrenJobListRespJobType) MarshalJSON

func (c ChildrenJobListRespJobType) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespJobType) UnmarshalJSON

func (c *ChildrenJobListRespJobType) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespJobType) Value

type ChildrenJobListRespJobTypeEnum

type ChildrenJobListRespJobTypeEnum struct {
	MIGRATION        ChildrenJobListRespJobType
	SYNC             ChildrenJobListRespJobType
	CLOUD_DATA_GUARD ChildrenJobListRespJobType
}

func GetChildrenJobListRespJobTypeEnum

func GetChildrenJobListRespJobTypeEnum() ChildrenJobListRespJobTypeEnum

type ChildrenJobListRespNetType

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

func (ChildrenJobListRespNetType) MarshalJSON

func (c ChildrenJobListRespNetType) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespNetType) UnmarshalJSON

func (c *ChildrenJobListRespNetType) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespNetType) Value

type ChildrenJobListRespNetTypeEnum

type ChildrenJobListRespNetTypeEnum struct {
	EIP ChildrenJobListRespNetType
	VPC ChildrenJobListRespNetType
	VPN ChildrenJobListRespNetType
}

func GetChildrenJobListRespNetTypeEnum

func GetChildrenJobListRespNetTypeEnum() ChildrenJobListRespNetTypeEnum

type ChildrenJobListRespStatus

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

func (ChildrenJobListRespStatus) MarshalJSON

func (c ChildrenJobListRespStatus) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespStatus) UnmarshalJSON

func (c *ChildrenJobListRespStatus) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespStatus) Value

type ChildrenJobListRespStatusEnum

type ChildrenJobListRespStatusEnum struct {
	CREATING                        ChildrenJobListRespStatus
	CREATE_FAILED                   ChildrenJobListRespStatus
	CONFIGURATION                   ChildrenJobListRespStatus
	STARTJOBING                     ChildrenJobListRespStatus
	WAITING_FOR_START               ChildrenJobListRespStatus
	START_JOB_FAILED                ChildrenJobListRespStatus
	FULL_TRANSFER_STARTED           ChildrenJobListRespStatus
	FULL_TRANSFER_FAILED            ChildrenJobListRespStatus
	FULL_TRANSFER_COMPLETE          ChildrenJobListRespStatus
	INCRE_TRANSFER_STARTED          ChildrenJobListRespStatus
	INCRE_TRANSFER_FAILED           ChildrenJobListRespStatus
	RELEASE_RESOURCE_STARTED        ChildrenJobListRespStatus
	RELEASE_RESOURCE_FAILED         ChildrenJobListRespStatus
	RELEASE_RESOURCE_COMPLETE       ChildrenJobListRespStatus
	CHANGE_JOB_STARTED              ChildrenJobListRespStatus
	CHANGE_JOB_FAILED               ChildrenJobListRespStatus
	CHILD_TRANSFER_STARTING         ChildrenJobListRespStatus
	CHILD_TRANSFER_STARTED          ChildrenJobListRespStatus
	CHILD_TRANSFER_COMPLETE         ChildrenJobListRespStatus
	CHILD_TRANSFER_FAILED           ChildrenJobListRespStatus
	RELEASE_CHILD_TRANSFER_STARTED  ChildrenJobListRespStatus
	RELEASE_CHILD_TRANSFER_COMPLETE ChildrenJobListRespStatus
}

func GetChildrenJobListRespStatusEnum

func GetChildrenJobListRespStatusEnum() ChildrenJobListRespStatusEnum

type ChildrenJobListRespTaskType

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

func (ChildrenJobListRespTaskType) MarshalJSON

func (c ChildrenJobListRespTaskType) MarshalJSON() ([]byte, error)

func (*ChildrenJobListRespTaskType) UnmarshalJSON

func (c *ChildrenJobListRespTaskType) UnmarshalJSON(b []byte) error

func (ChildrenJobListRespTaskType) Value

type ChildrenJobListRespTaskTypeEnum

type ChildrenJobListRespTaskTypeEnum struct {
	FULL_TRANS      ChildrenJobListRespTaskType
	FULL_INCR_TRANS ChildrenJobListRespTaskType
	INCR_TRANS      ChildrenJobListRespTaskType
}

func GetChildrenJobListRespTaskTypeEnum

func GetChildrenJobListRespTaskTypeEnum() ChildrenJobListRespTaskTypeEnum

type CloneJobReq added in v0.1.49

type CloneJobReq struct {

	// 被克隆任务ID。
	JobId string `json:"job_id"`

	// 克隆任务名称。名称在4位到50位之间,必须以字母开头,可以包含字母、数字、中划线或下划线,不能包含其他特殊字符,任务名称不能重复。
	Name string `json:"name"`

	// 任务版本号,新UX任务为2.0。默认为空,即克隆老任务。
	TaskVersion *CloneJobReqTaskVersion `json:"task_version,omitempty"`
}

CloneJobReq 克隆任务请求体。

func (CloneJobReq) String added in v0.1.49

func (o CloneJobReq) String() string

type CloneJobReqTaskVersion added in v0.1.49

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

func (CloneJobReqTaskVersion) MarshalJSON added in v0.1.49

func (c CloneJobReqTaskVersion) MarshalJSON() ([]byte, error)

func (*CloneJobReqTaskVersion) UnmarshalJSON added in v0.1.49

func (c *CloneJobReqTaskVersion) UnmarshalJSON(b []byte) error

func (CloneJobReqTaskVersion) Value added in v0.1.49

func (c CloneJobReqTaskVersion) Value() string

type CloneJobReqTaskVersionEnum added in v0.1.49

type CloneJobReqTaskVersionEnum struct {
	E_2_0 CloneJobReqTaskVersion
}

func GetCloneJobReqTaskVersionEnum added in v0.1.49

func GetCloneJobReqTaskVersionEnum() CloneJobReqTaskVersionEnum

type CloudBaseInfo

type CloudBaseInfo struct {

	// 区域ID,当数据库实例类型为ecs(华为云ECS自建数据库),cloud(华为云数据库)时为必填项。获取方法请参见地区和终端节点。 注意:当该Region下存在子项目时,Region ID为区域项目ID与子项目ID,由“_”下划线拼接,例如:cn-north-4_abc。
	Region string `json:"region"`

	// 租户在某一Region下的Project ID。 获取方法请参见获取项目ID。
	ProjectId string `json:"project_id"`

	// 数据库所在可用分区(AZ)名称。
	AzCode *string `json:"az_code,omitempty"`
}

CloudBaseInfo 数据库实例所在Region,项目等信息,当数据库实例类型为ecs(华为云ECS自建数据库),cloud(华为云数据库)时为必填项。

func (CloudBaseInfo) String

func (o CloudBaseInfo) String() string

type CloudVpcInfo

type CloudVpcInfo struct {

	// 数据库实例所在的虚拟私有云ID,获取方法如下: 方法1:登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。 方法2:通过虚拟私有云服务的API接口查询,具体操作可参考查询VPC列表。
	VpcId string `json:"vpc_id"`

	// 数据库实例所在子网ID,获取方法如下: 方法1:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。 方法2:通过虚拟私有云服务的API接口查询,具体操作可参考查询子网列表。
	SubnetId string `json:"subnet_id"`

	// 数据库实例所在的安全组ID,获取方法如下: 方法1:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。 方法2:通过虚拟私有云服务的API接口查询,具体操作可参考查询安全组列表。
	SecurityGroupId *string `json:"security_group_id,omitempty"`
}

CloudVpcInfo 数据库实例所在VPC,子网,安全组等信息,当数据库实例类型为ecs(华为云ECS自建数据库),cloud(华为云数据库)时为必填项。

func (CloudVpcInfo) String

func (o CloudVpcInfo) String() string

type CollectColumnsRequest added in v0.1.58

type CollectColumnsRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *CollectColumnsRequestXLanguage `json:"X-Language,omitempty"`

	Body *QueryColumnReq `json:"body,omitempty"`
}

CollectColumnsRequest Request Object

func (CollectColumnsRequest) String added in v0.1.58

func (o CollectColumnsRequest) String() string

type CollectColumnsRequestXLanguage added in v0.1.58

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

func (CollectColumnsRequestXLanguage) MarshalJSON added in v0.1.58

func (c CollectColumnsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CollectColumnsRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *CollectColumnsRequestXLanguage) UnmarshalJSON(b []byte) error

func (CollectColumnsRequestXLanguage) Value added in v0.1.58

type CollectColumnsRequestXLanguageEnum added in v0.1.58

type CollectColumnsRequestXLanguageEnum struct {
	EN_US CollectColumnsRequestXLanguage
	ZH_CN CollectColumnsRequestXLanguage
}

func GetCollectColumnsRequestXLanguageEnum added in v0.1.58

func GetCollectColumnsRequestXLanguageEnum() CollectColumnsRequestXLanguageEnum

type CollectColumnsResponse added in v0.1.58

type CollectColumnsResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *CollectColumnsResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

CollectColumnsResponse Response Object

func (CollectColumnsResponse) String added in v0.1.58

func (o CollectColumnsResponse) String() string

type CollectColumnsResponseStatus added in v0.1.58

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

func (CollectColumnsResponseStatus) MarshalJSON added in v0.1.58

func (c CollectColumnsResponseStatus) MarshalJSON() ([]byte, error)

func (*CollectColumnsResponseStatus) UnmarshalJSON added in v0.1.58

func (c *CollectColumnsResponseStatus) UnmarshalJSON(b []byte) error

func (CollectColumnsResponseStatus) Value added in v0.1.58

type CollectColumnsResponseStatusEnum added in v0.1.58

type CollectColumnsResponseStatusEnum struct {
	PENDING CollectColumnsResponseStatus
	FAILED  CollectColumnsResponseStatus
	SUCCESS CollectColumnsResponseStatus
}

func GetCollectColumnsResponseStatusEnum added in v0.1.58

func GetCollectColumnsResponseStatusEnum() CollectColumnsResponseStatusEnum

type CollectDbObjectsAsyncRequest added in v0.1.21

type CollectDbObjectsAsyncRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *CollectDbObjectsAsyncRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`

	// 查询对象信息类型。 取值: - source:查询源库对象信息。 - modified:查询已选择的(已同步的和未下发的)对象信息。 - synchronized:查询已同步的(已下发的)对象信息 , 使用场景在任务处于全量中或者增量中。
	Type CollectDbObjectsAsyncRequestType `json:"type"`

	// 是否强制刷新。 取值: - true:是,表示从源库重新查询。    - false:否,表示从已缓存中数据查询。
	IsRefresh *bool `json:"is_refresh,omitempty"`

	// 查询指定库的信息。
	DbNames *[]string `json:"db_names,omitempty"`
}

CollectDbObjectsAsyncRequest Request Object

func (CollectDbObjectsAsyncRequest) String added in v0.1.21

type CollectDbObjectsAsyncRequestType added in v0.1.21

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

func (CollectDbObjectsAsyncRequestType) MarshalJSON added in v0.1.21

func (c CollectDbObjectsAsyncRequestType) MarshalJSON() ([]byte, error)

func (*CollectDbObjectsAsyncRequestType) UnmarshalJSON added in v0.1.21

func (c *CollectDbObjectsAsyncRequestType) UnmarshalJSON(b []byte) error

func (CollectDbObjectsAsyncRequestType) Value added in v0.1.21

type CollectDbObjectsAsyncRequestTypeEnum added in v0.1.21

type CollectDbObjectsAsyncRequestTypeEnum struct {
	SOURCE       CollectDbObjectsAsyncRequestType
	MODIFIED     CollectDbObjectsAsyncRequestType
	SYNCHRONIZED CollectDbObjectsAsyncRequestType
}

func GetCollectDbObjectsAsyncRequestTypeEnum added in v0.1.21

func GetCollectDbObjectsAsyncRequestTypeEnum() CollectDbObjectsAsyncRequestTypeEnum

type CollectDbObjectsAsyncRequestXLanguage added in v0.1.21

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

func (CollectDbObjectsAsyncRequestXLanguage) MarshalJSON added in v0.1.21

func (c CollectDbObjectsAsyncRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CollectDbObjectsAsyncRequestXLanguage) UnmarshalJSON added in v0.1.21

func (c *CollectDbObjectsAsyncRequestXLanguage) UnmarshalJSON(b []byte) error

func (CollectDbObjectsAsyncRequestXLanguage) Value added in v0.1.21

type CollectDbObjectsAsyncRequestXLanguageEnum added in v0.1.21

type CollectDbObjectsAsyncRequestXLanguageEnum struct {
	EN_US CollectDbObjectsAsyncRequestXLanguage
	ZH_CN CollectDbObjectsAsyncRequestXLanguage
}

func GetCollectDbObjectsAsyncRequestXLanguageEnum added in v0.1.21

func GetCollectDbObjectsAsyncRequestXLanguageEnum() CollectDbObjectsAsyncRequestXLanguageEnum

type CollectDbObjectsAsyncResponse added in v0.1.21

type CollectDbObjectsAsyncResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *CollectDbObjectsAsyncResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                                  `json:"-"`
}

CollectDbObjectsAsyncResponse Response Object

func (CollectDbObjectsAsyncResponse) String added in v0.1.21

type CollectDbObjectsAsyncResponseStatus added in v0.1.21

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

func (CollectDbObjectsAsyncResponseStatus) MarshalJSON added in v0.1.21

func (c CollectDbObjectsAsyncResponseStatus) MarshalJSON() ([]byte, error)

func (*CollectDbObjectsAsyncResponseStatus) UnmarshalJSON added in v0.1.21

func (c *CollectDbObjectsAsyncResponseStatus) UnmarshalJSON(b []byte) error

func (CollectDbObjectsAsyncResponseStatus) Value added in v0.1.21

type CollectDbObjectsAsyncResponseStatusEnum added in v0.1.21

type CollectDbObjectsAsyncResponseStatusEnum struct {
	PENDING CollectDbObjectsAsyncResponseStatus
	FAILED  CollectDbObjectsAsyncResponseStatus
	SUCCESS CollectDbObjectsAsyncResponseStatus
}

func GetCollectDbObjectsAsyncResponseStatusEnum added in v0.1.21

func GetCollectDbObjectsAsyncResponseStatusEnum() CollectDbObjectsAsyncResponseStatusEnum

type CollectDbObjectsInfoRequest added in v0.1.58

type CollectDbObjectsInfoRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *CollectDbObjectsInfoRequestXLanguage `json:"X-Language,omitempty"`

	Body *QuerySelectObjectInfoReq `json:"body,omitempty"`
}

CollectDbObjectsInfoRequest Request Object

func (CollectDbObjectsInfoRequest) String added in v0.1.58

type CollectDbObjectsInfoRequestXLanguage added in v0.1.58

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

func (CollectDbObjectsInfoRequestXLanguage) MarshalJSON added in v0.1.58

func (c CollectDbObjectsInfoRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CollectDbObjectsInfoRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *CollectDbObjectsInfoRequestXLanguage) UnmarshalJSON(b []byte) error

func (CollectDbObjectsInfoRequestXLanguage) Value added in v0.1.58

type CollectDbObjectsInfoRequestXLanguageEnum added in v0.1.58

type CollectDbObjectsInfoRequestXLanguageEnum struct {
	EN_US CollectDbObjectsInfoRequestXLanguage
	ZH_CN CollectDbObjectsInfoRequestXLanguage
}

func GetCollectDbObjectsInfoRequestXLanguageEnum added in v0.1.58

func GetCollectDbObjectsInfoRequestXLanguageEnum() CollectDbObjectsInfoRequestXLanguageEnum

type CollectDbObjectsInfoResponse added in v0.1.58

type CollectDbObjectsInfoResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *CollectDbObjectsInfoResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                                 `json:"-"`
}

CollectDbObjectsInfoResponse Response Object

func (CollectDbObjectsInfoResponse) String added in v0.1.58

type CollectDbObjectsInfoResponseStatus added in v0.1.58

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

func (CollectDbObjectsInfoResponseStatus) MarshalJSON added in v0.1.58

func (c CollectDbObjectsInfoResponseStatus) MarshalJSON() ([]byte, error)

func (*CollectDbObjectsInfoResponseStatus) UnmarshalJSON added in v0.1.58

func (c *CollectDbObjectsInfoResponseStatus) UnmarshalJSON(b []byte) error

func (CollectDbObjectsInfoResponseStatus) Value added in v0.1.58

type CollectDbObjectsInfoResponseStatusEnum added in v0.1.58

type CollectDbObjectsInfoResponseStatusEnum struct {
	PENDING CollectDbObjectsInfoResponseStatus
	FAILED  CollectDbObjectsInfoResponseStatus
	SUCCESS CollectDbObjectsInfoResponseStatus
}

func GetCollectDbObjectsInfoResponseStatusEnum added in v0.1.58

func GetCollectDbObjectsInfoResponseStatusEnum() CollectDbObjectsInfoResponseStatusEnum

type ColumnObject

type ColumnObject struct {

	// 该列在实时同步场景下的类型。取值: - config:当该列作为数据过滤高级设置的关联列时,需要填写,同时如果该列是主建或优化查询所需的索引,则需要填写primary_key_for_data_filtering或index_for_data_filtering。(注意:是否同步该列到目标库由“filtered”属性控制,与库级、模式级、表级控制方式不同。)
	SyncType *string `json:"sync_type,omitempty"`

	// 该列是否在数据过滤高级设置场景下为主键,如果是主建则填该列列名,否则不填。
	PrimaryKeyForDataFiltering *string `json:"primary_key_for_data_filtering,omitempty"`

	// 优化查询所需的索引,将会为缓存数据增加索引,不会影响源表,当该列作为数据过滤高级设置的关联索引时,需要填写,否则不填。
	IndexForDataFiltering *string `json:"index_for_data_filtering,omitempty"`

	// 该列在目标库的名称(列名映射),当该列为“附加列”时须与数据库表级对象中列名保持一致。
	Name *string `json:"name,omitempty"`

	// 该列字段的数据类型。 列过滤:填写源列字段的数据类型。 附加列:新填充的列指定字段的数据类型,根据不同操作类型来决定取值范围与约束。取值: - 以默认值方式,支持:int,long,varchar(256),datetime,timestamp。 - 以create_time为列,支持:long,datetime,timestamp。 - 以update_time为列,支持:long,datetime,timestamp。 - 以表达式为列,支持:varchar(256),且列值仅为:concat(__current_database, '@', __current_table) - 以serverName@database@table为列,支持:varchar(256)。
	Type *string `json:"type,omitempty"`

	// 该列是否在列映射场景下为主键,如果是主建则填PRI,否则填空。
	PrimaryKeyForColumnFiltering *string `json:"primary_key_for_column_filtering,omitempty"`

	// 该列是否进列过滤,不能与附加列additional同时使用。取值: - true:表示同步该列。 - false:表示过滤该列不同步。
	Filtered *bool `json:"filtered,omitempty"`

	// 该列是否为附加列,当该列为附加列时:name必须与表级对象中列名一致,并且不能与列过滤filtered同时使用。
	Additional *bool `json:"additional,omitempty"`

	// 操作类型,以特定的操作类型填充新加的列。取值: - 以默认值方式:\"operation_type\":\"ADDITIONALCOLUMN,default_value\" - 以create_time为列:\"operation_type\":\"ADDITIONALCOLUMN,create_time\" - 以update_time为列:\"operation_type\":\"ADDITIONALCOLUMN,update_time\" - 以表达式为列:\"operation_type\":\"ADDITIONALCOLUMN,expression\" - 以serverName@database@table为列:\"operation_type\":\"ADDITIONALCOLUMN,server_database_table\"
	OperationType *string `json:"operation_type,omitempty"`

	// 附加列的值。约束: - 当操作类型仅“以默认值方式”,“以serverName@database@table为列”时,才支持输入对应字段类型的值。 - 当操作类型为“以表达式为列”时,该字段为固定值\"concat(__current_database, '@', __current_table)\",不需要填写。
	Value *string `json:"value,omitempty"`
}

ColumnObject 数据库列信息。

func (ColumnObject) String

func (o ColumnObject) String() string

type CommitAsyncJobRequest

type CommitAsyncJobRequest struct {

	// 批量异步创建的任务ID,由创建批量异步任务接口返回。
	AsyncJobId string `json:"async_job_id"`

	// 请求语言类型。
	XLanguage *CommitAsyncJobRequestXLanguage `json:"X-Language,omitempty"`
}

CommitAsyncJobRequest Request Object

func (CommitAsyncJobRequest) String

func (o CommitAsyncJobRequest) String() string

type CommitAsyncJobRequestXLanguage

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

func (CommitAsyncJobRequestXLanguage) MarshalJSON

func (c CommitAsyncJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CommitAsyncJobRequestXLanguage) UnmarshalJSON

func (c *CommitAsyncJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (CommitAsyncJobRequestXLanguage) Value

type CommitAsyncJobRequestXLanguageEnum

type CommitAsyncJobRequestXLanguageEnum struct {
	EN_US CommitAsyncJobRequestXLanguage
	ZH_CN CommitAsyncJobRequestXLanguage
}

func GetCommitAsyncJobRequestXLanguageEnum

func GetCommitAsyncJobRequestXLanguageEnum() CommitAsyncJobRequestXLanguageEnum

type CommitAsyncJobResponse

type CommitAsyncJobResponse struct {
	Job            *AsyncCommitJobResp `json:"job,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

CommitAsyncJobResponse Response Object

func (CommitAsyncJobResponse) String

func (o CommitAsyncJobResponse) String() string

type CompareJobInfo

type CompareJobInfo struct {

	// 对比任务ID。
	Id *string `json:"id,omitempty"`

	// 对比类型。
	Type *string `json:"type,omitempty"`

	// 开始时间。
	StartTime *string `json:"start_time,omitempty"`

	// 结束时间。
	EndTime *string `json:"end_time,omitempty"`

	// 对比任务的状态。取值: - RUNNING:运行中。 - WAITING_FOR_RUNNING:等待启动中。 - SUCCESSFUL:完成。 - FAILED:失败。 - CANCELLED:已取消。 - TIMEOUT_INTERRUPT:超时中断。 - FULL_DOING:全量校验中。 - INCRE_DOING:增量校验中。
	Status *CompareJobInfoStatus `json:"status,omitempty"`

	// 对比计算资源。
	ComputeType *string `json:"compute_type,omitempty"`

	// 导出比对结果状态。
	ExportStatus *string `json:"export_status,omitempty"`

	// 导出比对结果有效期剩余时间。
	ReportRemainSeconds *string `json:"report_remain_seconds,omitempty"`

	// 对比任务的标签。
	CompareJobTag map[string]string `json:"compare_job_tag,omitempty"`

	// 失败原因。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

CompareJobInfo 对比列表信息体。

func (CompareJobInfo) String

func (o CompareJobInfo) String() string

type CompareJobInfoStatus

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

func (CompareJobInfoStatus) MarshalJSON

func (c CompareJobInfoStatus) MarshalJSON() ([]byte, error)

func (*CompareJobInfoStatus) UnmarshalJSON

func (c *CompareJobInfoStatus) UnmarshalJSON(b []byte) error

func (CompareJobInfoStatus) Value

func (c CompareJobInfoStatus) Value() string

type CompareJobInfoStatusEnum

type CompareJobInfoStatusEnum struct {
	RUNNING             CompareJobInfoStatus
	WAITING_FOR_RUNNING CompareJobInfoStatus
	SUCCESSFUL          CompareJobInfoStatus
	FAILED              CompareJobInfoStatus
	CANCELLED           CompareJobInfoStatus
	TIMEOUT_INTERRUPT   CompareJobInfoStatus
	FULL_DOING          CompareJobInfoStatus
	INCRE_DOING         CompareJobInfoStatus
}

func GetCompareJobInfoStatusEnum

func GetCompareJobInfoStatusEnum() CompareJobInfoStatusEnum

type CompareResultInfo

type CompareResultInfo struct {
	ObjectsCompareOverviewInfo *ObjectsCompareTaskInfo `json:"objects_compare_overview_info,omitempty"`

	// 对象级对比详情信息体。
	ObjectsCompareDetailInfos *[]ObjectsCompareDetailInfo `json:"objects_compare_detail_infos,omitempty"`

	// 数据对比任务列表。
	DataCompareTaskList *[]CompareJobInfo `json:"data_compare_task_list,omitempty"`

	// 行数对比概览信息体。
	LineCompareOverviewInfos *[]LineCompareOverviewInfo `json:"line_compare_overview_infos,omitempty"`

	// 行数对比任务表级详情。
	LineCompareDetailInfos *[]TableLineCompareDetailInfo `json:"line_compare_detail_infos,omitempty"`

	// 内容对比概览信息体。
	ContentCompareOverviewInfos *[]ContentCompareOverviewInfo `json:"content_compare_overview_infos,omitempty"`

	// 内容对比详情信息体。
	ContentCompareDetailInfos *[]ContentCompareDetailInfo `json:"content_compare_detail_infos,omitempty"`
}

CompareResultInfo 查询对比任务信息体。

func (CompareResultInfo) String

func (o CompareResultInfo) String() string

type CompareTaskParams

type CompareTaskParams struct {

	// 取消对比任务必填。
	CompareTaskId *string `json:"compare_task_id,omitempty"`

	// 对比任务模式。取值: - object:对象对比。 - lines:行数对比。 - contents:内容对比。
	Type *CompareTaskParamsType `json:"type,omitempty"`

	// 定时启动时间,时间戳格式。
	StartTime *string `json:"start_time,omitempty"`

	// 对比策略。
	Option map[string]string `json:"option,omitempty"`

	// 对比选择对象。
	DbObject map[string]DatabaseObject `json:"db_object,omitempty"`
}

CompareTaskParams 创建或取消对比任务信息体。

func (CompareTaskParams) String

func (o CompareTaskParams) String() string

type CompareTaskParamsType

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

func (CompareTaskParamsType) MarshalJSON

func (c CompareTaskParamsType) MarshalJSON() ([]byte, error)

func (*CompareTaskParamsType) UnmarshalJSON

func (c *CompareTaskParamsType) UnmarshalJSON(b []byte) error

func (CompareTaskParamsType) Value

func (c CompareTaskParamsType) Value() string

type CompareTaskParamsTypeEnum

type CompareTaskParamsTypeEnum struct {
	OBJECT   CompareTaskParamsType
	LINES    CompareTaskParamsType
	CONTENTS CompareTaskParamsType
}

func GetCompareTaskParamsTypeEnum

func GetCompareTaskParamsTypeEnum() CompareTaskParamsTypeEnum

type ContentCompareDetailInfo

type ContentCompareDetailInfo struct {

	// 源库库名。
	SourceDb *string `json:"source_db,omitempty"`

	// 目标库库名。
	TargetDb *string `json:"target_db,omitempty"`

	// 源库表名。
	SourceTableName *string `json:"source_table_name,omitempty"`

	// 目标库表名。
	TargetTableName *string `json:"target_table_name,omitempty"`

	// 源库表行数。
	SourceRowNum *int64 `json:"source_row_num,omitempty"`

	// 目标库表行数。
	TargetRowNum *int64 `json:"target_row_num,omitempty"`

	// 对比不一致行数。
	DifferenceRowNum *int64 `json:"difference_row_num,omitempty"`

	// 行对比结果。取值: - true:一致。 - false:不一致。
	LineCompareResult *bool `json:"line_compare_result,omitempty"`

	// 内容对比结果。取值: - true:一致。 - false:不一致。
	ContentCompareResult *bool `json:"content_compare_result,omitempty"`

	// 失败原因。
	Message *string `json:"message,omitempty"`
}

ContentCompareDetailInfo 内容对比详情信息体。

func (ContentCompareDetailInfo) String

func (o ContentCompareDetailInfo) String() string

type ContentCompareOverviewInfo

type ContentCompareOverviewInfo struct {

	// 源库库名。
	SourceDb *string `json:"source_db,omitempty"`

	// 目标库库名。
	TargetDb *string `json:"target_db,omitempty"`

	// 对比结果。取值: - CONSISTENT:一致。 - INCONSISTENT:不一致。 - COMPARING:正在对比。 - WAITING_FOR_COMPARISON:等待对比。 - FAILED_TO_COMPARE:对比失败。 - TARGET_DB_NOT_EXIST:目标库不存在。 - CAN_NOT_COMPARE:无法对比。
	Status *ContentCompareOverviewInfoStatus `json:"status,omitempty"`

	// 对比结果。
	CompareResult *bool `json:"compare_result,omitempty"`
}

ContentCompareOverviewInfo 内容对比概览信息体。

func (ContentCompareOverviewInfo) String

type ContentCompareOverviewInfoStatus

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

func (ContentCompareOverviewInfoStatus) MarshalJSON

func (c ContentCompareOverviewInfoStatus) MarshalJSON() ([]byte, error)

func (*ContentCompareOverviewInfoStatus) UnmarshalJSON

func (c *ContentCompareOverviewInfoStatus) UnmarshalJSON(b []byte) error

func (ContentCompareOverviewInfoStatus) Value

type ContentCompareOverviewInfoStatusEnum

type ContentCompareOverviewInfoStatusEnum struct {
	CONSISTENT             ContentCompareOverviewInfoStatus
	INCONSISTENT           ContentCompareOverviewInfoStatus
	COMPARING              ContentCompareOverviewInfoStatus
	WAITING_FOR_COMPARISON ContentCompareOverviewInfoStatus
	FAILED_TO_COMPARE      ContentCompareOverviewInfoStatus
	TARGET_DB_NOT_EXIST    ContentCompareOverviewInfoStatus
	CAN_NOT_COMPARE        ContentCompareOverviewInfoStatus
}

func GetContentCompareOverviewInfoStatusEnum

func GetContentCompareOverviewInfoStatusEnum() ContentCompareOverviewInfoStatusEnum

type CopyJobRequest added in v0.1.49

type CopyJobRequest struct {

	// 请求语言类型。
	XLanguage *CopyJobRequestXLanguage `json:"X-Language,omitempty"`

	Body *CloneJobReq `json:"body,omitempty"`
}

CopyJobRequest Request Object

func (CopyJobRequest) String added in v0.1.49

func (o CopyJobRequest) String() string

type CopyJobRequestXLanguage added in v0.1.49

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

func (CopyJobRequestXLanguage) MarshalJSON added in v0.1.49

func (c CopyJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CopyJobRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *CopyJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (CopyJobRequestXLanguage) Value added in v0.1.49

func (c CopyJobRequestXLanguage) Value() string

type CopyJobRequestXLanguageEnum added in v0.1.49

type CopyJobRequestXLanguageEnum struct {
	EN_US CopyJobRequestXLanguage
	ZH_CN CopyJobRequestXLanguage
}

func GetCopyJobRequestXLanguageEnum added in v0.1.49

func GetCopyJobRequestXLanguageEnum() CopyJobRequestXLanguageEnum

type CopyJobResponse added in v0.1.49

type CopyJobResponse struct {

	// 任务ID。
	Id *string `json:"id,omitempty"`

	// 任务名称。
	Name *string `json:"name,omitempty"`

	// 任务状态。
	Status *string `json:"status,omitempty"`

	// 任务创建时间。
	CreateTime *string `json:"create_time,omitempty"`

	// 是否为克隆任务。
	IsCloneJob     *string `json:"is_clone_job,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CopyJobResponse Response Object

func (CopyJobResponse) String added in v0.1.49

func (o CopyJobResponse) String() string

type CreateJobReq

type CreateJobReq struct {
	BaseInfo *JobBaseInfo `json:"base_info"`

	// 创建任务数据库信息体。
	SourceEndpoint []JobEndpointInfo `json:"source_endpoint"`

	// 创建任务数据库信息体。
	TargetEndpoint []JobEndpointInfo `json:"target_endpoint"`

	PeriodOrder *PeriodOrderInfo `json:"period_order,omitempty"`

	NodeInfo *JobNodeInfo `json:"node_info"`
}

CreateJobReq 创建单个任务请求体。

func (CreateJobReq) String

func (o CreateJobReq) String() string

type CreateJobRequest

type CreateJobRequest struct {

	// 请求语言类型。
	XLanguage *CreateJobRequestXLanguage `json:"X-Language,omitempty"`

	Body *SingleCreateJobReq `json:"body,omitempty"`
}

CreateJobRequest Request Object

func (CreateJobRequest) String

func (o CreateJobRequest) String() string

type CreateJobRequestXLanguage

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

func (CreateJobRequestXLanguage) MarshalJSON

func (c CreateJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CreateJobRequestXLanguage) UnmarshalJSON

func (c *CreateJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (CreateJobRequestXLanguage) Value

type CreateJobRequestXLanguageEnum

type CreateJobRequestXLanguageEnum struct {
	EN_US CreateJobRequestXLanguage
	ZH_CN CreateJobRequestXLanguage
}

func GetCreateJobRequestXLanguageEnum

func GetCreateJobRequestXLanguageEnum() CreateJobRequestXLanguageEnum

type CreateJobResp

type CreateJobResp struct {

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 任务状态。
	Status string `json:"status"`

	// 任务创建时间。
	CreateTime string `json:"create_time"`

	// 是否为克隆任务。
	IsCloneJob *string `json:"is_clone_job,omitempty"`
}

CreateJobResp 创建任务响应体。

func (CreateJobResp) String

func (o CreateJobResp) String() string

type CreateJobResponse

type CreateJobResponse struct {
	Job            *CreateJobResp `json:"job,omitempty"`
	HttpStatusCode int            `json:"-"`
}

CreateJobResponse Response Object

func (CreateJobResponse) String

func (o CreateJobResponse) String() string

type DataFilteringCondition added in v0.1.58

type DataFilteringCondition struct {

	// 过滤条件 当filtering_type是configConditionalFilter时, value默认填写config 当filtering_type是contentConditionalFilter时, value默认填写过滤条件  注意: 每张表仅支持添加一个校验规则。 数据过滤每次最多支持500张表。 过滤表达式不支持使用某种数据库引擎特有的package、函数、变量、常量等写法,须使用通用SQL标准。请直接输入SQL语句中WHERE之后的部分(不包含WHERE和分号,例如:sid > 3 and sname like \"G %\"),最多支持输入512个字符。 过滤条件填写的SQL语句中,关键字需要用反引号,datatime类型(包含日期和时间)需要用单引号,例如:update > '2022-07-13 00:00:00' and age >10。 不支持对LOB字段设置过滤条件,如CLOB、BLOB、BYTEA等大字段类型。 不支持库名、表名带有换行符的对象设置过滤规则。 建议不要对非精确类型字段设置过滤条件,如FLOAT、DECIMAL、DOUBLE等。 建议不要对带有特殊字符的字段设置过滤条件。 不建议使用非幂等表达式或函数作为数据加工条件,如SYSTIMESTAMP,SYSDATE等,因其每次调用返回的结果可能会有差异,导致达不到预期。
	Value *string `json:"value,omitempty"`

	// 过滤条件类型  contentConditionalFilter: 简单条件过滤 configConditionalFilter: 关联表过滤
	FilteringType *DataFilteringConditionFilteringType `json:"filtering_type,omitempty"`
}

DataFilteringCondition 数据过滤数条件信息体

func (DataFilteringCondition) String added in v0.1.58

func (o DataFilteringCondition) String() string

type DataFilteringConditionFilteringType added in v0.1.58

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

func (DataFilteringConditionFilteringType) MarshalJSON added in v0.1.58

func (c DataFilteringConditionFilteringType) MarshalJSON() ([]byte, error)

func (*DataFilteringConditionFilteringType) UnmarshalJSON added in v0.1.58

func (c *DataFilteringConditionFilteringType) UnmarshalJSON(b []byte) error

func (DataFilteringConditionFilteringType) Value added in v0.1.58

type DataFilteringConditionFilteringTypeEnum added in v0.1.58

type DataFilteringConditionFilteringTypeEnum struct {
	CONTENT_CONDITIONAL_FILTER DataFilteringConditionFilteringType
	CONFIG_CONDITIONAL_FILTER  DataFilteringConditionFilteringType
}

func GetDataFilteringConditionFilteringTypeEnum added in v0.1.58

func GetDataFilteringConditionFilteringTypeEnum() DataFilteringConditionFilteringTypeEnum

type DataProcessInfo added in v0.1.58

type DataProcessInfo struct {

	// 指定任务数据加工规则请求体
	FilterConditions *[]DataFilteringCondition `json:"filter_conditions,omitempty"`

	// 库级、批量表级处理为true,单表操作为false
	IsBatchProcess *bool `json:"is_batch_process,omitempty"`

	// 附加列 当选择附加列时必须填写 约束:使用多对一操作时,需要使用数据加工的附加列操作来避免数据冲突。
	AddColumns *[]AddColumnInfo `json:"add_columns,omitempty"`

	// 支持DDL的语法 选择增量迁移或同步的DDL操作。取值及意思如下: \"table\": \"CREATE TABLE, ALTER TABLE,DROP TABLE,RENAME TABLE\" 如该值为空,不迁移或同步DDL操作
	DdlOperation map[string]string `json:"ddl_operation,omitempty"`

	// 支持DML的语法 选择DML操作时,取值如下: i:INSERT。 u:UPDATE。 d:DELETE。 如该值为空,不增量迁移或同步DML操作。
	DmlOperation *string `json:"dml_operation,omitempty"`

	DbObjectColumnInfo *DbObjectColumnInfo `json:"db_object_column_info,omitempty"`

	DbOrTableRenameRule *DbOrTableRenameRule `json:"db_or_table_rename_rule,omitempty"`

	DbObject *DbObject `json:"db_object,omitempty"`

	// 表示该规则是否已同步至目标库
	IsSynchronized *bool `json:"is_synchronized,omitempty"`
}

func (DataProcessInfo) String added in v0.1.58

func (o DataProcessInfo) String() string

type DataProcessReq added in v0.1.58

type DataProcessReq struct {

	// 指定任务数据加工规则请求体
	DataProcessInfo *[]DataProcessInfo `json:"data_process_info,omitempty"`
}

DataProcessReq 指定任务数据加工规则请求体

func (DataProcessReq) String added in v0.1.58

func (o DataProcessReq) String() string

type DatabaseObject

type DatabaseObject struct {

	// 该数据库在实时同步场景下的类型。取值: - config:仅当该库作为数据过滤高级设置的关联库时,需要填写,此时该库以及该库下的schemas、tables“不会”被同步到目标库,name、all属性不生效,schemas、tables需要填写被关联的相关对象。(注意:如果需要同步该库级对象,则在下级对象中填写sync_type值为config。)
	SyncType *DatabaseObjectSyncType `json:"sync_type,omitempty"`

	// 该数据库在目标库的名称(库名映射)。
	Name *string `json:"name,omitempty"`

	// 是否整库迁移或同步。注意: 1.当该库下的模式、表、列需要做数据过滤、列过滤、列映射时,填false,否则填true; 2.当该库下的表需要做附加列时,需要填true,并且在表级对象的columns里填写附加列信息; 3.当该库下的表所包含的列作为数据过滤高级设置的关联列时,需要填true,并且在columns里填写关联列信息,在config_conditions填写数据过滤高级设置的配置条件;
	All *bool `json:"all,omitempty"`

	// 需要迁移或同步的模式,当整库迁移或同步为false时需要填写。
	Schemas map[string]SchemaObject `json:"schemas,omitempty"`

	// 需要迁移或同步的表,当整库迁移或同步为false时需要填写。
	Tables map[string]TableObject `json:"tables,omitempty"`

	// 库下的表的数量,表的数量超过阈值就不显示。
	TotalTableNum *int32 `json:"total_table_num,omitempty"`

	// 是否已同步
	IsSynchronized *bool `json:"is_synchronized,omitempty"`
}

DatabaseObject 数据库库级对象。

func (DatabaseObject) String

func (o DatabaseObject) String() string

type DatabaseObjectSyncType

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

func (DatabaseObjectSyncType) MarshalJSON

func (c DatabaseObjectSyncType) MarshalJSON() ([]byte, error)

func (*DatabaseObjectSyncType) UnmarshalJSON

func (c *DatabaseObjectSyncType) UnmarshalJSON(b []byte) error

func (DatabaseObjectSyncType) Value

func (c DatabaseObjectSyncType) Value() string

type DatabaseObjectSyncTypeEnum

type DatabaseObjectSyncTypeEnum struct {
	CONFIG DatabaseObjectSyncType
}

func GetDatabaseObjectSyncTypeEnum

func GetDatabaseObjectSyncTypeEnum() DatabaseObjectSyncTypeEnum

type DbObject

type DbObject struct {

	// 数据库对象迁移或同步范围。取值: - all:全部迁移。 - database:库级迁移或同步。 - table:表级迁移或同步。
	ObjectScope DbObjectObjectScope `json:"object_scope"`

	TargetRootDb *TargetRootDb `json:"target_root_db,omitempty"`

	// 数据库对象迁移或同步信息,object_scope为all时不填,为库级或表级时必填。
	ObjectInfo map[string]DatabaseObject `json:"object_info,omitempty"`
}

DbObject 数据库对象信息体。实时迁移、实时同步需要迁移或同步的库或者表,支持实时同步场景对数据库对象进行加工,即可以为数据库对象添加过滤规则、高级设置、列加工、附加列等。 数据加工相关具体约束参考:https://support.huaweicloud.com/realtimesyn-drs/drs_03_0035.html

func (DbObject) String

func (o DbObject) String() string

type DbObjectColumnInfo added in v0.1.58

type DbObjectColumnInfo struct {

	// 数据库库名称。
	DbName *string `json:"db_name,omitempty"`

	// 数据库schema名称。
	SchemaName *string `json:"schema_name,omitempty"`

	// 数据库表名称。
	TableName *string `json:"table_name,omitempty"`

	// 数据库列信息。
	ColumnInfos *[]QueryColumnInfo `json:"column_infos,omitempty"`

	// 数据库列信息总数,与分页无关,仅作为返回体参数
	TotalCount *int32 `json:"total_count,omitempty"`
}

DbObjectColumnInfo 列加工对象 约束: 列加工提供列级的查询、映射和过滤能力。 编辑列名后,目标数据库的列名为修改后的名称。 列映射名不能和原列名或已存在的映射名相同。 不支持库名、表名带有换行符的列进行映射。 任务再编辑时,已经同步的表不支持修改列信息。 只有勾选的列才会被同步。 MySQL->MySQL、MySQL->GaussDB(for MySQL)不支持分区表的分区字段进行列映射。 GaussDB分区键不可以被过滤。

func (DbObjectColumnInfo) String added in v0.1.58

func (o DbObjectColumnInfo) String() string

type DbObjectFilteringResult added in v0.1.58

type DbObjectFilteringResult struct {

	// 数据库库名。
	DbName *string `json:"db_name,omitempty"`

	// 数据库Schema名称。
	SchemaName *string `json:"schema_name,omitempty"`

	// 数据库表名称。
	TableName *string `json:"table_name,omitempty"`

	// 数据过滤校验结果。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 当数据过滤校验结果是false,返回校验失败的原因。
	Message *string `json:"message,omitempty"`
}

DbObjectFilteringResult 数据库表过滤规则响应体

func (DbObjectFilteringResult) String added in v0.1.58

func (o DbObjectFilteringResult) String() string

type DbObjectInfo added in v0.1.49

type DbObjectInfo struct {

	// 源数据库库名。
	SourceDbName *string `json:"source_db_name,omitempty"`

	// 源数据库模式名。
	SourceSchemaName *string `json:"source_schema_name,omitempty"`

	// 源数据库表名。
	SourceTableName *string `json:"source_table_name,omitempty"`

	// 目标数据库库名。
	TargetDbName *string `json:"target_db_name,omitempty"`

	// 目标数据库模式名。
	TargetSchemaName *string `json:"target_schema_name,omitempty"`

	// 目标数据库表名。
	TargetTableName *string `json:"target_table_name,omitempty"`

	// 是否有列映射。
	HasColumnInfo *bool `json:"has_column_info,omitempty"`
}

DbObjectInfo 对象信息。

func (DbObjectInfo) String added in v0.1.49

func (o DbObjectInfo) String() string

type DbObjectObjectScope

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

func (DbObjectObjectScope) MarshalJSON

func (c DbObjectObjectScope) MarshalJSON() ([]byte, error)

func (*DbObjectObjectScope) UnmarshalJSON

func (c *DbObjectObjectScope) UnmarshalJSON(b []byte) error

func (DbObjectObjectScope) Value

func (c DbObjectObjectScope) Value() string

type DbObjectObjectScopeEnum

type DbObjectObjectScopeEnum struct {
	ALL      DbObjectObjectScope
	DATABASE DbObjectObjectScope
	TABLE    DbObjectObjectScope
}

func GetDbObjectObjectScopeEnum

func GetDbObjectObjectScopeEnum() DbObjectObjectScopeEnum

type DbOrTableRenameRule added in v0.1.58

type DbOrTableRenameRule struct {

	// 前缀名称 当type为prefixAndSuffix, 填写prefix_name,库表名称仅增加前缀,若同时也填写suffix_name, 库表名称增加前后缀
	PrefixName *string `json:"prefix_name,omitempty"`

	// 后缀名称 当type为prefixAndSuffix, 填写suffix_name,库表名称仅增加后缀,若同时也填写prefix_name, 库表名称同时增加前后缀
	SuffixName *string `json:"suffix_name,omitempty"`

	// 库表映射类型 prefixAndSuffix:前缀、后缀或者前后缀
	Type *DbOrTableRenameRuleType `json:"type,omitempty"`
}

DbOrTableRenameRule 库表更名规则 可以在名称添加前后缀, 填写前缀名,会给库表名称前面添加对前缀名,填写后缀名,会给库表名称后面添加对后缀名; 当前缀名和后缀名都写时,会给库表名称前后面添加对字符;

func (DbOrTableRenameRule) String added in v0.1.58

func (o DbOrTableRenameRule) String() string

type DbOrTableRenameRuleType added in v0.1.58

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

func (DbOrTableRenameRuleType) MarshalJSON added in v0.1.58

func (c DbOrTableRenameRuleType) MarshalJSON() ([]byte, error)

func (*DbOrTableRenameRuleType) UnmarshalJSON added in v0.1.58

func (c *DbOrTableRenameRuleType) UnmarshalJSON(b []byte) error

func (DbOrTableRenameRuleType) Value added in v0.1.58

func (c DbOrTableRenameRuleType) Value() string

type DbOrTableRenameRuleTypeEnum added in v0.1.58

type DbOrTableRenameRuleTypeEnum struct {
	PREFIX_AND_SUFFIX DbOrTableRenameRuleType
	MANY_TO_ONE       DbOrTableRenameRuleType
}

func GetDbOrTableRenameRuleTypeEnum added in v0.1.58

func GetDbOrTableRenameRuleTypeEnum() DbOrTableRenameRuleTypeEnum

type DbParam

type DbParam struct {

	// 数据库参数名。
	Key string `json:"key"`

	// 目标数据库参数值。
	TargetValue string `json:"target_value"`
}

DbParam 数据库参数名、目标数据库参数值。

func (DbParam) String

func (o DbParam) String() string

type DbParamInfo

type DbParamInfo struct {

	// 常规参数。只有对比结果为不一致的目标库参数能被修改。
	Common *[]DbParam `json:"common,omitempty"`

	// 性能参数。对比结果一致也可以修改目标库的值。
	Performance *[]DbParam `json:"performance,omitempty"`
}

DbParamInfo 数据库参数信息体。MySQL迁移和MySQL灾备需要修改的数据库参数,部分参数的修改需重启目标库后生效,建议在迁移开始前或迁移结束后重启目标库,具体参数值与有效范围请通过“批量获取数据库参数”接口查询。约束: - 实时灾备场景:双主灾备时父任务不支持。 当前支持的参数: 常规参数: - character_set_server:服务器字符集。 - collation_server:服务器默认排序。 - connect_timeout:mysqld服务器在回Bad handshake响应之前等待连接数据包的时间(秒)。 - explicit_defaults_for_timestamp:处理TIMESTAMP字段的默认值、NULL值时是否开启非标准行为。默认该参数是关闭的,即开启非标准行为。 - innodb_flush_log_at_trx_commit:当重新安排并批量处理与提交相关的I/O操作时,可以控制提交操作在严格遵守ACID合规性和高性能之间的平衡。当值设为0时,每秒把事务日志缓存区的数据写入日志文件并刷新到磁盘;当设为默认值1时,是为了保证完整的ACID,每次提交事务时,把事务日志从缓存区写到日志文件中,并刷新日志文件的数据到磁盘上;如果设为2,每次提交事务都会把事务日志从缓存区写入日志文件,大约每隔一秒会刷新到磁盘。 - innodb_lock_wait_timeout:放弃事务前,InnoDB事务等待行锁的时间。 - max_connections:允许同时连接的客户端总数。如果设定值为default,表示该参数随内存规格变化。 - net_read_timeout:中止读数据之前从一个连接等待更多数据的秒数。 - net_write_timeout:中止写之前等待一个块被写入连接的秒数。 性能参数: - binlog_cache_size:在事务中,为二进制日志存储SQL语句的缓存容量。该参数必须设置为4096的倍数。目标库允许值:4096~16777216。 - binlog_stmt_cache_size:此变量决定在事务中,二进制日志存储下发的非事务语句的缓存空间。该参数必须设置为4096的倍数。目标库允许值:4096~16777216。 - bulk_insert_buffer_size:限制MyISAM缓存树每个线程的大小,单位为字节。目标库允许值:0~18446744073709551615。 - innodb_buffer_pool_size:对于缓存数据及其表格索引,innodb使用的内存缓存字节大小。如果设定值为default,表示该参数随内存规格变化(建议不高于目标库实例总内存的70%)。该参数必须设置为134217728的倍数。目标库允许值:536870912~1717986918。 - long_query_time:当SQL语句执行时间超过此数值时,就会被记录到慢日志中,单位为秒。目标库允许值:0.03~3600。 - read_buffer_size:对每个进行顺序扫描的线程将分配一个缓冲区。如果要进行大量顺序扫描,可增大参数值以提升性能。目标库允许值:8192~2147479552。 - read_rnd_buffer_size:在key-sort操作后按排序读取行时,避免读取磁盘。增大该参数值可提升ORDER BY操作的性能。该参数必须设置为4096的倍数。目标库允许值:1~2147483647。 - sort_buffer_size:增大该参数值可提升ORDER BY或GROUP BY操作的性能。目标库允许值:32768~18446744073709551615。 - sync_binlog:同步binlog(MySQL持久化到硬盘,或依赖于操作系统)。目标库允许值:0~4294967295。 示例: { 'common' : [ {\\'key\\':\\'character_set_server\\',\\'target_value\\':\\'utf8mb4\\'} ], 'performance' : [ {\\'key\\':\\'long_query_time\\',\\'target_value\\':\\'1\\'} ] }

func (DbParamInfo) String

func (o DbParamInfo) String() string

type DeleteJobRequest

type DeleteJobRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *DeleteJobRequestXLanguage `json:"X-Language,omitempty"`
}

DeleteJobRequest Request Object

func (DeleteJobRequest) String

func (o DeleteJobRequest) String() string

type DeleteJobRequestXLanguage

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

func (DeleteJobRequestXLanguage) MarshalJSON

func (c DeleteJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*DeleteJobRequestXLanguage) UnmarshalJSON

func (c *DeleteJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (DeleteJobRequestXLanguage) Value

type DeleteJobRequestXLanguageEnum

type DeleteJobRequestXLanguageEnum struct {
	EN_US DeleteJobRequestXLanguage
	ZH_CN DeleteJobRequestXLanguage
}

func GetDeleteJobRequestXLanguageEnum

func GetDeleteJobRequestXLanguageEnum() DeleteJobRequestXLanguageEnum

type DeleteJobResp

type DeleteJobResp struct {

	// 错误码。
	ErrorCode string `json:"error_code"`

	// 错误描述。
	ErrorMsg string `json:"error_msg"`

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 删除结果。
	Status string `json:"status"`
}

DeleteJobResp 删除任务响应体。

func (DeleteJobResp) String

func (o DeleteJobResp) String() string

type DeleteJobResponse

type DeleteJobResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteJobResponse Response Object

func (DeleteJobResponse) String

func (o DeleteJobResponse) String() string

type DirtyData added in v0.1.49

type DirtyData struct {

	// 数据库名称。
	DbName *string `json:"db_name,omitempty"`

	// 模式名称。
	SchemaName *string `json:"schema_name,omitempty"`

	// 表名称。
	TableName *string `json:"table_name,omitempty"`

	// 异常SQL。
	ErrorSql *string `json:"error_sql,omitempty"`

	// 发生异常时间,UTC时间,例如:2023-06-10T03:01:52Z
	ErrorTime *string `json:"error_time,omitempty"`

	// 异常信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

DirtyData 异常数据。

func (DirtyData) String added in v0.1.49

func (o DirtyData) String() string

type DownloadBatchCreateTemplateRequest added in v0.1.49

type DownloadBatchCreateTemplateRequest struct {

	// 请求语言类型。
	XLanguage *DownloadBatchCreateTemplateRequestXLanguage `json:"X-Language,omitempty"`
}

DownloadBatchCreateTemplateRequest Request Object

func (DownloadBatchCreateTemplateRequest) String added in v0.1.49

type DownloadBatchCreateTemplateRequestXLanguage added in v0.1.49

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

func (DownloadBatchCreateTemplateRequestXLanguage) MarshalJSON added in v0.1.49

func (*DownloadBatchCreateTemplateRequestXLanguage) UnmarshalJSON added in v0.1.49

func (DownloadBatchCreateTemplateRequestXLanguage) Value added in v0.1.49

type DownloadBatchCreateTemplateRequestXLanguageEnum added in v0.1.49

type DownloadBatchCreateTemplateRequestXLanguageEnum struct {
	EN_US DownloadBatchCreateTemplateRequestXLanguage
	ZH_CN DownloadBatchCreateTemplateRequestXLanguage
}

func GetDownloadBatchCreateTemplateRequestXLanguageEnum added in v0.1.49

func GetDownloadBatchCreateTemplateRequestXLanguageEnum() DownloadBatchCreateTemplateRequestXLanguageEnum

type DownloadBatchCreateTemplateResponse added in v0.1.49

type DownloadBatchCreateTemplateResponse struct {

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误描述。
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DownloadBatchCreateTemplateResponse Response Object

func (DownloadBatchCreateTemplateResponse) String added in v0.1.49

type DownloadDbObjectTemplateRequest

type DownloadDbObjectTemplateRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *DownloadDbObjectTemplateRequestXLanguage `json:"X-Language,omitempty"`

	// 文件模板支持数据同步级别,不填默认为table表级。 - database:库级 - table:表级
	FileImportDbLevel *DownloadDbObjectTemplateRequestFileImportDbLevel `json:"file_import_db_level,omitempty"`
}

DownloadDbObjectTemplateRequest Request Object

func (DownloadDbObjectTemplateRequest) String

type DownloadDbObjectTemplateRequestFileImportDbLevel added in v0.1.49

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

func (DownloadDbObjectTemplateRequestFileImportDbLevel) MarshalJSON added in v0.1.49

func (*DownloadDbObjectTemplateRequestFileImportDbLevel) UnmarshalJSON added in v0.1.49

func (DownloadDbObjectTemplateRequestFileImportDbLevel) Value added in v0.1.49

type DownloadDbObjectTemplateRequestFileImportDbLevelEnum added in v0.1.49

type DownloadDbObjectTemplateRequestFileImportDbLevelEnum struct {
	DATABASE DownloadDbObjectTemplateRequestFileImportDbLevel
	TABLE    DownloadDbObjectTemplateRequestFileImportDbLevel
}

func GetDownloadDbObjectTemplateRequestFileImportDbLevelEnum added in v0.1.49

func GetDownloadDbObjectTemplateRequestFileImportDbLevelEnum() DownloadDbObjectTemplateRequestFileImportDbLevelEnum

type DownloadDbObjectTemplateRequestXLanguage

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

func (DownloadDbObjectTemplateRequestXLanguage) MarshalJSON

func (*DownloadDbObjectTemplateRequestXLanguage) UnmarshalJSON

func (c *DownloadDbObjectTemplateRequestXLanguage) UnmarshalJSON(b []byte) error

func (DownloadDbObjectTemplateRequestXLanguage) Value

type DownloadDbObjectTemplateRequestXLanguageEnum

type DownloadDbObjectTemplateRequestXLanguageEnum struct {
	EN_US DownloadDbObjectTemplateRequestXLanguage
	ZH_CN DownloadDbObjectTemplateRequestXLanguage
}

func GetDownloadDbObjectTemplateRequestXLanguageEnum

func GetDownloadDbObjectTemplateRequestXLanguageEnum() DownloadDbObjectTemplateRequestXLanguageEnum

type DownloadDbObjectTemplateResponse

type DownloadDbObjectTemplateResponse struct {
	HttpStatusCode int           `json:"-"`
	Body           io.ReadCloser `json:"-" type:"stream"`
}

DownloadDbObjectTemplateResponse Response Object

func (DownloadDbObjectTemplateResponse) Consume

func (o DownloadDbObjectTemplateResponse) Consume(writer io.Writer) (int64, error)

func (DownloadDbObjectTemplateResponse) String

type EndpointSslConfig

type EndpointSslConfig struct {

	// 是否SSL安全连接。如果数据库启用了SSL安全连接,参数值为true。
	SslLink *bool `json:"ssl_link,omitempty"`

	// SSL证书名字。
	SslCertName *string `json:"ssl_cert_name,omitempty"`

	// SSL证书内容,用base64加密。
	SslCertKey *string `json:"ssl_cert_key,omitempty"`

	// SSL证书内容checksum值,后端校验,源库安全连接必选。
	SslCertCheckSum *string `json:"ssl_cert_check_sum,omitempty"`

	// SSL证书密码,证书文件后缀为.p12时必填。
	SslCertPassword *string `json:"ssl_cert_password,omitempty"`
}

EndpointSslConfig 数据库SSL证书信息体。如果数据库启用了SSL安全连接,请确保相关配置正确,并输入SSL证书相关参数,否则无需填写此参数。

func (EndpointSslConfig) String

func (o EndpointSslConfig) String() string

type EnterpriseProject added in v0.1.49

type EnterpriseProject struct {

	// 企业项目ID,0表示默认企业项目。
	Id *string `json:"id,omitempty"`

	// 企业项目名称。
	Name *string `json:"name,omitempty"`

	// 描述。
	Description *string `json:"description,omitempty"`

	// 企业项目状态。 - 1:启用 - 2:停用
	Status *string `json:"status,omitempty"`

	// 创建时间,例如:2023-01-20T07:18:26Z
	CreatedAt *string `json:"created_at,omitempty"`

	// 更新时间,例如:2023-03-01T09:42:02Z
	UpdatedAt *string `json:"updated_at,omitempty"`
}

EnterpriseProject 企业项目信息。

func (EnterpriseProject) String added in v0.1.49

func (o EnterpriseProject) String() string

type ErrorResp

type ErrorResp struct {

	// 错误码。
	ErrorCode string `json:"error_code"`

	// 错误描述。
	ErrorMsg string `json:"error_msg"`
}

ErrorResp 请求失败时返回的错误对象响应体。

func (ErrorResp) String

func (o ErrorResp) String() string

type ExecuteJobActionRequest

type ExecuteJobActionRequest struct {

	// 任务ID (对比任务相关操作,多任务场景传父任务详情返回的master_job_id)
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ExecuteJobActionRequestXLanguage `json:"X-Language,omitempty"`

	Body *JobActionReq `json:"body,omitempty"`
}

ExecuteJobActionRequest Request Object

func (ExecuteJobActionRequest) String

func (o ExecuteJobActionRequest) String() string

type ExecuteJobActionRequestXLanguage

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

func (ExecuteJobActionRequestXLanguage) MarshalJSON

func (c ExecuteJobActionRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ExecuteJobActionRequestXLanguage) UnmarshalJSON

func (c *ExecuteJobActionRequestXLanguage) UnmarshalJSON(b []byte) error

func (ExecuteJobActionRequestXLanguage) Value

type ExecuteJobActionRequestXLanguageEnum

type ExecuteJobActionRequestXLanguageEnum struct {
	EN_US ExecuteJobActionRequestXLanguage
	ZH_CN ExecuteJobActionRequestXLanguage
}

func GetExecuteJobActionRequestXLanguageEnum

func GetExecuteJobActionRequestXLanguageEnum() ExecuteJobActionRequestXLanguageEnum

type ExecuteJobActionResponse

type ExecuteJobActionResponse struct {

	// 异步操作任务响应查询ID。
	QueryId        *string `json:"query_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExecuteJobActionResponse Response Object

func (ExecuteJobActionResponse) String

func (o ExecuteJobActionResponse) String() string

type ExportOperationInfoRequest added in v0.1.58

type ExportOperationInfoRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ExportOperationInfoRequestXLanguage `json:"X-Language,omitempty"`
}

ExportOperationInfoRequest Request Object

func (ExportOperationInfoRequest) String added in v0.1.58

type ExportOperationInfoRequestXLanguage added in v0.1.58

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

func (ExportOperationInfoRequestXLanguage) MarshalJSON added in v0.1.58

func (c ExportOperationInfoRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ExportOperationInfoRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ExportOperationInfoRequestXLanguage) UnmarshalJSON(b []byte) error

func (ExportOperationInfoRequestXLanguage) Value added in v0.1.58

type ExportOperationInfoRequestXLanguageEnum added in v0.1.58

type ExportOperationInfoRequestXLanguageEnum struct {
	EN_US ExportOperationInfoRequestXLanguage
	ZH_CN ExportOperationInfoRequestXLanguage
}

func GetExportOperationInfoRequestXLanguageEnum added in v0.1.58

func GetExportOperationInfoRequestXLanguageEnum() ExportOperationInfoRequestXLanguageEnum

type ExportOperationInfoResponse added in v0.1.58

type ExportOperationInfoResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExportOperationInfoResponse Response Object

func (ExportOperationInfoResponse) String added in v0.1.58

type FlowCompareData added in v0.1.49

type FlowCompareData struct {

	// 源数据库名称。
	SrcDb *string `json:"src_db,omitempty"`

	// 源对象名称。
	SrcTb *string `json:"src_tb,omitempty"`

	// 目标数据库名称。
	DstDb *string `json:"dst_db,omitempty"`

	// 目标对象名称。
	DstTb *string `json:"dst_tb,omitempty"`

	// 进度,1-100。
	Progress *int32 `json:"progress,omitempty"`
}

FlowCompareData 对比结果。

func (FlowCompareData) String added in v0.1.49

func (o FlowCompareData) String() string

type HealthCompareJob added in v0.1.49

type HealthCompareJob struct {

	// 对比任务ID。
	Id *string `json:"id,omitempty"`

	// 对比类型。 - object:对象对比 - lines:行对比 - contents:内容对比 - account:用户对比
	Type *string `json:"type,omitempty"`

	// 状态。 - WAITING_FOR_RUNNING:等待启动中 - RUNNING:运行中 - SUCCESSFUL:完成 - FAILED:失败 - CANCELLED:已取消 - TIMEOUT_INTERRUPT:超时中断 - FULL_DOING:全量校验中 - INCRE_DOING:增量校验中
	Status *string `json:"status,omitempty"`

	// 对比开始时间。
	StartTime *string `json:"start_time,omitempty"`

	// 对比结束时间。
	EndTime *string `json:"end_time,omitempty"`

	// 对比计算资源。
	ComputeType *string `json:"compute_type,omitempty"`
}

HealthCompareJob 健康对比任务。

func (HealthCompareJob) String added in v0.1.49

func (o HealthCompareJob) String() string

type ImportBatchCreateJobsRequest added in v0.1.49

type ImportBatchCreateJobsRequest struct {

	// 请求语言类型。
	XLanguage *ImportBatchCreateJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *ImportBatchCreateJobsRequestBody `json:"body,omitempty" type:"multipart"`
}

ImportBatchCreateJobsRequest Request Object

func (ImportBatchCreateJobsRequest) String added in v0.1.49

type ImportBatchCreateJobsRequestBody added in v0.1.49

type ImportBatchCreateJobsRequestBody struct {

	// 待上传的模板文件。
	File *def.FilePart `json:"file"`
}

func (ImportBatchCreateJobsRequestBody) String added in v0.1.49

func (*ImportBatchCreateJobsRequestBody) UnmarshalJSON added in v0.1.49

func (o *ImportBatchCreateJobsRequestBody) UnmarshalJSON(b []byte) error

type ImportBatchCreateJobsRequestXLanguage added in v0.1.49

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

func (ImportBatchCreateJobsRequestXLanguage) MarshalJSON added in v0.1.49

func (c ImportBatchCreateJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ImportBatchCreateJobsRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ImportBatchCreateJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ImportBatchCreateJobsRequestXLanguage) Value added in v0.1.49

type ImportBatchCreateJobsRequestXLanguageEnum added in v0.1.49

type ImportBatchCreateJobsRequestXLanguageEnum struct {
	EN_US ImportBatchCreateJobsRequestXLanguage
	ZH_CN ImportBatchCreateJobsRequestXLanguage
}

func GetImportBatchCreateJobsRequestXLanguageEnum added in v0.1.49

func GetImportBatchCreateJobsRequestXLanguageEnum() ImportBatchCreateJobsRequestXLanguageEnum

type ImportBatchCreateJobsResponse added in v0.1.49

type ImportBatchCreateJobsResponse struct {

	// 批量导入任务id。
	AsyncJobId *string `json:"async_job_id,omitempty"`

	// 导入失败的错误信息。
	ImportErrorMessages *[]ImportErrorMessageResp `json:"import_error_messages,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误描述。
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ImportBatchCreateJobsResponse Response Object

func (ImportBatchCreateJobsResponse) String added in v0.1.49

type ImportErrorMessageResp added in v0.1.49

type ImportErrorMessageResp struct {

	// sheet名称。
	SheetName *string `json:"sheet_name,omitempty"`

	// 行号。
	RowRum *string `json:"row_rum,omitempty"`

	// 字段值。
	Value *string `json:"value,omitempty"`

	// 错误信息。
	ErrorMessage *string `json:"error_message,omitempty"`
}

ImportErrorMessageResp 导入失败详情响应体。

func (ImportErrorMessageResp) String added in v0.1.49

func (o ImportErrorMessageResp) String() string

type IncreComponentDetail added in v0.1.58

type IncreComponentDetail struct {

	// 组件类型 - capture:抓取 - apply:回放
	Type *IncreComponentDetailType `json:"type,omitempty"`

	// 状态。 - STOPPED:停止 - STARTED:运行中 - STOPPING:停止中 - STARTING:启动中
	Status *string `json:"status,omitempty"`

	// 启动时间
	StartTime *string `json:"start_time,omitempty"`

	// 启动位点
	StartPoint *string `json:"start_point,omitempty"`

	// 当前位点
	CurrentPoint *string `json:"current_point,omitempty"`

	// 解析时间
	ResolutionTime *string `json:"resolution_time,omitempty"`

	// 时延,单位:秒
	Delay *string `json:"delay,omitempty"`
}

IncreComponentDetail 增量组件详情。

func (IncreComponentDetail) String added in v0.1.58

func (o IncreComponentDetail) String() string

type IncreComponentDetailType added in v0.1.58

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

func (IncreComponentDetailType) MarshalJSON added in v0.1.58

func (c IncreComponentDetailType) MarshalJSON() ([]byte, error)

func (*IncreComponentDetailType) UnmarshalJSON added in v0.1.58

func (c *IncreComponentDetailType) UnmarshalJSON(b []byte) error

func (IncreComponentDetailType) Value added in v0.1.58

func (c IncreComponentDetailType) Value() string

type IncreComponentDetailTypeEnum added in v0.1.58

type IncreComponentDetailTypeEnum struct {
	CAPTURE IncreComponentDetailType
	APPLY   IncreComponentDetailType
}

func GetIncreComponentDetailTypeEnum added in v0.1.58

func GetIncreComponentDetailTypeEnum() IncreComponentDetailTypeEnum

type JobActionReq

type JobActionReq struct {
	Job *ActionReq `json:"job"`
}

JobActionReq 操作单个任务请求体,支持测试连接、预检查、启动、暂停、续传、重置、对比、结束等操作。

func (JobActionReq) String

func (o JobActionReq) String() string

type JobActions

type JobActions struct {

	// 任务可操作命令集合。 - CREATE:创建任务 - CHOOSE_OBJECT:选择对象,任务增量中再编辑 - PRE_CHECK:预检查 - CHANGE_MODE:修改任务模式 - FREE_RESOURCE:释放资源 - MODIFY_DB_CONFIG:修改数据库配置 - RESET_DB_PWD:重置数据库密码(源库、目标库) - MODIFY_CONFIGURATION:修改任务配置 - PAUSE:暂停任务 - START:启动任务 - CHANGE:修改任务 - RETRY:重试任务 - RESET:重置任务 - DELETE:删除任务 - QUERY_PRE_CHECK:预检查 - SWITCH_OVER:容灾倒换 - START_INCR:CASSANDRA启动增量任务 - MODIFY_TASK_NUMBER:CASSANDRA修改线程数配置 - CONTINUE_JOB:oracle-GaussDB分布式:启动失败或者停止的任务 - STOP_JOB:oracle-GaussDB分布式:停止任务 - CONTINUE_CAPTURE:启动抓取 - STOP_CAPTURE:停止抓取 - CONTINUE_APPLY:启动回放 - STOP_APPLY:停止回放 - PAY_ORDER:包年包月支付订单 - UNSUBSCRIBE:包年包月退订 - TO_PERIOD:转包周期 - TO_RENEW:包周期续费 - ORDER_INFO:订单详情 - CHANGE_FLAVOR:规格变更 - CLONE:克隆任务
	AvailableActions []string `json:"available_actions"`

	// 任务可操作命令集合。 - CREATE:创建任务 - CHOOSE_OBJECT:选择对象,任务增量中再编辑 - PRE_CHECK:预检查 - CHANGE_MODE:修改任务模式 - FREE_RESOURCE:释放资源 - MODIFY_DB_CONFIG:修改数据库配置 - RESET_DB_PWD:重置数据库密码(源库、目标库) - MODIFY_CONFIGURATION:修改任务配置 - PAUSE:暂停任务 - START:启动任务 - CHANGE:修改任务 - RETRY:重试任务 - RESET:重置任务 - DELETE:删除任务 - QUERY_PRE_CHECK:预检查 - SWITCH_OVER:容灾倒换 - START_INCR:CASSANDRA启动增量任务 - MODIFY_TASK_NUMBER:CASSANDRA修改线程数配置 - CONTINUE_JOB:oracle-GaussDB分布式:启动失败或者停止的任务 - STOP_JOB:oracle-GaussDB分布式:停止任务 - CONTINUE_CAPTURE:启动抓取 - STOP_CAPTURE:停止抓取 - CONTINUE_APPLY:启动回放 - STOP_APPLY:停止回放 - PAY_ORDER:包年包月支付订单 - UNSUBSCRIBE:包年包月退订 - TO_PERIOD:转包周期 - TO_RENEW:包周期续费 - ORDER_INFO:订单详情 - CHANGE_FLAVOR:规格变更 - CLONE:克隆任务
	UnavailableActions []string `json:"unavailable_actions"`

	// 任务当前操作命令。取值: - API_CONFIGURATION_ACTION:OPEN API配置中的任务能调用。 - CHANGE:修改任务。 - CHANGE_MODE:修改任务模式。 - CHOOSE_OBJECT:选择对象。 - CLONE:克隆任务。 - CONTINUE_APPLY:启动回放,Oracle同步到GaussDB分布式适用。 - CONTINUE_CAPTURE:启动抓取,Oracle同步到GaussDB分布式适用。 - CONTINUE_JOB:启动失败或者停止的任务,Oracle同步到GaussDB分布式适用。 - CREATE:创建任务。 - DELETE:删除任务。 - FREE_RESOURCE:释放资源。 - JUMP_RETRY:跳跃续传任务。 - MODIFY_CONFIGURATION:修改任务配置。 - MODIFY_DB_CONFIG:修改数据库配置。 - MODIFY_TASK_NUMBER:修改线程数配置。 - NODE_FLAVOR_MODIFY:规格变更。 - ORDER_INFO:订单详情。 - PAUSE:暂停任务。 - PAY_ORDER:包年/包月支付订单。 - PRE_CHECK:预检查。 - QUERY_PRE_CHECK:查询预检查结果。 - RESET:重置任务。 - RESET_DB_PWD:重置数据库密码(源库、目标库)。 - RETRY:重试任务。 - START:启动任务。 - START_INCR:启动增量任务。 - STOP_APPLY:停止回放,Oracle同步到GaussDB分布式适用。 - STOP_CAPTURE:停止抓取,Oracle同步到GaussDB分布式适用。 - STOP_JOB:停止任务,Oracle同步到GaussDB分布式适用。 - SWITCH_OVER:灾备倒换。 - TO_PERIOD:转包年/包月任务。 - TO_RENEW:包年/包月任务续费。 - UNSUBSCRIBE:包年/包月任务退订。
	CurrentAction JobActionsCurrentAction `json:"current_action"`
}

JobActions 任务操作命令集合。

func (JobActions) String

func (o JobActions) String() string

type JobActionsCurrentAction

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

func (JobActionsCurrentAction) MarshalJSON

func (c JobActionsCurrentAction) MarshalJSON() ([]byte, error)

func (*JobActionsCurrentAction) UnmarshalJSON

func (c *JobActionsCurrentAction) UnmarshalJSON(b []byte) error

func (JobActionsCurrentAction) Value

func (c JobActionsCurrentAction) Value() string

type JobBaseInfo

type JobBaseInfo struct {

	// 任务名称。 约束:任务名称在4位到50位之间,不区分大小写,可以包含字母、数字、中划线或下划线,不能包括其他特殊字符。 - 最小长度:4 - 最大长度:50
	Name *string `json:"name,omitempty"`

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType *JobBaseInfoJobType `json:"job_type,omitempty"`

	// 灾备类型是否双主灾备。说明: - job_type 是cloudDataGuard时,必填,灾备类型是双主灾备时,multi_write取值true, 否则为false。 - job_type 是其他类型时,multi_write是非必选参数。
	MultiWrite *bool `json:"multi_write,omitempty"`

	// 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。
	EngineType *JobBaseInfoEngineType `json:"engine_type,omitempty"`

	// 迁移方向。取值: - up:入云 ,灾备场景时对应本云为备。 - down:出云,灾备场景时对应本云为主。 - non-dbs:自建。
	JobDirection *JobBaseInfoJobDirection `json:"job_direction,omitempty"`

	// 迁移模式。取值: - FULL_TRANS :全量。 - FULL_INCR_TRANS:全量+增量。 - INCR_TRANS:增量。
	TaskType *JobBaseInfoTaskType `json:"task_type,omitempty"`

	// 网络类型。取值: - eip:公网网络。 - vpc:VPC网络,灾备场景不支持选择VPC网络。 - vpn:VPN、专线网络。
	NetType *JobBaseInfoNetType `json:"net_type,omitempty"`

	// 计费模式,默认按需。取值: - period:包周期。 - on_demand:按需。
	ChargingMode *JobBaseInfoChargingMode `json:"charging_mode,omitempty"`

	// 企业项目ID。 缺省值:\"0\",表示\"default\"企业项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 任务描述。 约束:任务描述不能超过256位,且不能包含!<>&'\"\\特殊字符。
	Description *string `json:"description,omitempty"`

	// 任务定时启动时间。
	StartTime *string `json:"start_time,omitempty"`

	// 任务处于异常状态一段时间后,将会自动结束。单位为天。(范围14-100),不传默认为14天。
	ExpiredDays *string `json:"expired_days,omitempty"`

	// 标签信息,最多添加10个标签。
	Tags *[]ResourceTag `json:"tags,omitempty"`
}

JobBaseInfo 创建任务基本信息体。

func (JobBaseInfo) String

func (o JobBaseInfo) String() string

type JobBaseInfoChargingMode

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

func (JobBaseInfoChargingMode) MarshalJSON

func (c JobBaseInfoChargingMode) MarshalJSON() ([]byte, error)

func (*JobBaseInfoChargingMode) UnmarshalJSON

func (c *JobBaseInfoChargingMode) UnmarshalJSON(b []byte) error

func (JobBaseInfoChargingMode) Value

func (c JobBaseInfoChargingMode) Value() string

type JobBaseInfoChargingModeEnum

type JobBaseInfoChargingModeEnum struct {
	PERIOD    JobBaseInfoChargingMode
	ON_DEMAND JobBaseInfoChargingMode
}

func GetJobBaseInfoChargingModeEnum

func GetJobBaseInfoChargingModeEnum() JobBaseInfoChargingModeEnum

type JobBaseInfoEngineType

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

func (JobBaseInfoEngineType) MarshalJSON

func (c JobBaseInfoEngineType) MarshalJSON() ([]byte, error)

func (*JobBaseInfoEngineType) UnmarshalJSON

func (c *JobBaseInfoEngineType) UnmarshalJSON(b []byte) error

func (JobBaseInfoEngineType) Value

func (c JobBaseInfoEngineType) Value() string

type JobBaseInfoEngineTypeEnum

type JobBaseInfoEngineTypeEnum struct {
	ORACLE_TO_GAUSSDBV5 JobBaseInfoEngineType
}

func GetJobBaseInfoEngineTypeEnum

func GetJobBaseInfoEngineTypeEnum() JobBaseInfoEngineTypeEnum

type JobBaseInfoJobDirection

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

func (JobBaseInfoJobDirection) MarshalJSON

func (c JobBaseInfoJobDirection) MarshalJSON() ([]byte, error)

func (*JobBaseInfoJobDirection) UnmarshalJSON

func (c *JobBaseInfoJobDirection) UnmarshalJSON(b []byte) error

func (JobBaseInfoJobDirection) Value

func (c JobBaseInfoJobDirection) Value() string

type JobBaseInfoJobDirectionEnum

type JobBaseInfoJobDirectionEnum struct {
	UP      JobBaseInfoJobDirection
	DOWN    JobBaseInfoJobDirection
	NON_DBS JobBaseInfoJobDirection
}

func GetJobBaseInfoJobDirectionEnum

func GetJobBaseInfoJobDirectionEnum() JobBaseInfoJobDirectionEnum

type JobBaseInfoJobType

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

func (JobBaseInfoJobType) MarshalJSON

func (c JobBaseInfoJobType) MarshalJSON() ([]byte, error)

func (*JobBaseInfoJobType) UnmarshalJSON

func (c *JobBaseInfoJobType) UnmarshalJSON(b []byte) error

func (JobBaseInfoJobType) Value

func (c JobBaseInfoJobType) Value() string

type JobBaseInfoJobTypeEnum

type JobBaseInfoJobTypeEnum struct {
	MIGRATION        JobBaseInfoJobType
	SYNC             JobBaseInfoJobType
	CLOUD_DATA_GUARD JobBaseInfoJobType
}

func GetJobBaseInfoJobTypeEnum

func GetJobBaseInfoJobTypeEnum() JobBaseInfoJobTypeEnum

type JobBaseInfoNetType

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

func (JobBaseInfoNetType) MarshalJSON

func (c JobBaseInfoNetType) MarshalJSON() ([]byte, error)

func (*JobBaseInfoNetType) UnmarshalJSON

func (c *JobBaseInfoNetType) UnmarshalJSON(b []byte) error

func (JobBaseInfoNetType) Value

func (c JobBaseInfoNetType) Value() string

type JobBaseInfoNetTypeEnum

type JobBaseInfoNetTypeEnum struct {
	EIP JobBaseInfoNetType
	VPC JobBaseInfoNetType
	VPN JobBaseInfoNetType
}

func GetJobBaseInfoNetTypeEnum

func GetJobBaseInfoNetTypeEnum() JobBaseInfoNetTypeEnum

type JobBaseInfoTaskType

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

func (JobBaseInfoTaskType) MarshalJSON

func (c JobBaseInfoTaskType) MarshalJSON() ([]byte, error)

func (*JobBaseInfoTaskType) UnmarshalJSON

func (c *JobBaseInfoTaskType) UnmarshalJSON(b []byte) error

func (JobBaseInfoTaskType) Value

func (c JobBaseInfoTaskType) Value() string

type JobBaseInfoTaskTypeEnum

type JobBaseInfoTaskTypeEnum struct {
	FULL_TRANS      JobBaseInfoTaskType
	FULL_INCR_TRANS JobBaseInfoTaskType
	INCR_TRANS      JobBaseInfoTaskType
}

func GetJobBaseInfoTaskTypeEnum

func GetJobBaseInfoTaskTypeEnum() JobBaseInfoTaskTypeEnum

type JobDetailResp

type JobDetailResp struct {

	// 任务ID。
	Id *string `json:"id,omitempty"`

	// 任务状态。
	Status *string `json:"status,omitempty"`

	// 任务创建时间。
	CreateTime *string `json:"create_time,omitempty"`

	// 列表中的项目总数,与分页无关。
	TotalCount *int32 `json:"total_count,omitempty"`

	// 多任务主节点的任务ID。
	MasterJobId *string `json:"master_job_id,omitempty"`

	BaseInfo *JobBaseInfo `json:"base_info,omitempty"`

	// 任务源数据库信息体。
	SourceEndpoint *[]JobEndpointInfo `json:"source_endpoint,omitempty"`

	// 任务目标数据库信息体。
	TargetEndpoint *[]JobEndpointInfo `json:"target_endpoint,omitempty"`

	AlarmNotify *AlarmNotifyConfig `json:"alarm_notify,omitempty"`

	// 限速信息体。 - 限速:自定义的最大迁移速度,迁移过程中的迁移速度将不会超过该速度。  - 不限速:对迁移速度不进行限制,通常会最大化使用源数据库的出口带宽。该流速模式同时会对源数据库造成读消耗,消耗取决于源数据库的出口带宽。比如:源数据库的出口带宽为100MB/s,假设高速模式使用了80%带宽,则迁移对源数据库将造成80MB/s的读操作IO消耗。
	SpeedLimit *[]SpeedLimitInfo `json:"speed_limit,omitempty"`

	UserMigration *UserMigrationInfo `json:"user_migration,omitempty"`

	PolicyConfig *PolicyConfig `json:"policy_config,omitempty"`

	DbParam *DbParamInfo `json:"db_param,omitempty"`

	TuningParams *TuningParamInfo `json:"tuning_params,omitempty"`

	PeriodOrder *PeriodOrderInfo `json:"period_order,omitempty"`

	NodeInfo *JobNodeInfo `json:"node_info,omitempty"`

	// 日志查询结果信息体。
	Logs *[]TaskLogInfo `json:"logs,omitempty"`

	// 网络打通测试结果信息体。
	NetworkResults *[]QueryNetworkResult `json:"network_results,omitempty"`

	PrecheckResult *QueryPreCheckResult `json:"precheck_result,omitempty"`

	ProgressInfo *JobProgressInfo `json:"progress_info,omitempty"`

	MigrationObjectProgressInfo *QueryMigrationObjectProgressInfo `json:"migration_object_progress_info,omitempty"`

	Metrics *QueryMetricResult `json:"metrics,omitempty"`

	CompareResult *CompareResultInfo `json:"compare_result,omitempty"`

	SupportImportFileResp *SupportImportFileResult `json:"support_import_file_resp,omitempty"`

	// 由开关和版本共同控制的任务级别的功能列表。
	InstanceFeatures map[string]string `json:"instance_features,omitempty"`

	// 任务版本。
	TaskVersion *string `json:"task_version,omitempty"`
}

JobDetailResp 任务详情响应体。

func (JobDetailResp) String

func (o JobDetailResp) String() string

type JobEndpointInfo

type JobEndpointInfo struct {

	// 数据库类型。取值:  - oracle:Oracle。 - gaussdbv5:GaussDB分布式版。
	DbType JobEndpointInfoDbType `json:"db_type"`

	// 数据库实例类型。取值:  - offline:自建数据库。 - ecs:华为云ECS自建数据库。 - cloud:华为云数据库。
	EndpointType JobEndpointInfoEndpointType `json:"endpoint_type"`

	// 数据库实例角色。取值: - so:源库。 - ta:目标库。
	EndpointRole JobEndpointInfoEndpointRole `json:"endpoint_role"`

	Endpoint *BaseEndpoint `json:"endpoint"`

	Cloud *CloudBaseInfo `json:"cloud,omitempty"`

	Vpc *CloudVpcInfo `json:"vpc,omitempty"`

	Config *BaseEndpointConfig `json:"config,omitempty"`

	Ssl *EndpointSslConfig `json:"ssl,omitempty"`
}

JobEndpointInfo 创建任务数据库信息体。

func (JobEndpointInfo) String

func (o JobEndpointInfo) String() string

type JobEndpointInfoDbType

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

func (JobEndpointInfoDbType) MarshalJSON

func (c JobEndpointInfoDbType) MarshalJSON() ([]byte, error)

func (*JobEndpointInfoDbType) UnmarshalJSON

func (c *JobEndpointInfoDbType) UnmarshalJSON(b []byte) error

func (JobEndpointInfoDbType) Value

func (c JobEndpointInfoDbType) Value() string

type JobEndpointInfoDbTypeEnum

type JobEndpointInfoDbTypeEnum struct {
	ORACLE    JobEndpointInfoDbType
	GAUSSDBV5 JobEndpointInfoDbType
}

func GetJobEndpointInfoDbTypeEnum

func GetJobEndpointInfoDbTypeEnum() JobEndpointInfoDbTypeEnum

type JobEndpointInfoEndpointRole

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

func (JobEndpointInfoEndpointRole) MarshalJSON

func (c JobEndpointInfoEndpointRole) MarshalJSON() ([]byte, error)

func (*JobEndpointInfoEndpointRole) UnmarshalJSON

func (c *JobEndpointInfoEndpointRole) UnmarshalJSON(b []byte) error

func (JobEndpointInfoEndpointRole) Value

type JobEndpointInfoEndpointRoleEnum

type JobEndpointInfoEndpointRoleEnum struct {
	SO JobEndpointInfoEndpointRole
	TA JobEndpointInfoEndpointRole
}

func GetJobEndpointInfoEndpointRoleEnum

func GetJobEndpointInfoEndpointRoleEnum() JobEndpointInfoEndpointRoleEnum

type JobEndpointInfoEndpointType

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

func (JobEndpointInfoEndpointType) MarshalJSON

func (c JobEndpointInfoEndpointType) MarshalJSON() ([]byte, error)

func (*JobEndpointInfoEndpointType) UnmarshalJSON

func (c *JobEndpointInfoEndpointType) UnmarshalJSON(b []byte) error

func (JobEndpointInfoEndpointType) Value

type JobEndpointInfoEndpointTypeEnum

type JobEndpointInfoEndpointTypeEnum struct {
	OFFLINE JobEndpointInfoEndpointType
	ECS     JobEndpointInfoEndpointType
	CLOUD   JobEndpointInfoEndpointType
}

func GetJobEndpointInfoEndpointTypeEnum

func GetJobEndpointInfoEndpointTypeEnum() JobEndpointInfoEndpointTypeEnum

type JobLinkResp

type JobLinkResp struct {

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType JobLinkRespJobType `json:"job_type"`

	// 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。
	EngineType JobLinkRespEngineType `json:"engine_type"`

	// 源数据库实例类型。取值: - offline:自建数据库。 - ecs:华为云ECS自建数据库。 - cloud:华为云数据库。
	SourceEndpointType JobLinkRespSourceEndpointType `json:"source_endpoint_type"`

	// 目标数据库实例类型。取值: - offline:自建数据库。 - ecs:华为云ECS自建数据库。 - cloud:华为云数据库。
	TargetEndpointType JobLinkRespTargetEndpointType `json:"target_endpoint_type"`

	// 迁移方向。取值: - up:入云 ,灾备场景时对应本云为备。 - down:出云,灾备场景时对应本云为主。 - non-dbs:自建。
	JobDirection JobLinkRespJobDirection `json:"job_direction"`

	// 网络类型。取值: - eip:公网网络。 - vpc:VPC网络,灾备场景不支持选择VPC网络。 - vpn:VPN、专线网络。
	NetType JobLinkRespNetType `json:"net_type"`

	// 迁移模式。取值: - FULL_TRANS :全量。 - FULL_INCR_TRANS:全量+增量。 - INCR_TRANS:增量。
	TaskTypes []JobLinkRespTaskTypes `json:"task_types"`

	// 引擎实例模式。取值: - Single:单机模式。 - Ha:主备模式。 - Cluster:集群模式。 - Sharding:分片模式。 - Independent:GaussDB独立部署模式。
	ClusterModes []JobLinkRespClusterModes `json:"cluster_modes"`

	// 链路描述。
	Description string `json:"description"`
}

JobLinkResp 可用链路返回体。

func (JobLinkResp) String

func (o JobLinkResp) String() string

type JobLinkRespClusterModes

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

func (JobLinkRespClusterModes) MarshalJSON

func (c JobLinkRespClusterModes) MarshalJSON() ([]byte, error)

func (*JobLinkRespClusterModes) UnmarshalJSON

func (c *JobLinkRespClusterModes) UnmarshalJSON(b []byte) error

func (JobLinkRespClusterModes) Value

func (c JobLinkRespClusterModes) Value() string

type JobLinkRespClusterModesEnum

type JobLinkRespClusterModesEnum struct {
	SINGLE      JobLinkRespClusterModes
	HA          JobLinkRespClusterModes
	CLUSTER     JobLinkRespClusterModes
	SHARDING    JobLinkRespClusterModes
	INDEPENDENT JobLinkRespClusterModes
}

func GetJobLinkRespClusterModesEnum

func GetJobLinkRespClusterModesEnum() JobLinkRespClusterModesEnum

type JobLinkRespEngineType

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

func (JobLinkRespEngineType) MarshalJSON

func (c JobLinkRespEngineType) MarshalJSON() ([]byte, error)

func (*JobLinkRespEngineType) UnmarshalJSON

func (c *JobLinkRespEngineType) UnmarshalJSON(b []byte) error

func (JobLinkRespEngineType) Value

func (c JobLinkRespEngineType) Value() string

type JobLinkRespEngineTypeEnum

type JobLinkRespEngineTypeEnum struct {
	ORACLE_TO_GAUSSDBV5 JobLinkRespEngineType
}

func GetJobLinkRespEngineTypeEnum

func GetJobLinkRespEngineTypeEnum() JobLinkRespEngineTypeEnum

type JobLinkRespJobDirection

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

func (JobLinkRespJobDirection) MarshalJSON

func (c JobLinkRespJobDirection) MarshalJSON() ([]byte, error)

func (*JobLinkRespJobDirection) UnmarshalJSON

func (c *JobLinkRespJobDirection) UnmarshalJSON(b []byte) error

func (JobLinkRespJobDirection) Value

func (c JobLinkRespJobDirection) Value() string

type JobLinkRespJobDirectionEnum

type JobLinkRespJobDirectionEnum struct {
	UP      JobLinkRespJobDirection
	DOWN    JobLinkRespJobDirection
	NON_DBS JobLinkRespJobDirection
}

func GetJobLinkRespJobDirectionEnum

func GetJobLinkRespJobDirectionEnum() JobLinkRespJobDirectionEnum

type JobLinkRespJobType

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

func (JobLinkRespJobType) MarshalJSON

func (c JobLinkRespJobType) MarshalJSON() ([]byte, error)

func (*JobLinkRespJobType) UnmarshalJSON

func (c *JobLinkRespJobType) UnmarshalJSON(b []byte) error

func (JobLinkRespJobType) Value

func (c JobLinkRespJobType) Value() string

type JobLinkRespJobTypeEnum

type JobLinkRespJobTypeEnum struct {
	MIGRATION        JobLinkRespJobType
	SYNC             JobLinkRespJobType
	CLOUD_DATA_GUARD JobLinkRespJobType
}

func GetJobLinkRespJobTypeEnum

func GetJobLinkRespJobTypeEnum() JobLinkRespJobTypeEnum

type JobLinkRespNetType

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

func (JobLinkRespNetType) MarshalJSON

func (c JobLinkRespNetType) MarshalJSON() ([]byte, error)

func (*JobLinkRespNetType) UnmarshalJSON

func (c *JobLinkRespNetType) UnmarshalJSON(b []byte) error

func (JobLinkRespNetType) Value

func (c JobLinkRespNetType) Value() string

type JobLinkRespNetTypeEnum

type JobLinkRespNetTypeEnum struct {
	EIP JobLinkRespNetType
	VPC JobLinkRespNetType
	VPN JobLinkRespNetType
}

func GetJobLinkRespNetTypeEnum

func GetJobLinkRespNetTypeEnum() JobLinkRespNetTypeEnum

type JobLinkRespSourceEndpointType

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

func (JobLinkRespSourceEndpointType) MarshalJSON

func (c JobLinkRespSourceEndpointType) MarshalJSON() ([]byte, error)

func (*JobLinkRespSourceEndpointType) UnmarshalJSON

func (c *JobLinkRespSourceEndpointType) UnmarshalJSON(b []byte) error

func (JobLinkRespSourceEndpointType) Value

type JobLinkRespSourceEndpointTypeEnum

type JobLinkRespSourceEndpointTypeEnum struct {
	OFFLINE JobLinkRespSourceEndpointType
	ECS     JobLinkRespSourceEndpointType
	CLOUD   JobLinkRespSourceEndpointType
}

func GetJobLinkRespSourceEndpointTypeEnum

func GetJobLinkRespSourceEndpointTypeEnum() JobLinkRespSourceEndpointTypeEnum

type JobLinkRespTargetEndpointType

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

func (JobLinkRespTargetEndpointType) MarshalJSON

func (c JobLinkRespTargetEndpointType) MarshalJSON() ([]byte, error)

func (*JobLinkRespTargetEndpointType) UnmarshalJSON

func (c *JobLinkRespTargetEndpointType) UnmarshalJSON(b []byte) error

func (JobLinkRespTargetEndpointType) Value

type JobLinkRespTargetEndpointTypeEnum

type JobLinkRespTargetEndpointTypeEnum struct {
	OFFLINE JobLinkRespTargetEndpointType
	ECS     JobLinkRespTargetEndpointType
	CLOUD   JobLinkRespTargetEndpointType
}

func GetJobLinkRespTargetEndpointTypeEnum

func GetJobLinkRespTargetEndpointTypeEnum() JobLinkRespTargetEndpointTypeEnum

type JobLinkRespTaskTypes

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

func (JobLinkRespTaskTypes) MarshalJSON

func (c JobLinkRespTaskTypes) MarshalJSON() ([]byte, error)

func (*JobLinkRespTaskTypes) UnmarshalJSON

func (c *JobLinkRespTaskTypes) UnmarshalJSON(b []byte) error

func (JobLinkRespTaskTypes) Value

func (c JobLinkRespTaskTypes) Value() string

type JobLinkRespTaskTypesEnum

type JobLinkRespTaskTypesEnum struct {
	FULL_TRANS      JobLinkRespTaskTypes
	FULL_INCR_TRANS JobLinkRespTaskTypes
	INCR_TRANS      JobLinkRespTaskTypes
}

func GetJobLinkRespTaskTypesEnum

func GetJobLinkRespTaskTypesEnum() JobLinkRespTaskTypesEnum

type JobListResp

type JobListResp struct {

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 任务状态。取值: - CREATING:创建中。 - CREATE_FAILED:创建失败。 - CONFIGURATION:配置中。 - STARTJOBING:启动中。 - WAITING_FOR_START:等待启动中。 - START_JOB_FAILED:任务启动失败。 - FULL_TRANSFER_STARTED:全量迁移中 灾备场景为初始化。 - FULL_TRANSFER_FAILED:全量迁移失败 灾备场景为初始化失败。 - FULL_TRANSFER_COMPLETE:全量迁移完成 灾备场景为初始化完成。 - INCRE_TRANSFER_STARTED:增量迁移中 灾备场景为灾备中。 - INCRE_TRANSFER_FAILED:增量迁移失败 灾备场景为灾备异常。 - RELEASE_RESOURCE_STARTED:结束任务中。 - RELEASE_RESOURCE_FAILED:结束任务失败。 - RELEASE_RESOURCE_COMPLETE:已结束。 - CHANGE_JOB_STARTED:任务变更中。 - CHANGE_JOB_FAILED:任务变更失败。 - CHILD_TRANSFER_STARTING:子任务启动中。 - CHILD_TRANSFER_STARTED:子任务迁移中。 - CHILD_TRANSFER_COMPLETE:子任务迁移完成。 - CHILD_TRANSFER_FAILED:子任务迁移失败。 - RELEASE_CHILD_TRANSFER_STARTED:子任务结束中。 - RELEASE_CHILD_TRANSFER_COMPLETE:子任务已结束。
	Status JobListRespStatus `json:"status"`

	// 任务描述。
	Description string `json:"description"`

	// 任务创建时间。
	CreateTime string `json:"create_time"`

	// 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。
	EngineType JobListRespEngineType `json:"engine_type"`

	// 网络类型。取值: - eip:公网网络。 - vpc:VPC网络,灾备场景不支持选择VPC网络。 - vpn:VPN、专线网络。
	NetType JobListRespNetType `json:"net_type"`

	// 计费模式。取值: - period:包周期。 - on_demand:按需。
	ChargingMode JobListRespChargingMode `json:"charging_mode"`

	// 是否计费。
	BillingTag bool `json:"billing_tag"`

	// 任务方向。取值: - up:入云 ,灾备场景时对应本云为备。 - down:出云,灾备场景时对应本云为主。 - non-dbs:自建。
	JobDirection JobListRespJobDirection `json:"job_direction"`

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType JobListRespJobType `json:"job_type"`

	// 任务模式。取值: - FULL_TRANS :全量。 - FULL_INCR_TRANS:全量+增量。 - INCR_TRANS:增量。
	TaskType JobListRespTaskType `json:"task_type"`

	// 企业项目ID。
	EnterpriseProjectId string `json:"enterprise_project_id"`

	// 任务模式。取值: - single:单任务。 - sync_child:同步子任务。 - multi_to_single:多对一任务。
	JobMode JobListRespJobMode `json:"job_mode"`

	// 任务角色。取值: - parent:父任务。 - child:子任务。 - master:主任务。 - slave:备任务。
	JobModeRole JobListRespJobModeRole `json:"job_mode_role"`

	// 是否跨AZ任务。
	IsMultiAz bool `json:"is_multi_az"`

	// 任务节点角色。
	NodeRole string `json:"node_role"`

	// 是否新框架。
	NodeNewFramework bool `json:"node_new_framework"`

	JobAction *JobActions `json:"job_action"`

	// 子任务列表信息体。
	Children *[]ChildrenJobListResp `json:"children,omitempty"`
}

JobListResp 任务列表响应体。

func (JobListResp) String

func (o JobListResp) String() string

type JobListRespChargingMode

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

func (JobListRespChargingMode) MarshalJSON

func (c JobListRespChargingMode) MarshalJSON() ([]byte, error)

func (*JobListRespChargingMode) UnmarshalJSON

func (c *JobListRespChargingMode) UnmarshalJSON(b []byte) error

func (JobListRespChargingMode) Value

func (c JobListRespChargingMode) Value() string

type JobListRespChargingModeEnum

type JobListRespChargingModeEnum struct {
	PERIOD    JobListRespChargingMode
	ON_DEMAND JobListRespChargingMode
}

func GetJobListRespChargingModeEnum

func GetJobListRespChargingModeEnum() JobListRespChargingModeEnum

type JobListRespEngineType

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

func (JobListRespEngineType) MarshalJSON

func (c JobListRespEngineType) MarshalJSON() ([]byte, error)

func (*JobListRespEngineType) UnmarshalJSON

func (c *JobListRespEngineType) UnmarshalJSON(b []byte) error

func (JobListRespEngineType) Value

func (c JobListRespEngineType) Value() string

type JobListRespEngineTypeEnum

type JobListRespEngineTypeEnum struct {
	ORACLE_TO_GAUSSDBV5 JobListRespEngineType
}

func GetJobListRespEngineTypeEnum

func GetJobListRespEngineTypeEnum() JobListRespEngineTypeEnum

type JobListRespJobDirection

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

func (JobListRespJobDirection) MarshalJSON

func (c JobListRespJobDirection) MarshalJSON() ([]byte, error)

func (*JobListRespJobDirection) UnmarshalJSON

func (c *JobListRespJobDirection) UnmarshalJSON(b []byte) error

func (JobListRespJobDirection) Value

func (c JobListRespJobDirection) Value() string

type JobListRespJobDirectionEnum

type JobListRespJobDirectionEnum struct {
	UP      JobListRespJobDirection
	DOWN    JobListRespJobDirection
	NON_DBS JobListRespJobDirection
}

func GetJobListRespJobDirectionEnum

func GetJobListRespJobDirectionEnum() JobListRespJobDirectionEnum

type JobListRespJobMode

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

func (JobListRespJobMode) MarshalJSON

func (c JobListRespJobMode) MarshalJSON() ([]byte, error)

func (*JobListRespJobMode) UnmarshalJSON

func (c *JobListRespJobMode) UnmarshalJSON(b []byte) error

func (JobListRespJobMode) Value

func (c JobListRespJobMode) Value() string

type JobListRespJobModeEnum

type JobListRespJobModeEnum struct {
	SINGLE          JobListRespJobMode
	SYNC_CHILD      JobListRespJobMode
	MULTI_TO_SINGLE JobListRespJobMode
}

func GetJobListRespJobModeEnum

func GetJobListRespJobModeEnum() JobListRespJobModeEnum

type JobListRespJobModeRole

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

func (JobListRespJobModeRole) MarshalJSON

func (c JobListRespJobModeRole) MarshalJSON() ([]byte, error)

func (*JobListRespJobModeRole) UnmarshalJSON

func (c *JobListRespJobModeRole) UnmarshalJSON(b []byte) error

func (JobListRespJobModeRole) Value

func (c JobListRespJobModeRole) Value() string

type JobListRespJobModeRoleEnum

type JobListRespJobModeRoleEnum struct {
	PARENT JobListRespJobModeRole
	CHILD  JobListRespJobModeRole
	MASTER JobListRespJobModeRole
	SLAVE  JobListRespJobModeRole
}

func GetJobListRespJobModeRoleEnum

func GetJobListRespJobModeRoleEnum() JobListRespJobModeRoleEnum

type JobListRespJobType

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

func (JobListRespJobType) MarshalJSON

func (c JobListRespJobType) MarshalJSON() ([]byte, error)

func (*JobListRespJobType) UnmarshalJSON

func (c *JobListRespJobType) UnmarshalJSON(b []byte) error

func (JobListRespJobType) Value

func (c JobListRespJobType) Value() string

type JobListRespJobTypeEnum

type JobListRespJobTypeEnum struct {
	MIGRATION        JobListRespJobType
	SYNC             JobListRespJobType
	CLOUD_DATA_GUARD JobListRespJobType
}

func GetJobListRespJobTypeEnum

func GetJobListRespJobTypeEnum() JobListRespJobTypeEnum

type JobListRespNetType

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

func (JobListRespNetType) MarshalJSON

func (c JobListRespNetType) MarshalJSON() ([]byte, error)

func (*JobListRespNetType) UnmarshalJSON

func (c *JobListRespNetType) UnmarshalJSON(b []byte) error

func (JobListRespNetType) Value

func (c JobListRespNetType) Value() string

type JobListRespNetTypeEnum

type JobListRespNetTypeEnum struct {
	EIP JobListRespNetType
	VPC JobListRespNetType
	VPN JobListRespNetType
}

func GetJobListRespNetTypeEnum

func GetJobListRespNetTypeEnum() JobListRespNetTypeEnum

type JobListRespStatus

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

func (JobListRespStatus) MarshalJSON

func (c JobListRespStatus) MarshalJSON() ([]byte, error)

func (*JobListRespStatus) UnmarshalJSON

func (c *JobListRespStatus) UnmarshalJSON(b []byte) error

func (JobListRespStatus) Value

func (c JobListRespStatus) Value() string

type JobListRespStatusEnum

type JobListRespStatusEnum struct {
	CREATING                        JobListRespStatus
	CREATE_FAILED                   JobListRespStatus
	CONFIGURATION                   JobListRespStatus
	STARTJOBING                     JobListRespStatus
	WAITING_FOR_START               JobListRespStatus
	START_JOB_FAILED                JobListRespStatus
	FULL_TRANSFER_STARTED           JobListRespStatus
	FULL_TRANSFER_FAILED            JobListRespStatus
	FULL_TRANSFER_COMPLETE          JobListRespStatus
	INCRE_TRANSFER_STARTED          JobListRespStatus
	INCRE_TRANSFER_FAILED           JobListRespStatus
	RELEASE_RESOURCE_STARTED        JobListRespStatus
	RELEASE_RESOURCE_FAILED         JobListRespStatus
	RELEASE_RESOURCE_COMPLETE       JobListRespStatus
	CHANGE_JOB_STARTED              JobListRespStatus
	CHANGE_JOB_FAILED               JobListRespStatus
	CHILD_TRANSFER_STARTING         JobListRespStatus
	CHILD_TRANSFER_STARTED          JobListRespStatus
	CHILD_TRANSFER_COMPLETE         JobListRespStatus
	CHILD_TRANSFER_FAILED           JobListRespStatus
	RELEASE_CHILD_TRANSFER_STARTED  JobListRespStatus
	RELEASE_CHILD_TRANSFER_COMPLETE JobListRespStatus
}

func GetJobListRespStatusEnum

func GetJobListRespStatusEnum() JobListRespStatusEnum

type JobListRespTaskType

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

func (JobListRespTaskType) MarshalJSON

func (c JobListRespTaskType) MarshalJSON() ([]byte, error)

func (*JobListRespTaskType) UnmarshalJSON

func (c *JobListRespTaskType) UnmarshalJSON(b []byte) error

func (JobListRespTaskType) Value

func (c JobListRespTaskType) Value() string

type JobListRespTaskTypeEnum

type JobListRespTaskTypeEnum struct {
	FULL_TRANS      JobListRespTaskType
	FULL_INCR_TRANS JobListRespTaskType
	INCR_TRANS      JobListRespTaskType
}

func GetJobListRespTaskTypeEnum

func GetJobListRespTaskTypeEnum() JobListRespTaskTypeEnum

type JobNodeBaseInfo added in v0.1.49

type JobNodeBaseInfo struct {

	// 实例类型。取值: - single:单机。 - ha:主备。
	InstanceType JobNodeBaseInfoInstanceType `json:"instance_type"`

	// CPU架构。取值: - x86 - arm
	Arch JobNodeBaseInfoArch `json:"arch"`

	// 可用区ID。 约束:对于任务实例类型不是单机的实例,需要分别为实例所有节点指定可用区,并用“,”英文逗号隔开。示例: - 实例类型为single:\"cn-north-4a\" - 实例类型为ha:\"cn-north-4a,cn-north-4b\"
	AvailabilityZone string `json:"availability_zone"`

	// 状态。
	Status *string `json:"status,omitempty"`

	// 任务主备角色。
	Role *string `json:"role,omitempty"`
}

JobNodeBaseInfo 任务实例基本信息体。

func (JobNodeBaseInfo) String added in v0.1.49

func (o JobNodeBaseInfo) String() string

type JobNodeBaseInfoArch added in v0.1.49

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

func (JobNodeBaseInfoArch) MarshalJSON added in v0.1.49

func (c JobNodeBaseInfoArch) MarshalJSON() ([]byte, error)

func (*JobNodeBaseInfoArch) UnmarshalJSON added in v0.1.49

func (c *JobNodeBaseInfoArch) UnmarshalJSON(b []byte) error

func (JobNodeBaseInfoArch) Value added in v0.1.49

func (c JobNodeBaseInfoArch) Value() string

type JobNodeBaseInfoArchEnum added in v0.1.49

type JobNodeBaseInfoArchEnum struct {
	X86 JobNodeBaseInfoArch
	ARM JobNodeBaseInfoArch
}

func GetJobNodeBaseInfoArchEnum added in v0.1.49

func GetJobNodeBaseInfoArchEnum() JobNodeBaseInfoArchEnum

type JobNodeBaseInfoInstanceType added in v0.1.49

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

func (JobNodeBaseInfoInstanceType) MarshalJSON added in v0.1.49

func (c JobNodeBaseInfoInstanceType) MarshalJSON() ([]byte, error)

func (*JobNodeBaseInfoInstanceType) UnmarshalJSON added in v0.1.49

func (c *JobNodeBaseInfoInstanceType) UnmarshalJSON(b []byte) error

func (JobNodeBaseInfoInstanceType) Value added in v0.1.49

type JobNodeBaseInfoInstanceTypeEnum added in v0.1.49

type JobNodeBaseInfoInstanceTypeEnum struct {
	SINGLE JobNodeBaseInfoInstanceType
	HA     JobNodeBaseInfoInstanceType
}

func GetJobNodeBaseInfoInstanceTypeEnum added in v0.1.49

func GetJobNodeBaseInfoInstanceTypeEnum() JobNodeBaseInfoInstanceTypeEnum

type JobNodeInfo

type JobNodeInfo struct {
	Spec *JobNodeSpecInfo `json:"spec"`

	Vpc *JobNodeVpcInfo `json:"vpc,omitempty"`

	BaseInfo *JobNodeBaseInfo `json:"base_info,omitempty"`
}

JobNodeInfo 任务实例信息体。

func (JobNodeInfo) String

func (o JobNodeInfo) String() string

type JobNodeSpecInfo

type JobNodeSpecInfo struct {

	// 实例规格编码。取值: - micro:极小规格。 - small:小规格。 - medium:中规格。 - high:大规格。
	NodeType JobNodeSpecInfoNodeType `json:"node_type"`
}

JobNodeSpecInfo 任务实例规格信息体。

func (JobNodeSpecInfo) String

func (o JobNodeSpecInfo) String() string

type JobNodeSpecInfoNodeType

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

func (JobNodeSpecInfoNodeType) MarshalJSON

func (c JobNodeSpecInfoNodeType) MarshalJSON() ([]byte, error)

func (*JobNodeSpecInfoNodeType) UnmarshalJSON

func (c *JobNodeSpecInfoNodeType) UnmarshalJSON(b []byte) error

func (JobNodeSpecInfoNodeType) Value

func (c JobNodeSpecInfoNodeType) Value() string

type JobNodeSpecInfoNodeTypeEnum

type JobNodeSpecInfoNodeTypeEnum struct {
	MICRO  JobNodeSpecInfoNodeType
	SMALL  JobNodeSpecInfoNodeType
	MEDIUM JobNodeSpecInfoNodeType
	HIGH   JobNodeSpecInfoNodeType
}

func GetJobNodeSpecInfoNodeTypeEnum

func GetJobNodeSpecInfoNodeTypeEnum() JobNodeSpecInfoNodeTypeEnum

type JobNodeVpcInfo

type JobNodeVpcInfo struct {

	// 任务实例所在虚拟私有云ID。
	VpcId string `json:"vpc_id"`

	// 任务实例所在子网ID。
	SubnetId string `json:"subnet_id"`

	// 指定创建任务实例IP地址,多个IP端口之间请用“,”英文逗号分隔,目前仅支持设置IPv4地址,获取方法如下: - 方法1:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找子网的网段,选择未被占用的IP 。 - 方法2:通过虚拟私有云服务的API接口查询,具体操作可参考查询私有IP列表,选择“device_owner”为空的私有IP。 示例: \"192.168.0.10,192.168.0.11\"
	CustomNodeIp *string `json:"custom_node_ip,omitempty"`

	// 任务实例所在的安全组ID。
	SecurityGroupId *string `json:"security_group_id,omitempty"`
}

JobNodeVpcInfo 任务实例VPC信息体。

func (JobNodeVpcInfo) String

func (o JobNodeVpcInfo) String() string

type JobProgressInfo

type JobProgressInfo struct {

	// 迁移对比百分比。
	Progress *string `json:"progress,omitempty"`

	// 增量迁移时延(单位:s)。
	IncrTransDelay *string `json:"incr_trans_delay,omitempty"`

	// 增量迁移时延(单位:ms)。
	IncrTransDelayMillis *string `json:"incr_trans_delay_millis,omitempty"`

	// 迁移模式。
	TaskMode *string `json:"task_mode,omitempty"`

	// 迁移状态。
	TransferStatus *string `json:"transfer_status,omitempty"`

	// 迁移时间。
	ProcessTime *string `json:"process_time,omitempty"`

	// 预计剩余时间。
	RemainingTime *string `json:"remaining_time,omitempty"`

	// 全量迁移进度详情。
	ProgressMap map[string]ProgressCompleteInfo `json:"progress_map,omitempty"`
}

JobProgressInfo 任务进度信息。

func (JobProgressInfo) String

func (o JobProgressInfo) String() string

type LineCompareOverviewInfo

type LineCompareOverviewInfo struct {

	// 源库库名。
	SourceDbName *string `json:"source_db_name,omitempty"`

	// 目标库库名。
	TargetDbName *string `json:"target_db_name,omitempty"`

	// 行对比结果。取值: - CONSISTENT:一致。 - INCONSISTENT:不一致。 - COMPARING:正在对比。 - WAITING_FOR_COMPARISON:等待对比。 - FAILED_TO_COMPARE:对比失败。 - TARGET_DB_NOT_EXIST:目标库不存在。 - CAN_NOT_COMPARE:无法对比。
	Status *LineCompareOverviewInfoStatus `json:"status,omitempty"`
}

LineCompareOverviewInfo 行数对比概览信息体。

func (LineCompareOverviewInfo) String

func (o LineCompareOverviewInfo) String() string

type LineCompareOverviewInfoStatus

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

func (LineCompareOverviewInfoStatus) MarshalJSON

func (c LineCompareOverviewInfoStatus) MarshalJSON() ([]byte, error)

func (*LineCompareOverviewInfoStatus) UnmarshalJSON

func (c *LineCompareOverviewInfoStatus) UnmarshalJSON(b []byte) error

func (LineCompareOverviewInfoStatus) Value

type LineCompareOverviewInfoStatusEnum

type LineCompareOverviewInfoStatusEnum struct {
	CONSISTENT             LineCompareOverviewInfoStatus
	INCONSISTENT           LineCompareOverviewInfoStatus
	COMPARING              LineCompareOverviewInfoStatus
	WAITING_FOR_COMPARISON LineCompareOverviewInfoStatus
	FAILED_TO_COMPARE      LineCompareOverviewInfoStatus
	TARGET_DB_NOT_EXIST    LineCompareOverviewInfoStatus
	CAN_NOT_COMPARE        LineCompareOverviewInfoStatus
}

func GetLineCompareOverviewInfoStatusEnum

func GetLineCompareOverviewInfoStatusEnum() LineCompareOverviewInfoStatusEnum

type ListAsyncJobDetailRequest

type ListAsyncJobDetailRequest struct {

	// 批量异步创建的任务ID,由创建批量异步任务接口返回。
	AsyncJobId string `json:"async_job_id"`

	// 请求语言类型。
	XLanguage *ListAsyncJobDetailRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`
}

ListAsyncJobDetailRequest Request Object

func (ListAsyncJobDetailRequest) String

func (o ListAsyncJobDetailRequest) String() string

type ListAsyncJobDetailRequestXLanguage

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

func (ListAsyncJobDetailRequestXLanguage) MarshalJSON

func (c ListAsyncJobDetailRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListAsyncJobDetailRequestXLanguage) UnmarshalJSON

func (c *ListAsyncJobDetailRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListAsyncJobDetailRequestXLanguage) Value

type ListAsyncJobDetailRequestXLanguageEnum

type ListAsyncJobDetailRequestXLanguageEnum struct {
	EN_US ListAsyncJobDetailRequestXLanguage
	ZH_CN ListAsyncJobDetailRequestXLanguage
}

func GetListAsyncJobDetailRequestXLanguageEnum

func GetListAsyncJobDetailRequestXLanguageEnum() ListAsyncJobDetailRequestXLanguageEnum

type ListAsyncJobDetailResponse

type ListAsyncJobDetailResponse struct {

	// 列表中的项目总数,与分页无关。
	TotalCount int32 `json:"total_count"`

	// 查询租户指定ID批量异步任务详情响应体。
	Jobs           []JobDetailResp `json:"jobs"`
	HttpStatusCode int             `json:"-"`
}

ListAsyncJobDetailResponse Response Object

func (ListAsyncJobDetailResponse) String

type ListAsyncJobsRequest

type ListAsyncJobsRequest struct {

	// 请求语言类型。
	XLanguage *ListAsyncJobsRequestXLanguage `json:"X-Language,omitempty"`

	// 批量异步创建的任务ID。
	AsyncJobId *string `json:"async_job_id,omitempty"`

	// 批量异步创建的任务状态。
	Status *string `json:"status,omitempty"`

	// 批量异步创建的任务的租户名。
	DomainName *string `json:"domain_name,omitempty"`

	// 批量异步创建的任务的用户名。
	UserName *string `json:"user_name,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`

	// 返回结果按该关键字排序,默认为“create_time”。
	SortKey *string `json:"sort_key,omitempty"`

	// 降序或升序(分别对应desc和asc,默认为“desc”)。
	SortDir *string `json:"sort_dir,omitempty"`
}

ListAsyncJobsRequest Request Object

func (ListAsyncJobsRequest) String

func (o ListAsyncJobsRequest) String() string

type ListAsyncJobsRequestXLanguage

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

func (ListAsyncJobsRequestXLanguage) MarshalJSON

func (c ListAsyncJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListAsyncJobsRequestXLanguage) UnmarshalJSON

func (c *ListAsyncJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListAsyncJobsRequestXLanguage) Value

type ListAsyncJobsRequestXLanguageEnum

type ListAsyncJobsRequestXLanguageEnum struct {
	EN_US ListAsyncJobsRequestXLanguage
	ZH_CN ListAsyncJobsRequestXLanguage
}

func GetListAsyncJobsRequestXLanguageEnum

func GetListAsyncJobsRequestXLanguageEnum() ListAsyncJobsRequestXLanguageEnum

type ListAsyncJobsResponse

type ListAsyncJobsResponse struct {

	// 列表中的项目总数,与分页无关。
	TotalCount int32 `json:"total_count"`

	// 所有批量异步创建任务响应体。
	Jobs           []AsyncJobResp `json:"jobs"`
	HttpStatusCode int            `json:"-"`
}

ListAsyncJobsResponse Response Object

func (ListAsyncJobsResponse) String

func (o ListAsyncJobsResponse) String() string

type ListDbObjectsRequest

type ListDbObjectsRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ListDbObjectsRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`

	// 查询对象信息类型。 取值: - source:查询源库对象信息。 - modified:查询已选择的(已同步的和未下发的)对象信息。 - synchronized:查询已同步的(已下发的)对象信息 , 使用场景在任务处于全量中或者增量中。
	Type string `json:"type"`

	// 查询指定库的信息。
	DbNames *[]string `json:"db_names,omitempty"`
}

ListDbObjectsRequest Request Object

func (ListDbObjectsRequest) String

func (o ListDbObjectsRequest) String() string

type ListDbObjectsRequestXLanguage

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

func (ListDbObjectsRequestXLanguage) MarshalJSON

func (c ListDbObjectsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListDbObjectsRequestXLanguage) UnmarshalJSON

func (c *ListDbObjectsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListDbObjectsRequestXLanguage) Value

type ListDbObjectsRequestXLanguageEnum

type ListDbObjectsRequestXLanguageEnum struct {
	EN_US ListDbObjectsRequestXLanguage
	ZH_CN ListDbObjectsRequestXLanguage
}

func GetListDbObjectsRequestXLanguageEnum

func GetListDbObjectsRequestXLanguageEnum() ListDbObjectsRequestXLanguageEnum

type ListDbObjectsResponse

type ListDbObjectsResponse struct {
	TargetRootDb *TargetRootDb `json:"target_root_db,omitempty"`

	// 数据库对象迁移或同步信息。
	ObjectInfo map[string]DatabaseObject `json:"object_info,omitempty"`

	// 库下表数量的阈值。
	MaxTableNum *int32 `json:"max_table_num,omitempty"`

	// 获取提交查询对象选择信息的状态
	Status *ListDbObjectsResponseStatus `json:"status,omitempty"`

	// 任务id
	Id *string `json:"id,omitempty"`

	// 该数据库在实时同步场景下的类型
	ObjectScope    *string `json:"object_scope,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListDbObjectsResponse Response Object

func (ListDbObjectsResponse) String

func (o ListDbObjectsResponse) String() string

type ListDbObjectsResponseStatus added in v0.1.21

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

func (ListDbObjectsResponseStatus) MarshalJSON added in v0.1.21

func (c ListDbObjectsResponseStatus) MarshalJSON() ([]byte, error)

func (*ListDbObjectsResponseStatus) UnmarshalJSON added in v0.1.21

func (c *ListDbObjectsResponseStatus) UnmarshalJSON(b []byte) error

func (ListDbObjectsResponseStatus) Value added in v0.1.21

type ListDbObjectsResponseStatusEnum added in v0.1.21

type ListDbObjectsResponseStatusEnum struct {
	SUCCESS ListDbObjectsResponseStatus
	FAILED  ListDbObjectsResponseStatus
	PENDING ListDbObjectsResponseStatus
}

func GetListDbObjectsResponseStatusEnum added in v0.1.21

func GetListDbObjectsResponseStatusEnum() ListDbObjectsResponseStatusEnum

type ListJobsRequest

type ListJobsRequest struct {

	// 请求语言类型。
	XLanguage *ListJobsRequestXLanguage `json:"X-Language,omitempty"`

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType ListJobsRequestJobType `json:"job_type"`

	// 任务ID或名称。
	Name *string `json:"name,omitempty"`

	// 任务状态。取值: - CREATING:创建中。 - CREATE_FAILED:创建失败。 - CONFIGURATION:配置中。 - STARTJOBING:启动中。 - WAITING_FOR_START:等待启动中。 - START_JOB_FAILED:任务启动失败。 - FULL_TRANSFER_STARTED:全量迁移中,灾备场景为初始化。 - FULL_TRANSFER_FAILED:全量迁移失败,灾备场景为初始化失败。 - FULL_TRANSFER_COMPLETE:全量迁移完成,灾备场景为初始化完成。 - INCRE_TRANSFER_STARTED:增量迁移中,灾备场景为灾备中。 - INCRE_TRANSFER_FAILED:增量迁移失败,灾备场景为灾备异常。 - RELEASE_RESOURCE_STARTED:结束任务中。 - RELEASE_RESOURCE_FAILED:结束任务失败。 - RELEASE_RESOURCE_COMPLETE:已结束。 - CHANGE_JOB_STARTED:任务变更中。 - CHANGE_JOB_FAILED:任务变更失败。 - CHILD_TRANSFER_STARTING:子任务启动中。 - CHILD_TRANSFER_STARTED:子任务迁移中。 - CHILD_TRANSFER_COMPLETE:子任务迁移完成。 - CHILD_TRANSFER_FAILED:子任务迁移失败。 - RELEASE_CHILD_TRANSFER_STARTED:子任务结束中。 - RELEASE_CHILD_TRANSFER_COMPLETE:子任务已结束。 其中,异常状态可单独查询,也可以通过以下方式查询全部异常任务: CREATE_FAILED,START_JOB_FAILED,FULL_TRANSFER_FAILED,INCRE_TRANSFER_FAILED,RELEASE_RESOURCE_FAILED,CHANGE_JOB_FAILED,CHILD_TRANSFER_FAILED
	Status *ListJobsRequestStatus `json:"status,omitempty"`

	// 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。
	EngineType *ListJobsRequestEngineType `json:"engine_type,omitempty"`

	// 网络类型。取值: - eip:公网网络。 - vpc:VPC网络。 - vpn:VPN、专线网络。
	NetType *ListJobsRequestNetType `json:"net_type,omitempty"`

	// 企业项目ID。 缺省值:\"\",表示查询所有企业项目任务。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`

	// 返回结果按该关键字排序,默认为“create_time”。
	SortKey *string `json:"sort_key,omitempty"`

	// 降序或升序(分别对应desc和asc,默认为“desc”)。
	SortDir *string `json:"sort_dir,omitempty"`

	// 数据库实例ID列表,最多支持10个
	InstanceIds *[]string `json:"instance_ids,omitempty"`

	// 数据库实例IP
	InstanceIp *string `json:"instance_ip,omitempty"`
}

ListJobsRequest Request Object

func (ListJobsRequest) String

func (o ListJobsRequest) String() string

type ListJobsRequestEngineType

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

func (ListJobsRequestEngineType) MarshalJSON

func (c ListJobsRequestEngineType) MarshalJSON() ([]byte, error)

func (*ListJobsRequestEngineType) UnmarshalJSON

func (c *ListJobsRequestEngineType) UnmarshalJSON(b []byte) error

func (ListJobsRequestEngineType) Value

type ListJobsRequestEngineTypeEnum

type ListJobsRequestEngineTypeEnum struct {
	ORACLE_TO_GAUSSDBV5 ListJobsRequestEngineType
}

func GetListJobsRequestEngineTypeEnum

func GetListJobsRequestEngineTypeEnum() ListJobsRequestEngineTypeEnum

type ListJobsRequestJobType

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

func (ListJobsRequestJobType) MarshalJSON

func (c ListJobsRequestJobType) MarshalJSON() ([]byte, error)

func (*ListJobsRequestJobType) UnmarshalJSON

func (c *ListJobsRequestJobType) UnmarshalJSON(b []byte) error

func (ListJobsRequestJobType) Value

func (c ListJobsRequestJobType) Value() string

type ListJobsRequestJobTypeEnum

type ListJobsRequestJobTypeEnum struct {
	MIGRATION        ListJobsRequestJobType
	SYNC             ListJobsRequestJobType
	CLOUD_DATA_GUARD ListJobsRequestJobType
}

func GetListJobsRequestJobTypeEnum

func GetListJobsRequestJobTypeEnum() ListJobsRequestJobTypeEnum

type ListJobsRequestNetType

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

func (ListJobsRequestNetType) MarshalJSON

func (c ListJobsRequestNetType) MarshalJSON() ([]byte, error)

func (*ListJobsRequestNetType) UnmarshalJSON

func (c *ListJobsRequestNetType) UnmarshalJSON(b []byte) error

func (ListJobsRequestNetType) Value

func (c ListJobsRequestNetType) Value() string

type ListJobsRequestNetTypeEnum

type ListJobsRequestNetTypeEnum struct {
	EIP ListJobsRequestNetType
	VPC ListJobsRequestNetType
	VPN ListJobsRequestNetType
}

func GetListJobsRequestNetTypeEnum

func GetListJobsRequestNetTypeEnum() ListJobsRequestNetTypeEnum

type ListJobsRequestStatus

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

func (ListJobsRequestStatus) MarshalJSON

func (c ListJobsRequestStatus) MarshalJSON() ([]byte, error)

func (*ListJobsRequestStatus) UnmarshalJSON

func (c *ListJobsRequestStatus) UnmarshalJSON(b []byte) error

func (ListJobsRequestStatus) Value

func (c ListJobsRequestStatus) Value() string

type ListJobsRequestStatusEnum

type ListJobsRequestStatusEnum struct {
	CREATING                        ListJobsRequestStatus
	CREATE_FAILED                   ListJobsRequestStatus
	CONFIGURATION                   ListJobsRequestStatus
	STARTJOBING                     ListJobsRequestStatus
	WAITING_FOR_START               ListJobsRequestStatus
	START_JOB_FAILED                ListJobsRequestStatus
	FULL_TRANSFER_STARTED           ListJobsRequestStatus
	FULL_TRANSFER_FAILED            ListJobsRequestStatus
	FULL_TRANSFER_COMPLETE          ListJobsRequestStatus
	INCRE_TRANSFER_STARTED          ListJobsRequestStatus
	INCRE_TRANSFER_FAILED           ListJobsRequestStatus
	RELEASE_RESOURCE_STARTED        ListJobsRequestStatus
	RELEASE_RESOURCE_FAILED         ListJobsRequestStatus
	RELEASE_RESOURCE_COMPLETE       ListJobsRequestStatus
	CHANGE_JOB_STARTED              ListJobsRequestStatus
	CHANGE_JOB_FAILED               ListJobsRequestStatus
	CHILD_TRANSFER_STARTING         ListJobsRequestStatus
	CHILD_TRANSFER_STARTED          ListJobsRequestStatus
	CHILD_TRANSFER_COMPLETE         ListJobsRequestStatus
	CHILD_TRANSFER_FAILED           ListJobsRequestStatus
	RELEASE_CHILD_TRANSFER_STARTED  ListJobsRequestStatus
	RELEASE_CHILD_TRANSFER_COMPLETE ListJobsRequestStatus
}

func GetListJobsRequestStatusEnum

func GetListJobsRequestStatusEnum() ListJobsRequestStatusEnum

type ListJobsRequestXLanguage

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

func (ListJobsRequestXLanguage) MarshalJSON

func (c ListJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListJobsRequestXLanguage) UnmarshalJSON

func (c *ListJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListJobsRequestXLanguage) Value

func (c ListJobsRequestXLanguage) Value() string

type ListJobsRequestXLanguageEnum

type ListJobsRequestXLanguageEnum struct {
	EN_US ListJobsRequestXLanguage
	ZH_CN ListJobsRequestXLanguage
}

func GetListJobsRequestXLanguageEnum

func GetListJobsRequestXLanguageEnum() ListJobsRequestXLanguageEnum

type ListJobsResponse

type ListJobsResponse struct {

	// 列表中的项目总数,与分页无关。
	TotalCount int32 `json:"total_count"`

	// 任务信息列表。
	Jobs           []JobListResp `json:"jobs"`
	HttpStatusCode int           `json:"-"`
}

ListJobsResponse Response Object

func (ListJobsResponse) String

func (o ListJobsResponse) String() string

type ListLinksRequest

type ListLinksRequest struct {

	// 请求语言类型。
	XLanguage *ListLinksRequestXLanguage `json:"X-Language,omitempty"`

	// 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。
	JobType ListLinksRequestJobType `json:"job_type"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`
}

ListLinksRequest Request Object

func (ListLinksRequest) String

func (o ListLinksRequest) String() string

type ListLinksRequestJobType

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

func (ListLinksRequestJobType) MarshalJSON

func (c ListLinksRequestJobType) MarshalJSON() ([]byte, error)

func (*ListLinksRequestJobType) UnmarshalJSON

func (c *ListLinksRequestJobType) UnmarshalJSON(b []byte) error

func (ListLinksRequestJobType) Value

func (c ListLinksRequestJobType) Value() string

type ListLinksRequestJobTypeEnum

type ListLinksRequestJobTypeEnum struct {
	MIGRATION        ListLinksRequestJobType
	SYNC             ListLinksRequestJobType
	CLOUD_DATA_GUARD ListLinksRequestJobType
}

func GetListLinksRequestJobTypeEnum

func GetListLinksRequestJobTypeEnum() ListLinksRequestJobTypeEnum

type ListLinksRequestXLanguage

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

func (ListLinksRequestXLanguage) MarshalJSON

func (c ListLinksRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListLinksRequestXLanguage) UnmarshalJSON

func (c *ListLinksRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListLinksRequestXLanguage) Value

type ListLinksRequestXLanguageEnum

type ListLinksRequestXLanguageEnum struct {
	EN_US ListLinksRequestXLanguage
	ZH_CN ListLinksRequestXLanguage
}

func GetListLinksRequestXLanguageEnum

func GetListLinksRequestXLanguageEnum() ListLinksRequestXLanguageEnum

type ListLinksResponse

type ListLinksResponse struct {

	// 可用链路信息。
	JobLinks *[]JobLinkResp `json:"job_links,omitempty"`

	// 可用链路总条数。
	TotalCount     *int32 `json:"total_count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListLinksResponse Response Object

func (ListLinksResponse) String

func (o ListLinksResponse) String() string

type ListProjectTagsRequest added in v0.1.58

type ListProjectTagsRequest struct {

	// 资源类型。 - migration:实时迁移 - sync:实时同步 - cloudDataGuard:实时灾备 - subscription:数据订阅 - backupMigration:备份迁移 - replay:仿真回放
	ResourceType ListProjectTagsRequestResourceType `json:"resource_type"`

	// 请求语言类型。
	XLanguage *ListProjectTagsRequestXLanguage `json:"X-Language,omitempty"`
}

ListProjectTagsRequest Request Object

func (ListProjectTagsRequest) String added in v0.1.58

func (o ListProjectTagsRequest) String() string

type ListProjectTagsRequestResourceType added in v0.1.58

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

func (ListProjectTagsRequestResourceType) MarshalJSON added in v0.1.58

func (c ListProjectTagsRequestResourceType) MarshalJSON() ([]byte, error)

func (*ListProjectTagsRequestResourceType) UnmarshalJSON added in v0.1.58

func (c *ListProjectTagsRequestResourceType) UnmarshalJSON(b []byte) error

func (ListProjectTagsRequestResourceType) Value added in v0.1.58

type ListProjectTagsRequestResourceTypeEnum added in v0.1.58

func GetListProjectTagsRequestResourceTypeEnum added in v0.1.58

func GetListProjectTagsRequestResourceTypeEnum() ListProjectTagsRequestResourceTypeEnum

type ListProjectTagsRequestXLanguage added in v0.1.58

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

func (ListProjectTagsRequestXLanguage) MarshalJSON added in v0.1.58

func (c ListProjectTagsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListProjectTagsRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ListProjectTagsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListProjectTagsRequestXLanguage) Value added in v0.1.58

type ListProjectTagsRequestXLanguageEnum added in v0.1.58

type ListProjectTagsRequestXLanguageEnum struct {
	EN_US ListProjectTagsRequestXLanguage
	ZH_CN ListProjectTagsRequestXLanguage
}

func GetListProjectTagsRequestXLanguageEnum added in v0.1.58

func GetListProjectTagsRequestXLanguageEnum() ListProjectTagsRequestXLanguageEnum

type ListProjectTagsResponse added in v0.1.58

type ListProjectTagsResponse struct {

	// 标签列表。
	Tags           *[]ProjectTag `json:"tags,omitempty"`
	HttpStatusCode int           `json:"-"`
}

ListProjectTagsResponse Response Object

func (ListProjectTagsResponse) String added in v0.1.58

func (o ListProjectTagsResponse) String() string

type MigrationObjectOverviewInfo

type MigrationObjectOverviewInfo struct {

	// 类型。
	Type *string `json:"type,omitempty"`

	// 待迁移数量。
	SrcCount *string `json:"src_count,omitempty"`

	// 已迁移数量。
	DstCount *string `json:"dst_count,omitempty"`

	// 状态.
	Status *string `json:"status,omitempty"`

	// 开始时间。
	StartTime *string `json:"start_time,omitempty"`

	// 结束时间。
	EndTime *string `json:"end_time,omitempty"`
}

MigrationObjectOverviewInfo 迁移详情概览。

func (MigrationObjectOverviewInfo) String

type ModifyStartPositionReq added in v0.1.58

type ModifyStartPositionReq struct {

	// - MySQL为源通过show master status命令获取源库位点,根据提示分别填写File:Position。例如:mysql-bin.000277:805  文件名只能为1-60个字符且不能包含< > & : \" \\' / \\\\\\\\ 特殊字符,文件编号只能为3-20个数字,binlog事件位置只能为1-20个数字,且总长度不能超过100个字符。格式为:文件名.文件编号:事件位点  - mogo为源的任务,任务的源库日志从位点开始获取(含当前启动位点),位点需设置在oplog范围以内。非集群通过db.getReplicationInfo()直接获得oplog范围,集群通过db.watch([], {startAtOperationTime: Timestamp(xx, xx)})命令,将启动位点填在xx处,校验位点是否在oplog范围以内。格式为:timestamp:incre。timestamp和incre均为范围在1~2,147,483,647之间的整数。
	FileAndPosition string `json:"file_and_position"`

	// MySQL为源的任务需要,通过show master status命令获取源库位点,根据提示填写Executed_Gtid_Set(如果源库为MySQL 5.5版本,则不支持使用同步任务)。 - 不能包含< > & \" \\' / \\\\\\\\ 特殊字符和中文。且不能超过2048个字符
	GtidSet *string `json:"gtid_set,omitempty"`
}

ModifyStartPositionReq 更新增量位点请求体。

func (ModifyStartPositionReq) String added in v0.1.58

func (o ModifyStartPositionReq) String() string

type ModifyTuningParams

type ModifyTuningParams struct {

	// 全量参数的参数名及对应的取值。
	FullSync map[string]string `json:"full_sync,omitempty"`

	// 增量抓取参数的参数名及对应的取值。
	IncreCapture map[string]string `json:"incre_capture"`

	// 增量回放参数的参数名及对应的取值。
	IncreApply map[string]string `json:"incre_apply"`

	// 增量日志拉取参数的参数名及对应的取值。
	IncreRelay map[string]string `json:"incre_relay,omitempty"`

	// 是否一键还原到默认值。
	Recovery *bool `json:"recovery,omitempty"`
}

ModifyTuningParams 修改高级设置信息体。

func (ModifyTuningParams) String

func (o ModifyTuningParams) String() string

type ObjectsCompareDetailInfo

type ObjectsCompareDetailInfo struct {

	// 源库对比值。
	SourceDbValue *string `json:"source_db_value,omitempty"`

	// 目标库对比值。
	TargetDbValue *string `json:"target_db_value,omitempty"`

	// 源库名称。
	SourceDbName *string `json:"source_db_name,omitempty"`

	// 目标库名称。
	TargetDbName *string `json:"target_db_name,omitempty"`

	// 失败原因。
	ErrorMessage *string `json:"error_message,omitempty"`
}

ObjectsCompareDetailInfo 对象级对比详情信息体。

func (ObjectsCompareDetailInfo) String

func (o ObjectsCompareDetailInfo) String() string

type ObjectsCompareOverviewInfo

type ObjectsCompareOverviewInfo struct {

	// 对象类型。取值: - DB:数据库。 - TABLE:表。 - VIEW:视图。 - EVENT:事件。 - ROUTINE:存储过程和函数。 - INDEX:索引。 - TRIGGER:触发器。 - SYNONYM:同义词。 - FUNCTION:函数。 - PROCEDURE:存储过程。 - TYPE:自定义类型。 - RULE:规则。 - DEFAULT_TYPE:缺省值。 - PLAN_GUIDE:执行计划。 - CONSTRAINT:约束。 - FILE_GROUP:文件组。 - PARTITION_FUNCTION:分区函数。 - PARTITION_SCHEME:分区方案。 - TABLE_COLLATION:表的排序规则。 - EXTENSIONS:插件。
	Type *ObjectsCompareOverviewInfoType `json:"type,omitempty"`

	// 源数量。
	SourceCount *int64 `json:"source_count,omitempty"`

	// 目标数量。
	TargetCount *int64 `json:"target_count,omitempty"`

	// 对比结果。取值: CONSISTENT:一致。 INCONSISTENT:不一致。 COMPARING:正在对比。 WAITING_FOR_COMPARISON:等待对比。 FAILED_TO_COMPARE:对比失败。 TARGET_DB_NOT_EXIST:目标库不存在。 CAN_NOT_COMPARE:无法对比。
	Status *ObjectsCompareOverviewInfoStatus `json:"status,omitempty"`
}

ObjectsCompareOverviewInfo 对象对比结果信息体。

func (ObjectsCompareOverviewInfo) String

type ObjectsCompareOverviewInfoStatus

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

func (ObjectsCompareOverviewInfoStatus) MarshalJSON

func (c ObjectsCompareOverviewInfoStatus) MarshalJSON() ([]byte, error)

func (*ObjectsCompareOverviewInfoStatus) UnmarshalJSON

func (c *ObjectsCompareOverviewInfoStatus) UnmarshalJSON(b []byte) error

func (ObjectsCompareOverviewInfoStatus) Value

type ObjectsCompareOverviewInfoStatusEnum

type ObjectsCompareOverviewInfoStatusEnum struct {
	CONSISTENT             ObjectsCompareOverviewInfoStatus
	INCONSISTENT           ObjectsCompareOverviewInfoStatus
	COMPARING              ObjectsCompareOverviewInfoStatus
	WAITING_FOR_COMPARISON ObjectsCompareOverviewInfoStatus
	FAILED_TO_COMPARE      ObjectsCompareOverviewInfoStatus
	TARGET_DB_NOT_EXIST    ObjectsCompareOverviewInfoStatus
	CAN_NOT_COMPARE        ObjectsCompareOverviewInfoStatus
}

func GetObjectsCompareOverviewInfoStatusEnum

func GetObjectsCompareOverviewInfoStatusEnum() ObjectsCompareOverviewInfoStatusEnum

type ObjectsCompareOverviewInfoType

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

func (ObjectsCompareOverviewInfoType) MarshalJSON

func (c ObjectsCompareOverviewInfoType) MarshalJSON() ([]byte, error)

func (*ObjectsCompareOverviewInfoType) UnmarshalJSON

func (c *ObjectsCompareOverviewInfoType) UnmarshalJSON(b []byte) error

func (ObjectsCompareOverviewInfoType) Value

type ObjectsCompareTaskInfo

type ObjectsCompareTaskInfo struct {

	// 对比任务创建时间。
	CreateTime *string `json:"create_time,omitempty"`

	// 对比结果。
	CompareResults *[]ObjectsCompareOverviewInfo `json:"compare_results,omitempty"`

	// 对比任务开始时间。
	StartTime *string `json:"start_time,omitempty"`

	// 对比任务状态。取值: - RUNNING:运行中。 - WAITING_FOR_RUNNING:等待启动中。 - SUCCESSFUL:完成。 - FAILED:失败。 - CANCELLED:已取消。
	Status *ObjectsCompareTaskInfoStatus `json:"status,omitempty"`

	// 导出比对结果状态。
	ExportStatus *string `json:"export_status,omitempty"`

	// 导出比对结果有效期剩余时间。
	ReportRemainSeconds *int64 `json:"report_remain_seconds,omitempty"`

	// 对比任务ID。
	CompareJobId *string `json:"compare_job_id,omitempty"`

	// 失败原因。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

ObjectsCompareTaskInfo 对象级对比任务信息体。

func (ObjectsCompareTaskInfo) String

func (o ObjectsCompareTaskInfo) String() string

type ObjectsCompareTaskInfoStatus

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

func (ObjectsCompareTaskInfoStatus) MarshalJSON

func (c ObjectsCompareTaskInfoStatus) MarshalJSON() ([]byte, error)

func (*ObjectsCompareTaskInfoStatus) UnmarshalJSON

func (c *ObjectsCompareTaskInfoStatus) UnmarshalJSON(b []byte) error

func (ObjectsCompareTaskInfoStatus) Value

type ObjectsCompareTaskInfoStatusEnum

type ObjectsCompareTaskInfoStatusEnum struct {
	RUNNING             ObjectsCompareTaskInfoStatus
	WAITING_FOR_RUNNING ObjectsCompareTaskInfoStatus
	SUCCESSFUL          ObjectsCompareTaskInfoStatus
	FAILED              ObjectsCompareTaskInfoStatus
	CANCELLED           ObjectsCompareTaskInfoStatus
}

func GetObjectsCompareTaskInfoStatusEnum

func GetObjectsCompareTaskInfoStatusEnum() ObjectsCompareTaskInfoStatusEnum

type PeriodOrderInfo

type PeriodOrderInfo struct {

	// 订购周期类型。取值: - 2:月。 - 3:年。
	PeriodType PeriodOrderInfoPeriodType `json:"period_type"`

	// 订购周期数。根据period_type取值不同,代表不同周期数,例如: - 当period_type为2时,period_num为1代表1月。 - 当period_type为3时,period_num为1代表1年。
	PeriodNum int32 `json:"period_num"`

	// 是否自动续订。取值: - 0:否(默认值,需要客户手动去支付)。 - 1:是(自动支付)。
	IsAutoRenew *PeriodOrderInfoIsAutoRenew `json:"is_auto_renew,omitempty"`
}

PeriodOrderInfo 包年/包月信息体。

func (PeriodOrderInfo) String

func (o PeriodOrderInfo) String() string

type PeriodOrderInfoIsAutoRenew

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

func (PeriodOrderInfoIsAutoRenew) MarshalJSON

func (c PeriodOrderInfoIsAutoRenew) MarshalJSON() ([]byte, error)

func (*PeriodOrderInfoIsAutoRenew) UnmarshalJSON

func (c *PeriodOrderInfoIsAutoRenew) UnmarshalJSON(b []byte) error

func (PeriodOrderInfoIsAutoRenew) Value

type PeriodOrderInfoIsAutoRenewEnum

type PeriodOrderInfoIsAutoRenewEnum struct {
	E_0 PeriodOrderInfoIsAutoRenew
	E_1 PeriodOrderInfoIsAutoRenew
}

func GetPeriodOrderInfoIsAutoRenewEnum

func GetPeriodOrderInfoIsAutoRenewEnum() PeriodOrderInfoIsAutoRenewEnum

type PeriodOrderInfoPeriodType

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

func (PeriodOrderInfoPeriodType) MarshalJSON

func (c PeriodOrderInfoPeriodType) MarshalJSON() ([]byte, error)

func (*PeriodOrderInfoPeriodType) UnmarshalJSON

func (c *PeriodOrderInfoPeriodType) UnmarshalJSON(b []byte) error

func (PeriodOrderInfoPeriodType) Value

func (c PeriodOrderInfoPeriodType) Value() int32

type PeriodOrderInfoPeriodTypeEnum

type PeriodOrderInfoPeriodTypeEnum struct {
	E_2 PeriodOrderInfoPeriodType
	E_3 PeriodOrderInfoPeriodType
}

func GetPeriodOrderInfoPeriodTypeEnum

func GetPeriodOrderInfoPeriodTypeEnum() PeriodOrderInfoPeriodTypeEnum

type PolicyConfig

type PolicyConfig struct {

	// 过滤DDL策略。取值: - drop_database  场景区别: - 实时迁移场景:MySQL迁移可填\"\",表示不过滤DROP DATABASE。 - 实时同步场景:MySQL同步只能填\"drop_database\"。
	FilterDdlPolicy *PolicyConfigFilterDdlPolicy `json:"filter_ddl_policy,omitempty"`

	// 增量阶段冲突策略。该冲突策略特指增量同步中的冲突处理策略,全量阶段的冲突默认忽略。取值: - ignore:忽略。当同步数据与目标库已有数据冲突时(主键/唯一键重复等),DRS将忽略源库的冲突数据,并保留目标库中的冲突数据,继续进行后续同步。  - stop:报错。当同步数据与目标库已有数据冲突时(主键/唯一键重复等),同步任务将失败并立即中止。可在同步日志中查看详细信息。  - overwrite:覆盖。当同步数据与目标库已有数据冲突时(主键/唯一键重复等),将覆盖原来的冲突数据。  场景区别: - 实时迁移场景:不支持。 - 实时同步场景:支持。
	ConflictPolicy *PolicyConfigConflictPolicy `json:"conflict_policy,omitempty"`

	// 对象同步范围:是否同步普通索引。DRS将默认同步主键/唯一索引,普通索引是指除主键/唯一索引以外的其他类型索引。取值: - true:将会同步全部的索引。 - false:仅同步主键/唯一索引,普通索引不会同步。
	IndexTrans *bool `json:"index_trans,omitempty"`

	// 对象同步范围:同步增量阶段是否同步DDL。取值: - true:增量阶段同步DDL。 - false:增量阶段不同步DDL。
	DdlTrans *bool `json:"ddl_trans,omitempty"`

	// 数据同步拓扑。数据同步功能支持多种同步拓扑,您可以根据业务需求规划您的同步实例。参考链接。取值: - one2one:一对一。 - one2many:一对多。 - many2one:多对一。
	DataSyncTopologyType *PolicyConfigDataSyncTopologyType `json:"data_sync_topology_type,omitempty"`

	// 增量支持的DDL。取值: - \"CREATE_TABLE,ADD_COLUMN,MODIFY_COLUMN,CHANGE_COLUMN,DROP_INDEX,ADD_INDEX,CREATE_INDEX,RENAME_INDEX\"。 - 含义解释: - CREATE_TABLE:创建表。 - ADD_COLUMN:加列。 - MODIFY_COLUMN:改列属性。 - CHANGE_COLUMN:改列属性。 - DROP_INDEX:删除索引。 - ADD_INDEX:加索引。 - CREATE_INDEX:创建索引。 - RENAME_INDEX:重命名索引。 - 使用提示: 1.一对一,一对多场景,如果业务上认为源和目标应该使用保持严格一致,那么高危类DDL也应该勾选并同步。 2.一对一,一对多场景,如果业务上确定某个高危DDL不应该发生,则可以不勾选同步高危类DDL,这样DRS将拦截过滤这个DDL,从而起到保护目标数据的作用,但需要知晓过滤DDL的附带问题是可能导致同步失败,例如过滤删列动作。 3.多对一数据聚合场景,最佳实践是推荐只选择同步加列DDL,其他大部分DDL同步都因目标表修改而导致其他任务失败/数据不一致的情况发生,常见情况有:a、同步truncate导致目标数据全部被清空; b、同步创建索引导致目标表被锁定; c、同步rename导致其他任务找不到目标表而失败;d、同步改列导致其他任务因数据类型不兼容而失败;
	SupportDdlInfo *PolicyConfigSupportDdlInfo `json:"support_ddl_info,omitempty"`

	// 同步数据类型。取值:supportAllType(同步所有类型),tableData(同步数据),tableStructure(同步表结构),constraintData(索引同步)。 说明:除supportAllType以外,其他类型可组合填写,例如:\"tableData,tableStructure\" 。
	SyncTypePolicy *string `json:"sync_type_policy,omitempty"`

	// oracle-gausssdb增量读取方式:logminer,xstream
	IncrementReadMode *string `json:"increment_read_mode,omitempty"`
}

PolicyConfig 策略信息体。设置迁移、同步策略,包括冲突策略、过滤DROP Datase、对象同步范围等。

func (PolicyConfig) String

func (o PolicyConfig) String() string

type PolicyConfigConflictPolicy

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

func (PolicyConfigConflictPolicy) MarshalJSON

func (c PolicyConfigConflictPolicy) MarshalJSON() ([]byte, error)

func (*PolicyConfigConflictPolicy) UnmarshalJSON

func (c *PolicyConfigConflictPolicy) UnmarshalJSON(b []byte) error

func (PolicyConfigConflictPolicy) Value

type PolicyConfigConflictPolicyEnum

type PolicyConfigConflictPolicyEnum struct {
	IGNORE    PolicyConfigConflictPolicy
	STOP      PolicyConfigConflictPolicy
	OVERWRITE PolicyConfigConflictPolicy
}

func GetPolicyConfigConflictPolicyEnum

func GetPolicyConfigConflictPolicyEnum() PolicyConfigConflictPolicyEnum

type PolicyConfigDataSyncTopologyType

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

func (PolicyConfigDataSyncTopologyType) MarshalJSON

func (c PolicyConfigDataSyncTopologyType) MarshalJSON() ([]byte, error)

func (*PolicyConfigDataSyncTopologyType) UnmarshalJSON

func (c *PolicyConfigDataSyncTopologyType) UnmarshalJSON(b []byte) error

func (PolicyConfigDataSyncTopologyType) Value

type PolicyConfigDataSyncTopologyTypeEnum

type PolicyConfigDataSyncTopologyTypeEnum struct {
	ONE2ONE  PolicyConfigDataSyncTopologyType
	ONE2MANY PolicyConfigDataSyncTopologyType
	MANY2ONE PolicyConfigDataSyncTopologyType
}

func GetPolicyConfigDataSyncTopologyTypeEnum

func GetPolicyConfigDataSyncTopologyTypeEnum() PolicyConfigDataSyncTopologyTypeEnum

type PolicyConfigFilterDdlPolicy

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

func (PolicyConfigFilterDdlPolicy) MarshalJSON

func (c PolicyConfigFilterDdlPolicy) MarshalJSON() ([]byte, error)

func (*PolicyConfigFilterDdlPolicy) UnmarshalJSON

func (c *PolicyConfigFilterDdlPolicy) UnmarshalJSON(b []byte) error

func (PolicyConfigFilterDdlPolicy) Value

type PolicyConfigFilterDdlPolicyEnum

type PolicyConfigFilterDdlPolicyEnum struct {
	DROP_DATABASE PolicyConfigFilterDdlPolicy
}

func GetPolicyConfigFilterDdlPolicyEnum

func GetPolicyConfigFilterDdlPolicyEnum() PolicyConfigFilterDdlPolicyEnum

type PolicyConfigSupportDdlInfo

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

func (PolicyConfigSupportDdlInfo) MarshalJSON

func (c PolicyConfigSupportDdlInfo) MarshalJSON() ([]byte, error)

func (*PolicyConfigSupportDdlInfo) UnmarshalJSON

func (c *PolicyConfigSupportDdlInfo) UnmarshalJSON(b []byte) error

func (PolicyConfigSupportDdlInfo) Value

type PolicyConfigSupportDdlInfoEnum

type PolicyConfigSupportDdlInfoEnum struct {
	CREATE_TABLE  PolicyConfigSupportDdlInfo
	ADD_COLUMN    PolicyConfigSupportDdlInfo
	MODIFY_COLUMN PolicyConfigSupportDdlInfo
	CHANGE_COLUMN PolicyConfigSupportDdlInfo
	DROP_INDEX    PolicyConfigSupportDdlInfo
	ADD_INDEX     PolicyConfigSupportDdlInfo
	CREATE_INDEX  PolicyConfigSupportDdlInfo
	RENAME_INDEX  PolicyConfigSupportDdlInfo
}

func GetPolicyConfigSupportDdlInfoEnum

func GetPolicyConfigSupportDdlInfoEnum() PolicyConfigSupportDdlInfoEnum

type PrecheckFailSubJobResult

type PrecheckFailSubJobResult struct {

	// 子任务ID。
	Id *string `json:"id,omitempty"`

	// 子任务名称。
	Name *string `json:"name,omitempty"`

	// 子任务检查结果。
	CheckResult *string `json:"check_result,omitempty"`
}

PrecheckFailSubJobResult 失败子任务详情。

func (PrecheckFailSubJobResult) String

func (o PrecheckFailSubJobResult) String() string

type PrecheckResult

type PrecheckResult struct {

	// 检查项。
	Item *string `json:"item,omitempty"`

	// 检查结果。取值: - PASSED:检查通过。 - ALARM:检查告警项。 - FAILED:检查失败。
	Result *PrecheckResultResult `json:"result,omitempty"`

	// 失败原因。
	FailedReason *string `json:"failed_reason,omitempty"`

	// 失败数据。
	Data *string `json:"data,omitempty"`

	// 失败详情。
	RawErrorMsg *string `json:"raw_error_msg,omitempty"`

	// 检查项分组。
	Group *string `json:"group,omitempty"`

	// 是否支持跳过。
	IsSupportSkip *bool `json:"is_support_skip,omitempty"`

	// 是否已跳过。
	IsSkipped *bool `json:"is_skipped,omitempty"`

	// 失败子任务详情。
	FailedSubJobs *[]PrecheckFailSubJobResult `json:"failed_sub_jobs,omitempty"`
}

PrecheckResult 预检查项结果。

func (PrecheckResult) String

func (o PrecheckResult) String() string

type PrecheckResultResult

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

func (PrecheckResultResult) MarshalJSON

func (c PrecheckResultResult) MarshalJSON() ([]byte, error)

func (*PrecheckResultResult) UnmarshalJSON

func (c *PrecheckResultResult) UnmarshalJSON(b []byte) error

func (PrecheckResultResult) Value

func (c PrecheckResultResult) Value() string

type PrecheckResultResultEnum

type PrecheckResultResultEnum struct {
	PASSED PrecheckResultResult
	ALARM  PrecheckResultResult
	FAILED PrecheckResultResult
}

func GetPrecheckResultResultEnum

func GetPrecheckResultResultEnum() PrecheckResultResultEnum

type ProductInfo added in v0.1.49

type ProductInfo struct {

	// ID标识,同一次询价中不能重复,用于标识返回询价结果和请求的映射关系。
	Id *string `json:"id,omitempty"`

	// 用户购买云服务产品的云服务类型,例如EC2,云服务类型为hws.service.type.ec2。
	CloudServiceType *string `json:"cloud_service_type,omitempty"`

	// 用户购买云服务产品的资源类型,例如EC2中的VM,资源类型为hws.resource.type.vm。
	ResourceType *string `json:"resource_type,omitempty"`

	// 用户购买云服务产品的资源规格,例如VM的小型规格,资源规格为m1.tiny。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`

	// 资源容量度量标识。
	ResourceSize *int32 `json:"resource_size,omitempty"`

	// 使用量因子,按需计费必填,取值和话单中的使用量因子一致,云服务和使用量因子对应关系如下: - Duration:云服务器 - flow:流量
	UsageFactor *string `json:"usage_factor,omitempty"`

	// 使用量值,按需询价必填,例如按小时询价,使用量值为1,使用量单位为小时。
	UsageValue *float64 `json:"usage_value,omitempty"`

	// 使用量单位标识,按需询价必填,例如按小时询价,使用量值为1,使用量单位为小时。 - 4:小时 - 10:GB - 11:MB - 13:Byte - 17:FLOW_GB
	UsageMeasureId *int32 `json:"usage_measure_id,omitempty"`

	// 资源容量大小,例如购买的卷大小或带宽大小。
	ResourceSizeMeasureId *int32 `json:"resource_size_measure_id,omitempty"`
}

ProductInfo 产品信息。

func (ProductInfo) String added in v0.1.49

func (o ProductInfo) String() string

type ProgressCompleteInfo

type ProgressCompleteInfo struct {

	// 完成进度。
	Completed *string `json:"completed,omitempty"`

	// 预计剩余时间。
	RemainingTime *string `json:"remaining_time,omitempty"`
}

ProgressCompleteInfo 全量迁移进度。

func (ProgressCompleteInfo) String

func (o ProgressCompleteInfo) String() string

type ProjectTag added in v0.1.58

type ProjectTag struct {

	// 标签键。
	Key *string `json:"key,omitempty"`

	// 标签值。
	Values *[]string `json:"values,omitempty"`
}

func (ProjectTag) String added in v0.1.58

func (o ProjectTag) String() string

type QueryColumnInfo added in v0.1.58

type QueryColumnInfo struct {

	// 列名
	ColumnName *string `json:"column_name,omitempty"`

	// 列类型
	ColumnType *string `json:"column_type,omitempty"`

	// 主键或者唯一索引
	PrimaryKeyOrUniqueIndex *string `json:"primary_key_or_unique_index,omitempty"`

	// 列映射后的名称
	ColumnMappedName *string `json:"column_mapped_name,omitempty"`

	// 该列是否过滤
	IsFiltered *bool `json:"is_filtered,omitempty"`

	// 该列是否partitionKey
	IsPartitionKey *bool `json:"is_partition_key,omitempty"`
}

QueryColumnInfo 数据库列信息

func (QueryColumnInfo) String added in v0.1.58

func (o QueryColumnInfo) String() string

type QueryColumnReq added in v0.1.58

type QueryColumnReq struct {

	// 是否从Node获取最新的列信息
	IsForceRefresh *bool `json:"is_force_refresh,omitempty"`

	// 指定数据库表信息
	DbObjectInfos []SelectDbTableObjectInfo `json:"db_object_infos"`
}

QueryColumnReq 是否从源库获取最新的列信息

func (QueryColumnReq) String added in v0.1.58

func (o QueryColumnReq) String() string

type QueryMetricResult

type QueryMetricResult struct {

	// 任务ID。
	JobId *string `json:"job_id,omitempty"`

	// 实例ID。
	NodeId *string `json:"node_id,omitempty"`

	// 上报时间。
	TimeStamp *string `json:"time_stamp,omitempty"`

	// CPU使用率。
	CpuUtil *string `json:"cpu_util,omitempty"`

	// 内存使用率。
	MemUtil *string `json:"mem_util,omitempty"`

	// 网络输入吞吐量。
	NetworkIncomingBytesRate *string `json:"network_incoming_bytes_rate,omitempty"`

	// 网络输出吞吐量。
	NetworkOutgoingBytesRate *string `json:"network_outgoing_bytes_rate,omitempty"`

	// 磁盘读吞吐量。
	DiskReadBytesRate *string `json:"disk_read_bytes_rate,omitempty"`

	// 磁盘写吞吐量。
	DiskWriteBytesRate *string `json:"disk_write_bytes_rate,omitempty"`

	// 写目标库频率。
	ApplyRowsRate *string `json:"apply_rows_rate,omitempty"`

	// DML TPS。
	ApplyTransactionsRate *string `json:"apply_transactions_rate,omitempty"`

	// DDL TPS。
	ApplyDdlRate *string `json:"apply_ddl_rate,omitempty"`

	// 事务平均执行时间。
	ApplyAverageExecuteTime *string `json:"apply_average_execute_time,omitempty"`

	// 事务平均提交时间。
	ApplyAverageCommitTime *string `json:"apply_average_commit_time,omitempty"`

	// 同步状态。
	ApplyCurrentState *string `json:"apply_current_state,omitempty"`
}

QueryMetricResult Node节点指标项。

func (QueryMetricResult) String

func (o QueryMetricResult) String() string

type QueryMigrationObjectProgressInfo

type QueryMigrationObjectProgressInfo struct {

	// 概览详情。
	MigrationObjectOverview *[]MigrationObjectOverviewInfo `json:"migration_object_overview,omitempty"`

	// 数据生成时间。
	CreateTime *string `json:"create_time,omitempty"`

	// 全量开始时间。
	FullStartTime *string `json:"full_start_time,omitempty"`

	// 全量完成时间。
	FullCompleteTime *string `json:"full_complete_time,omitempty"`

	// 增量开始时间。
	IncrStartTime *string `json:"incr_start_time,omitempty"`

	// 结束时间。
	EndTime *string `json:"end_time,omitempty"`
}

QueryMigrationObjectProgressInfo 迁移中对象进度信息体。

func (QueryMigrationObjectProgressInfo) String

type QueryNetworkResult

type QueryNetworkResult struct {

	// 测试连接IP。
	Ip *string `json:"ip,omitempty"`

	// 测试连接是否成功。
	Success bool `json:"success"`

	// 测试连接结果。
	Result *string `json:"result,omitempty"`

	// 测试连接是否成功。取值: - success:成功。 - failed:不成功。
	Status QueryNetworkResultStatus `json:"status"`

	// 测试连接失败错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 测试连接失败错误内容。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

QueryNetworkResult 测试连接结果响应体。

func (QueryNetworkResult) String

func (o QueryNetworkResult) String() string

type QueryNetworkResultStatus

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

func (QueryNetworkResultStatus) MarshalJSON

func (c QueryNetworkResultStatus) MarshalJSON() ([]byte, error)

func (*QueryNetworkResultStatus) UnmarshalJSON

func (c *QueryNetworkResultStatus) UnmarshalJSON(b []byte) error

func (QueryNetworkResultStatus) Value

func (c QueryNetworkResultStatus) Value() string

type QueryNetworkResultStatusEnum

type QueryNetworkResultStatusEnum struct {
	SUCCESS QueryNetworkResultStatus
	FAILED  QueryNetworkResultStatus
}

func GetQueryNetworkResultStatusEnum

func GetQueryNetworkResultStatusEnum() QueryNetworkResultStatusEnum

type QueryPreCheckResult

type QueryPreCheckResult struct {

	// 返回的预检查结果是否通过。
	Result *bool `json:"result,omitempty"`

	// 预检查进度百分比。
	Process *string `json:"process,omitempty"`

	// 预检查通过百分比。
	TotalPassedRate *string `json:"total_passed_rate,omitempty"`

	// 数据库实例ID。
	RdsInstanceId *string `json:"rds_instance_id,omitempty"`

	// 迁移方向。
	JobDirection *string `json:"job_direction,omitempty"`

	// 预检查各项结果。
	PrecheckResults *[]PrecheckResult `json:"precheck_results,omitempty"`
}

QueryPreCheckResult 预检查结果信息体。

func (QueryPreCheckResult) String

func (o QueryPreCheckResult) String() string

type QuerySelectObjectInfoReq added in v0.1.58

type QuerySelectObjectInfoReq struct {

	// 查询指定库的信息。
	DbNames *[]string `json:"db_names,omitempty"`

	// 查询对象信息类型,取值: - source:查询源库对象信息。 - modified:查询已选择的(已同步的和未下发的)对象信息。 - synchronized:查询已同步的(已下发的)对象信息 , 使用场景在任务处于全量中或者增量中。
	Type string `json:"type"`

	// 是否强制刷新。取值: - true:是,表示从源库重新查询。 - false:否,表示从已缓存中数据查询。
	IsRefresh *string `json:"is_refresh,omitempty"`
}

QuerySelectObjectInfoReq 数据库对象采集请求体

func (QuerySelectObjectInfoReq) String added in v0.1.58

func (o QuerySelectObjectInfoReq) String() string

type QueryUserSelectedObjectInfoReq added in v0.1.49

type QueryUserSelectedObjectInfoReq struct {

	// 库名。
	DbName *string `json:"db_name,omitempty"`

	// 模式名。
	SchemaName *string `json:"schema_name,omitempty"`

	// 表名。
	TableName *string `json:"table_name,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset 大于等于 0。默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量。默认为10,取值范围【1-1000】
	Limit *int32 `json:"limit,omitempty"`

	// 是否有映射。
	HasColumnInfo *bool `json:"has_column_info,omitempty"`
}

QueryUserSelectedObjectInfoReq 查询同步映射请求参数。

func (QueryUserSelectedObjectInfoReq) String added in v0.1.49

type ResourceTag

type ResourceTag struct {

	// 标签键。 约束:最大长度36,只能包含字母、数字、下划线、中划线和中文。
	Key *string `json:"key,omitempty"`

	// 标签值。 约束:最大长度43,只能包含字母、数字、下划线、中划线和中文。
	Value *string `json:"value,omitempty"`
}

ResourceTag 标签信息体。

func (ResourceTag) String

func (o ResourceTag) String() string

type SchemaObject

type SchemaObject struct {

	// 该模式在实时同步场景下的类型。取值: - config:仅当该模式作为数据过滤高级设置的关联模式时,需要填写,此时该模式以及该模式下的tables“不会”被同步到目标库,name、all属性不生效,tables需要填写被关联的相关对象。(注意:如果需要同步该模式对象,则在下级对象中填写sync_type值为config。)
	SyncType *string `json:"sync_type,omitempty"`

	// 该模式在目标库的名称(模式名映射)。
	Name *string `json:"name,omitempty"`

	// 是否整模式迁移或同步。注意: 1.当该模式下的表、列需要做数据过滤、列过滤、列映射时,填false,否则填true; 2.当该模式下的表需要做附加列时,需要填true,并且在表级对象的columns里填写附加列信息; 3.当该模式下的表所包含的列作为数据过滤高级设置的关联列时,需要填true,并且在columns里填写关联列信息、config_conditions填写数据过滤高级设置的配置条件;
	All *bool `json:"all,omitempty"`

	// 需要迁移或同步的表,当整模式迁移或同步为false时需要填写。
	Tables map[string]TableObject `json:"tables,omitempty"`
}

SchemaObject 数据库模式对象。

func (SchemaObject) String

func (o SchemaObject) String() string

type SelectDbTableObjectInfo added in v0.1.58

type SelectDbTableObjectInfo struct {

	// 数据库名称。
	DbName string `json:"db_name"`

	// 数据库schema名称。
	SchemaName *string `json:"schema_name,omitempty"`

	// 数据库表名称。
	TableName string `json:"table_name"`
}

SelectDbTableObjectInfo 指定库表信息

func (SelectDbTableObjectInfo) String added in v0.1.58

func (o SelectDbTableObjectInfo) String() string

type ShowActionsRequest added in v0.1.49

type ShowActionsRequest struct {

	// 请求语言类型。
	XLanguage *ShowActionsRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`
}

ShowActionsRequest Request Object

func (ShowActionsRequest) String added in v0.1.49

func (o ShowActionsRequest) String() string

type ShowActionsRequestXLanguage added in v0.1.49

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

func (ShowActionsRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowActionsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowActionsRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowActionsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowActionsRequestXLanguage) Value added in v0.1.49

type ShowActionsRequestXLanguageEnum added in v0.1.49

type ShowActionsRequestXLanguageEnum struct {
	EN_US ShowActionsRequestXLanguage
	ZH_CN ShowActionsRequestXLanguage
}

func GetShowActionsRequestXLanguageEnum added in v0.1.49

func GetShowActionsRequestXLanguageEnum() ShowActionsRequestXLanguageEnum

type ShowActionsResponse added in v0.1.49

type ShowActionsResponse struct {
	JobAction      *JobActions `json:"job_action,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ShowActionsResponse Response Object

func (ShowActionsResponse) String added in v0.1.49

func (o ShowActionsResponse) String() string

type ShowColumnInfoResultRequest added in v0.1.58

type ShowColumnInfoResultRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowColumnInfoResultRequestXLanguage `json:"X-Language,omitempty"`

	// 指定数据库表的列信息采集的ID,提交采集指定数据库表的列信息接口返回的ID。
	QueryId string `json:"query_id"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`
}

ShowColumnInfoResultRequest Request Object

func (ShowColumnInfoResultRequest) String added in v0.1.58

type ShowColumnInfoResultRequestXLanguage added in v0.1.58

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

func (ShowColumnInfoResultRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowColumnInfoResultRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowColumnInfoResultRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowColumnInfoResultRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowColumnInfoResultRequestXLanguage) Value added in v0.1.58

type ShowColumnInfoResultRequestXLanguageEnum added in v0.1.58

type ShowColumnInfoResultRequestXLanguageEnum struct {
	EN_US ShowColumnInfoResultRequestXLanguage
	ZH_CN ShowColumnInfoResultRequestXLanguage
}

func GetShowColumnInfoResultRequestXLanguageEnum added in v0.1.58

func GetShowColumnInfoResultRequestXLanguageEnum() ShowColumnInfoResultRequestXLanguageEnum

type ShowColumnInfoResultResponse added in v0.1.58

type ShowColumnInfoResultResponse struct {

	// 指定数据库表列信息
	Results *[]DbObjectColumnInfo `json:"results,omitempty"`

	// 列表中的项目总数,与分页无关
	TotalCount     *int32 `json:"total_count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowColumnInfoResultResponse Response Object

func (ShowColumnInfoResultResponse) String added in v0.1.58

type ShowComparePolicyRequest added in v0.1.49

type ShowComparePolicyRequest struct {

	// 请求语言类型。
	XLanguage *ShowComparePolicyRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`
}

ShowComparePolicyRequest Request Object

func (ShowComparePolicyRequest) String added in v0.1.49

func (o ShowComparePolicyRequest) String() string

type ShowComparePolicyRequestXLanguage added in v0.1.49

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

func (ShowComparePolicyRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowComparePolicyRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowComparePolicyRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowComparePolicyRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowComparePolicyRequestXLanguage) Value added in v0.1.49

type ShowComparePolicyRequestXLanguageEnum added in v0.1.49

type ShowComparePolicyRequestXLanguageEnum struct {
	EN_US ShowComparePolicyRequestXLanguage
	ZH_CN ShowComparePolicyRequestXLanguage
}

func GetShowComparePolicyRequestXLanguageEnum added in v0.1.49

func GetShowComparePolicyRequestXLanguageEnum() ShowComparePolicyRequestXLanguageEnum

type ShowComparePolicyResponse added in v0.1.49

type ShowComparePolicyResponse struct {

	// 对比时间。
	Period *string `json:"period,omitempty"`

	// 对比策略状态。 - OPEN:开启 - CLOSED:关闭 - NO_SUPPORT:不支持
	Status *ShowComparePolicyResponseStatus `json:"status,omitempty"`

	// 对比开始时间。
	BeginTime *string `json:"begin_time,omitempty"`

	// 对比结束时间。
	EndTime *string `json:"end_time,omitempty"`

	// 对比类型。 - object:对象对比 - lines:行对比 - contents:内容对比 - account:用户对比
	CompareType *[]string `json:"compare_type,omitempty"`

	// 下次对比时间,UTC时间,例如:2023-06-12T08:00:00Z
	NextCompareTime *string `json:"next_compare_time,omitempty"`

	// 对比策略。 - normal:普通对比 - manyToOne:多对一对比
	ComparePolicy *string `json:"compare_policy,omitempty"`

	// 间隔时间。
	IntervalHour   *int32 `json:"interval_hour,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowComparePolicyResponse Response Object

func (ShowComparePolicyResponse) String added in v0.1.49

func (o ShowComparePolicyResponse) String() string

type ShowComparePolicyResponseStatus added in v0.1.49

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

func (ShowComparePolicyResponseStatus) MarshalJSON added in v0.1.49

func (c ShowComparePolicyResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowComparePolicyResponseStatus) UnmarshalJSON added in v0.1.49

func (c *ShowComparePolicyResponseStatus) UnmarshalJSON(b []byte) error

func (ShowComparePolicyResponseStatus) Value added in v0.1.49

type ShowComparePolicyResponseStatusEnum added in v0.1.49

type ShowComparePolicyResponseStatusEnum struct {
	OPEN       ShowComparePolicyResponseStatus
	CLOSED     ShowComparePolicyResponseStatus
	NO_SUPPORT ShowComparePolicyResponseStatus
}

func GetShowComparePolicyResponseStatusEnum added in v0.1.49

func GetShowComparePolicyResponseStatusEnum() ShowComparePolicyResponseStatusEnum

type ShowDataFilteringResultRequest added in v0.1.58

type ShowDataFilteringResultRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDataFilteringResultRequestXLanguage `json:"X-Language,omitempty"`

	// 数据过滤校验请求ID
	QueryId string `json:"query_id"`
}

ShowDataFilteringResultRequest Request Object

func (ShowDataFilteringResultRequest) String added in v0.1.58

type ShowDataFilteringResultRequestXLanguage added in v0.1.58

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

func (ShowDataFilteringResultRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowDataFilteringResultRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowDataFilteringResultRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowDataFilteringResultRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowDataFilteringResultRequestXLanguage) Value added in v0.1.58

type ShowDataFilteringResultRequestXLanguageEnum added in v0.1.58

type ShowDataFilteringResultRequestXLanguageEnum struct {
	EN_US ShowDataFilteringResultRequestXLanguage
	ZH_CN ShowDataFilteringResultRequestXLanguage
}

func GetShowDataFilteringResultRequestXLanguageEnum added in v0.1.58

func GetShowDataFilteringResultRequestXLanguageEnum() ShowDataFilteringResultRequestXLanguageEnum

type ShowDataFilteringResultResponse added in v0.1.58

type ShowDataFilteringResultResponse struct {

	// 数据过滤规则校验成功的数量
	SuccessCount *int64 `json:"success_count,omitempty"`

	// 数据过滤规则校验失败的数量
	FailedCount *int64 `json:"failed_count,omitempty"`

	// 库表过滤规则校验结果
	DbObjectFilteringResult *[]DbObjectFilteringResult `json:"db_object_filtering_result,omitempty"`
	HttpStatusCode          int                        `json:"-"`
}

ShowDataFilteringResultResponse Response Object

func (ShowDataFilteringResultResponse) String added in v0.1.58

type ShowDataProcessingRulesResultRequest added in v0.1.58

type ShowDataProcessingRulesResultRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDataProcessingRulesResultRequestXLanguage `json:"X-Language,omitempty"`

	// 更新数据加工规则ID。
	QueryId string `json:"query_id"`
}

ShowDataProcessingRulesResultRequest Request Object

func (ShowDataProcessingRulesResultRequest) String added in v0.1.58

type ShowDataProcessingRulesResultRequestXLanguage added in v0.1.58

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

func (ShowDataProcessingRulesResultRequestXLanguage) MarshalJSON added in v0.1.58

func (*ShowDataProcessingRulesResultRequestXLanguage) UnmarshalJSON added in v0.1.58

func (ShowDataProcessingRulesResultRequestXLanguage) Value added in v0.1.58

type ShowDataProcessingRulesResultRequestXLanguageEnum added in v0.1.58

type ShowDataProcessingRulesResultRequestXLanguageEnum struct {
	EN_US ShowDataProcessingRulesResultRequestXLanguage
	ZH_CN ShowDataProcessingRulesResultRequestXLanguage
}

func GetShowDataProcessingRulesResultRequestXLanguageEnum added in v0.1.58

func GetShowDataProcessingRulesResultRequestXLanguageEnum() ShowDataProcessingRulesResultRequestXLanguageEnum

type ShowDataProcessingRulesResultResponse added in v0.1.58

type ShowDataProcessingRulesResultResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *ShowDataProcessingRulesResultResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                                          `json:"-"`
}

ShowDataProcessingRulesResultResponse Response Object

func (ShowDataProcessingRulesResultResponse) String added in v0.1.58

type ShowDataProcessingRulesResultResponseStatus added in v0.1.58

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

func (ShowDataProcessingRulesResultResponseStatus) MarshalJSON added in v0.1.58

func (*ShowDataProcessingRulesResultResponseStatus) UnmarshalJSON added in v0.1.58

func (ShowDataProcessingRulesResultResponseStatus) Value added in v0.1.58

type ShowDataProcessingRulesResultResponseStatusEnum added in v0.1.58

type ShowDataProcessingRulesResultResponseStatusEnum struct {
	PENDING ShowDataProcessingRulesResultResponseStatus
	FAILED  ShowDataProcessingRulesResultResponseStatus
	SUCCESS ShowDataProcessingRulesResultResponseStatus
}

func GetShowDataProcessingRulesResultResponseStatusEnum added in v0.1.58

func GetShowDataProcessingRulesResultResponseStatusEnum() ShowDataProcessingRulesResultResponseStatusEnum

type ShowDataProgressRequest added in v0.1.58

type ShowDataProgressRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDataProgressRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`
}

ShowDataProgressRequest Request Object

func (ShowDataProgressRequest) String added in v0.1.58

func (o ShowDataProgressRequest) String() string

type ShowDataProgressRequestXLanguage added in v0.1.58

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

func (ShowDataProgressRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowDataProgressRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowDataProgressRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowDataProgressRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowDataProgressRequestXLanguage) Value added in v0.1.58

type ShowDataProgressRequestXLanguageEnum added in v0.1.58

type ShowDataProgressRequestXLanguageEnum struct {
	EN_US ShowDataProgressRequestXLanguage
	ZH_CN ShowDataProgressRequestXLanguage
}

func GetShowDataProgressRequestXLanguageEnum added in v0.1.58

func GetShowDataProgressRequestXLanguageEnum() ShowDataProgressRequestXLanguageEnum

type ShowDataProgressResponse added in v0.1.58

type ShowDataProgressResponse struct {

	// 数据加工规则响应体
	DataProcessInfo *[]DataProcessInfo `json:"data_process_info,omitempty"`

	// 数据加工规则总数目
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowDataProgressResponse Response Object

func (ShowDataProgressResponse) String added in v0.1.58

func (o ShowDataProgressResponse) String() string

type ShowDbObjectCollectionStatusRequest added in v0.1.21

type ShowDbObjectCollectionStatusRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDbObjectCollectionStatusRequestXLanguage `json:"X-Language,omitempty"`

	// 对象信息采集的ID,提交查询数据库对象信息接口返回的ID。
	QueryId string `json:"query_id"`
}

ShowDbObjectCollectionStatusRequest Request Object

func (ShowDbObjectCollectionStatusRequest) String added in v0.1.21

type ShowDbObjectCollectionStatusRequestXLanguage added in v0.1.58

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

func (ShowDbObjectCollectionStatusRequestXLanguage) MarshalJSON added in v0.1.58

func (*ShowDbObjectCollectionStatusRequestXLanguage) UnmarshalJSON added in v0.1.58

func (ShowDbObjectCollectionStatusRequestXLanguage) Value added in v0.1.58

type ShowDbObjectCollectionStatusRequestXLanguageEnum added in v0.1.58

type ShowDbObjectCollectionStatusRequestXLanguageEnum struct {
	EN_US ShowDbObjectCollectionStatusRequestXLanguage
	ZH_CN ShowDbObjectCollectionStatusRequestXLanguage
}

func GetShowDbObjectCollectionStatusRequestXLanguageEnum added in v0.1.58

func GetShowDbObjectCollectionStatusRequestXLanguageEnum() ShowDbObjectCollectionStatusRequestXLanguageEnum

type ShowDbObjectCollectionStatusResponse added in v0.1.21

type ShowDbObjectCollectionStatusResponse struct {
	TargetRootDb *TargetRootDb `json:"target_root_db,omitempty"`

	// 数据库对象迁移或同步信息。
	ObjectInfo map[string]DatabaseObject `json:"object_info,omitempty"`

	// 库下表数量的阈值。
	MaxTableNum *int32 `json:"max_table_num,omitempty"`

	// 获取提交查询对象选择信息的状态
	Status *ShowDbObjectCollectionStatusResponseStatus `json:"status,omitempty"`

	// 任务id
	Id *string `json:"id,omitempty"`

	// 该数据库在实时同步场景下的类型
	ObjectScope    *string `json:"object_scope,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDbObjectCollectionStatusResponse Response Object

func (ShowDbObjectCollectionStatusResponse) String added in v0.1.21

type ShowDbObjectCollectionStatusResponseStatus added in v0.1.21

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

func (ShowDbObjectCollectionStatusResponseStatus) MarshalJSON added in v0.1.21

func (*ShowDbObjectCollectionStatusResponseStatus) UnmarshalJSON added in v0.1.21

func (ShowDbObjectCollectionStatusResponseStatus) Value added in v0.1.21

type ShowDbObjectCollectionStatusResponseStatusEnum added in v0.1.21

type ShowDbObjectCollectionStatusResponseStatusEnum struct {
	SUCCESS ShowDbObjectCollectionStatusResponseStatus
	FAILED  ShowDbObjectCollectionStatusResponseStatus
	PENDING ShowDbObjectCollectionStatusResponseStatus
}

func GetShowDbObjectCollectionStatusResponseStatusEnum added in v0.1.21

func GetShowDbObjectCollectionStatusResponseStatusEnum() ShowDbObjectCollectionStatusResponseStatusEnum

type ShowDbObjectTemplateProgressRequest

type ShowDbObjectTemplateProgressRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDbObjectTemplateProgressRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。
	Limit *int32 `json:"limit,omitempty"`
}

ShowDbObjectTemplateProgressRequest Request Object

func (ShowDbObjectTemplateProgressRequest) String

type ShowDbObjectTemplateProgressRequestXLanguage

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

func (ShowDbObjectTemplateProgressRequestXLanguage) MarshalJSON

func (*ShowDbObjectTemplateProgressRequestXLanguage) UnmarshalJSON

func (ShowDbObjectTemplateProgressRequestXLanguage) Value

type ShowDbObjectTemplateProgressResponse

type ShowDbObjectTemplateProgressResponse struct {

	// 是否上传完成。
	SendSuccess *bool `json:"send_success,omitempty"`

	// 文件解析状态。
	ProcessStatus *string `json:"process_status,omitempty"`

	// 解析成功的行数。
	ParsedSuccessNumber *string `json:"parsed_success_number,omitempty"`
	HttpStatusCode      int     `json:"-"`
}

ShowDbObjectTemplateProgressResponse Response Object

func (ShowDbObjectTemplateProgressResponse) String

type ShowDbObjectTemplateResultRequest

type ShowDbObjectTemplateResultRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDbObjectTemplateResultRequestXLanguage `json:"X-Language,omitempty"`

	// 导入的结果类型。取值: - detail:获取最新导入的文件与校验结果,上传后的文件若存在错误,会同时将错误原因标记在文件内。 - synchronized:获取已同步的(已下发的)对象文件结果。 - change: 获取新增和删除的对象结果(当再编辑时使用)
	Type ShowDbObjectTemplateResultRequestType `json:"type"`
}

ShowDbObjectTemplateResultRequest Request Object

func (ShowDbObjectTemplateResultRequest) String

type ShowDbObjectTemplateResultRequestType

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

func (ShowDbObjectTemplateResultRequestType) MarshalJSON

func (c ShowDbObjectTemplateResultRequestType) MarshalJSON() ([]byte, error)

func (*ShowDbObjectTemplateResultRequestType) UnmarshalJSON

func (c *ShowDbObjectTemplateResultRequestType) UnmarshalJSON(b []byte) error

func (ShowDbObjectTemplateResultRequestType) Value

type ShowDbObjectTemplateResultRequestXLanguage

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

func (ShowDbObjectTemplateResultRequestXLanguage) MarshalJSON

func (*ShowDbObjectTemplateResultRequestXLanguage) UnmarshalJSON

func (ShowDbObjectTemplateResultRequestXLanguage) Value

type ShowDbObjectTemplateResultResponse

type ShowDbObjectTemplateResultResponse struct {
	HttpStatusCode int           `json:"-"`
	Body           io.ReadCloser `json:"-" type:"stream"`
}

ShowDbObjectTemplateResultResponse Response Object

func (ShowDbObjectTemplateResultResponse) Consume

func (ShowDbObjectTemplateResultResponse) String

type ShowDbObjectsListRequest added in v0.1.58

type ShowDbObjectsListRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowDbObjectsListRequestXLanguage `json:"X-Language,omitempty"`

	// 查询对象信息类型。 取值:  - modified:查询已选择的(已同步的和未下发的)对象信息。
	Type string `json:"type"`
}

ShowDbObjectsListRequest Request Object

func (ShowDbObjectsListRequest) String added in v0.1.58

func (o ShowDbObjectsListRequest) String() string

type ShowDbObjectsListRequestXLanguage added in v0.1.58

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

func (ShowDbObjectsListRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowDbObjectsListRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowDbObjectsListRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowDbObjectsListRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowDbObjectsListRequestXLanguage) Value added in v0.1.58

type ShowDbObjectsListRequestXLanguageEnum added in v0.1.58

type ShowDbObjectsListRequestXLanguageEnum struct {
	EN_US ShowDbObjectsListRequestXLanguage
	ZH_CN ShowDbObjectsListRequestXLanguage
}

func GetShowDbObjectsListRequestXLanguageEnum added in v0.1.58

func GetShowDbObjectsListRequestXLanguageEnum() ShowDbObjectsListRequestXLanguageEnum

type ShowDbObjectsListResponse added in v0.1.58

type ShowDbObjectsListResponse struct {
	TargetRootDb *TargetRootDb `json:"target_root_db,omitempty"`

	// 数据库对象迁移或同步信息。
	ObjectInfo map[string]DatabaseObject `json:"object_info,omitempty"`

	// 库下表数量的阈值。
	MaxTableNum *int32 `json:"max_table_num,omitempty"`

	// 获取提交查询对象选择信息的状态
	Status *ShowDbObjectsListResponseStatus `json:"status,omitempty"`

	// 任务id
	Id *string `json:"id,omitempty"`

	// 该数据库在实时同步场景下的类型
	ObjectScope    *string `json:"object_scope,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDbObjectsListResponse Response Object

func (ShowDbObjectsListResponse) String added in v0.1.58

func (o ShowDbObjectsListResponse) String() string

type ShowDbObjectsListResponseStatus added in v0.1.58

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

func (ShowDbObjectsListResponseStatus) MarshalJSON added in v0.1.58

func (c ShowDbObjectsListResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowDbObjectsListResponseStatus) UnmarshalJSON added in v0.1.58

func (c *ShowDbObjectsListResponseStatus) UnmarshalJSON(b []byte) error

func (ShowDbObjectsListResponseStatus) Value added in v0.1.58

type ShowDbObjectsListResponseStatusEnum added in v0.1.58

type ShowDbObjectsListResponseStatusEnum struct {
	SUCCESS ShowDbObjectsListResponseStatus
	FAILED  ShowDbObjectsListResponseStatus
	PENDING ShowDbObjectsListResponseStatus
}

func GetShowDbObjectsListResponseStatusEnum added in v0.1.58

func GetShowDbObjectsListResponseStatusEnum() ShowDbObjectsListResponseStatusEnum

type ShowDirtyDataRequest added in v0.1.49

type ShowDirtyDataRequest struct {

	// 请求语言类型。
	XLanguage *ShowDirtyDataRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`

	// 开始时间,UTC时间,例如:2020-09-01T18:50:20Z
	BeginTime *string `json:"begin_time,omitempty"`

	// 结束时间,UTC时间,例如:2020-09-01T19:50:20Z
	EndTime *string `json:"end_time,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset 大于等于 0。默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量。默认为10,取值范围【1-1000】
	Limit *int32 `json:"limit,omitempty"`
}

ShowDirtyDataRequest Request Object

func (ShowDirtyDataRequest) String added in v0.1.49

func (o ShowDirtyDataRequest) String() string

type ShowDirtyDataRequestXLanguage added in v0.1.49

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

func (ShowDirtyDataRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowDirtyDataRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowDirtyDataRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowDirtyDataRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowDirtyDataRequestXLanguage) Value added in v0.1.49

type ShowDirtyDataRequestXLanguageEnum added in v0.1.49

type ShowDirtyDataRequestXLanguageEnum struct {
	EN_US ShowDirtyDataRequestXLanguage
	ZH_CN ShowDirtyDataRequestXLanguage
}

func GetShowDirtyDataRequestXLanguageEnum added in v0.1.49

func GetShowDirtyDataRequestXLanguageEnum() ShowDirtyDataRequestXLanguageEnum

type ShowDirtyDataResponse added in v0.1.49

type ShowDirtyDataResponse struct {

	// 总数。
	Count *int32 `json:"count,omitempty"`

	// 异常数据列表。
	DirtyDataList  *[]DirtyData `json:"dirty_data_list,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ShowDirtyDataResponse Response Object

func (ShowDirtyDataResponse) String added in v0.1.49

func (o ShowDirtyDataResponse) String() string

type ShowEnterpriseProjectRequest added in v0.1.49

type ShowEnterpriseProjectRequest struct {

	// 请求语言类型。
	XLanguage *ShowEnterpriseProjectRequestXLanguage `json:"X-Language,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset 大于等于 0。默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量。默认为10,取值范围【1-1000】
	Limit *int32 `json:"limit,omitempty"`

	// 企业项目名称,支持模糊搜索。
	Name *string `json:"name,omitempty"`

	// IAM用户所属帐号ID。op_service权限必须携带此参数,非op_service权限可不携带此参数。
	DomainId *string `json:"domain_id,omitempty"`
}

ShowEnterpriseProjectRequest Request Object

func (ShowEnterpriseProjectRequest) String added in v0.1.49

type ShowEnterpriseProjectRequestXLanguage added in v0.1.49

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

func (ShowEnterpriseProjectRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowEnterpriseProjectRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowEnterpriseProjectRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowEnterpriseProjectRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowEnterpriseProjectRequestXLanguage) Value added in v0.1.49

type ShowEnterpriseProjectRequestXLanguageEnum added in v0.1.49

type ShowEnterpriseProjectRequestXLanguageEnum struct {
	EN_US ShowEnterpriseProjectRequestXLanguage
	ZH_CN ShowEnterpriseProjectRequestXLanguage
}

func GetShowEnterpriseProjectRequestXLanguageEnum added in v0.1.49

func GetShowEnterpriseProjectRequestXLanguageEnum() ShowEnterpriseProjectRequestXLanguageEnum

type ShowEnterpriseProjectResponse added in v0.1.49

type ShowEnterpriseProjectResponse struct {

	// 总数。
	Count *int32 `json:"count,omitempty"`

	// 企业项目列表。
	EnterpriseProjectList *[]EnterpriseProject `json:"enterprise_project_list,omitempty"`
	HttpStatusCode        int                  `json:"-"`
}

ShowEnterpriseProjectResponse Response Object

func (ShowEnterpriseProjectResponse) String added in v0.1.49

type ShowHealthCompareJobListRequest added in v0.1.49

type ShowHealthCompareJobListRequest struct {

	// 请求语言类型。
	XLanguage *ShowHealthCompareJobListRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`

	// 状态,不传查询所有状态。 - WAITING_FOR_RUNNING:等待启动中 - RUNNING:运行中 - SUCCESSFUL:完成 - FAILED:失败 - CANCELLED:已取消 - TIMEOUT_INTERRUPT:超时中断 - FULL_DOING:全量校验中 - INCRE_DOING:增量校验中
	Status *ShowHealthCompareJobListRequestStatus `json:"status,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset 大于等于 0。默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量。默认为10,取值范围【1-1000】
	Limit *int32 `json:"limit,omitempty"`
}

ShowHealthCompareJobListRequest Request Object

func (ShowHealthCompareJobListRequest) String added in v0.1.49

type ShowHealthCompareJobListRequestStatus added in v0.1.49

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

func (ShowHealthCompareJobListRequestStatus) MarshalJSON added in v0.1.49

func (c ShowHealthCompareJobListRequestStatus) MarshalJSON() ([]byte, error)

func (*ShowHealthCompareJobListRequestStatus) UnmarshalJSON added in v0.1.49

func (c *ShowHealthCompareJobListRequestStatus) UnmarshalJSON(b []byte) error

func (ShowHealthCompareJobListRequestStatus) Value added in v0.1.49

type ShowHealthCompareJobListRequestXLanguage added in v0.1.49

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

func (ShowHealthCompareJobListRequestXLanguage) MarshalJSON added in v0.1.49

func (*ShowHealthCompareJobListRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowHealthCompareJobListRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowHealthCompareJobListRequestXLanguage) Value added in v0.1.49

type ShowHealthCompareJobListRequestXLanguageEnum added in v0.1.49

type ShowHealthCompareJobListRequestXLanguageEnum struct {
	EN_US ShowHealthCompareJobListRequestXLanguage
	ZH_CN ShowHealthCompareJobListRequestXLanguage
}

func GetShowHealthCompareJobListRequestXLanguageEnum added in v0.1.49

func GetShowHealthCompareJobListRequestXLanguageEnum() ShowHealthCompareJobListRequestXLanguageEnum

type ShowHealthCompareJobListResponse added in v0.1.49

type ShowHealthCompareJobListResponse struct {

	// 总数。
	Count *int64 `json:"count,omitempty"`

	// 健康对比任务列表。
	CompareJobs    *[]HealthCompareJob `json:"compare_jobs,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ShowHealthCompareJobListResponse Response Object

func (ShowHealthCompareJobListResponse) String added in v0.1.49

type ShowIncrementComponentsDetailRequest added in v0.1.58

type ShowIncrementComponentsDetailRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowIncrementComponentsDetailRequestXLanguage `json:"X-Language,omitempty"`
}

ShowIncrementComponentsDetailRequest Request Object

func (ShowIncrementComponentsDetailRequest) String added in v0.1.58

type ShowIncrementComponentsDetailRequestXLanguage added in v0.1.58

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

func (ShowIncrementComponentsDetailRequestXLanguage) MarshalJSON added in v0.1.58

func (*ShowIncrementComponentsDetailRequestXLanguage) UnmarshalJSON added in v0.1.58

func (ShowIncrementComponentsDetailRequestXLanguage) Value added in v0.1.58

type ShowIncrementComponentsDetailRequestXLanguageEnum added in v0.1.58

type ShowIncrementComponentsDetailRequestXLanguageEnum struct {
	EN_US ShowIncrementComponentsDetailRequestXLanguage
	ZH_CN ShowIncrementComponentsDetailRequestXLanguage
}

func GetShowIncrementComponentsDetailRequestXLanguageEnum added in v0.1.58

func GetShowIncrementComponentsDetailRequestXLanguageEnum() ShowIncrementComponentsDetailRequestXLanguageEnum

type ShowIncrementComponentsDetailResponse added in v0.1.58

type ShowIncrementComponentsDetailResponse struct {

	// 更新时间。
	UpdateTime *string `json:"update_time,omitempty"`

	// 增量组件详情。
	IncrementComponentsList *[]IncreComponentDetail `json:"increment_components_list,omitempty"`
	HttpStatusCode          int                     `json:"-"`
}

ShowIncrementComponentsDetailResponse Response Object

func (ShowIncrementComponentsDetailResponse) String added in v0.1.58

type ShowInstanceTagsRequest added in v0.1.58

type ShowInstanceTagsRequest struct {

	// 资源类型。 - migration:实时迁移 - sync:实时同步 - cloudDataGuard:实时灾备 - subscription:数据订阅 - backupMigration:备份迁移 - replay:仿真回放
	ResourceType ShowInstanceTagsRequestResourceType `json:"resource_type"`

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowInstanceTagsRequestXLanguage `json:"X-Language,omitempty"`
}

ShowInstanceTagsRequest Request Object

func (ShowInstanceTagsRequest) String added in v0.1.58

func (o ShowInstanceTagsRequest) String() string

type ShowInstanceTagsRequestResourceType added in v0.1.58

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

func (ShowInstanceTagsRequestResourceType) MarshalJSON added in v0.1.58

func (c ShowInstanceTagsRequestResourceType) MarshalJSON() ([]byte, error)

func (*ShowInstanceTagsRequestResourceType) UnmarshalJSON added in v0.1.58

func (c *ShowInstanceTagsRequestResourceType) UnmarshalJSON(b []byte) error

func (ShowInstanceTagsRequestResourceType) Value added in v0.1.58

type ShowInstanceTagsRequestResourceTypeEnum added in v0.1.58

func GetShowInstanceTagsRequestResourceTypeEnum added in v0.1.58

func GetShowInstanceTagsRequestResourceTypeEnum() ShowInstanceTagsRequestResourceTypeEnum

type ShowInstanceTagsRequestXLanguage added in v0.1.58

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

func (ShowInstanceTagsRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowInstanceTagsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowInstanceTagsRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowInstanceTagsRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowInstanceTagsRequestXLanguage) Value added in v0.1.58

type ShowInstanceTagsRequestXLanguageEnum added in v0.1.58

type ShowInstanceTagsRequestXLanguageEnum struct {
	EN_US ShowInstanceTagsRequestXLanguage
	ZH_CN ShowInstanceTagsRequestXLanguage
}

func GetShowInstanceTagsRequestXLanguageEnum added in v0.1.58

func GetShowInstanceTagsRequestXLanguageEnum() ShowInstanceTagsRequestXLanguageEnum

type ShowInstanceTagsResponse added in v0.1.58

type ShowInstanceTagsResponse struct {

	// 标签列表
	Tags           *[]BatchResourceTag `json:"tags,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ShowInstanceTagsResponse Response Object

func (ShowInstanceTagsResponse) String added in v0.1.58

func (o ShowInstanceTagsResponse) String() string

type ShowJobDetailRequest

type ShowJobDetailRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowJobDetailRequestXLanguage `json:"X-Language,omitempty"`

	// 任务详情类型。取值: - overview:任务概览信息。 - detail:任务基本信息。 - network:测试连接结果信息,需配合query_id参数一起查询。 - precheck:预检查结果信息,需配合query_id参数一起查询。 - progress:任务进度信息。 - log:任务日志信息,支持分页查询参数offset与limit。 - comapre:查询对比任务。 - file:对象导入信息
	Type ShowJobDetailRequestType `json:"type"`

	// 通过指定Query ID查询任务详情。  说明:部分type类型的任务详情,需要通过触发该操作的请求返回的query_id进行操作结果查询。
	QueryId *string `json:"query_id,omitempty"`

	// 偏移量,表示查询该偏移量后面的记录。  说明:部分type类型的任务详情支持分页查询,可以通过传递该参数进行分页控制。
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制。  说明:部分type类型的任务详情支持分页查询,可以通过传递该参数进行分页控制。
	Limit *int32 `json:"limit,omitempty"`

	// 对比任务类型 - object_compare:对象对比。 - line_compare:行对比。 - content_compare:内容对比。 - data_compare:数据对比。
	CompareType *ShowJobDetailRequestCompareType `json:"compare_type,omitempty"`

	// 查询对比内容。取值: - overview:对比任务概览。 - list:数据对比任务列表。 - detail:对比详情。 - diff:不一致详情。
	QueryType *ShowJobDetailRequestQueryType `json:"query_type,omitempty"`

	// 查询对象对比详情类型。取值: - DB:库级对比详情。 - TABLE:表级对比详情。 - INDEX:索引对比详情。
	ObjectType *ShowJobDetailRequestObjectType `json:"object_type,omitempty"`

	// 对比任务ID。
	CompareTaskId *string `json:"compare_task_id,omitempty"`

	// 数据对比源库名称。
	SourceDbName *string `json:"source_db_name,omitempty"`

	// 数据对比目标库名称。
	TargetDbName *string `json:"target_db_name,omitempty"`

	// 对比结果类型。取值: - compare:对比完成。 - uncompare:无法对比。
	CompareDetailType *ShowJobDetailRequestCompareDetailType `json:"compare_detail_type,omitempty"`
}

ShowJobDetailRequest Request Object

func (ShowJobDetailRequest) String

func (o ShowJobDetailRequest) String() string

type ShowJobDetailRequestCompareDetailType

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

func (ShowJobDetailRequestCompareDetailType) MarshalJSON

func (c ShowJobDetailRequestCompareDetailType) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestCompareDetailType) UnmarshalJSON

func (c *ShowJobDetailRequestCompareDetailType) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestCompareDetailType) Value

type ShowJobDetailRequestCompareDetailTypeEnum

type ShowJobDetailRequestCompareDetailTypeEnum struct {
	COMPARE   ShowJobDetailRequestCompareDetailType
	UNCOMPARE ShowJobDetailRequestCompareDetailType
}

func GetShowJobDetailRequestCompareDetailTypeEnum

func GetShowJobDetailRequestCompareDetailTypeEnum() ShowJobDetailRequestCompareDetailTypeEnum

type ShowJobDetailRequestCompareType

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

func (ShowJobDetailRequestCompareType) MarshalJSON

func (c ShowJobDetailRequestCompareType) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestCompareType) UnmarshalJSON

func (c *ShowJobDetailRequestCompareType) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestCompareType) Value

type ShowJobDetailRequestCompareTypeEnum

type ShowJobDetailRequestCompareTypeEnum struct {
	OBJECT_COMPARE  ShowJobDetailRequestCompareType
	LINE_COMPARE    ShowJobDetailRequestCompareType
	CONTENT_COMPARE ShowJobDetailRequestCompareType
	DATA_COMPARE    ShowJobDetailRequestCompareType
}

func GetShowJobDetailRequestCompareTypeEnum

func GetShowJobDetailRequestCompareTypeEnum() ShowJobDetailRequestCompareTypeEnum

type ShowJobDetailRequestObjectType

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

func (ShowJobDetailRequestObjectType) MarshalJSON

func (c ShowJobDetailRequestObjectType) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestObjectType) UnmarshalJSON

func (c *ShowJobDetailRequestObjectType) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestObjectType) Value

type ShowJobDetailRequestQueryType

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

func (ShowJobDetailRequestQueryType) MarshalJSON

func (c ShowJobDetailRequestQueryType) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestQueryType) UnmarshalJSON

func (c *ShowJobDetailRequestQueryType) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestQueryType) Value

type ShowJobDetailRequestQueryTypeEnum

type ShowJobDetailRequestQueryTypeEnum struct {
	OVERVIEW ShowJobDetailRequestQueryType
	LIST     ShowJobDetailRequestQueryType
	DETAIL   ShowJobDetailRequestQueryType
}

func GetShowJobDetailRequestQueryTypeEnum

func GetShowJobDetailRequestQueryTypeEnum() ShowJobDetailRequestQueryTypeEnum

type ShowJobDetailRequestType

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

func (ShowJobDetailRequestType) MarshalJSON

func (c ShowJobDetailRequestType) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestType) UnmarshalJSON

func (c *ShowJobDetailRequestType) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestType) Value

func (c ShowJobDetailRequestType) Value() string

type ShowJobDetailRequestXLanguage

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

func (ShowJobDetailRequestXLanguage) MarshalJSON

func (c ShowJobDetailRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowJobDetailRequestXLanguage) UnmarshalJSON

func (c *ShowJobDetailRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowJobDetailRequestXLanguage) Value

type ShowJobDetailRequestXLanguageEnum

type ShowJobDetailRequestXLanguageEnum struct {
	EN_US ShowJobDetailRequestXLanguage
	ZH_CN ShowJobDetailRequestXLanguage
}

func GetShowJobDetailRequestXLanguageEnum

func GetShowJobDetailRequestXLanguageEnum() ShowJobDetailRequestXLanguageEnum

type ShowJobDetailResponse

type ShowJobDetailResponse struct {
	Job            *JobDetailResp `json:"job,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ShowJobDetailResponse Response Object

func (ShowJobDetailResponse) String

func (o ShowJobDetailResponse) String() string

type ShowMeteringRequest added in v0.1.49

type ShowMeteringRequest struct {

	// 请求语言类型。
	XLanguage *ShowMeteringRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`
}

ShowMeteringRequest Request Object

func (ShowMeteringRequest) String added in v0.1.49

func (o ShowMeteringRequest) String() string

type ShowMeteringRequestXLanguage added in v0.1.49

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

func (ShowMeteringRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowMeteringRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowMeteringRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowMeteringRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowMeteringRequestXLanguage) Value added in v0.1.49

type ShowMeteringRequestXLanguageEnum added in v0.1.49

type ShowMeteringRequestXLanguageEnum struct {
	EN_US ShowMeteringRequestXLanguage
	ZH_CN ShowMeteringRequestXLanguage
}

func GetShowMeteringRequestXLanguageEnum added in v0.1.49

func GetShowMeteringRequestXLanguageEnum() ShowMeteringRequestXLanguageEnum

type ShowMeteringResponse added in v0.1.49

type ShowMeteringResponse struct {

	// 资源信息列表。
	ProductInfoList *[]ProductInfo `json:"product_info_list,omitempty"`
	HttpStatusCode  int            `json:"-"`
}

ShowMeteringResponse Response Object

func (ShowMeteringResponse) String added in v0.1.49

func (o ShowMeteringResponse) String() string

type ShowMonitorDataRequest added in v0.1.58

type ShowMonitorDataRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowMonitorDataRequestXLanguage `json:"X-Language,omitempty"`
}

ShowMonitorDataRequest Request Object

func (ShowMonitorDataRequest) String added in v0.1.58

func (o ShowMonitorDataRequest) String() string

type ShowMonitorDataRequestXLanguage added in v0.1.58

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

func (ShowMonitorDataRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowMonitorDataRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowMonitorDataRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowMonitorDataRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowMonitorDataRequestXLanguage) Value added in v0.1.58

type ShowMonitorDataRequestXLanguageEnum added in v0.1.58

type ShowMonitorDataRequestXLanguageEnum struct {
	EN_US ShowMonitorDataRequestXLanguage
	ZH_CN ShowMonitorDataRequestXLanguage
}

func GetShowMonitorDataRequestXLanguageEnum added in v0.1.58

func GetShowMonitorDataRequestXLanguageEnum() ShowMonitorDataRequestXLanguageEnum

type ShowMonitorDataResponse added in v0.1.58

type ShowMonitorDataResponse struct {

	// EIP带宽,单位:MB/S
	Bandwidth *string `json:"bandwidth,omitempty"`

	// 源库连接状态是否正常。
	IsSrcNormal *bool `json:"is_src_normal,omitempty"`

	// 目标库连接状态是否正常。
	IsDstNormal *bool `json:"is_dst_normal,omitempty"`

	// 源库offSet位点。
	SrcOffset *string `json:"src_offset,omitempty"`

	// 迁移实例offSet位点。
	NodeOffset *string `json:"node_offset,omitempty"`

	// 目标库offSet位点。
	DstOffset *string `json:"dst_offset,omitempty"`

	// 源库时延。
	SrcDelay *int32 `json:"src_delay,omitempty"`

	// 目标库时延。
	DstDelay *int32 `json:"dst_delay,omitempty"`

	// 源库RPS。
	SrcRps *string `json:"src_rps,omitempty"`

	// 源库IO。
	SrcIo *string `json:"src_io,omitempty"`

	// 目标库RPS。
	DstRps *string `json:"dst_rps,omitempty"`

	// 目标库IO。
	DstIo *string `json:"dst_io,omitempty"`

	// 迁移数据量。单位:MB
	TransData *string `json:"trans_data,omitempty"`

	// 迁移数据行数。
	TransLines *string `json:"trans_lines,omitempty"`

	// 磁盘使用量。单位:GB
	UsedVolumes *string `json:"used_volumes,omitempty"`

	// 内存使用量。单位:MB
	UsedMemory *string `json:"used_memory,omitempty"`

	// CPU使用百分比。
	UsedCpuPercent *string `json:"used_cpu_percent,omitempty"`

	// node磁盘总大小。单位:GB
	NodeVolumeSize *int32 `json:"node_volume_size,omitempty"`

	// node内存总大小。单位:MB
	NodeMemorySize *int32 `json:"node_memory_size,omitempty"`

	// 更新时间。
	UpdateTime *string `json:"update_time,omitempty"`

	// 同步速度。单位:byte/s
	ApplyRate      *int32 `json:"apply_rate,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowMonitorDataResponse Response Object

func (ShowMonitorDataResponse) String added in v0.1.58

func (o ShowMonitorDataResponse) String() string

type ShowObjectMappingRequest added in v0.1.49

type ShowObjectMappingRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowObjectMappingRequestXLanguage `json:"X-Language,omitempty"`

	Body *QueryUserSelectedObjectInfoReq `json:"body,omitempty"`
}

ShowObjectMappingRequest Request Object

func (ShowObjectMappingRequest) String added in v0.1.49

func (o ShowObjectMappingRequest) String() string

type ShowObjectMappingRequestXLanguage added in v0.1.58

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

func (ShowObjectMappingRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowObjectMappingRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowObjectMappingRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowObjectMappingRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowObjectMappingRequestXLanguage) Value added in v0.1.58

type ShowObjectMappingRequestXLanguageEnum added in v0.1.58

type ShowObjectMappingRequestXLanguageEnum struct {
	EN_US ShowObjectMappingRequestXLanguage
	ZH_CN ShowObjectMappingRequestXLanguage
}

func GetShowObjectMappingRequestXLanguageEnum added in v0.1.58

func GetShowObjectMappingRequestXLanguageEnum() ShowObjectMappingRequestXLanguageEnum

type ShowObjectMappingResponse added in v0.1.49

type ShowObjectMappingResponse struct {

	// 总数。
	Count *int64 `json:"count,omitempty"`

	// 同步映射数据列表。
	ObjectMappingList *[]DbObjectInfo `json:"object_mapping_list,omitempty"`
	HttpStatusCode    int             `json:"-"`
}

ShowObjectMappingResponse Response Object

func (ShowObjectMappingResponse) String added in v0.1.49

func (o ShowObjectMappingResponse) String() string

type ShowProgressDataRequest added in v0.1.49

type ShowProgressDataRequest struct {

	// 请求语言类型。
	XLanguage *ShowProgressDataRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID。
	JobId string `json:"job_id"`

	// 偏移量,表示从此偏移量开始查询, offset 大于等于 0。默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量。默认为10,取值范围【1-1000】
	Limit *int32 `json:"limit,omitempty"`

	// 迁移对象类型。 - table - event - table_structure - procedure - view - function - database - trigger - table_indexs
	Type string `json:"type"`
}

ShowProgressDataRequest Request Object

func (ShowProgressDataRequest) String added in v0.1.49

func (o ShowProgressDataRequest) String() string

type ShowProgressDataRequestXLanguage added in v0.1.49

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

func (ShowProgressDataRequestXLanguage) MarshalJSON added in v0.1.49

func (c ShowProgressDataRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowProgressDataRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ShowProgressDataRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowProgressDataRequestXLanguage) Value added in v0.1.49

type ShowProgressDataRequestXLanguageEnum added in v0.1.49

type ShowProgressDataRequestXLanguageEnum struct {
	EN_US ShowProgressDataRequestXLanguage
	ZH_CN ShowProgressDataRequestXLanguage
}

func GetShowProgressDataRequestXLanguageEnum added in v0.1.49

func GetShowProgressDataRequestXLanguageEnum() ShowProgressDataRequestXLanguageEnum

type ShowProgressDataResponse added in v0.1.49

type ShowProgressDataResponse struct {

	// 总数。
	Count *int64 `json:"count,omitempty"`

	// 数据生成时间,UTC时间,例如:2020-09-01T18:50:20.200Z
	CreateTime *string `json:"create_time,omitempty"`

	// 对比结果。
	FlowCompareData *[]FlowCompareData `json:"flow_compare_data,omitempty"`
	HttpStatusCode  int                `json:"-"`
}

ShowProgressDataResponse Response Object

func (ShowProgressDataResponse) String added in v0.1.49

func (o ShowProgressDataResponse) String() string

type ShowSupportObjectTypeRequest added in v0.1.58

type ShowSupportObjectTypeRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowSupportObjectTypeRequestXLanguage `json:"X-Language,omitempty"`
}

ShowSupportObjectTypeRequest Request Object

func (ShowSupportObjectTypeRequest) String added in v0.1.58

type ShowSupportObjectTypeRequestXLanguage added in v0.1.58

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

func (ShowSupportObjectTypeRequestXLanguage) MarshalJSON added in v0.1.58

func (c ShowSupportObjectTypeRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowSupportObjectTypeRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *ShowSupportObjectTypeRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowSupportObjectTypeRequestXLanguage) Value added in v0.1.58

type ShowSupportObjectTypeRequestXLanguageEnum added in v0.1.58

type ShowSupportObjectTypeRequestXLanguageEnum struct {
	EN_US ShowSupportObjectTypeRequestXLanguage
	ZH_CN ShowSupportObjectTypeRequestXLanguage
}

func GetShowSupportObjectTypeRequestXLanguageEnum added in v0.1.58

func GetShowSupportObjectTypeRequestXLanguageEnum() ShowSupportObjectTypeRequestXLanguageEnum

type ShowSupportObjectTypeResponse added in v0.1.58

type ShowSupportObjectTypeResponse struct {

	// 全量任务是否支持对象选择。
	IsFullTransSupportObject *bool `json:"is_full_trans_support_object,omitempty"`

	// 增量任务是否支持对象选择。
	IsIncreTransSupportObject *bool `json:"is_incre_trans_support_object,omitempty"`

	// 全量加增量任务是否支持对象选择。
	IsFullIncreTransSupportObject *bool `json:"is_full_incre_trans_support_object,omitempty"`

	// 支持对象导入的引引擎。
	SupportObjectImportEngine *[]string `json:"support_object_import_engine,omitempty"`

	// 是否支持列映射。
	IsSupportColumnMapping *bool `json:"is_support_column_mapping,omitempty"`

	// 库是否支持搜索。
	IsDatabaseSupportSearch *bool `json:"is_database_support_search,omitempty"`

	// schema是否支持搜索。
	IsSchemaSupportSearch *bool `json:"is_schema_support_search,omitempty"`

	// 表是否支持搜索。
	IsTableSupportSearch *bool `json:"is_table_support_search,omitempty"`

	// 对象导入支持的文件大小。
	FileSize *string `json:"file_size,omitempty"`

	// 上一次选择迁移对象或者同步对象的方式。 - srcImportObject:当前任务上次选择的方式为导入方式
	PreviousSelect *string `json:"previous_select,omitempty"`

	// 对象导入类型。 - table:表级 - database:库级
	ImportLevel    *string `json:"import_level,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowSupportObjectTypeResponse Response Object

func (ShowSupportObjectTypeResponse) String added in v0.1.58

type ShowUpdateObjectSavingStatusRequest added in v0.1.21

type ShowUpdateObjectSavingStatusRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *ShowUpdateObjectSavingStatusRequestXLanguage `json:"X-Language,omitempty"`

	// 保存对象接口返回的ID。
	QueryId string `json:"query_id"`
}

ShowUpdateObjectSavingStatusRequest Request Object

func (ShowUpdateObjectSavingStatusRequest) String added in v0.1.21

type ShowUpdateObjectSavingStatusRequestXLanguage added in v0.1.58

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

func (ShowUpdateObjectSavingStatusRequestXLanguage) MarshalJSON added in v0.1.58

func (*ShowUpdateObjectSavingStatusRequestXLanguage) UnmarshalJSON added in v0.1.58

func (ShowUpdateObjectSavingStatusRequestXLanguage) Value added in v0.1.58

type ShowUpdateObjectSavingStatusRequestXLanguageEnum added in v0.1.58

type ShowUpdateObjectSavingStatusRequestXLanguageEnum struct {
	EN_US ShowUpdateObjectSavingStatusRequestXLanguage
	ZH_CN ShowUpdateObjectSavingStatusRequestXLanguage
}

func GetShowUpdateObjectSavingStatusRequestXLanguageEnum added in v0.1.58

func GetShowUpdateObjectSavingStatusRequestXLanguageEnum() ShowUpdateObjectSavingStatusRequestXLanguageEnum

type ShowUpdateObjectSavingStatusResponse added in v0.1.21

type ShowUpdateObjectSavingStatusResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *ShowUpdateObjectSavingStatusResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                                         `json:"-"`
}

ShowUpdateObjectSavingStatusResponse Response Object

func (ShowUpdateObjectSavingStatusResponse) String added in v0.1.21

type ShowUpdateObjectSavingStatusResponseStatus added in v0.1.21

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

func (ShowUpdateObjectSavingStatusResponseStatus) MarshalJSON added in v0.1.21

func (*ShowUpdateObjectSavingStatusResponseStatus) UnmarshalJSON added in v0.1.21

func (ShowUpdateObjectSavingStatusResponseStatus) Value added in v0.1.21

type ShowUpdateObjectSavingStatusResponseStatusEnum added in v0.1.21

type ShowUpdateObjectSavingStatusResponseStatusEnum struct {
	PENDING ShowUpdateObjectSavingStatusResponseStatus
	FAILED  ShowUpdateObjectSavingStatusResponseStatus
	SUCCESS ShowUpdateObjectSavingStatusResponseStatus
}

func GetShowUpdateObjectSavingStatusResponseStatusEnum added in v0.1.21

func GetShowUpdateObjectSavingStatusResponseStatusEnum() ShowUpdateObjectSavingStatusResponseStatusEnum

type SingleCreateJobReq

type SingleCreateJobReq struct {
	Job *CreateJobReq `json:"job"`
}

SingleCreateJobReq 创建单个任务请求体。

func (SingleCreateJobReq) String

func (o SingleCreateJobReq) String() string

type SingleUpdateJobReq

type SingleUpdateJobReq struct {
	Job *UpdateJobReq `json:"job"`
}

SingleUpdateJobReq 更新单个任务请求体。

func (SingleUpdateJobReq) String

func (o SingleUpdateJobReq) String() string

type SkipPreCheckInfo

type SkipPreCheckInfo struct {

	// 跳过的预检查项。
	SkippedPrecheckList []string `json:"skipped_precheck_list"`

	// 跳过预检查原因。
	SkipReason string `json:"skip_reason"`
}

SkipPreCheckInfo 跳过预检查项参数。

func (SkipPreCheckInfo) String

func (o SkipPreCheckInfo) String() string

type SpeedLimitInfo

type SpeedLimitInfo struct {

	// 开始限速时间,此时间为UTC时间,开始时间为整时,若有分钟,则会忽略,格式为hh:mm,小时数为两位,例如:01:00。
	Begin string `json:"begin"`

	// 结束时间,此时间为UTC时间,输入必须为59分结尾,格式为hh:mm,例如:15:59。
	End string `json:"end"`

	// 限速值,取值范围为1~9999,单位为MB/s。
	Speed string `json:"speed"`
}

SpeedLimitInfo 限速信息体。 - 限速:自定义的最大迁移速度,迁移过程中的迁移速度将不会超过该速度。 - 不限速:对迁移速度不进行限制,通常会最大化使用源数据库的出口带宽。该流速模式同时会对源数据库造成读消耗,消耗取决于源数据库的出口带宽。比如:源数据库的出口带宽为100MB/s,假设高速模式使用了80%带宽,则迁移对源数据库将造成80MB/s的读操作IO消耗。

func (SpeedLimitInfo) String

func (o SpeedLimitInfo) String() string

type StopJobActionInfo added in v0.1.58

type StopJobActionInfo struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 强制结束任务时取值true,默认false。
	IsForceStop *bool `json:"is_force_stop,omitempty"`
}

StopJobActionInfo 结束任务请求体。

func (StopJobActionInfo) String added in v0.1.58

func (o StopJobActionInfo) String() string

type StopJobActionReq added in v0.1.58

type StopJobActionReq struct {

	// 强制结束任务时取值true,默认false。
	IsForceStop *bool `json:"is_force_stop,omitempty"`
}

StopJobActionReq 结束单个任务请求体。

func (StopJobActionReq) String added in v0.1.58

func (o StopJobActionReq) String() string

type StopJobActionRequest added in v0.1.58

type StopJobActionRequest struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *StopJobActionRequestXLanguage `json:"X-Language,omitempty"`

	Body *StopJobActionReq `json:"body,omitempty"`
}

StopJobActionRequest Request Object

func (StopJobActionRequest) String added in v0.1.58

func (o StopJobActionRequest) String() string

type StopJobActionRequestXLanguage added in v0.1.58

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

func (StopJobActionRequestXLanguage) MarshalJSON added in v0.1.58

func (c StopJobActionRequestXLanguage) MarshalJSON() ([]byte, error)

func (*StopJobActionRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *StopJobActionRequestXLanguage) UnmarshalJSON(b []byte) error

func (StopJobActionRequestXLanguage) Value added in v0.1.58

type StopJobActionRequestXLanguageEnum added in v0.1.58

type StopJobActionRequestXLanguageEnum struct {
	EN_US StopJobActionRequestXLanguage
	ZH_CN StopJobActionRequestXLanguage
}

func GetStopJobActionRequestXLanguageEnum added in v0.1.58

func GetStopJobActionRequestXLanguageEnum() StopJobActionRequestXLanguageEnum

type StopJobActionResponse added in v0.1.58

type StopJobActionResponse struct {

	// 错误码。
	ErrorCode string `json:"error_code"`

	// 错误描述。
	ErrorMsg string `json:"error_msg"`

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 操作结果。
	Status         string `json:"status"`
	HttpStatusCode int    `json:"-"`
}

StopJobActionResponse Response Object

func (StopJobActionResponse) String added in v0.1.58

func (o StopJobActionResponse) String() string

type SupportImportFileResult added in v0.1.49

type SupportImportFileResult struct {

	// 文件导入阈值。
	FileSize *string `json:"file_size,omitempty"`

	// 上一次选择对象的方式。
	PreviousSelect *string `json:"previous_select,omitempty"`
}

SupportImportFileResult 对象导入信息。

func (SupportImportFileResult) String added in v0.1.49

func (o SupportImportFileResult) String() string

type TableLineCompareDetailInfo

type TableLineCompareDetailInfo struct {

	// 源库表名称。
	SourceTableName *string `json:"source_table_name,omitempty"`

	// 源库表行数。
	SourceRowNum *string `json:"source_row_num,omitempty"`

	// 目标库表名称。
	TargetTableName *string `json:"target_table_name,omitempty"`

	// 目标库表行数。
	TargetRowNum *string `json:"target_row_num,omitempty"`

	// 差异值。
	DifferenceRowNum *string `json:"difference_row_num,omitempty"`

	// 对比结果。取值: - CONSISTENT:一致。 - INCONSISTENT:不一致。 - COMPARING:正在对比。 - WAITING_FOR_COMPARISON:等待对比。 - FAILED_TO_COMPARE:对比失败。 - TARGET_DB_NOT_EXIST:目标库不存在。 - CAN_NOT_COMPARE:无法对比。
	Status *TableLineCompareDetailInfoStatus `json:"status,omitempty"`

	// 信息。
	Message *string `json:"message,omitempty"`
}

TableLineCompareDetailInfo 行数对比任务表级详情。

func (TableLineCompareDetailInfo) String

type TableLineCompareDetailInfoStatus

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

func (TableLineCompareDetailInfoStatus) MarshalJSON

func (c TableLineCompareDetailInfoStatus) MarshalJSON() ([]byte, error)

func (*TableLineCompareDetailInfoStatus) UnmarshalJSON

func (c *TableLineCompareDetailInfoStatus) UnmarshalJSON(b []byte) error

func (TableLineCompareDetailInfoStatus) Value

type TableLineCompareDetailInfoStatusEnum

type TableLineCompareDetailInfoStatusEnum struct {
	CONSISTENT             TableLineCompareDetailInfoStatus
	INCONSISTENT           TableLineCompareDetailInfoStatus
	COMPARING              TableLineCompareDetailInfoStatus
	WAITING_FOR_COMPARISON TableLineCompareDetailInfoStatus
	FAILED_TO_COMPARE      TableLineCompareDetailInfoStatus
	TARGET_DB_NOT_EXIST    TableLineCompareDetailInfoStatus
	CAN_NOT_COMPARE        TableLineCompareDetailInfoStatus
}

func GetTableLineCompareDetailInfoStatusEnum

func GetTableLineCompareDetailInfoStatusEnum() TableLineCompareDetailInfoStatusEnum

type TableObject

type TableObject struct {

	// 该表在实时同步场景下的类型。取值: - config:仅当该表作为数据过滤高级设置的关联表时,需要填写,此时该表以及该表下的columns“不会”被同步到目标库,name、all、filtered、filter_conditions属性不生效,columns需要填写被关联的相关对象,config_conditions需要填写数据过滤高级设置的配置条件。(注意:如果需要同步该表级对象,则在下级对象中填写sync_type值为config。)
	SyncType *string `json:"sync_type,omitempty"`

	// 对象类型。取值: - table:表。 - view:视图。 - procedure:存储过程。
	Type *TableObjectType `json:"type,omitempty"`

	// 该表在目标库的名称(表名映射)。
	Name *string `json:"name,omitempty"`

	// 是否整表迁移或同步。注意: 1.当该表不需要做列过滤、列映射时,填true,如果需要做列过滤、列映射则填false; 2.当该表需要做附加列时,需要填true,并且在columns里填写附加列信息; 3.当该表所包含的列作为数据过滤高级设置的关联列时,需要填true,并且在columns里填写关联列信息、config_conditions填写数据过滤高级设置的配置条件;
	All *bool `json:"all,omitempty"`

	// 一对多情况下,表级上对库名的映射。
	DbAliasName *string `json:"db_alias_name,omitempty"`

	// 一对多情况下,表级上对schema名的映射。
	SchemaAliasName *string `json:"schema_alias_name,omitempty"`

	// 该表是否进行数据过滤。
	Filtered *bool `json:"filtered,omitempty"`

	// 该表数据的过滤条件,生成加工规则值为SQL条件语句,长度限制512。
	FilterConditions *[]string `json:"filter_conditions,omitempty"`

	// 该表数据过滤高级设置的配置条件,当该表作为联表查询时填写,生成加工规则值为SQL条件语句,长度限制512。
	ConfigConditions *[]string `json:"config_conditions,omitempty"`

	// 是否已经进行同步。
	IsSynchronized *bool `json:"is_synchronized,omitempty"`

	// 需要同步/映射/过滤/新增的列,当需要列过滤、列映射、附加列功能时填写,仅在实时同步任务中生效,当整表同步为false时需要填写。
	Columns map[string]ColumnObject `json:"columns,omitempty"`
}

TableObject 数据库表级对象。

func (TableObject) String

func (o TableObject) String() string

type TableObjectType

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

func (TableObjectType) MarshalJSON

func (c TableObjectType) MarshalJSON() ([]byte, error)

func (*TableObjectType) UnmarshalJSON

func (c *TableObjectType) UnmarshalJSON(b []byte) error

func (TableObjectType) Value

func (c TableObjectType) Value() string

type TableObjectTypeEnum

type TableObjectTypeEnum struct {
	TABLE     TableObjectType
	VIEW      TableObjectType
	PROCEDURE TableObjectType
}

func GetTableObjectTypeEnum

func GetTableObjectTypeEnum() TableObjectTypeEnum

type TargetRootDb

type TargetRootDb struct {

	// 库名。
	DbName *string `json:"db_name,omitempty"`

	// 默认编码格式是utf8。
	DbEncoding *string `json:"db_encoding,omitempty"`
}

TargetRootDb 数据库对象迁移或同步目标库信息,两层到三层数据库时需要指定。

func (TargetRootDb) String

func (o TargetRootDb) String() string

type TaskLogInfo

type TaskLogInfo struct {

	// 日志级别。
	Level *string `json:"level,omitempty"`

	// 日志信息。
	Message *string `json:"message,omitempty"`

	// 日志时间。
	CreateTime *string `json:"create_time,omitempty"`
}

TaskLogInfo 日志查询结果信息体。

func (TaskLogInfo) String

func (o TaskLogInfo) String() string

type TuningParamInfo

type TuningParamInfo struct {

	// 全量调优参数。
	FullSync []TuningParameter `json:"full_sync"`

	// 增量抓取调优参数。
	IncreCapture []TuningParameter `json:"incre_capture"`

	// 增量回放调优参数。
	IncreApply []TuningParameter `json:"incre_apply"`

	// 增量日志拉取调优参数。
	IncreRelay []TuningParameter `json:"incre_relay"`
}

TuningParamInfo 高级设置信息体。

func (TuningParamInfo) String

func (o TuningParamInfo) String() string

type TuningParameter

type TuningParameter struct {

	// 参数名称。
	ParamName string `json:"param_name"`

	// 参数取值。
	ParamValue string `json:"param_value"`

	// 是否可用。
	Availability bool `json:"availability"`
}

TuningParameter 调优参数。

func (TuningParameter) String

func (o TuningParameter) String() string

type UpdateBatchAsyncJobsRequest

type UpdateBatchAsyncJobsRequest struct {

	// 批量异步创建的任务ID,由创建批量异步任务接口返回。
	AsyncJobId string `json:"async_job_id"`

	// 请求语言类型。
	XLanguage *UpdateBatchAsyncJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchAsyncUpdateJobReq `json:"body,omitempty"`
}

UpdateBatchAsyncJobsRequest Request Object

func (UpdateBatchAsyncJobsRequest) String

type UpdateBatchAsyncJobsRequestXLanguage

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

func (UpdateBatchAsyncJobsRequestXLanguage) MarshalJSON

func (c UpdateBatchAsyncJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateBatchAsyncJobsRequestXLanguage) UnmarshalJSON

func (c *UpdateBatchAsyncJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateBatchAsyncJobsRequestXLanguage) Value

type UpdateBatchAsyncJobsRequestXLanguageEnum

type UpdateBatchAsyncJobsRequestXLanguageEnum struct {
	EN_US UpdateBatchAsyncJobsRequestXLanguage
	ZH_CN UpdateBatchAsyncJobsRequestXLanguage
}

func GetUpdateBatchAsyncJobsRequestXLanguageEnum

func GetUpdateBatchAsyncJobsRequestXLanguageEnum() UpdateBatchAsyncJobsRequestXLanguageEnum

type UpdateBatchAsyncJobsResponse

type UpdateBatchAsyncJobsResponse struct {

	// 批量更新指定ID异步任务响应体。
	Jobs           *[]AsyncUpdateJobResp `json:"jobs,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

UpdateBatchAsyncJobsResponse Response Object

func (UpdateBatchAsyncJobsResponse) String

type UpdateDataProgressRequest added in v0.1.58

type UpdateDataProgressRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *UpdateDataProgressRequestXLanguage `json:"X-Language,omitempty"`

	Body *DataProcessReq `json:"body,omitempty"`
}

UpdateDataProgressRequest Request Object

func (UpdateDataProgressRequest) String added in v0.1.58

func (o UpdateDataProgressRequest) String() string

type UpdateDataProgressRequestXLanguage added in v0.1.58

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

func (UpdateDataProgressRequestXLanguage) MarshalJSON added in v0.1.58

func (c UpdateDataProgressRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateDataProgressRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *UpdateDataProgressRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateDataProgressRequestXLanguage) Value added in v0.1.58

type UpdateDataProgressRequestXLanguageEnum added in v0.1.58

type UpdateDataProgressRequestXLanguageEnum struct {
	EN_US UpdateDataProgressRequestXLanguage
	ZH_CN UpdateDataProgressRequestXLanguage
}

func GetUpdateDataProgressRequestXLanguageEnum added in v0.1.58

func GetUpdateDataProgressRequestXLanguageEnum() UpdateDataProgressRequestXLanguageEnum

type UpdateDataProgressResponse added in v0.1.58

type UpdateDataProgressResponse struct {

	// 查询结果id
	Id *string `json:"id,omitempty"`

	// 查询状态
	Status         *UpdateDataProgressResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                               `json:"-"`
}

UpdateDataProgressResponse Response Object

func (UpdateDataProgressResponse) String added in v0.1.58

type UpdateDataProgressResponseStatus added in v0.1.58

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

func (UpdateDataProgressResponseStatus) MarshalJSON added in v0.1.58

func (c UpdateDataProgressResponseStatus) MarshalJSON() ([]byte, error)

func (*UpdateDataProgressResponseStatus) UnmarshalJSON added in v0.1.58

func (c *UpdateDataProgressResponseStatus) UnmarshalJSON(b []byte) error

func (UpdateDataProgressResponseStatus) Value added in v0.1.58

type UpdateDataProgressResponseStatusEnum added in v0.1.58

type UpdateDataProgressResponseStatusEnum struct {
	PENDING UpdateDataProgressResponseStatus
	FAILED  UpdateDataProgressResponseStatus
	SUCCESS UpdateDataProgressResponseStatus
}

func GetUpdateDataProgressResponseStatusEnum added in v0.1.58

func GetUpdateDataProgressResponseStatusEnum() UpdateDataProgressResponseStatusEnum

type UpdateJob

type UpdateJob struct {

	// 待更新的任务ID。
	JobId *string `json:"job_id,omitempty"`

	BaseInfo *JobBaseInfo `json:"base_info,omitempty"`

	// 任务源数据库信息体。
	SourceEndpoint *[]JobEndpointInfo `json:"source_endpoint,omitempty"`

	// 任务目标数据库信息体。
	TargetEndpoint *[]JobEndpointInfo `json:"target_endpoint,omitempty"`

	AlarmNotify *AlarmNotifyConfig `json:"alarm_notify,omitempty"`

	// 限速信息体。 - 限速:自定义的最大迁移速度,迁移过程中的迁移速度将不会超过该速度。 - 不限速:对迁移速度不进行限制,通常会最大化使用源数据库的出口带宽。该流速模式同时会对源数据库造成读消耗,消耗取决于源数据库的出口带宽。比如:源数据库的出口带宽为100MB/s,假设高速模式使用了80%带宽,则迁移对源数据库将造成80MB/s的读操作IO消耗。
	SpeedLimit *[]SpeedLimitInfo `json:"speed_limit,omitempty"`

	UserMigration *UserMigrationInfo `json:"user_migration,omitempty"`

	PolicyConfig *PolicyConfig `json:"policy_config,omitempty"`

	DbObject *DbObject `json:"db_object,omitempty"`

	DbParam *DbParamInfo `json:"db_param,omitempty"`

	TuningParams *ModifyTuningParams `json:"tuning_params,omitempty"`

	PeriodOrder *PeriodOrderInfo `json:"period_order,omitempty"`

	NodeInfo *JobNodeInfo `json:"node_info,omitempty"`
}

UpdateJob 更新任务信息体。

func (UpdateJob) String

func (o UpdateJob) String() string

type UpdateJobReq

type UpdateJobReq struct {

	// 更新指定ID任务详情类型。  场景一:更新单个任务详情,取值: - name:更新该任务名称。 - description:更新该任务描述。 - re_create:配置中任务三天以后虚拟机删除后重建。 - expired_days:更新任务异常自动结束时间,单位为天。  场景二:更新批量异步任务详情,取值: - all:批量异步创建的任务,参数校验不通过,需要指定全部参数进行更新时。 - network:批量异步创建的任务,测试连接不通过,需要更新源库/目标库信息时。 - policy:批量异步创建的任务,需要更新任务配置时。 - db_object:批量异步创建的任务,需要更新对象信息时。 - precheck:批量异步创建的任务,需要重新预检查时。
	Type UpdateJobReqType `json:"type"`

	Params *UpdateJob `json:"params"`
}

UpdateJobReq 更新指定ID任务请求体。

func (UpdateJobReq) String

func (o UpdateJobReq) String() string

type UpdateJobReqType

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

func (UpdateJobReqType) MarshalJSON

func (c UpdateJobReqType) MarshalJSON() ([]byte, error)

func (*UpdateJobReqType) UnmarshalJSON

func (c *UpdateJobReqType) UnmarshalJSON(b []byte) error

func (UpdateJobReqType) Value

func (c UpdateJobReqType) Value() string

type UpdateJobReqTypeEnum

type UpdateJobReqTypeEnum struct {
	NAME         UpdateJobReqType
	DESCRIPTION  UpdateJobReqType
	ALL          UpdateJobReqType
	NETWORK      UpdateJobReqType
	POLICY       UpdateJobReqType
	DB_OBJECT    UpdateJobReqType
	PRECHECK     UpdateJobReqType
	RE_CREATE    UpdateJobReqType
	EXPIRED_DAYS UpdateJobReqType
}

func GetUpdateJobReqTypeEnum

func GetUpdateJobReqTypeEnum() UpdateJobReqTypeEnum

type UpdateJobRequest

type UpdateJobRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *UpdateJobRequestXLanguage `json:"X-Language,omitempty"`

	Body *SingleUpdateJobReq `json:"body,omitempty"`
}

UpdateJobRequest Request Object

func (UpdateJobRequest) String

func (o UpdateJobRequest) String() string

type UpdateJobRequestXLanguage

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

func (UpdateJobRequestXLanguage) MarshalJSON

func (c UpdateJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateJobRequestXLanguage) UnmarshalJSON

func (c *UpdateJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateJobRequestXLanguage) Value

type UpdateJobRequestXLanguageEnum

type UpdateJobRequestXLanguageEnum struct {
	EN_US UpdateJobRequestXLanguage
	ZH_CN UpdateJobRequestXLanguage
}

func GetUpdateJobRequestXLanguageEnum

func GetUpdateJobRequestXLanguageEnum() UpdateJobRequestXLanguageEnum

type UpdateJobResponse

type UpdateJobResponse struct {

	// 错误码。
	ErrorCode string `json:"error_code"`

	// 错误描述。
	ErrorMsg string `json:"error_msg"`

	// 任务ID。
	Id string `json:"id"`

	// 任务名称。
	Name string `json:"name"`

	// 操作结果。
	Status         string `json:"status"`
	HttpStatusCode int    `json:"-"`
}

UpdateJobResponse Response Object

func (UpdateJobResponse) String

func (o UpdateJobResponse) String() string

type UpdateStartPositionRequest added in v0.1.58

type UpdateStartPositionRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *UpdateStartPositionRequestXLanguage `json:"X-Language,omitempty"`

	Body *ModifyStartPositionReq `json:"body,omitempty"`
}

UpdateStartPositionRequest Request Object

func (UpdateStartPositionRequest) String added in v0.1.58

type UpdateStartPositionRequestXLanguage added in v0.1.58

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

func (UpdateStartPositionRequestXLanguage) MarshalJSON added in v0.1.58

func (c UpdateStartPositionRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateStartPositionRequestXLanguage) UnmarshalJSON added in v0.1.58

func (c *UpdateStartPositionRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateStartPositionRequestXLanguage) Value added in v0.1.58

type UpdateStartPositionRequestXLanguageEnum added in v0.1.58

type UpdateStartPositionRequestXLanguageEnum struct {
	EN_US UpdateStartPositionRequestXLanguage
	ZH_CN UpdateStartPositionRequestXLanguage
}

func GetUpdateStartPositionRequestXLanguageEnum added in v0.1.58

func GetUpdateStartPositionRequestXLanguageEnum() UpdateStartPositionRequestXLanguageEnum

type UpdateStartPositionResponse added in v0.1.58

type UpdateStartPositionResponse struct {

	// 空响应体。
	Body           *interface{} `json:"body,omitempty"`
	HttpStatusCode int          `json:"-"`
}

UpdateStartPositionResponse Response Object

func (UpdateStartPositionResponse) String added in v0.1.58

type UploadDbObjectTemplateRequest

type UploadDbObjectTemplateRequest struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型。
	XLanguage *UploadDbObjectTemplateRequestXLanguage `json:"X-Language,omitempty"`

	// 文件模板支持数据同步级别,不填默认为table表级。 - database:库级 - table:表级
	FileImportDbLevel *UploadDbObjectTemplateRequestFileImportDbLevel `json:"file_import_db_level,omitempty"`

	Body *UploadDbObjectTemplateRequestBody `json:"body,omitempty" type:"multipart"`
}

UploadDbObjectTemplateRequest Request Object

func (UploadDbObjectTemplateRequest) String

type UploadDbObjectTemplateRequestBody

type UploadDbObjectTemplateRequestBody struct {

	// 待上传的模板文件。
	File *def.FilePart `json:"file"`
}

func (UploadDbObjectTemplateRequestBody) String

func (*UploadDbObjectTemplateRequestBody) UnmarshalJSON

func (o *UploadDbObjectTemplateRequestBody) UnmarshalJSON(b []byte) error

type UploadDbObjectTemplateRequestFileImportDbLevel added in v0.1.49

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

func (UploadDbObjectTemplateRequestFileImportDbLevel) MarshalJSON added in v0.1.49

func (*UploadDbObjectTemplateRequestFileImportDbLevel) UnmarshalJSON added in v0.1.49

func (UploadDbObjectTemplateRequestFileImportDbLevel) Value added in v0.1.49

type UploadDbObjectTemplateRequestFileImportDbLevelEnum added in v0.1.49

type UploadDbObjectTemplateRequestFileImportDbLevelEnum struct {
	DATABASE UploadDbObjectTemplateRequestFileImportDbLevel
	TABLE    UploadDbObjectTemplateRequestFileImportDbLevel
}

func GetUploadDbObjectTemplateRequestFileImportDbLevelEnum added in v0.1.49

func GetUploadDbObjectTemplateRequestFileImportDbLevelEnum() UploadDbObjectTemplateRequestFileImportDbLevelEnum

type UploadDbObjectTemplateRequestXLanguage

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

func (UploadDbObjectTemplateRequestXLanguage) MarshalJSON

func (c UploadDbObjectTemplateRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UploadDbObjectTemplateRequestXLanguage) UnmarshalJSON

func (c *UploadDbObjectTemplateRequestXLanguage) UnmarshalJSON(b []byte) error

func (UploadDbObjectTemplateRequestXLanguage) Value

type UploadDbObjectTemplateRequestXLanguageEnum

type UploadDbObjectTemplateRequestXLanguageEnum struct {
	EN_US UploadDbObjectTemplateRequestXLanguage
	ZH_CN UploadDbObjectTemplateRequestXLanguage
}

func GetUploadDbObjectTemplateRequestXLanguageEnum

func GetUploadDbObjectTemplateRequestXLanguageEnum() UploadDbObjectTemplateRequestXLanguageEnum

type UploadDbObjectTemplateResponse

type UploadDbObjectTemplateResponse struct {

	// 是否上传完成。
	SendSuccess *bool `json:"send_success,omitempty"`

	// 文件解析状态。
	ProcessStatus *string `json:"process_status,omitempty"`

	// 解析成功的行数。
	ParsedSuccessNumber *string `json:"parsed_success_number,omitempty"`
	HttpStatusCode      int     `json:"-"`
}

UploadDbObjectTemplateResponse Response Object

func (UploadDbObjectTemplateResponse) String

type UserMigrationInfo

type UserMigrationInfo struct {

	// 是否迁移用户。
	IsMigrateUser bool `json:"is_migrate_user"`

	// 是否统一重置密码。取值: - true:重置密码为统一密码。 - false:不统一重置密码。 当前支持的场景:  - 实时迁移场景:MySQL迁移。
	IsSetPassword bool `json:"is_set_password"`

	// 重置后的统一密码。统一重置密码为true时必填。 约束:密码不能为空。
	Password *string `json:"password,omitempty"`

	UserList *[]UserMigrationList `json:"user_list,omitempty"`

	RoleList *[]UserMigrationRole `json:"role_list,omitempty"`
}

UserMigrationInfo 用户迁移信息体。

func (UserMigrationInfo) String

func (o UserMigrationInfo) String() string

type UserMigrationList

type UserMigrationList struct {

	// 用户ID。
	Id string `json:"id"`

	// 用户。
	Account string `json:"account"`

	// 是否重置该用户密码。当前支持的场景: - 实时迁移场景:MySQL迁移。
	IsSetPassword *bool `json:"is_set_password,omitempty"`

	// 重置后的密码。统一重置密码或单个用户重置密码为true时必填,约束:密码不能为空。
	Password *string `json:"password,omitempty"`
}

UserMigrationList 用户迁移信息用户列表字段。当前支持的场景: - 实时迁移场景:MySQL迁移,MongoDB迁移。

func (UserMigrationList) String

func (o UserMigrationList) String() string

type UserMigrationRole

type UserMigrationRole struct {

	// 角色。
	Role string `json:"role"`
}

UserMigrationRole 用户迁移信息角色列表字段。当前支持的场景: - 实时迁移场景:MongoDB迁移。

func (UserMigrationRole) String

func (o UserMigrationRole) String() string

type ValidateJobNameRequest added in v0.1.49

type ValidateJobNameRequest struct {

	// 请求语言类型。
	XLanguage *ValidateJobNameRequestXLanguage `json:"X-Language,omitempty"`

	Body *CheckJobNameReq `json:"body,omitempty"`
}

ValidateJobNameRequest Request Object

func (ValidateJobNameRequest) String added in v0.1.49

func (o ValidateJobNameRequest) String() string

type ValidateJobNameRequestXLanguage added in v0.1.49

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

func (ValidateJobNameRequestXLanguage) MarshalJSON added in v0.1.49

func (c ValidateJobNameRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ValidateJobNameRequestXLanguage) UnmarshalJSON added in v0.1.49

func (c *ValidateJobNameRequestXLanguage) UnmarshalJSON(b []byte) error

func (ValidateJobNameRequestXLanguage) Value added in v0.1.49

type ValidateJobNameRequestXLanguageEnum added in v0.1.49

type ValidateJobNameRequestXLanguageEnum struct {
	EN_US ValidateJobNameRequestXLanguage
	ZH_CN ValidateJobNameRequestXLanguage
}

func GetValidateJobNameRequestXLanguageEnum added in v0.1.49

func GetValidateJobNameRequestXLanguageEnum() ValidateJobNameRequestXLanguageEnum

type ValidateJobNameResponse added in v0.1.49

type ValidateJobNameResponse struct {

	// 任务名称是否有效。
	IsValid *bool `json:"is_valid,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ValidateJobNameResponse Response Object

func (ValidateJobNameResponse) String added in v0.1.49

func (o ValidateJobNameResponse) String() string

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL