model

package
v0.1.24 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2023 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 

func (o BatchCreateJobsAsyncRequest) String() 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 

func (c BatchCreateJobsAsyncRequestXLanguage) Value() string

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 

func (o BatchCreateJobsAsyncResponse) String() 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 

func (o BatchDeleteJobsByIdRequest) String() 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 

func (c BatchDeleteJobsByIdRequestXLanguage) Value() string

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 

func (o BatchDeleteJobsByIdResponse) String() string

type BatchExecuteJobActionsRequest 

type BatchExecuteJobActionsRequest struct {

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

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

Request Object

func (BatchExecuteJobActionsRequest) String 

func (o BatchExecuteJobActionsRequest) String() 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 

func (c BatchExecuteJobActionsRequestXLanguage) Value() string

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 

func (o BatchExecuteJobActionsResponse) String() 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 

func (c ChildrenJobListRespChargingMode) Value() string

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 

func (c ChildrenJobListRespEngineType) Value() string

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 

func (c ChildrenJobListRespJobDirection) Value() string

type ChildrenJobListRespJobDirectionEnum 

type ChildrenJobListRespJobDirectionEnum struct {
	UP      ChildrenJobListRespJobDirection
	DOWN    ChildrenJobListRespJobDirection
	NON_DBS ChildrenJobListRespJobDirection
}

func GetChildrenJobListRespJobDirectionEnum 

func GetChildrenJobListRespJobDirectionEnum() ChildrenJobListRespJobDirectionEnum

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 

func (c ChildrenJobListRespJobMode) Value() string

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 

func (c ChildrenJobListRespJobModeRole) Value() string

type ChildrenJobListRespJobModeRoleEnum 

type ChildrenJobListRespJobModeRoleEnum struct {
	PARENT ChildrenJobListRespJobModeRole
	CHILD  ChildrenJobListRespJobModeRole
	MASTER ChildrenJobListRespJobModeRole
	SLAVE  ChildrenJobListRespJobModeRole
}

func GetChildrenJobListRespJobModeRoleEnum 

func GetChildrenJobListRespJobModeRoleEnum() ChildrenJobListRespJobModeRoleEnum

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 

func (c ChildrenJobListRespJobType) Value() string

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 

func (c ChildrenJobListRespNetType) Value() string

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 

func (c ChildrenJobListRespStatus) Value() string

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 

func (c ChildrenJobListRespTaskType) Value() string

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 CollectDbObjectsAsyncRequest added in v0.1.21 

type CollectDbObjectsAsyncRequest struct {

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

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

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

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

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

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

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

Request Object

func (CollectDbObjectsAsyncRequest) String added in v0.1.21 

func (o CollectDbObjectsAsyncRequest) String() string

type CollectDbObjectsAsyncRequestType added in v0.1.21 

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

func (CollectDbObjectsAsyncRequestType) MarshalJSON added in v0.1.21 

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

func (*CollectDbObjectsAsyncRequestType) UnmarshalJSON added in v0.1.21 

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

func (CollectDbObjectsAsyncRequestType) Value added in v0.1.21 

func (c CollectDbObjectsAsyncRequestType) Value() string

type CollectDbObjectsAsyncRequestTypeEnum added in v0.1.21 

type CollectDbObjectsAsyncRequestTypeEnum struct {
	SOURCE       CollectDbObjectsAsyncRequestType
	MODIFIED     CollectDbObjectsAsyncRequestType
	SYNCHRONIZED CollectDbObjectsAsyncRequestType
}

func GetCollectDbObjectsAsyncRequestTypeEnum added in v0.1.21 

func GetCollectDbObjectsAsyncRequestTypeEnum() CollectDbObjectsAsyncRequestTypeEnum

type CollectDbObjectsAsyncRequestXLanguage added in v0.1.21 

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

func (CollectDbObjectsAsyncRequestXLanguage) MarshalJSON added in v0.1.21 

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

func (*CollectDbObjectsAsyncRequestXLanguage) UnmarshalJSON added in v0.1.21 

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

func (CollectDbObjectsAsyncRequestXLanguage) Value added in v0.1.21 

func (c CollectDbObjectsAsyncRequestXLanguage) Value() string

type CollectDbObjectsAsyncRequestXLanguageEnum added in v0.1.21 

type CollectDbObjectsAsyncRequestXLanguageEnum struct {
	EN_US CollectDbObjectsAsyncRequestXLanguage
	ZH_CN CollectDbObjectsAsyncRequestXLanguage
}

func GetCollectDbObjectsAsyncRequestXLanguageEnum added in v0.1.21 

func GetCollectDbObjectsAsyncRequestXLanguageEnum() CollectDbObjectsAsyncRequestXLanguageEnum

type CollectDbObjectsAsyncResponse added in v0.1.21 

type CollectDbObjectsAsyncResponse struct {

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

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

Response Object

func (CollectDbObjectsAsyncResponse) String added in v0.1.21 

func (o CollectDbObjectsAsyncResponse) String() string

type CollectDbObjectsAsyncResponseStatus added in v0.1.21 

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

func (CollectDbObjectsAsyncResponseStatus) MarshalJSON added in v0.1.21 

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

func (*CollectDbObjectsAsyncResponseStatus) UnmarshalJSON added in v0.1.21 

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

func (CollectDbObjectsAsyncResponseStatus) Value added in v0.1.21 

func (c CollectDbObjectsAsyncResponseStatus) Value() string

type CollectDbObjectsAsyncResponseStatusEnum added in v0.1.21 

type CollectDbObjectsAsyncResponseStatusEnum struct {
	PENDING CollectDbObjectsAsyncResponseStatus
	FAILED  CollectDbObjectsAsyncResponseStatus
	SUCCESS CollectDbObjectsAsyncResponseStatus
}

func GetCollectDbObjectsAsyncResponseStatusEnum added in v0.1.21 

func GetCollectDbObjectsAsyncResponseStatusEnum() CollectDbObjectsAsyncResponseStatusEnum

type 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 

func (c CommitAsyncJobRequestXLanguage) Value() string

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 

func (o ContentCompareOverviewInfo) String() 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 

func (c ContentCompareOverviewInfoStatus) Value() string

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 

func (c CreateJobRequestXLanguage) Value() string

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

	// 是否已同步
	IsSynchronized *bool `json:"is_synchronized,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 

func (c DeleteJobRequestXLanguage) Value() string

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 

func (o DownloadDbObjectTemplateRequest) String() string

type DownloadDbObjectTemplateRequestXLanguage 

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

func (DownloadDbObjectTemplateRequestXLanguage) MarshalJSON 

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

func (*DownloadDbObjectTemplateRequestXLanguage) UnmarshalJSON 

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

func (DownloadDbObjectTemplateRequestXLanguage) Value 

func (c DownloadDbObjectTemplateRequestXLanguage) Value() string

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 

func (o DownloadDbObjectTemplateResponse) String() 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 

func (c ExecuteJobActionRequestXLanguage) Value() string

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 JobActionsCurrentActionEnum 

type JobActionsCurrentActionEnum struct {
	API_CONFIGURATION_ACTION JobActionsCurrentAction
	CHANGE                   JobActionsCurrentAction
	CHANGE_MODE              JobActionsCurrentAction
	CHOOSE_OBJECT            JobActionsCurrentAction
	CLONE                    JobActionsCurrentAction
	CONTINUE_APPLY           JobActionsCurrentAction
	CONTINUE_CAPTURE         JobActionsCurrentAction
	CONTINUE_JOB             JobActionsCurrentAction
	CREATE                   JobActionsCurrentAction
	DELETE                   JobActionsCurrentAction
	FREE_RESOURCE            JobActionsCurrentAction
	JUMP_RETRY               JobActionsCurrentAction
	MODIFY_CONFIGURATION     JobActionsCurrentAction
	MODIFY_DB_CONFIG         JobActionsCurrentAction
	MODIFY_TASK_NUMBER       JobActionsCurrentAction
	NODE_FLAVOR_MODIFY       JobActionsCurrentAction
	ORDER_INFO               JobActionsCurrentAction
	PAUSE                    JobActionsCurrentAction
	PAY_ORDER                JobActionsCurrentAction
	PRE_CHECK                JobActionsCurrentAction
	QUERY_PRE_CHECK          JobActionsCurrentAction
	RESET                    JobActionsCurrentAction
	RESET_DB_PWD             JobActionsCurrentAction
	RETRY                    JobActionsCurrentAction
	START                    JobActionsCurrentAction
	START_INCR               JobActionsCurrentAction
	STOP_APPLY               JobActionsCurrentAction
	STOP_CAPTURE             JobActionsCurrentAction
	STOP_JOB                 JobActionsCurrentAction
	SWITCH_OVER              JobActionsCurrentAction
	TO_PERIOD                JobActionsCurrentAction
	TO_RENEW                 JobActionsCurrentAction
	UNSUBSCRIBE              JobActionsCurrentAction
}

func GetJobActionsCurrentActionEnum 

func GetJobActionsCurrentActionEnum() JobActionsCurrentActionEnum

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 

func (c JobEndpointInfoEndpointRole) Value() string

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 

func (c JobEndpointInfoEndpointType) Value() string

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 

func (c JobLinkRespSourceEndpointType) Value() string

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 

func (c JobLinkRespTargetEndpointType) Value() string

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 

func (c LineCompareOverviewInfoStatus) Value() string

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 

func (c ListAsyncJobDetailRequestXLanguage) Value() string

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 

func (o ListAsyncJobDetailResponse) String() 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 

func (c ListAsyncJobsRequestXLanguage) Value() string

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 *int32 `json:"offset,omitempty"`

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

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

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

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 

func (c ListDbObjectsRequestXLanguage) Value() string

type ListDbObjectsRequestXLanguageEnum 

type ListDbObjectsRequestXLanguageEnum struct {
	EN_US ListDbObjectsRequestXLanguage
	ZH_CN ListDbObjectsRequestXLanguage
}

func GetListDbObjectsRequestXLanguageEnum 

func GetListDbObjectsRequestXLanguageEnum() ListDbObjectsRequestXLanguageEnum

type ListDbObjectsResponse 

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

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

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

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

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

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

Response Object

func (ListDbObjectsResponse) String 

func (o ListDbObjectsResponse) String() string

type ListDbObjectsResponseStatus added in v0.1.21 

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

func (ListDbObjectsResponseStatus) MarshalJSON added in v0.1.21 

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

func (*ListDbObjectsResponseStatus) UnmarshalJSON added in v0.1.21 

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

func (ListDbObjectsResponseStatus) Value added in v0.1.21 

func (c ListDbObjectsResponseStatus) Value() string

type ListDbObjectsResponseStatusEnum added in v0.1.21 

type ListDbObjectsResponseStatusEnum struct {
	SUCCESS ListDbObjectsResponseStatus
	FAILED  ListDbObjectsResponseStatus
	PENDING ListDbObjectsResponseStatus
}

func GetListDbObjectsResponseStatusEnum added in v0.1.21 

func GetListDbObjectsResponseStatusEnum() ListDbObjectsResponseStatusEnum

type ListJobsRequest 

type ListJobsRequest struct {

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

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

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

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

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

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

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

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

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

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

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

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 

func (c ListJobsRequestEngineType) Value() string

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 

func (c ListLinksRequestXLanguage) Value() string

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 

func (o MigrationObjectOverviewInfo) String() string

type ModifyTuningParams 

type ModifyTuningParams struct {

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

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

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

	// 增量日志拉取参数的参数名及对应的取值。
	IncreRelay map[string]string `json:"incre_relay,omitempty"`

	// 是否一键还原到默认值。
	Recovery *bool `json:"recovery,omitempty"`
}

修改高级设置信息体。

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 

func (o ObjectsCompareOverviewInfo) String() 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 

func (c ObjectsCompareOverviewInfoStatus) Value() string

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 

func (c ObjectsCompareOverviewInfoType) Value() string

type ObjectsCompareOverviewInfoTypeEnum 

type ObjectsCompareOverviewInfoTypeEnum struct {
	DB                 ObjectsCompareOverviewInfoType
	TABLE              ObjectsCompareOverviewInfoType
	VIEW               ObjectsCompareOverviewInfoType
	EVENT              ObjectsCompareOverviewInfoType
	ROUTINE            ObjectsCompareOverviewInfoType
	INDEX              ObjectsCompareOverviewInfoType
	TRIGGER            ObjectsCompareOverviewInfoType
	SYNONYM            ObjectsCompareOverviewInfoType
	FUNCTION           ObjectsCompareOverviewInfoType
	PROCEDURE          ObjectsCompareOverviewInfoType
	TYPE               ObjectsCompareOverviewInfoType
	RULE               ObjectsCompareOverviewInfoType
	DEFAULT_TYPE       ObjectsCompareOverviewInfoType
	PLAN_GUIDE         ObjectsCompareOverviewInfoType
	CONSTRAINT         ObjectsCompareOverviewInfoType
	FILE_GROUP         ObjectsCompareOverviewInfoType
	PARTITION_FUNCTION ObjectsCompareOverviewInfoType
	PARTITION_SCHEME   ObjectsCompareOverviewInfoType
	TABLE_COLLATION    ObjectsCompareOverviewInfoType
	EXTENSIONS         ObjectsCompareOverviewInfoType
}

func GetObjectsCompareOverviewInfoTypeEnum 

func GetObjectsCompareOverviewInfoTypeEnum() ObjectsCompareOverviewInfoTypeEnum

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 

func (c ObjectsCompareTaskInfoStatus) Value() string

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 

func (c PeriodOrderInfoIsAutoRenew) Value() int32

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 

func (c PolicyConfigConflictPolicy) Value() string

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 

func (c PolicyConfigDataSyncTopologyType) Value() string

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 

func (c PolicyConfigFilterDdlPolicy) Value() string

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 

func (c PolicyConfigSupportDdlInfo) Value() string

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 

func (o QueryMigrationObjectProgressInfo) String() 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 ShowDbObjectCollectionStatusRequest added in v0.1.21 

type ShowDbObjectCollectionStatusRequest struct {

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

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

	// 对象信息采集的ID，提交查询数据库对象信息接口返回的ID。
	QueryId string `json:"query_id"`
}

Request Object

func (ShowDbObjectCollectionStatusRequest) String added in v0.1.21 

func (o ShowDbObjectCollectionStatusRequest) String() string

type ShowDbObjectCollectionStatusResponse added in v0.1.21 

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

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

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

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

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

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

Response Object

func (ShowDbObjectCollectionStatusResponse) String added in v0.1.21 

func (o ShowDbObjectCollectionStatusResponse) String() string

type ShowDbObjectCollectionStatusResponseStatus added in v0.1.21 

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

func (ShowDbObjectCollectionStatusResponseStatus) MarshalJSON added in v0.1.21 

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

func (*ShowDbObjectCollectionStatusResponseStatus) UnmarshalJSON added in v0.1.21 

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

func (ShowDbObjectCollectionStatusResponseStatus) Value added in v0.1.21 

func (c ShowDbObjectCollectionStatusResponseStatus) Value() string

type ShowDbObjectCollectionStatusResponseStatusEnum added in v0.1.21 

type ShowDbObjectCollectionStatusResponseStatusEnum struct {
	SUCCESS ShowDbObjectCollectionStatusResponseStatus
	FAILED  ShowDbObjectCollectionStatusResponseStatus
	PENDING ShowDbObjectCollectionStatusResponseStatus
}

func GetShowDbObjectCollectionStatusResponseStatusEnum added in v0.1.21 

func GetShowDbObjectCollectionStatusResponseStatusEnum() ShowDbObjectCollectionStatusResponseStatusEnum

type ShowDbObjectTemplateProgressRequest 

type ShowDbObjectTemplateProgressRequest struct {

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

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

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

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

Request Object

func (ShowDbObjectTemplateProgressRequest) String 

func (o ShowDbObjectTemplateProgressRequest) String() string

type ShowDbObjectTemplateProgressRequestXLanguage 

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

func (ShowDbObjectTemplateProgressRequestXLanguage) MarshalJSON 

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

func (*ShowDbObjectTemplateProgressRequestXLanguage) UnmarshalJSON 

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

func (ShowDbObjectTemplateProgressRequestXLanguage) Value 

func (c ShowDbObjectTemplateProgressRequestXLanguage) Value() string

type ShowDbObjectTemplateProgressRequestXLanguageEnum 

type ShowDbObjectTemplateProgressRequestXLanguageEnum struct {
	EN_US ShowDbObjectTemplateProgressRequestXLanguage
	ZH_CN ShowDbObjectTemplateProgressRequestXLanguage
}

func GetShowDbObjectTemplateProgressRequestXLanguageEnum 

func GetShowDbObjectTemplateProgressRequestXLanguageEnum() ShowDbObjectTemplateProgressRequestXLanguageEnum

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 

func (o ShowDbObjectTemplateProgressResponse) String() 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 

func (o ShowDbObjectTemplateResultRequest) String() 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 

func (c ShowDbObjectTemplateResultRequestType) Value() string

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 (c ShowDbObjectTemplateResultRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowDbObjectTemplateResultRequestXLanguage) UnmarshalJSON 

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

func (ShowDbObjectTemplateResultRequestXLanguage) Value 

func (c ShowDbObjectTemplateResultRequestXLanguage) Value() string

type ShowDbObjectTemplateResultRequestXLanguageEnum 

type ShowDbObjectTemplateResultRequestXLanguageEnum struct {
	EN_US ShowDbObjectTemplateResultRequestXLanguage
	ZH_CN ShowDbObjectTemplateResultRequestXLanguage
}

func GetShowDbObjectTemplateResultRequestXLanguageEnum 

func GetShowDbObjectTemplateResultRequestXLanguageEnum() ShowDbObjectTemplateResultRequestXLanguageEnum

type ShowDbObjectTemplateResultResponse 

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

Response Object

func (ShowDbObjectTemplateResultResponse) Consume 

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

func (ShowDbObjectTemplateResultResponse) String 

func (o ShowDbObjectTemplateResultResponse) String() string

type ShowJobDetailRequest 

type ShowJobDetailRequest struct {

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

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

	// 任务详情类型。取值： - overview：任务概览信息。 - detail：任务基本信息。 - network：测试连接结果信息，需配合query_id参数一起查询。 - precheck：预检查结果信息，需配合query_id参数一起查询。 - progress：任务进度信息。 - log：任务日志信息，支持分页查询参数offset与limit。 - comapre：查询对比任务。
	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 

func (c ShowJobDetailRequestCompareDetailType) Value() string

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 

func (c ShowJobDetailRequestCompareType) Value() string

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 

func (c ShowJobDetailRequestObjectType) Value() string

type ShowJobDetailRequestObjectTypeEnum 

type ShowJobDetailRequestObjectTypeEnum struct {
	DB    ShowJobDetailRequestObjectType
	TABLE ShowJobDetailRequestObjectType
	INDEX ShowJobDetailRequestObjectType
}

func GetShowJobDetailRequestObjectTypeEnum 

func GetShowJobDetailRequestObjectTypeEnum() ShowJobDetailRequestObjectTypeEnum

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 

func (c ShowJobDetailRequestQueryType) Value() string

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 ShowJobDetailRequestTypeEnum 

type ShowJobDetailRequestTypeEnum struct {
	OVERVIEW ShowJobDetailRequestType
	DETAIL   ShowJobDetailRequestType
	NETWORK  ShowJobDetailRequestType
	PRECHECK ShowJobDetailRequestType
	PROGRESS ShowJobDetailRequestType
	LOG      ShowJobDetailRequestType
	COMAPRE  ShowJobDetailRequestType
}

func GetShowJobDetailRequestTypeEnum 

func GetShowJobDetailRequestTypeEnum() ShowJobDetailRequestTypeEnum

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 

func (c ShowJobDetailRequestXLanguage) Value() string

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 ShowUpdateObjectSavingStatusRequest added in v0.1.21 

type ShowUpdateObjectSavingStatusRequest struct {

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

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

	// 保存对象接口返回的ID。
	QueryId string `json:"query_id"`
}

Request Object

func (ShowUpdateObjectSavingStatusRequest) String added in v0.1.21 

func (o ShowUpdateObjectSavingStatusRequest) String() string

type ShowUpdateObjectSavingStatusResponse added in v0.1.21 

type ShowUpdateObjectSavingStatusResponse struct {

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

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

Response Object

func (ShowUpdateObjectSavingStatusResponse) String added in v0.1.21 

func (o ShowUpdateObjectSavingStatusResponse) String() string

type ShowUpdateObjectSavingStatusResponseStatus added in v0.1.21 

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

func (ShowUpdateObjectSavingStatusResponseStatus) MarshalJSON added in v0.1.21 

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

func (*ShowUpdateObjectSavingStatusResponseStatus) UnmarshalJSON added in v0.1.21 

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

func (ShowUpdateObjectSavingStatusResponseStatus) Value added in v0.1.21 

func (c ShowUpdateObjectSavingStatusResponseStatus) Value() string

type ShowUpdateObjectSavingStatusResponseStatusEnum added in v0.1.21 

type ShowUpdateObjectSavingStatusResponseStatusEnum struct {
	PENDING ShowUpdateObjectSavingStatusResponseStatus
	FAILED  ShowUpdateObjectSavingStatusResponseStatus
	SUCCESS ShowUpdateObjectSavingStatusResponseStatus
}

func GetShowUpdateObjectSavingStatusResponseStatusEnum added in v0.1.21 

func GetShowUpdateObjectSavingStatusResponseStatusEnum() ShowUpdateObjectSavingStatusResponseStatusEnum

type SingleCreateJobReq 

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

创建单个任务请求体。

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 

func (o TableLineCompareDetailInfo) String() 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 

func (c TableLineCompareDetailInfoStatus) Value() string

type TableLineCompareDetailInfoStatusEnum 

type TableLineCompareDetailInfoStatusEnum struct {
	CONSISTENT             TableLineCompareDetailInfoStatus
	INCONSISTENT           TableLineCompareDetailInfoStatus
	COMPARING              TableLineCompareDetailInfoStatus
	WAITING_FOR_COMPARISON TableLineCompareDetailInfoStatus
	FAILED_TO_COMPARE      TableLineCompareDetailInfoStatus
	TARGET_DB_NOT_EXIST    TableLineCompareDetailInfoStatus
	CAN_NOT_COMPARE        TableLineCompareDetailInfoStatus
}

func GetTableLineCompareDetailInfoStatusEnum 

func GetTableLineCompareDetailInfoStatusEnum() TableLineCompareDetailInfoStatusEnum

type TableObject 

type TableObject struct {

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

	// 对象类型。取值： - table：表。 - view：视图。 - procedure：存储过程。
	Type *TableObjectType `json:"type,omitempty"`

	// 该表在目标库的名称（表名映射）。
	Name *string `json:"name,omitempty"`

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

	// 一对多情况下，表级上对库名的映射。
	DbAliasName *string `json:"db_alias_name,omitempty"`

	// 一对多情况下，表级上对schema名的映射。
	SchemaAliasName *string `json:"schema_alias_name,omitempty"`

	// 该表是否进行数据过滤。
	Filtered *bool `json:"filtered,omitempty"`

	// 该表数据的过滤条件，生成加工规则值为SQL条件语句，长度限制512。
	FilterConditions *[]string `json:"filter_conditions,omitempty"`

	// 该表数据过滤高级设置的配置条件，当该表作为联表查询时填写，生成加工规则值为SQL条件语句，长度限制512。
	ConfigConditions *[]string `json:"config_conditions,omitempty"`

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

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

数据库表级对象。

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 

func (o UpdateBatchAsyncJobsRequest) String() 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 

func (c UpdateBatchAsyncJobsRequestXLanguage) Value() string

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 

func (o UpdateBatchAsyncJobsResponse) String() 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 

func (c UpdateJobRequestXLanguage) Value() string

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 

func (o UploadDbObjectTemplateRequest) String() string

type UploadDbObjectTemplateRequestBody 

type UploadDbObjectTemplateRequestBody struct {

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

func (UploadDbObjectTemplateRequestBody) String 

func (o UploadDbObjectTemplateRequestBody) String() 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 

func (c UploadDbObjectTemplateRequestXLanguage) Value() string

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 

func (o UploadDbObjectTemplateResponse) String() 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.