Documentation ¶
Index ¶
- type ActionParams
- type ActionReq
- type ActionReqActionName
- type ActionReqActionNameEnum
- type AlarmNotifyConfig
- type AsyncActionBaseResp
- type AsyncActionResp
- type AsyncCommitJobResp
- type AsyncCreateJobReq
- type AsyncCreateJobResp
- type AsyncJobResp
- type AsyncJobRespStatus
- type AsyncJobRespStatusEnum
- type AsyncUpdateJobResp
- type BaseEndpoint
- type BaseEndpointConfig
- type BaseEndpointEndpointName
- type BaseEndpointEndpointNameEnum
- type BaseResp
- type BatchAsyncCreateJobReq
- type BatchAsyncUpdateJobReq
- type BatchCreateJobsAsyncRequest
- type BatchCreateJobsAsyncRequestXLanguage
- type BatchCreateJobsAsyncRequestXLanguageEnum
- type BatchCreateJobsAsyncResponse
- type BatchDeleteJobReq
- type BatchDeleteJobsByIdRequest
- type BatchDeleteJobsByIdRequestXLanguage
- type BatchDeleteJobsByIdRequestXLanguageEnum
- type BatchDeleteJobsByIdResponse
- type BatchExecuteJobActionsRequest
- type BatchExecuteJobActionsRequestXLanguage
- type BatchExecuteJobActionsRequestXLanguageEnum
- type BatchExecuteJobActionsResponse
- type BatchJobActionReq
- type ChildrenJobListResp
- type ChildrenJobListRespChargingMode
- type ChildrenJobListRespChargingModeEnum
- type ChildrenJobListRespEngineType
- type ChildrenJobListRespEngineTypeEnum
- type ChildrenJobListRespJobDirection
- type ChildrenJobListRespJobDirectionEnum
- type ChildrenJobListRespJobMode
- type ChildrenJobListRespJobModeEnum
- type ChildrenJobListRespJobModeRole
- type ChildrenJobListRespJobModeRoleEnum
- type ChildrenJobListRespJobType
- type ChildrenJobListRespJobTypeEnum
- type ChildrenJobListRespNetType
- type ChildrenJobListRespNetTypeEnum
- type ChildrenJobListRespStatus
- type ChildrenJobListRespStatusEnum
- type ChildrenJobListRespTaskType
- type ChildrenJobListRespTaskTypeEnum
- type CloudBaseInfo
- type CloudVpcInfo
- type ColumnObject
- type CommitAsyncJobRequest
- type CommitAsyncJobRequestXLanguage
- type CommitAsyncJobRequestXLanguageEnum
- type CommitAsyncJobResponse
- type CompareJobInfo
- type CompareJobInfoStatus
- type CompareJobInfoStatusEnum
- type CompareResultInfo
- type CompareTaskParams
- type CompareTaskParamsType
- type CompareTaskParamsTypeEnum
- type ContentCompareDetailInfo
- type ContentCompareOverviewInfo
- type ContentCompareOverviewInfoStatus
- type ContentCompareOverviewInfoStatusEnum
- type CreateJobReq
- type CreateJobRequest
- type CreateJobRequestXLanguage
- type CreateJobRequestXLanguageEnum
- type CreateJobResp
- type CreateJobResponse
- type DatabaseObject
- type DatabaseObjectSyncType
- type DatabaseObjectSyncTypeEnum
- type DbObject
- type DbObjectObjectScope
- type DbObjectObjectScopeEnum
- type DbParam
- type DbParamInfo
- type DeleteJobRequest
- type DeleteJobRequestXLanguage
- type DeleteJobRequestXLanguageEnum
- type DeleteJobResp
- type DeleteJobResponse
- type DownloadDbObjectTemplateRequest
- type DownloadDbObjectTemplateRequestXLanguage
- type DownloadDbObjectTemplateRequestXLanguageEnum
- type DownloadDbObjectTemplateResponse
- type EndpointSslConfig
- type ErrorResp
- type ExecuteJobActionRequest
- type ExecuteJobActionRequestXLanguage
- type ExecuteJobActionRequestXLanguageEnum
- type ExecuteJobActionResponse
- type JobActionReq
- type JobActions
- type JobActionsCurrentAction
- type JobActionsCurrentActionEnum
- type JobBaseInfo
- type JobBaseInfoChargingMode
- type JobBaseInfoChargingModeEnum
- type JobBaseInfoEngineType
- type JobBaseInfoEngineTypeEnum
- type JobBaseInfoJobDirection
- type JobBaseInfoJobDirectionEnum
- type JobBaseInfoJobType
- type JobBaseInfoJobTypeEnum
- type JobBaseInfoNetType
- type JobBaseInfoNetTypeEnum
- type JobBaseInfoTaskType
- type JobBaseInfoTaskTypeEnum
- type JobDetailResp
- type JobEndpointInfo
- type JobEndpointInfoDbType
- type JobEndpointInfoDbTypeEnum
- type JobEndpointInfoEndpointRole
- type JobEndpointInfoEndpointRoleEnum
- type JobEndpointInfoEndpointType
- type JobEndpointInfoEndpointTypeEnum
- type JobLinkResp
- type JobLinkRespClusterModes
- type JobLinkRespClusterModesEnum
- type JobLinkRespEngineType
- type JobLinkRespEngineTypeEnum
- type JobLinkRespJobDirection
- type JobLinkRespJobDirectionEnum
- type JobLinkRespJobType
- type JobLinkRespJobTypeEnum
- type JobLinkRespNetType
- type JobLinkRespNetTypeEnum
- type JobLinkRespSourceEndpointType
- type JobLinkRespSourceEndpointTypeEnum
- type JobLinkRespTargetEndpointType
- type JobLinkRespTargetEndpointTypeEnum
- type JobLinkRespTaskTypes
- type JobLinkRespTaskTypesEnum
- type JobListResp
- type JobListRespChargingMode
- type JobListRespChargingModeEnum
- type JobListRespEngineType
- type JobListRespEngineTypeEnum
- type JobListRespJobDirection
- type JobListRespJobDirectionEnum
- type JobListRespJobMode
- type JobListRespJobModeEnum
- type JobListRespJobModeRole
- type JobListRespJobModeRoleEnum
- type JobListRespJobType
- type JobListRespJobTypeEnum
- type JobListRespNetType
- type JobListRespNetTypeEnum
- type JobListRespStatus
- type JobListRespStatusEnum
- type JobListRespTaskType
- type JobListRespTaskTypeEnum
- type JobNodeInfo
- type JobNodeSpecInfo
- type JobNodeSpecInfoNodeType
- type JobNodeSpecInfoNodeTypeEnum
- type JobNodeVpcInfo
- type JobProgressInfo
- type LineCompareOverviewInfo
- type LineCompareOverviewInfoStatus
- type LineCompareOverviewInfoStatusEnum
- type ListAsyncJobDetailRequest
- type ListAsyncJobDetailRequestXLanguage
- type ListAsyncJobDetailRequestXLanguageEnum
- type ListAsyncJobDetailResponse
- type ListAsyncJobsRequest
- type ListAsyncJobsRequestXLanguage
- type ListAsyncJobsRequestXLanguageEnum
- type ListAsyncJobsResponse
- type ListDbObjectsRequest
- type ListDbObjectsRequestXLanguage
- type ListDbObjectsRequestXLanguageEnum
- type ListDbObjectsResponse
- type ListJobsRequest
- type ListJobsRequestEngineType
- type ListJobsRequestEngineTypeEnum
- type ListJobsRequestJobType
- type ListJobsRequestJobTypeEnum
- type ListJobsRequestNetType
- type ListJobsRequestNetTypeEnum
- type ListJobsRequestStatus
- type ListJobsRequestStatusEnum
- type ListJobsRequestXLanguage
- type ListJobsRequestXLanguageEnum
- type ListJobsResponse
- type ListLinksRequest
- type ListLinksRequestJobType
- type ListLinksRequestJobTypeEnum
- type ListLinksRequestXLanguage
- type ListLinksRequestXLanguageEnum
- type ListLinksResponse
- type MigrationObjectOverviewInfo
- type ModifyTuningParams
- type ObjectsCompareDetailInfo
- type ObjectsCompareOverviewInfo
- type ObjectsCompareOverviewInfoStatus
- type ObjectsCompareOverviewInfoStatusEnum
- type ObjectsCompareOverviewInfoType
- type ObjectsCompareOverviewInfoTypeEnum
- type ObjectsCompareTaskInfo
- type ObjectsCompareTaskInfoStatus
- type ObjectsCompareTaskInfoStatusEnum
- type PeriodOrderInfo
- type PeriodOrderInfoIsAutoRenew
- type PeriodOrderInfoIsAutoRenewEnum
- type PeriodOrderInfoPeriodType
- type PeriodOrderInfoPeriodTypeEnum
- type PolicyConfig
- type PolicyConfigConflictPolicy
- type PolicyConfigConflictPolicyEnum
- type PolicyConfigDataSyncTopologyType
- type PolicyConfigDataSyncTopologyTypeEnum
- type PolicyConfigFilterDdlPolicy
- type PolicyConfigFilterDdlPolicyEnum
- type PolicyConfigSupportDdlInfo
- type PolicyConfigSupportDdlInfoEnum
- type PrecheckFailSubJobResult
- type PrecheckResult
- type PrecheckResultResult
- type PrecheckResultResultEnum
- type ProgressCompleteInfo
- type QueryMetricResult
- type QueryMigrationObjectProgressInfo
- type QueryNetworkResult
- type QueryNetworkResultStatus
- type QueryNetworkResultStatusEnum
- type QueryPreCheckResult
- type ResourceTag
- type SchemaObject
- type ShowDbObjectTemplateProgressRequest
- type ShowDbObjectTemplateProgressRequestXLanguage
- type ShowDbObjectTemplateProgressRequestXLanguageEnum
- type ShowDbObjectTemplateProgressResponse
- type ShowDbObjectTemplateResultRequest
- type ShowDbObjectTemplateResultRequestType
- type ShowDbObjectTemplateResultRequestTypeEnum
- type ShowDbObjectTemplateResultRequestXLanguage
- type ShowDbObjectTemplateResultRequestXLanguageEnum
- type ShowDbObjectTemplateResultResponse
- type ShowJobDetailRequest
- type ShowJobDetailRequestCompareDetailType
- type ShowJobDetailRequestCompareDetailTypeEnum
- type ShowJobDetailRequestCompareType
- type ShowJobDetailRequestCompareTypeEnum
- type ShowJobDetailRequestObjectType
- type ShowJobDetailRequestObjectTypeEnum
- type ShowJobDetailRequestQueryType
- type ShowJobDetailRequestQueryTypeEnum
- type ShowJobDetailRequestType
- type ShowJobDetailRequestTypeEnum
- type ShowJobDetailRequestXLanguage
- type ShowJobDetailRequestXLanguageEnum
- type ShowJobDetailResponse
- type SingleCreateJobReq
- type SingleUpdateJobReq
- type SkipPreCheckInfo
- type SpeedLimitInfo
- type TableLineCompareDetailInfo
- type TableLineCompareDetailInfoStatus
- type TableLineCompareDetailInfoStatusEnum
- type TableObject
- type TableObjectType
- type TableObjectTypeEnum
- type TargetRootDb
- type TaskLogInfo
- type TuningParamInfo
- type TuningParameter
- type UpdateBatchAsyncJobsRequest
- type UpdateBatchAsyncJobsRequestXLanguage
- type UpdateBatchAsyncJobsRequestXLanguageEnum
- type UpdateBatchAsyncJobsResponse
- type UpdateJob
- type UpdateJobReq
- type UpdateJobReqType
- type UpdateJobReqTypeEnum
- type UpdateJobRequest
- type UpdateJobRequestXLanguage
- type UpdateJobRequestXLanguageEnum
- type UpdateJobResponse
- type UploadDbObjectTemplateRequest
- type UploadDbObjectTemplateRequestBody
- type UploadDbObjectTemplateRequestXLanguage
- type UploadDbObjectTemplateRequestXLanguageEnum
- type UploadDbObjectTemplateResponse
- type UserMigrationInfo
- type UserMigrationList
- type UserMigrationRole
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"` }
测试连接、预检查、启动、暂停、续传、重置、对比、结束等操作任务请求体。
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"` }
基础响应体。
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 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"` }
数据库库级对象。
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
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"` }
数据库参数名、目标数据库参数值。
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"` }
请求失败时返回的错误对象响应体。
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大于等于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量 Limit *int32 `json:"limit,omitempty"` // 查询对象信息类型。取值: - source:查询源库对象信息。 - modified:查询已选择的(未下发与已同步的)对象信息。 - synchronized:查询已同步的(已下发的)对象信息 。 Type string `json:"type"` }
Request Object
func (ListDbObjectsRequest) String ¶
func (o ListDbObjectsRequest) String() string
type ListDbObjectsRequestXLanguage ¶
type ListDbObjectsRequestXLanguage struct {
// contains filtered or unexported fields
}
func (ListDbObjectsRequestXLanguage) MarshalJSON ¶
func (c ListDbObjectsRequestXLanguage) MarshalJSON() ([]byte, error)
func (*ListDbObjectsRequestXLanguage) UnmarshalJSON ¶
func (c *ListDbObjectsRequestXLanguage) UnmarshalJSON(b []byte) error
func (ListDbObjectsRequestXLanguage) Value ¶
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"` HttpStatusCode int `json:"-"` }
Response Object
func (ListDbObjectsResponse) String ¶
func (o ListDbObjectsResponse) String() string
type ListJobsRequest ¶
type ListJobsRequest struct { // 请求语言类型。 XLanguage *ListJobsRequestXLanguage `json:"X-Language,omitempty"` // 任务场景。取值: - migration:实时迁移。 - sync:实时同步。 - cloudDataGuard:实时灾备。 JobType ListJobsRequestJobType `json:"job_type"` // 任务ID或名称。 Name *string `json:"name,omitempty"` // 任务状态。取值: - CREATING:创建中。 - CREATE_FAILED:创建失败。 - CONFIGURATION:配置中。 - STARTJOBING:启动中。 - WAITING_FOR_START:等待启动中。 - START_JOB_FAILED:任务启动失败。 - FULL_TRANSFER_STARTED:全量迁移中,灾备场景为初始化。 - FULL_TRANSFER_FAILED:全量迁移失败,灾备场景为初始化失败。 - FULL_TRANSFER_COMPLETE:全量迁移完成,灾备场景为初始化完成。 - INCRE_TRANSFER_STARTED:增量迁移中,灾备场景为灾备中。 - INCRE_TRANSFER_FAILED:增量迁移失败,灾备场景为灾备异常。 - RELEASE_RESOURCE_STARTED:结束任务中。 - RELEASE_RESOURCE_FAILED:结束任务失败。 - RELEASE_RESOURCE_COMPLETE:已结束。 - CHANGE_JOB_STARTED:任务变更中。 - CHANGE_JOB_FAILED:任务变更失败。 - CHILD_TRANSFER_STARTING:子任务启动中。 - CHILD_TRANSFER_STARTED:子任务迁移中。 - CHILD_TRANSFER_COMPLETE:子任务迁移完成。 - CHILD_TRANSFER_FAILED:子任务迁移失败。 - RELEASE_CHILD_TRANSFER_STARTED:子任务结束中。 - RELEASE_CHILD_TRANSFER_COMPLETE:子任务已结束。 其中,异常状态可单独查询,也可以通过以下方式查询全部异常任务: CREATE_FAILED,START_JOB_FAILED,FULL_TRANSFER_FAILED,INCRE_TRANSFER_FAILED,RELEASE_RESOURCE_FAILED,CHANGE_JOB_FAILED,CHILD_TRANSFER_FAILED Status *ListJobsRequestStatus `json:"status,omitempty"` // 引擎类型。取值: - oracle-to-gaussdbv5:Oracle同步到GaussDB分布式版,实时同步场景使用。 EngineType *ListJobsRequestEngineType `json:"engine_type,omitempty"` // 网络类型。取值: - eip:公网网络。 - vpc:VPC网络。 - vpn:VPN、专线网络。 NetType *ListJobsRequestNetType `json:"net_type,omitempty"` // 企业项目ID。 缺省值:\"\",表示查询所有企业项目任务。 EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` // 偏移量,表示查询该偏移量后面的记录。 Offset *int32 `json:"offset,omitempty"` // 查询返回记录的数量限制。 Limit *int32 `json:"limit,omitempty"` // 返回结果按该关键字排序,默认为“create_time”。 SortKey *string `json:"sort_key,omitempty"` // 降序或升序(分别对应desc和asc,默认为“desc”) SortDir *string `json:"sort_dir,omitempty"` }
Request Object
func (ListJobsRequest) String ¶
func (o ListJobsRequest) String() string
type ListJobsRequestEngineType ¶
type ListJobsRequestEngineType struct {
// contains filtered or unexported fields
}
func (ListJobsRequestEngineType) MarshalJSON ¶
func (c ListJobsRequestEngineType) MarshalJSON() ([]byte, error)
func (*ListJobsRequestEngineType) UnmarshalJSON ¶
func (c *ListJobsRequestEngineType) UnmarshalJSON(b []byte) error
func (ListJobsRequestEngineType) Value ¶
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 ShowDbObjectTemplateProgressRequest ¶
type ShowDbObjectTemplateProgressRequest struct { // 任务ID。 JobId string `json:"job_id"` // 请求语言类型。 XLanguage *ShowDbObjectTemplateProgressRequestXLanguage `json:"X-Language,omitempty"` // 偏移量,表示从此偏移量开始查询, offset大于等于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量 Limit *int32 `json:"limit,omitempty"` }
Request Object
func (ShowDbObjectTemplateProgressRequest) String ¶
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 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"` // 是否已经进行同步。 HasBeenSent *bool `json:"has_been_sent,omitempty"` // 需要同步/映射/过滤/新增的列,当需要列过滤、列映射、附加列功能时填写,仅在实时同步任务中生效,当整表同步为false时需要填写。 Columns map[string]ColumnObject `json:"columns,omitempty"` }
数据库表级对象。
func (TableObject) String ¶
func (o TableObject) String() string
type TableObjectType ¶
type TableObjectType struct {
// contains filtered or unexported fields
}
func (TableObjectType) MarshalJSON ¶
func (c TableObjectType) MarshalJSON() ([]byte, error)
func (*TableObjectType) UnmarshalJSON ¶
func (c *TableObjectType) UnmarshalJSON(b []byte) error
func (TableObjectType) Value ¶
func (c TableObjectType) Value() string
type TableObjectTypeEnum ¶
type TableObjectTypeEnum struct { TABLE TableObjectType VIEW TableObjectType PROCEDURE TableObjectType }
func GetTableObjectTypeEnum ¶
func GetTableObjectTypeEnum() TableObjectTypeEnum
type TargetRootDb ¶
type TargetRootDb struct { // 库名。 DbName *string `json:"db_name,omitempty"` // 默认编码格式是utf8。 DbEncoding *string `json:"db_encoding,omitempty"` }
数据库对象迁移或同步目标库信息,两层到三层数据库时需要指定。
func (TargetRootDb) String ¶
func (o TargetRootDb) String() string
type TaskLogInfo ¶
type TaskLogInfo struct { // 日志级别。 Level *string `json:"level,omitempty"` // 日志信息。 Message *string `json:"message,omitempty"` // 日志时间。 CreateTime *string `json:"create_time,omitempty"` }
日志查询结果信息体。
func (TaskLogInfo) String ¶
func (o TaskLogInfo) String() string
type TuningParamInfo ¶
type TuningParamInfo struct { // 全量调优参数。 FullSync []TuningParameter `json:"full_sync"` // 增量抓取调优参数。 IncreCapture []TuningParameter `json:"incre_capture"` // 增量回放调优参数。 IncreApply []TuningParameter `json:"incre_apply"` // 增量日志拉取调优参数。 IncreRelay []TuningParameter `json:"incre_relay"` }
高级设置信息体。
func (TuningParamInfo) String ¶
func (o TuningParamInfo) String() string
type TuningParameter ¶
type TuningParameter struct { // 参数名称。 ParamName string `json:"param_name"` // 参数取值。 ParamValue string `json:"param_value"` // 是否可用。 Availability bool `json:"availability"` }
调优参数。
func (TuningParameter) String ¶
func (o TuningParameter) String() string
type UpdateBatchAsyncJobsRequest ¶
type UpdateBatchAsyncJobsRequest struct { // 批量异步创建的任务ID,由创建批量异步任务接口返回。 AsyncJobId string `json:"async_job_id"` // 请求语言类型。 XLanguage *UpdateBatchAsyncJobsRequestXLanguage `json:"X-Language,omitempty"` Body *BatchAsyncUpdateJobReq `json:"body,omitempty"` }
Request Object
func (UpdateBatchAsyncJobsRequest) String ¶
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"` }
更新任务信息体。
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 ¶
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 ¶
- model_action_params.go
- model_action_req.go
- model_alarm_notify_config.go
- model_async_action_base_resp.go
- model_async_action_resp.go
- model_async_commit_job_resp.go
- model_async_create_job_req.go
- model_async_create_job_resp.go
- model_async_job_resp.go
- model_async_update_job_resp.go
- model_base_endpoint.go
- model_base_endpoint_config.go
- model_base_resp.go
- model_batch_async_create_job_req.go
- model_batch_async_update_job_req.go
- model_batch_create_jobs_async_request.go
- model_batch_create_jobs_async_response.go
- model_batch_delete_job_req.go
- model_batch_delete_jobs_by_id_request.go
- model_batch_delete_jobs_by_id_response.go
- model_batch_execute_job_actions_request.go
- model_batch_execute_job_actions_response.go
- model_batch_job_action_req.go
- model_children_job_list_resp.go
- model_cloud_base_info.go
- model_cloud_vpc_info.go
- model_column_object.go
- model_commit_async_job_request.go
- model_commit_async_job_response.go
- model_compare_job_info.go
- model_compare_result_info.go
- model_compare_task_params.go
- model_content_compare_detail_info.go
- model_content_compare_overview_info.go
- model_create_job_req.go
- model_create_job_request.go
- model_create_job_resp.go
- model_create_job_response.go
- model_database_object.go
- model_db_object.go
- model_db_param.go
- model_db_param_info.go
- model_delete_job_request.go
- model_delete_job_resp.go
- model_delete_job_response.go
- model_download_db_object_template_request.go
- model_download_db_object_template_response.go
- model_endpoint_ssl_config.go
- model_error_resp.go
- model_execute_job_action_request.go
- model_execute_job_action_response.go
- model_job_action_req.go
- model_job_actions.go
- model_job_base_info.go
- model_job_detail_resp.go
- model_job_endpoint_info.go
- model_job_link_resp.go
- model_job_list_resp.go
- model_job_node_info.go
- model_job_node_spec_info.go
- model_job_node_vpc_info.go
- model_job_progress_info.go
- model_line_compare_overview_info.go
- model_list_async_job_detail_request.go
- model_list_async_job_detail_response.go
- model_list_async_jobs_request.go
- model_list_async_jobs_response.go
- model_list_db_objects_request.go
- model_list_db_objects_response.go
- model_list_jobs_request.go
- model_list_jobs_response.go
- model_list_links_request.go
- model_list_links_response.go
- model_migration_object_overview_info.go
- model_modify_tuning_params.go
- model_objects_compare_detail_info.go
- model_objects_compare_overview_info.go
- model_objects_compare_task_info.go
- model_period_order_info.go
- model_policy_config.go
- model_precheck_fail_sub_job_result.go
- model_precheck_result.go
- model_progress_complete_info.go
- model_query_metric_result.go
- model_query_migration_object_progress_info.go
- model_query_network_result.go
- model_query_pre_check_result.go
- model_resource_tag.go
- model_schema_object.go
- model_show_db_object_template_progress_request.go
- model_show_db_object_template_progress_response.go
- model_show_db_object_template_result_request.go
- model_show_db_object_template_result_response.go
- model_show_job_detail_request.go
- model_show_job_detail_response.go
- model_single_create_job_req.go
- model_single_update_job_req.go
- model_skip_pre_check_info.go
- model_speed_limit_info.go
- model_table_line_compare_detail_info.go
- model_table_object.go
- model_target_root_db.go
- model_task_log_info.go
- model_tuning_param_info.go
- model_tuning_parameter.go
- model_update_batch_async_jobs_request.go
- model_update_batch_async_jobs_response.go
- model_update_job.go
- model_update_job_req.go
- model_update_job_request.go
- model_update_job_response.go
- model_upload_db_object_template_request.go
- model_upload_db_object_template_request_body.go
- model_upload_db_object_template_response.go
- model_user_migration_info.go
- model_user_migration_list.go
- model_user_migration_role.go