model

package
v0.1.15 Latest Latest
Warning

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

Go to latest
Published: Dec 8, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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

操作任务动作参数。

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

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

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

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

func (AlarmNotifyConfig) String

func (o AlarmNotifyConfig) String() string

type AsyncActionBaseResp

type AsyncActionBaseResp struct {

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

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

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

异步操作任务响应体。

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

提交异步任务响应体。

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

异步创建任务请求体。

func (AsyncCreateJobReq) String

func (o AsyncCreateJobReq) String() string

type AsyncCreateJobResp

type AsyncCreateJobResp struct {

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

创建异步任务响应体。

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:批量异步任务参数校验失败。 - ASYNC_JOB_CREATING:批量异步任务创建中。 - ASYNC_JOB_CREATE_FAILED:批量异步任务创建失败。 - ASYNC_JOB_COMPLETED:批量异步任务创建完成。
	Status AsyncJobRespStatus `json:"status"`

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

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

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

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

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
	ASYNC_JOB_CREATING        AsyncJobRespStatus
	ASYNC_JOB_CREATE_FAILED   AsyncJobRespStatus
	ASYNC_JOB_COMPLETED       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"`
}

更新异步任务响应体。

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

数据库基本信息体。

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

数据库基本设置信息体,当源库或者目标库在特定场景下需要额外设置时填写。例如: - 实时迁移入云场景:云数据库(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"`
}

基础响应体。

func (BaseResp) String

func (o BaseResp) String() string

type BatchAsyncCreateJobReq

type BatchAsyncCreateJobReq struct {

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

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

func (BatchAsyncCreateJobReq) String

func (o BatchAsyncCreateJobReq) String() string

type BatchAsyncUpdateJobReq

type BatchAsyncUpdateJobReq struct {

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

批量更新指定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"`
}

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

Response Object

func (BatchCreateJobsAsyncResponse) String

type BatchDeleteJobReq

type BatchDeleteJobReq struct {

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

批量删除任务请求体。

func (BatchDeleteJobReq) String

func (o BatchDeleteJobReq) String() string

type BatchDeleteJobsByIdRequest

type BatchDeleteJobsByIdRequest struct {

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

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

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

Response Object

func (BatchDeleteJobsByIdResponse) String

type BatchExecuteJobActionsRequest

type BatchExecuteJobActionsRequest struct {

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

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

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

Response Object

func (BatchExecuteJobActionsResponse) String

type BatchJobActionReq

type BatchJobActionReq struct {

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

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

func (BatchJobActionReq) String

func (o BatchJobActionReq) String() string

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

子任务列表响应体。

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

数据库实例所在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"`
}

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

func (CloudVpcInfo) String

func (o CloudVpcInfo) String() string

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

数据库列信息。

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

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

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

对比列表信息体。

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

查询对比任务信息体。

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

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

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

内容对比详情信息体。

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

内容对比概览信息体。

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

创建单个任务请求体。

func (CreateJobReq) String

func (o CreateJobReq) String() string

type CreateJobRequest

type CreateJobRequest struct {

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

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

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

创建任务响应体。

func (CreateJobResp) String

func (o CreateJobResp) String() string

type CreateJobResponse

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

Response Object

func (CreateJobResponse) String

func (o CreateJobResponse) 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"`
}

数据库库级对象。

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

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

func (DbObject) String

func (o DbObject) 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 DbParam

type DbParam struct {

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

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

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

func (DbParam) String

func (o DbParam) String() string

type DbParamInfo

type DbParamInfo struct {

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

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

数据库参数信息体。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"`
}

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

删除任务响应体。

func (DeleteJobResp) String

func (o DeleteJobResp) String() string

type DeleteJobResponse

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

Response Object

func (DeleteJobResponse) String

func (o DeleteJobResponse) String() string

type DownloadDbObjectTemplateRequest

type DownloadDbObjectTemplateRequest struct {

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

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

Request Object

func (DownloadDbObjectTemplateRequest) String

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

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

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

func (EndpointSslConfig) String

func (o EndpointSslConfig) String() string

type ErrorResp

type ErrorResp struct {

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

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

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

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

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

Response Object

func (ExecuteJobActionResponse) String

func (o ExecuteJobActionResponse) String() string

type JobActionReq

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

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

func (JobActionReq) String

func (o JobActionReq) String() string

type JobActions

type JobActions struct {

	// 任务可操作命令集合。
	AvailableActions []string `json:"available_actions"`

	// 任务不可操作命令集合。
	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"`
}

任务操作命令集合。

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

创建任务基本信息体。

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

任务详情响应体。

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

创建任务数据库信息体。

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

可用链路返回体。

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

任务列表响应体。

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 JobNodeInfo

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

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

任务实例信息体。

func (JobNodeInfo) String

func (o JobNodeInfo) String() string

type JobNodeSpecInfo

type JobNodeSpecInfo struct {

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

任务实例规格信息体。

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

任务实例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"`
}

任务进度信息。

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

行数对比概览信息体。

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

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

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

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

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大于等于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量
	Limit *int32 `json:"limit,omitempty"`

	// 查询对象信息类型。取值: - source:查询源库对象信息。 - modified:查询已选择的(未下发与已同步的)对象信息。 - synchronized:查询已同步的(已下发的)对象信息 。
	Type string `json:"type"`
}

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"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListDbObjectsResponse) String

func (o ListDbObjectsResponse) String() string

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

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

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

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

Response Object

func (ListLinksResponse) String

func (o ListLinksResponse) 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"`
}

迁移详情概览。

func (MigrationObjectOverviewInfo) 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"`
}

修改高级设置信息体。

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

对象级对比详情信息体。

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

对象对比结果信息体。

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

对象级对比任务信息体。

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

包年/包月信息体。

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

策略信息体。设置迁移、同步策略,包括冲突策略、过滤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"`
}

失败子任务详情。

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

预检查项结果。

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 ProgressCompleteInfo

type ProgressCompleteInfo struct {

	// 完成进度。
	Completed *string `json:"completed,omitempty"`

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

全量迁移进度。

func (ProgressCompleteInfo) String

func (o ProgressCompleteInfo) 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"`
}

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

迁移中对象进度信息体。

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

测试连接结果响应体。

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

预检查结果信息体。

func (QueryPreCheckResult) String

func (o QueryPreCheckResult) String() string

type ResourceTag

type ResourceTag struct {

	// 标签键。 约束:最大长度36,只能包含字母、数字、下划线、中划线和中文。
	Key *string `json:"key,omitempty"`

	// 标签值。 约束:最大长度43,只能包含字母、数字、下划线、中划线和中文。
	Value *string `json:"value,omitempty"`
}

标签信息体。

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

数据库模式对象。

func (SchemaObject) String

func (o SchemaObject) String() string

type ShowDbObjectTemplateProgressRequest

type ShowDbObjectTemplateProgressRequest struct {

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

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

	// 偏移量,表示从此偏移量开始查询, offset大于等于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量
	Limit *int32 `json:"limit,omitempty"`
}

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

Response Object

func (ShowDbObjectTemplateProgressResponse) String

type ShowDbObjectTemplateResultRequest

type ShowDbObjectTemplateResultRequest struct {

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

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

	// 导入的结果类型。取值: - detail:获取最新导入的文件与校验结果,上传后的文件若存在错误,会同时将错误原因标记在文件内。 - synchronized:获取已同步的(已下发的)对象文件结果。
	Type ShowDbObjectTemplateResultRequestType `json:"type"`
}

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 ShowDbObjectTemplateResultRequestTypeEnum

type ShowDbObjectTemplateResultRequestTypeEnum struct {
	DETAIL       ShowDbObjectTemplateResultRequestType
	SYNCHRONIZED ShowDbObjectTemplateResultRequestType
}

func GetShowDbObjectTemplateResultRequestTypeEnum

func GetShowDbObjectTemplateResultRequestTypeEnum() ShowDbObjectTemplateResultRequestTypeEnum

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

Response Object

func (ShowDbObjectTemplateResultResponse) Consume

func (ShowDbObjectTemplateResultResponse) 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:查询对比任务。
	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:对比详情。
	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"`
}

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

Response Object

func (ShowJobDetailResponse) String

func (o ShowJobDetailResponse) String() string

type SingleCreateJobReq

type SingleCreateJobReq struct {
	Job *CreateJobReq `json:"job"`
}

创建单个任务请求体。

func (SingleCreateJobReq) String

func (o SingleCreateJobReq) String() string

type SingleUpdateJobReq

type SingleUpdateJobReq struct {
	Job *UpdateJobReq `json:"job"`
}

更新单个任务请求体。

func (SingleUpdateJobReq) String

func (o SingleUpdateJobReq) String() string

type SkipPreCheckInfo

type SkipPreCheckInfo struct {

	// 跳过的预检查项。
	SkippedPrecheckList []string `json:"skipped_precheck_list"`

	// 跳过预检查原因。
	SkipReason string `json:"skip_reason"`
}

跳过预检查项参数。

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

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

func (SpeedLimitInfo) String

func (o SpeedLimitInfo) 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"`
}

行数对比任务表级详情。

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

	// 是否已经进行同步。
	HasBeenSent *bool `json:"has_been_sent,omitempty"`

	// 需要同步/映射/过滤/新增的列,当需要列过滤、列映射、附加列功能时填写,仅在实时同步任务中生效,当整表同步为false时需要填写。
	Columns map[string]ColumnObject `json:"columns,omitempty"`
}

数据库表级对象。

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

数据库对象迁移或同步目标库信息,两层到三层数据库时需要指定。

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

日志查询结果信息体。

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

高级设置信息体。

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

调优参数。

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

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

Response Object

func (UpdateBatchAsyncJobsResponse) String

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

更新任务信息体。

func (UpdateJob) String

func (o UpdateJob) String() string

type UpdateJobReq

type UpdateJobReq struct {

	// 更新指定ID任务详情类型。  场景一:更新单个任务详情,取值: - name:更新该任务名称。 - description:更新该任务描述。  场景二:更新批量异步任务详情,取值: - all:批量异步创建的任务,参数校验不通过,需要指定全部参数进行更新时。 - network:批量异步创建的任务,测试连接不通过,需要更新源库/目标库信息时。 - policy_config:批量异步创建的任务,需要更新任务配置时。 - db_object:批量异步创建的任务,需要更新对象信息时。 - precheck:批量异步创建的任务,需要重新预检查时。
	Type UpdateJobReqType `json:"type"`

	Params *UpdateJob `json:"params"`
}

更新指定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_CONFIG UpdateJobReqType
	DB_OBJECT     UpdateJobReqType
	PRECHECK      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"`
}

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

Response Object

func (UpdateJobResponse) String

func (o UpdateJobResponse) String() string

type UploadDbObjectTemplateRequest

type UploadDbObjectTemplateRequest struct {

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

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

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

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

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

用户迁移信息体。

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

用户迁移信息用户列表字段。当前支持的场景: - 实时迁移场景:MySQL迁移,MongoDB迁移。

func (UserMigrationList) String

func (o UserMigrationList) String() string

type UserMigrationRole

type UserMigrationRole struct {

	// 角色。
	Role string `json:"role"`
}

用户迁移信息角色列表字段。当前支持的场景: - 实时迁移场景:MongoDB迁移。

func (UserMigrationRole) String

func (o UserMigrationRole) String() string

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL