Documentation ¶
Index ¶
- Constants
- type ActivateSubscribeRequest
- type ActivateSubscribeRequestParams
- type ActivateSubscribeResponse
- type ActivateSubscribeResponseParams
- type Client
- func (c *Client) ActivateSubscribe(request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)
- func (c *Client) ActivateSubscribeWithContext(ctx context.Context, request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)
- func (c *Client) CompleteMigrateJob(request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)
- func (c *Client) CompleteMigrateJobWithContext(ctx context.Context, request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)
- func (c *Client) CreateMigrateCheckJob(request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)
- func (c *Client) CreateMigrateCheckJobWithContext(ctx context.Context, request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)
- func (c *Client) CreateMigrateJob(request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)
- func (c *Client) CreateMigrateJobWithContext(ctx context.Context, request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)
- func (c *Client) CreateSubscribe(request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
- func (c *Client) CreateSubscribeWithContext(ctx context.Context, request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
- func (c *Client) DeleteMigrateJob(request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)
- func (c *Client) DeleteMigrateJobWithContext(ctx context.Context, request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)
- func (c *Client) DescribeAsyncRequestInfo(request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)
- func (c *Client) DescribeAsyncRequestInfoWithContext(ctx context.Context, request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)
- func (c *Client) DescribeMigrateCheckJob(request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)
- func (c *Client) DescribeMigrateCheckJobWithContext(ctx context.Context, request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)
- func (c *Client) DescribeMigrateJobs(request *DescribeMigrateJobsRequest) (response *DescribeMigrateJobsResponse, err error)
- func (c *Client) DescribeMigrateJobsWithContext(ctx context.Context, request *DescribeMigrateJobsRequest) (response *DescribeMigrateJobsResponse, err error)
- func (c *Client) DescribeRegionConf(request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)
- func (c *Client) DescribeRegionConfWithContext(ctx context.Context, request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)
- func (c *Client) DescribeSubscribeConf(request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)
- func (c *Client) DescribeSubscribeConfWithContext(ctx context.Context, request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)
- func (c *Client) DescribeSubscribes(request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)
- func (c *Client) DescribeSubscribesWithContext(ctx context.Context, request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)
- func (c *Client) IsolateSubscribe(request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)
- func (c *Client) IsolateSubscribeWithContext(ctx context.Context, request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)
- func (c *Client) ModifyMigrateJob(request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)
- func (c *Client) ModifyMigrateJobWithContext(ctx context.Context, request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)
- func (c *Client) ModifySubscribeAutoRenewFlag(request *ModifySubscribeAutoRenewFlagRequest) (response *ModifySubscribeAutoRenewFlagResponse, err error)
- func (c *Client) ModifySubscribeAutoRenewFlagWithContext(ctx context.Context, request *ModifySubscribeAutoRenewFlagRequest) (response *ModifySubscribeAutoRenewFlagResponse, err error)
- func (c *Client) ModifySubscribeConsumeTime(request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)
- func (c *Client) ModifySubscribeConsumeTimeWithContext(ctx context.Context, request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)
- func (c *Client) ModifySubscribeName(request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)
- func (c *Client) ModifySubscribeNameWithContext(ctx context.Context, request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)
- func (c *Client) ModifySubscribeObjects(request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)
- func (c *Client) ModifySubscribeObjectsWithContext(ctx context.Context, request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)
- func (c *Client) ModifySubscribeVipVport(request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)
- func (c *Client) ModifySubscribeVipVportWithContext(ctx context.Context, request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)
- func (c *Client) OfflineIsolatedSubscribe(request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)
- func (c *Client) OfflineIsolatedSubscribeWithContext(ctx context.Context, request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)
- func (c *Client) ResetSubscribe(request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)
- func (c *Client) ResetSubscribeWithContext(ctx context.Context, request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)
- func (c *Client) StartMigrateJob(request *StartMigrateJobRequest) (response *StartMigrateJobResponse, err error)
- func (c *Client) StartMigrateJobWithContext(ctx context.Context, request *StartMigrateJobRequest) (response *StartMigrateJobResponse, err error)
- func (c *Client) StopMigrateJob(request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)
- func (c *Client) StopMigrateJobWithContext(ctx context.Context, request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)
- type CompleteMigrateJobRequest
- type CompleteMigrateJobRequestParams
- type CompleteMigrateJobResponse
- type CompleteMigrateJobResponseParams
- type ConsistencyParams
- type CreateMigrateCheckJobRequest
- type CreateMigrateCheckJobRequestParams
- type CreateMigrateCheckJobResponse
- type CreateMigrateCheckJobResponseParams
- type CreateMigrateJobRequest
- type CreateMigrateJobRequestParams
- type CreateMigrateJobResponse
- type CreateMigrateJobResponseParams
- type CreateSubscribeRequest
- type CreateSubscribeRequestParams
- type CreateSubscribeResponse
- type CreateSubscribeResponseParams
- type DeleteMigrateJobRequest
- type DeleteMigrateJobRequestParams
- type DeleteMigrateJobResponse
- type DeleteMigrateJobResponseParams
- type DescribeAsyncRequestInfoRequest
- type DescribeAsyncRequestInfoRequestParams
- type DescribeAsyncRequestInfoResponse
- type DescribeAsyncRequestInfoResponseParams
- type DescribeMigrateCheckJobRequest
- type DescribeMigrateCheckJobRequestParams
- type DescribeMigrateCheckJobResponse
- type DescribeMigrateCheckJobResponseParams
- type DescribeMigrateJobsRequest
- type DescribeMigrateJobsRequestParams
- type DescribeMigrateJobsResponse
- type DescribeMigrateJobsResponseParams
- type DescribeRegionConfRequest
- type DescribeRegionConfRequestParams
- type DescribeRegionConfResponse
- type DescribeRegionConfResponseParams
- type DescribeSubscribeConfRequest
- type DescribeSubscribeConfRequestParams
- type DescribeSubscribeConfResponse
- type DescribeSubscribeConfResponseParams
- type DescribeSubscribesRequest
- type DescribeSubscribesRequestParams
- type DescribeSubscribesResponse
- type DescribeSubscribesResponseParams
- type DstInfo
- type ErrorInfo
- type IsolateSubscribeRequest
- type IsolateSubscribeRequestParams
- type IsolateSubscribeResponse
- type IsolateSubscribeResponseParams
- type MigrateDetailInfo
- type MigrateJobInfo
- type MigrateOption
- type MigrateStepDetailInfo
- type ModifyMigrateJobRequest
- type ModifyMigrateJobRequestParams
- type ModifyMigrateJobResponse
- type ModifyMigrateJobResponseParams
- type ModifySubscribeAutoRenewFlagRequest
- type ModifySubscribeAutoRenewFlagRequestParams
- type ModifySubscribeAutoRenewFlagResponse
- type ModifySubscribeAutoRenewFlagResponseParams
- type ModifySubscribeConsumeTimeRequest
- type ModifySubscribeConsumeTimeRequestParams
- type ModifySubscribeConsumeTimeResponse
- type ModifySubscribeConsumeTimeResponseParams
- type ModifySubscribeNameRequest
- type ModifySubscribeNameRequestParams
- type ModifySubscribeNameResponse
- type ModifySubscribeNameResponseParams
- type ModifySubscribeObjectsRequest
- type ModifySubscribeObjectsRequestParams
- type ModifySubscribeObjectsResponse
- type ModifySubscribeObjectsResponseParams
- type ModifySubscribeVipVportRequest
- type ModifySubscribeVipVportRequestParams
- type ModifySubscribeVipVportResponse
- type ModifySubscribeVipVportResponseParams
- type OfflineIsolatedSubscribeRequest
- type OfflineIsolatedSubscribeRequestParams
- type OfflineIsolatedSubscribeResponse
- type OfflineIsolatedSubscribeResponseParams
- type ResetSubscribeRequest
- type ResetSubscribeRequestParams
- type ResetSubscribeResponse
- type ResetSubscribeResponseParams
- type SrcInfo
- type StartMigrateJobRequest
- type StartMigrateJobRequestParams
- type StartMigrateJobResponse
- type StartMigrateJobResponseParams
- type StopMigrateJobRequest
- type StopMigrateJobRequestParams
- type StopMigrateJobResponse
- type StopMigrateJobResponseParams
- type SubsErr
- type SubscribeInfo
- type SubscribeObject
- type SubscribeRegionConf
- type TagFilter
- type TagItem
Constants ¶
const ( // 认证失败。 AUTHFAILURE_AUTHFAILUREERROR = "AuthFailure.AuthFailureError" // 鉴权失败,当前用户不允许执行该操作。 AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" // 操作失败。 FAILEDOPERATION_FAILEDOPERATIONERROR = "FailedOperation.FailedOperationError" // 禁止该操作。 FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" // 代理出错。 FAILEDOPERATION_PROXYERROR = "FailedOperation.ProxyError" // 任务开始失败。 FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed" // 当前状态冲突,不能执行该操作。 FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" // 当前状态不允许操作。 FAILEDOPERATION_STATUSINCONFLICTERROR = "FailedOperation.StatusInConflictError" // 内部错误。 INTERNALERROR = "InternalError" // 添加异步任务失败。 INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError" // 内部调度系统错误。 INTERNALERROR_CELERYERROR = "InternalError.CeleryError" // cgw系统错误。 INTERNALERROR_CGWSYSTEMERROR = "InternalError.CgwSystemError" // 迁移平台数据库访问失败。 INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" // 迁移任务冲突。 INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" // 内部错误。 INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" // http请求访问出错。 INTERNALERROR_INTERNALHTTPSERVERERROR = "InternalError.InternalHttpServerError" // 内部组件访问错误。 INTERNALERROR_INTERNALINNERCOMMONERROR = "InternalError.InternalInnerCommonError" // 调用计费服务失败。 INTERNALERROR_INTERNALTRADEERROR = "InternalError.InternalTradeError" // 锁冲突。 INTERNALERROR_LOCKERROR = "InternalError.LockError" // 通信协议错误。 INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" // 内部错误。 INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" // 未知的内部错误。 INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" // 参数错误。 INVALIDPARAMETER = "InvalidParameter" // 参数值错误。 INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError" // 实例不存在。 INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" // ip地址错误。 INVALIDPARAMETER_INVALIDIPADDRESS = "InvalidParameter.InvalidIpAddress" // 参数无效。 INVALIDPARAMETER_INVALIDPARAMETERERROR = "InvalidParameter.InvalidParameterError" // 业务参数错误。 INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" // 数据转换错误。 INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" // 参数值错误。 INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue" // 非法参数。 INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" // 闲置迁移任务数目超过限制。 LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" // 操作被拒绝。 OPERATIONDENIED = "OperationDenied" // 当前操作不满足条件被阻止。 OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" // 任务操作失败。 OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" // 数据迁移服务不支持当前迁移类型。 OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError" // 用户余额不足。 OPERATIONDENIED_NOTENOUGHMONEYERROR = "OperationDenied.NotEnoughMoneyError" // 该操作不能执行。 OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" // 操作被拒绝。 OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" // 请求次数超限。 REQUESTLIMITEXCEEDED_REQUESTLIMITEXCEEDEDERROR = "RequestLimitExceeded.RequestLimitExceededError" // 资源不存在。 RESOURCENOTFOUND = "ResourceNotFound" // 未找到资源。 RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" // 迁移任务不存在。 RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" // 实例未找到。 RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound" // 资源未找到。 RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError" // 认证失败,没有足够权限。 UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges" // 未授权的操作。 UNAUTHORIZEDOPERATION_UNAUTHORIZEDOPERATIONERROR = "UnauthorizedOperation.UnauthorizedOperationError" // 操作不支持。 UNSUPPORTEDOPERATION = "UnsupportedOperation" // 自研上云用户创建迁移任务时未指定标签,需要补齐“运营部门”、“运营产品”、“负责人”这三类标签。 UNSUPPORTEDOPERATION_INTRANETUSERNOTTAGGEDERROR = "UnsupportedOperation.IntraNetUserNotTaggedError" )
const APIVersion = "2018-03-30"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActivateSubscribeRequest ¶
type ActivateSubscribeRequest struct { *tchttp.BaseRequest // 订阅实例ID。 SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据库实例ID InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 数据订阅类型0-全实例订阅,1数据订阅,2结构订阅,3数据订阅与结构订阅 SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil,omitempty" name:"SubscribeObjectType"` // 订阅对象 Objects *SubscribeObject `json:"Objects,omitnil,omitempty" name:"Objects"` // 数据订阅服务所在子网。默认为数据库实例所在的子网内。 UniqSubnetId *string `json:"UniqSubnetId,omitnil,omitempty" name:"UniqSubnetId"` // 订阅服务端口;默认为7507 Vport *int64 `json:"Vport,omitnil,omitempty" name:"Vport"` }
func NewActivateSubscribeRequest ¶
func NewActivateSubscribeRequest() (request *ActivateSubscribeRequest)
func (*ActivateSubscribeRequest) FromJsonString ¶
func (r *ActivateSubscribeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ActivateSubscribeRequest) ToJsonString ¶
func (r *ActivateSubscribeRequest) ToJsonString() string
type ActivateSubscribeRequestParams ¶ added in v1.0.426
type ActivateSubscribeRequestParams struct { // 订阅实例ID。 SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据库实例ID InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 数据订阅类型0-全实例订阅,1数据订阅,2结构订阅,3数据订阅与结构订阅 SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil,omitempty" name:"SubscribeObjectType"` // 订阅对象 Objects *SubscribeObject `json:"Objects,omitnil,omitempty" name:"Objects"` // 数据订阅服务所在子网。默认为数据库实例所在的子网内。 UniqSubnetId *string `json:"UniqSubnetId,omitnil,omitempty" name:"UniqSubnetId"` // 订阅服务端口;默认为7507 Vport *int64 `json:"Vport,omitnil,omitempty" name:"Vport"` }
Predefined struct for user
type ActivateSubscribeResponse ¶
type ActivateSubscribeResponse struct { *tchttp.BaseResponse Response *ActivateSubscribeResponseParams `json:"Response"` }
func NewActivateSubscribeResponse ¶
func NewActivateSubscribeResponse() (response *ActivateSubscribeResponse)
func (*ActivateSubscribeResponse) FromJsonString ¶
func (r *ActivateSubscribeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ActivateSubscribeResponse) ToJsonString ¶
func (r *ActivateSubscribeResponse) ToJsonString() string
type ActivateSubscribeResponseParams ¶ added in v1.0.426
type ActivateSubscribeResponseParams struct { // 配置数据订阅任务ID。 AsyncRequestId *string `json:"AsyncRequestId,omitnil,omitempty" name:"AsyncRequestId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type Client ¶
func NewClient ¶
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
Deprecated
func (*Client) ActivateSubscribe ¶
func (c *Client) ActivateSubscribe(request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)
ActivateSubscribe 本接口用于配置数据订阅,只有在未配置状态的订阅实例才能调用此接口。
可能返回的错误码:
INTERNALERROR = "InternalError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) ActivateSubscribeWithContext ¶ added in v1.0.324
func (c *Client) ActivateSubscribeWithContext(ctx context.Context, request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)
ActivateSubscribe 本接口用于配置数据订阅,只有在未配置状态的订阅实例才能调用此接口。
可能返回的错误码:
INTERNALERROR = "InternalError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) CompleteMigrateJob ¶
func (c *Client) CompleteMigrateJob(request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)
CompleteMigrateJob 本接口(CompleteMigrateJob)用于完成数据迁移任务。
选择采用增量迁移方式的任务, 需要在迁移进度进入准备完成阶段后, 调用本接口, 停止迁移增量数据。
通过DescribeMigrateJobs接口查询到任务的状态为准备完成(status=8)时,此时可以调用本接口完成迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) CompleteMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) CompleteMigrateJobWithContext(ctx context.Context, request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)
CompleteMigrateJob 本接口(CompleteMigrateJob)用于完成数据迁移任务。
选择采用增量迁移方式的任务, 需要在迁移进度进入准备完成阶段后, 调用本接口, 停止迁移增量数据。
通过DescribeMigrateJobs接口查询到任务的状态为准备完成(status=8)时,此时可以调用本接口完成迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) CreateMigrateCheckJob ¶
func (c *Client) CreateMigrateCheckJob(request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)
CreateMigrateCheckJob 创建校验迁移任务
在开始迁移前, 必须调用本接口创建校验, 且校验成功后才能开始迁移. 校验的结果可以通过DescribeMigrateCheckJob查看.
校验成功后,迁移任务若有修改, 则必须重新创建校验并通过后, 才能开始迁移.
如果是金融区链路, 请使用域名: https://dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_PROXYERROR = "FailedOperation.ProxyError" INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_CGWSYSTEMERROR = "InternalError.CgwSystemError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_LOCKERROR = "InternalError.LockError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" INVALIDPARAMETER_INVALIDIPADDRESS = "InvalidParameter.InvalidIpAddress" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges" UNSUPPORTEDOPERATION_INTRANETUSERNOTTAGGEDERROR = "UnsupportedOperation.IntraNetUserNotTaggedError"
func (*Client) CreateMigrateCheckJobWithContext ¶ added in v1.0.324
func (c *Client) CreateMigrateCheckJobWithContext(ctx context.Context, request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)
CreateMigrateCheckJob 创建校验迁移任务
在开始迁移前, 必须调用本接口创建校验, 且校验成功后才能开始迁移. 校验的结果可以通过DescribeMigrateCheckJob查看.
校验成功后,迁移任务若有修改, 则必须重新创建校验并通过后, 才能开始迁移.
如果是金融区链路, 请使用域名: https://dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_PROXYERROR = "FailedOperation.ProxyError" INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_CGWSYSTEMERROR = "InternalError.CgwSystemError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_LOCKERROR = "InternalError.LockError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" INVALIDPARAMETER_INVALIDIPADDRESS = "InvalidParameter.InvalidIpAddress" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges" UNSUPPORTEDOPERATION_INTRANETUSERNOTTAGGEDERROR = "UnsupportedOperation.IntraNetUserNotTaggedError"
func (*Client) CreateMigrateJob ¶
func (c *Client) CreateMigrateJob(request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)
CreateMigrateJob 本接口(CreateMigrateJob)用于创建数据迁移任务。
如果是金融区链路, 请使用域名: dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_INTERNALHTTPSERVERERROR = "InternalError.InternalHttpServerError" INTERNALERROR_INTERNALINNERCOMMONERROR = "InternalError.InternalInnerCommonError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError" INVALIDPARAMETER_INVALIDPARAMETERERROR = "InvalidParameter.InvalidParameterError" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_NOTENOUGHMONEYERROR = "OperationDenied.NotEnoughMoneyError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) CreateMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) CreateMigrateJobWithContext(ctx context.Context, request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)
CreateMigrateJob 本接口(CreateMigrateJob)用于创建数据迁移任务。
如果是金融区链路, 请使用域名: dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_INTERNALHTTPSERVERERROR = "InternalError.InternalHttpServerError" INTERNALERROR_INTERNALINNERCOMMONERROR = "InternalError.InternalInnerCommonError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError" INVALIDPARAMETER_INVALIDPARAMETERERROR = "InvalidParameter.InvalidParameterError" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_NOTENOUGHMONEYERROR = "OperationDenied.NotEnoughMoneyError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) CreateSubscribe ¶
func (c *Client) CreateSubscribe(request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
CreateSubscribe 本接口(CreateSubscribe)用于创建一个数据订阅实例。
可能返回的错误码:
INTERNALERROR = "InternalError" INTERNALERROR_INTERNALTRADEERROR = "InternalError.InternalTradeError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError"
func (*Client) CreateSubscribeWithContext ¶ added in v1.0.324
func (c *Client) CreateSubscribeWithContext(ctx context.Context, request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)
CreateSubscribe 本接口(CreateSubscribe)用于创建一个数据订阅实例。
可能返回的错误码:
INTERNALERROR = "InternalError" INTERNALERROR_INTERNALTRADEERROR = "InternalError.InternalTradeError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError"
func (*Client) DeleteMigrateJob ¶
func (c *Client) DeleteMigrateJob(request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)
DeleteMigrateJob 本接口(DeleteMigrationJob)用于删除数据迁移任务。当通过DescribeMigrateJobs接口查询到任务的状态为:检验中(status=3)、运行中(status=7)、准备完成(status=8)、撤销中(status=11)或者完成中(status=12)时,不允许删除任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges" UNAUTHORIZEDOPERATION_UNAUTHORIZEDOPERATIONERROR = "UnauthorizedOperation.UnauthorizedOperationError"
func (*Client) DeleteMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) DeleteMigrateJobWithContext(ctx context.Context, request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)
DeleteMigrateJob 本接口(DeleteMigrationJob)用于删除数据迁移任务。当通过DescribeMigrateJobs接口查询到任务的状态为:检验中(status=3)、运行中(status=7)、准备完成(status=8)、撤销中(status=11)或者完成中(status=12)时,不允许删除任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INTERNALERROR_CELERYERROR = "InternalError.CeleryError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges" UNAUTHORIZEDOPERATION_UNAUTHORIZEDOPERATIONERROR = "UnauthorizedOperation.UnauthorizedOperationError"
func (*Client) DescribeAsyncRequestInfo ¶
func (c *Client) DescribeAsyncRequestInfo(request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)
DescribeAsyncRequestInfo 本接口(DescribeAsyncRequestInfo)用于查询任务执行结果
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) DescribeAsyncRequestInfoWithContext ¶ added in v1.0.324
func (c *Client) DescribeAsyncRequestInfoWithContext(ctx context.Context, request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)
DescribeAsyncRequestInfo 本接口(DescribeAsyncRequestInfo)用于查询任务执行结果
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) DescribeMigrateCheckJob ¶
func (c *Client) DescribeMigrateCheckJob(request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)
DescribeMigrateCheckJob 本接口用于创建校验后,获取校验的结果. 能查询到当前校验的状态和进度.
若通过校验, 则可调用'StartMigrateJob' 开始迁移.
若未通过校验, 则能查询到校验失败的原因. 请按照报错, 通过'ModifyMigrateJob'修改迁移配置或是调整源/目标实例的相关参数.
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) DescribeMigrateCheckJobWithContext ¶ added in v1.0.324
func (c *Client) DescribeMigrateCheckJobWithContext(ctx context.Context, request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)
DescribeMigrateCheckJob 本接口用于创建校验后,获取校验的结果. 能查询到当前校验的状态和进度.
若通过校验, 则可调用'StartMigrateJob' 开始迁移.
若未通过校验, 则能查询到校验失败的原因. 请按照报错, 通过'ModifyMigrateJob'修改迁移配置或是调整源/目标实例的相关参数.
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) DescribeMigrateJobs ¶
func (c *Client) DescribeMigrateJobs(request *DescribeMigrateJobsRequest) (response *DescribeMigrateJobsResponse, err error)
DescribeMigrateJobs 查询数据迁移任务.
如果是金融区链路, 请使用域名: https://dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
AUTHFAILURE_AUTHFAILUREERROR = "AuthFailure.AuthFailureError" AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDPARAMETERERROR = "InvalidParameter.InvalidParameterError" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" REQUESTLIMITEXCEEDED_REQUESTLIMITEXCEEDEDERROR = "RequestLimitExceeded.RequestLimitExceededError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) DescribeMigrateJobsWithContext ¶ added in v1.0.324
func (c *Client) DescribeMigrateJobsWithContext(ctx context.Context, request *DescribeMigrateJobsRequest) (response *DescribeMigrateJobsResponse, err error)
DescribeMigrateJobs 查询数据迁移任务.
如果是金融区链路, 请使用域名: https://dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
AUTHFAILURE_AUTHFAILUREERROR = "AuthFailure.AuthFailureError" AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDPARAMETERERROR = "InvalidParameter.InvalidParameterError" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" REQUESTLIMITEXCEEDED_REQUESTLIMITEXCEEDEDERROR = "RequestLimitExceeded.RequestLimitExceededError" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) DescribeRegionConf ¶
func (c *Client) DescribeRegionConf(request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)
DescribeRegionConf 接口不再使用
本接口(DescribeRegionConf)用于查询可售卖订阅实例的地域
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) DescribeRegionConfWithContext ¶ added in v1.0.324
func (c *Client) DescribeRegionConfWithContext(ctx context.Context, request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)
DescribeRegionConf 接口不再使用
本接口(DescribeRegionConf)用于查询可售卖订阅实例的地域
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) DescribeSubscribeConf ¶
func (c *Client) DescribeSubscribeConf(request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)
DescribeSubscribeConf 本接口(DescribeSubscribeConf)用于查询订阅实例配置
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError"
func (*Client) DescribeSubscribeConfWithContext ¶ added in v1.0.324
func (c *Client) DescribeSubscribeConfWithContext(ctx context.Context, request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)
DescribeSubscribeConf 本接口(DescribeSubscribeConf)用于查询订阅实例配置
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError"
func (*Client) DescribeSubscribes ¶
func (c *Client) DescribeSubscribes(request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)
DescribeSubscribes 本接口(DescribeSubscribes)获取数据订阅实例信息列表,默认分页,每次返回20条
可能返回的错误码:
AUTHFAILURE_AUTHFAILUREERROR = "AuthFailure.AuthFailureError" AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" INTERNALERROR = "InternalError" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError"
func (*Client) DescribeSubscribesWithContext ¶ added in v1.0.324
func (c *Client) DescribeSubscribesWithContext(ctx context.Context, request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)
DescribeSubscribes 本接口(DescribeSubscribes)获取数据订阅实例信息列表,默认分页,每次返回20条
可能返回的错误码:
AUTHFAILURE_AUTHFAILUREERROR = "AuthFailure.AuthFailureError" AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError" INTERNALERROR = "InternalError" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError"
func (*Client) IsolateSubscribe ¶
func (c *Client) IsolateSubscribe(request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)
IsolateSubscribe 本接口(IsolateSubscribe)用于隔离小时计费的订阅实例。调用后,订阅实例将不能使用,同时停止计费。
可能返回的错误码:
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) IsolateSubscribeWithContext ¶ added in v1.0.324
func (c *Client) IsolateSubscribeWithContext(ctx context.Context, request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)
IsolateSubscribe 本接口(IsolateSubscribe)用于隔离小时计费的订阅实例。调用后,订阅实例将不能使用,同时停止计费。
可能返回的错误码:
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) ModifyMigrateJob ¶
func (c *Client) ModifyMigrateJob(request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)
ModifyMigrateJob 本接口(ModifyMigrateJob)用于修改数据迁移任务。
当迁移任务处于下述状态时,允许调用本接口修改迁移任务:迁移创建中(status=1)、 校验成功(status=4)、校验失败(status=5)、迁移失败(status=10)。但源实例、目标实例类型和目标实例地域不允许修改。
如果是金融区链路, 请使用域名: dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) ModifyMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) ModifyMigrateJobWithContext(ctx context.Context, request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)
ModifyMigrateJob 本接口(ModifyMigrateJob)用于修改数据迁移任务。
当迁移任务处于下述状态时,允许调用本接口修改迁移任务:迁移创建中(status=1)、 校验成功(status=4)、校验失败(status=5)、迁移失败(status=10)。但源实例、目标实例类型和目标实例地域不允许修改。
如果是金融区链路, 请使用域名: dts.ap-shenzhen-fsi.tencentcloudapi.com
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameterValue.BizInvalidParameterValueError" INVALIDPARAMETERVALUE_DATACONVERTERROR = "InvalidParameterValue.DataConvertError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) ModifySubscribeAutoRenewFlag ¶
func (c *Client) ModifySubscribeAutoRenewFlag(request *ModifySubscribeAutoRenewFlagRequest) (response *ModifySubscribeAutoRenewFlagResponse, err error)
ModifySubscribeAutoRenewFlag 修改订阅实例自动续费标识
可能返回的错误码:
INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeAutoRenewFlagWithContext ¶ added in v1.0.324
func (c *Client) ModifySubscribeAutoRenewFlagWithContext(ctx context.Context, request *ModifySubscribeAutoRenewFlagRequest) (response *ModifySubscribeAutoRenewFlagResponse, err error)
ModifySubscribeAutoRenewFlag 修改订阅实例自动续费标识
可能返回的错误码:
INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeConsumeTime ¶
func (c *Client) ModifySubscribeConsumeTime(request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)
ModifySubscribeConsumeTime 本接口(ModifySubscribeConsumeTime)用于修改数据订阅通道的消费时间点
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" FAILEDOPERATION_STATUSINCONFLICTERROR = "FailedOperation.StatusInConflictError" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeConsumeTimeWithContext ¶ added in v1.0.324
func (c *Client) ModifySubscribeConsumeTimeWithContext(ctx context.Context, request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)
ModifySubscribeConsumeTime 本接口(ModifySubscribeConsumeTime)用于修改数据订阅通道的消费时间点
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" FAILEDOPERATION_STATUSINCONFLICTERROR = "FailedOperation.StatusInConflictError" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeName ¶
func (c *Client) ModifySubscribeName(request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)
ModifySubscribeName 本接口(ModifySubscribeName)用于修改数据订阅实例的名称
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeNameWithContext ¶ added in v1.0.324
func (c *Client) ModifySubscribeNameWithContext(ctx context.Context, request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)
ModifySubscribeName 本接口(ModifySubscribeName)用于修改数据订阅实例的名称
可能返回的错误码:
INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeObjects ¶
func (c *Client) ModifySubscribeObjects(request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)
ModifySubscribeObjects 本接口(ModifySubscribeObjects)用于修改数据订阅通道的订阅规则
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError"
func (*Client) ModifySubscribeObjectsWithContext ¶ added in v1.0.324
func (c *Client) ModifySubscribeObjectsWithContext(ctx context.Context, request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)
ModifySubscribeObjects 本接口(ModifySubscribeObjects)用于修改数据订阅通道的订阅规则
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUEERROR = "InvalidParameterValue.InvalidParameterValueError" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError" RESOURCENOTFOUND_RESOURCENOTFOUNDERROR = "ResourceNotFound.ResourceNotFoundError"
func (*Client) ModifySubscribeVipVport ¶
func (c *Client) ModifySubscribeVipVport(request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)
ModifySubscribeVipVport 本接口(ModifySubscribeVipVport)用于修改数据订阅实例的IP和端口号
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ModifySubscribeVipVportWithContext ¶ added in v1.0.324
func (c *Client) ModifySubscribeVipVportWithContext(ctx context.Context, request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)
ModifySubscribeVipVport 本接口(ModifySubscribeVipVport)用于修改数据订阅实例的IP和端口号
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) OfflineIsolatedSubscribe ¶
func (c *Client) OfflineIsolatedSubscribe(request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)
OfflineIsolatedSubscribe 本接口(OfflineIsolatedSubscribe)用于下线已隔离的数据订阅实例
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONERROR = "FailedOperation.FailedOperationError" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" FAILEDOPERATION_STATUSINCONFLICTERROR = "FailedOperation.StatusInConflictError" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) OfflineIsolatedSubscribeWithContext ¶ added in v1.0.324
func (c *Client) OfflineIsolatedSubscribeWithContext(ctx context.Context, request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)
OfflineIsolatedSubscribe 本接口(OfflineIsolatedSubscribe)用于下线已隔离的数据订阅实例
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONERROR = "FailedOperation.FailedOperationError" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" FAILEDOPERATION_STATUSINCONFLICTERROR = "FailedOperation.StatusInConflictError" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ResetSubscribe ¶
func (c *Client) ResetSubscribe(request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)
ResetSubscribe 本接口(ResetSubscribe)用于重置数据订阅实例,已经激活的数据订阅实例,重置后可以使用ActivateSubscribe接口绑定其他的数据库实例
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) ResetSubscribeWithContext ¶ added in v1.0.324
func (c *Client) ResetSubscribeWithContext(ctx context.Context, request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)
ResetSubscribe 本接口(ResetSubscribe)用于重置数据订阅实例,已经激活的数据订阅实例,重置后可以使用ActivateSubscribe接口绑定其他的数据库实例
可能返回的错误码:
FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED = "OperationDenied" RESOURCENOTFOUND = "ResourceNotFound"
func (*Client) StartMigrateJob ¶
func (c *Client) StartMigrateJob(request *StartMigrateJobRequest) (response *StartMigrateJobResponse, err error)
StartMigrateJob 本接口(StartMigrationJob)用于启动迁移任务。非定时迁移任务会在调用后立即开始迁移,定时任务则会开始倒计时。
调用此接口前,请务必先使用CreateMigrateCheckJob校验数据迁移任务,并通过DescribeMigrateJobs接口查询到任务状态为校验通过(status=4)时,才能启动数据迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_INTERNALINNERCOMMONERROR = "InternalError.InternalInnerCommonError" INTERNALERROR_LOCKERROR = "InternalError.LockError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) StartMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) StartMigrateJobWithContext(ctx context.Context, request *StartMigrateJobRequest) (response *StartMigrateJobResponse, err error)
StartMigrateJob 本接口(StartMigrationJob)用于启动迁移任务。非定时迁移任务会在调用后立即开始迁移,定时任务则会开始倒计时。
调用此接口前,请务必先使用CreateMigrateCheckJob校验数据迁移任务,并通过DescribeMigrateJobs接口查询到任务状态为校验通过(status=4)时,才能启动数据迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_INTERNALERRORERROR = "InternalError.InternalErrorError" INTERNALERROR_INTERNALINNERCOMMONERROR = "InternalError.InternalInnerCommonError" INTERNALERROR_LOCKERROR = "InternalError.LockError" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs" OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" OPERATIONDENIED_OPERATIONDENIEDERROR = "OperationDenied.OperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) StopMigrateJob ¶
func (c *Client) StopMigrateJob(request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)
StopMigrateJob 本接口(StopMigrateJob)用于撤销数据迁移任务。
在迁移过程中允许调用该接口撤销迁移, 撤销迁移的任务会失败。通过DescribeMigrateJobs接口查询到任务状态为运行中(status=7)或准备完成(status=8)时,才能撤销数据迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
func (*Client) StopMigrateJobWithContext ¶ added in v1.0.324
func (c *Client) StopMigrateJobWithContext(ctx context.Context, request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)
StopMigrateJob 本接口(StopMigrateJob)用于撤销数据迁移任务。
在迁移过程中允许调用该接口撤销迁移, 撤销迁移的任务会失败。通过DescribeMigrateJobs接口查询到任务状态为运行中(status=7)或准备完成(status=8)时,才能撤销数据迁移任务。
可能返回的错误码:
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation" FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict" INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError" INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob" INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError" INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError" INVALIDPARAMETER = "InvalidParameter" OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError" RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist" UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"
type CompleteMigrateJobRequest ¶
type CompleteMigrateJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 完成任务的方式,仅支持旧版MySQL迁移任务。waitForSync-等待主从差距为0才停止,immediately-立即完成,不会等待主从差距一致。默认为waitForSync CompleteMode *string `json:"CompleteMode,omitnil,omitempty" name:"CompleteMode"` }
func NewCompleteMigrateJobRequest ¶
func NewCompleteMigrateJobRequest() (request *CompleteMigrateJobRequest)
func (*CompleteMigrateJobRequest) FromJsonString ¶
func (r *CompleteMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CompleteMigrateJobRequest) ToJsonString ¶
func (r *CompleteMigrateJobRequest) ToJsonString() string
type CompleteMigrateJobRequestParams ¶ added in v1.0.426
type CompleteMigrateJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 完成任务的方式,仅支持旧版MySQL迁移任务。waitForSync-等待主从差距为0才停止,immediately-立即完成,不会等待主从差距一致。默认为waitForSync CompleteMode *string `json:"CompleteMode,omitnil,omitempty" name:"CompleteMode"` }
Predefined struct for user
type CompleteMigrateJobResponse ¶
type CompleteMigrateJobResponse struct { *tchttp.BaseResponse Response *CompleteMigrateJobResponseParams `json:"Response"` }
func NewCompleteMigrateJobResponse ¶
func NewCompleteMigrateJobResponse() (response *CompleteMigrateJobResponse)
func (*CompleteMigrateJobResponse) FromJsonString ¶
func (r *CompleteMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CompleteMigrateJobResponse) ToJsonString ¶
func (r *CompleteMigrateJobResponse) ToJsonString() string
type CompleteMigrateJobResponseParams ¶ added in v1.0.426
type CompleteMigrateJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ConsistencyParams ¶
type ConsistencyParams struct { // 数据内容检测参数。表中选出用来数据对比的行,占表的总行数的百分比。取值范围是整数[1-100] SelectRowsPerTable *int64 `json:"SelectRowsPerTable,omitnil,omitempty" name:"SelectRowsPerTable"` // 数据内容检测参数。迁移库表中,要进行数据内容检测的表,占所有表的百分比。取值范围是整数[1-100] TablesSelectAll *int64 `json:"TablesSelectAll,omitnil,omitempty" name:"TablesSelectAll"` // 数据数量检测,检测表行数是否一致。迁移库表中,要进行数据数量检测的表,占所有表的百分比。取值范围是整数[1-100] TablesSelectCount *int64 `json:"TablesSelectCount,omitnil,omitempty" name:"TablesSelectCount"` }
type CreateMigrateCheckJobRequest ¶
type CreateMigrateCheckJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
func NewCreateMigrateCheckJobRequest ¶
func NewCreateMigrateCheckJobRequest() (request *CreateMigrateCheckJobRequest)
func (*CreateMigrateCheckJobRequest) FromJsonString ¶
func (r *CreateMigrateCheckJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateMigrateCheckJobRequest) ToJsonString ¶
func (r *CreateMigrateCheckJobRequest) ToJsonString() string
type CreateMigrateCheckJobRequestParams ¶ added in v1.0.426
type CreateMigrateCheckJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
Predefined struct for user
type CreateMigrateCheckJobResponse ¶
type CreateMigrateCheckJobResponse struct { *tchttp.BaseResponse Response *CreateMigrateCheckJobResponseParams `json:"Response"` }
func NewCreateMigrateCheckJobResponse ¶
func NewCreateMigrateCheckJobResponse() (response *CreateMigrateCheckJobResponse)
func (*CreateMigrateCheckJobResponse) FromJsonString ¶
func (r *CreateMigrateCheckJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateMigrateCheckJobResponse) ToJsonString ¶
func (r *CreateMigrateCheckJobResponse) ToJsonString() string
type CreateMigrateCheckJobResponseParams ¶ added in v1.0.426
type CreateMigrateCheckJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateMigrateJobRequest ¶
type CreateMigrateJobRequest struct { *tchttp.BaseRequest // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 迁移任务配置选项 MigrateOption *MigrateOption `json:"MigrateOption,omitnil,omitempty" name:"MigrateOption"` // 源实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver 不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。 SrcDatabaseType *string `json:"SrcDatabaseType,omitnil,omitempty" name:"SrcDatabaseType"` // 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例) SrcAccessType *string `json:"SrcAccessType,omitnil,omitempty" name:"SrcAccessType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfo *SrcInfo `json:"SrcInfo,omitnil,omitempty" name:"SrcInfo"` // 目标实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver,cynosdbmysql。不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。 DstDatabaseType *string `json:"DstDatabaseType,omitnil,omitempty" name:"DstDatabaseType"` // 目标实例接入类型,目前支持:cdb(腾讯云数据库实例) DstAccessType *string `json:"DstAccessType,omitnil,omitempty" name:"DstAccessType"` // 目标实例信息 DstInfo *DstInfo `json:"DstInfo,omitnil,omitempty" name:"DstInfo"` // 需要迁移的源数据库表信息,用json格式的字符串描述。当MigrateOption.MigrateObject配置为2(指定库表迁移)时必填。 // 对于database-table两级结构的数据库: // [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}] // 对于database-schema-table三级结构: // [{"Database":"db1","Schema":"s1","Table":["table1","table2"]},{"Database":"db1","Schema":"s2","Table":["table1","table2"]},{"Database":"db2","Schema":"s1","Table":["table1","table2"]},{"Database":"db3"},{"Database":"db4","Schema":"s1"}] DatabaseInfo *string `json:"DatabaseInfo,omitnil,omitempty" name:"DatabaseInfo"` // 迁移实例的tag Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点 SrcNodeType *string `json:"SrcNodeType,omitnil,omitempty" name:"SrcNodeType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil,omitempty" name:"SrcInfoMulti"` }
func NewCreateMigrateJobRequest ¶
func NewCreateMigrateJobRequest() (request *CreateMigrateJobRequest)
func (*CreateMigrateJobRequest) FromJsonString ¶
func (r *CreateMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateMigrateJobRequest) ToJsonString ¶
func (r *CreateMigrateJobRequest) ToJsonString() string
type CreateMigrateJobRequestParams ¶ added in v1.0.426
type CreateMigrateJobRequestParams struct { // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 迁移任务配置选项 MigrateOption *MigrateOption `json:"MigrateOption,omitnil,omitempty" name:"MigrateOption"` // 源实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver 不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。 SrcDatabaseType *string `json:"SrcDatabaseType,omitnil,omitempty" name:"SrcDatabaseType"` // 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例) SrcAccessType *string `json:"SrcAccessType,omitnil,omitempty" name:"SrcAccessType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfo *SrcInfo `json:"SrcInfo,omitnil,omitempty" name:"SrcInfo"` // 目标实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver,cynosdbmysql。不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。 DstDatabaseType *string `json:"DstDatabaseType,omitnil,omitempty" name:"DstDatabaseType"` // 目标实例接入类型,目前支持:cdb(腾讯云数据库实例) DstAccessType *string `json:"DstAccessType,omitnil,omitempty" name:"DstAccessType"` // 目标实例信息 DstInfo *DstInfo `json:"DstInfo,omitnil,omitempty" name:"DstInfo"` // 需要迁移的源数据库表信息,用json格式的字符串描述。当MigrateOption.MigrateObject配置为2(指定库表迁移)时必填。 // 对于database-table两级结构的数据库: // [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}] // 对于database-schema-table三级结构: // [{"Database":"db1","Schema":"s1","Table":["table1","table2"]},{"Database":"db1","Schema":"s2","Table":["table1","table2"]},{"Database":"db2","Schema":"s1","Table":["table1","table2"]},{"Database":"db3"},{"Database":"db4","Schema":"s1"}] DatabaseInfo *string `json:"DatabaseInfo,omitnil,omitempty" name:"DatabaseInfo"` // 迁移实例的tag Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点 SrcNodeType *string `json:"SrcNodeType,omitnil,omitempty" name:"SrcNodeType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil,omitempty" name:"SrcInfoMulti"` }
Predefined struct for user
type CreateMigrateJobResponse ¶
type CreateMigrateJobResponse struct { *tchttp.BaseResponse Response *CreateMigrateJobResponseParams `json:"Response"` }
func NewCreateMigrateJobResponse ¶
func NewCreateMigrateJobResponse() (response *CreateMigrateJobResponse)
func (*CreateMigrateJobResponse) FromJsonString ¶
func (r *CreateMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateMigrateJobResponse) ToJsonString ¶
func (r *CreateMigrateJobResponse) ToJsonString() string
type CreateMigrateJobResponseParams ¶ added in v1.0.426
type CreateMigrateJobResponseParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateSubscribeRequest ¶
type CreateSubscribeRequest struct { *tchttp.BaseRequest // 订阅的数据库类型,目前支持的有 mysql Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 实例付费类型,1小时计费,0包年包月 PayType *int64 `json:"PayType,omitnil,omitempty" name:"PayType"` // 购买时长。PayType为0时必填。单位为月,最大支持120 Duration *int64 `json:"Duration,omitnil,omitempty" name:"Duration"` // 购买数量,默认为1,最大为10 Count *int64 `json:"Count,omitnil,omitempty" name:"Count"` // 是否自动续费,0表示不自动续费,1表示自动续费,默认为0。小时计费实例设置该标识无效。 AutoRenew *int64 `json:"AutoRenew,omitnil,omitempty" name:"AutoRenew"` // 实例资源标签 Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 用户自定义实例名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` }
func NewCreateSubscribeRequest ¶
func NewCreateSubscribeRequest() (request *CreateSubscribeRequest)
func (*CreateSubscribeRequest) FromJsonString ¶
func (r *CreateSubscribeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateSubscribeRequest) ToJsonString ¶
func (r *CreateSubscribeRequest) ToJsonString() string
type CreateSubscribeRequestParams ¶ added in v1.0.426
type CreateSubscribeRequestParams struct { // 订阅的数据库类型,目前支持的有 mysql Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 实例付费类型,1小时计费,0包年包月 PayType *int64 `json:"PayType,omitnil,omitempty" name:"PayType"` // 购买时长。PayType为0时必填。单位为月,最大支持120 Duration *int64 `json:"Duration,omitnil,omitempty" name:"Duration"` // 购买数量,默认为1,最大为10 Count *int64 `json:"Count,omitnil,omitempty" name:"Count"` // 是否自动续费,0表示不自动续费,1表示自动续费,默认为0。小时计费实例设置该标识无效。 AutoRenew *int64 `json:"AutoRenew,omitnil,omitempty" name:"AutoRenew"` // 实例资源标签 Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 用户自定义实例名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` }
Predefined struct for user
type CreateSubscribeResponse ¶
type CreateSubscribeResponse struct { *tchttp.BaseResponse Response *CreateSubscribeResponseParams `json:"Response"` }
func NewCreateSubscribeResponse ¶
func NewCreateSubscribeResponse() (response *CreateSubscribeResponse)
func (*CreateSubscribeResponse) FromJsonString ¶
func (r *CreateSubscribeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateSubscribeResponse) ToJsonString ¶
func (r *CreateSubscribeResponse) ToJsonString() string
type CreateSubscribeResponseParams ¶ added in v1.0.426
type CreateSubscribeResponseParams struct { // 数据订阅实例的ID数组 // 注意:此字段可能返回 null,表示取不到有效值。 SubscribeIds []*string `json:"SubscribeIds,omitnil,omitempty" name:"SubscribeIds"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteMigrateJobRequest ¶
type DeleteMigrateJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
func NewDeleteMigrateJobRequest ¶
func NewDeleteMigrateJobRequest() (request *DeleteMigrateJobRequest)
func (*DeleteMigrateJobRequest) FromJsonString ¶
func (r *DeleteMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteMigrateJobRequest) ToJsonString ¶
func (r *DeleteMigrateJobRequest) ToJsonString() string
type DeleteMigrateJobRequestParams ¶ added in v1.0.426
type DeleteMigrateJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
Predefined struct for user
type DeleteMigrateJobResponse ¶
type DeleteMigrateJobResponse struct { *tchttp.BaseResponse Response *DeleteMigrateJobResponseParams `json:"Response"` }
func NewDeleteMigrateJobResponse ¶
func NewDeleteMigrateJobResponse() (response *DeleteMigrateJobResponse)
func (*DeleteMigrateJobResponse) FromJsonString ¶
func (r *DeleteMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteMigrateJobResponse) ToJsonString ¶
func (r *DeleteMigrateJobResponse) ToJsonString() string
type DeleteMigrateJobResponseParams ¶ added in v1.0.426
type DeleteMigrateJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeAsyncRequestInfoRequest ¶
type DescribeAsyncRequestInfoRequest struct { *tchttp.BaseRequest // 任务 ID AsyncRequestId *string `json:"AsyncRequestId,omitnil,omitempty" name:"AsyncRequestId"` }
func NewDescribeAsyncRequestInfoRequest ¶
func NewDescribeAsyncRequestInfoRequest() (request *DescribeAsyncRequestInfoRequest)
func (*DescribeAsyncRequestInfoRequest) FromJsonString ¶
func (r *DescribeAsyncRequestInfoRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeAsyncRequestInfoRequest) ToJsonString ¶
func (r *DescribeAsyncRequestInfoRequest) ToJsonString() string
type DescribeAsyncRequestInfoRequestParams ¶ added in v1.0.426
type DescribeAsyncRequestInfoRequestParams struct { // 任务 ID AsyncRequestId *string `json:"AsyncRequestId,omitnil,omitempty" name:"AsyncRequestId"` }
Predefined struct for user
type DescribeAsyncRequestInfoResponse ¶
type DescribeAsyncRequestInfoResponse struct { *tchttp.BaseResponse Response *DescribeAsyncRequestInfoResponseParams `json:"Response"` }
func NewDescribeAsyncRequestInfoResponse ¶
func NewDescribeAsyncRequestInfoResponse() (response *DescribeAsyncRequestInfoResponse)
func (*DescribeAsyncRequestInfoResponse) FromJsonString ¶
func (r *DescribeAsyncRequestInfoResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeAsyncRequestInfoResponse) ToJsonString ¶
func (r *DescribeAsyncRequestInfoResponse) ToJsonString() string
type DescribeAsyncRequestInfoResponseParams ¶ added in v1.0.426
type DescribeAsyncRequestInfoResponseParams struct { // 任务执行结果信息 Info *string `json:"Info,omitnil,omitempty" name:"Info"` // 任务执行状态,可能的值有:success,failed,running Status *string `json:"Status,omitnil,omitempty" name:"Status"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeMigrateCheckJobRequest ¶
type DescribeMigrateCheckJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
func NewDescribeMigrateCheckJobRequest ¶
func NewDescribeMigrateCheckJobRequest() (request *DescribeMigrateCheckJobRequest)
func (*DescribeMigrateCheckJobRequest) FromJsonString ¶
func (r *DescribeMigrateCheckJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeMigrateCheckJobRequest) ToJsonString ¶
func (r *DescribeMigrateCheckJobRequest) ToJsonString() string
type DescribeMigrateCheckJobRequestParams ¶ added in v1.0.426
type DescribeMigrateCheckJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
Predefined struct for user
type DescribeMigrateCheckJobResponse ¶
type DescribeMigrateCheckJobResponse struct { *tchttp.BaseResponse Response *DescribeMigrateCheckJobResponseParams `json:"Response"` }
func NewDescribeMigrateCheckJobResponse ¶
func NewDescribeMigrateCheckJobResponse() (response *DescribeMigrateCheckJobResponse)
func (*DescribeMigrateCheckJobResponse) FromJsonString ¶
func (r *DescribeMigrateCheckJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeMigrateCheckJobResponse) ToJsonString ¶
func (r *DescribeMigrateCheckJobResponse) ToJsonString() string
type DescribeMigrateCheckJobResponseParams ¶ added in v1.0.426
type DescribeMigrateCheckJobResponseParams struct { // 校验任务状态:unavailable(当前不可用), starting(开始中),running(校验中),finished(校验完成) Status *string `json:"Status,omitnil,omitempty" name:"Status"` // 任务的错误码 ErrorCode *int64 `json:"ErrorCode,omitnil,omitempty" name:"ErrorCode"` // 任务的错误信息 ErrorMessage *string `json:"ErrorMessage,omitnil,omitempty" name:"ErrorMessage"` // Check任务总进度,如:"30"表示30% Progress *string `json:"Progress,omitnil,omitempty" name:"Progress"` // 校验是否通过,0-未通过,1-校验通过, 3-未校验 CheckFlag *int64 `json:"CheckFlag,omitnil,omitempty" name:"CheckFlag"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeMigrateJobsRequest ¶
type DescribeMigrateJobsRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 排序字段,可以取值为JobId、Status、JobName、MigrateType、RunMode、CreateTime Order *string `json:"Order,omitnil,omitempty" name:"Order"` // 排序方式,升序为ASC,降序为DESC OrderSeq *string `json:"OrderSeq,omitnil,omitempty" name:"OrderSeq"` // 偏移量,默认为0 Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 返回实例数量,默认20,有效区间[1,100] Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 标签过滤条件 TagFilters []*TagFilter `json:"TagFilters,omitnil,omitempty" name:"TagFilters"` }
func NewDescribeMigrateJobsRequest ¶
func NewDescribeMigrateJobsRequest() (request *DescribeMigrateJobsRequest)
func (*DescribeMigrateJobsRequest) FromJsonString ¶
func (r *DescribeMigrateJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeMigrateJobsRequest) ToJsonString ¶
func (r *DescribeMigrateJobsRequest) ToJsonString() string
type DescribeMigrateJobsRequestParams ¶ added in v1.0.426
type DescribeMigrateJobsRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 排序字段,可以取值为JobId、Status、JobName、MigrateType、RunMode、CreateTime Order *string `json:"Order,omitnil,omitempty" name:"Order"` // 排序方式,升序为ASC,降序为DESC OrderSeq *string `json:"OrderSeq,omitnil,omitempty" name:"OrderSeq"` // 偏移量,默认为0 Offset *uint64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 返回实例数量,默认20,有效区间[1,100] Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 标签过滤条件 TagFilters []*TagFilter `json:"TagFilters,omitnil,omitempty" name:"TagFilters"` }
Predefined struct for user
type DescribeMigrateJobsResponse ¶
type DescribeMigrateJobsResponse struct { *tchttp.BaseResponse Response *DescribeMigrateJobsResponseParams `json:"Response"` }
func NewDescribeMigrateJobsResponse ¶
func NewDescribeMigrateJobsResponse() (response *DescribeMigrateJobsResponse)
func (*DescribeMigrateJobsResponse) FromJsonString ¶
func (r *DescribeMigrateJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeMigrateJobsResponse) ToJsonString ¶
func (r *DescribeMigrateJobsResponse) ToJsonString() string
type DescribeMigrateJobsResponseParams ¶ added in v1.0.426
type DescribeMigrateJobsResponseParams struct { // 任务数目 TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 任务详情数组 JobList []*MigrateJobInfo `json:"JobList,omitnil,omitempty" name:"JobList"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeRegionConfRequest ¶
type DescribeRegionConfRequest struct {
*tchttp.BaseRequest
}
func NewDescribeRegionConfRequest ¶
func NewDescribeRegionConfRequest() (request *DescribeRegionConfRequest)
func (*DescribeRegionConfRequest) FromJsonString ¶
func (r *DescribeRegionConfRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeRegionConfRequest) ToJsonString ¶
func (r *DescribeRegionConfRequest) ToJsonString() string
type DescribeRegionConfRequestParams ¶ added in v1.0.426
type DescribeRegionConfRequestParams struct { }
Predefined struct for user
type DescribeRegionConfResponse ¶
type DescribeRegionConfResponse struct { *tchttp.BaseResponse Response *DescribeRegionConfResponseParams `json:"Response"` }
func NewDescribeRegionConfResponse ¶
func NewDescribeRegionConfResponse() (response *DescribeRegionConfResponse)
func (*DescribeRegionConfResponse) FromJsonString ¶
func (r *DescribeRegionConfResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeRegionConfResponse) ToJsonString ¶
func (r *DescribeRegionConfResponse) ToJsonString() string
type DescribeRegionConfResponseParams ¶ added in v1.0.426
type DescribeRegionConfResponseParams struct { // 可售卖地域的数量 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 可售卖地域详情 Items []*SubscribeRegionConf `json:"Items,omitnil,omitempty" name:"Items"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeSubscribeConfRequest ¶
type DescribeSubscribeConfRequest struct { *tchttp.BaseRequest // 订阅实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
func NewDescribeSubscribeConfRequest ¶
func NewDescribeSubscribeConfRequest() (request *DescribeSubscribeConfRequest)
func (*DescribeSubscribeConfRequest) FromJsonString ¶
func (r *DescribeSubscribeConfRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSubscribeConfRequest) ToJsonString ¶
func (r *DescribeSubscribeConfRequest) ToJsonString() string
type DescribeSubscribeConfRequestParams ¶ added in v1.0.426
type DescribeSubscribeConfRequestParams struct { // 订阅实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
Predefined struct for user
type DescribeSubscribeConfResponse ¶
type DescribeSubscribeConfResponse struct { *tchttp.BaseResponse Response *DescribeSubscribeConfResponseParams `json:"Response"` }
func NewDescribeSubscribeConfResponse ¶
func NewDescribeSubscribeConfResponse() (response *DescribeSubscribeConfResponse)
func (*DescribeSubscribeConfResponse) FromJsonString ¶
func (r *DescribeSubscribeConfResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSubscribeConfResponse) ToJsonString ¶
func (r *DescribeSubscribeConfResponse) ToJsonString() string
type DescribeSubscribeConfResponseParams ¶ added in v1.0.426
type DescribeSubscribeConfResponseParams struct { // 订阅实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 订阅实例名称 SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` // 订阅通道 ChannelId *string `json:"ChannelId,omitnil,omitempty" name:"ChannelId"` // 订阅数据库类型 Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 被订阅的实例 InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 被订阅的实例的状态,可能的值有running,offline,isolate InstanceStatus *string `json:"InstanceStatus,omitnil,omitempty" name:"InstanceStatus"` // 订阅实例状态,可能的值有unconfigure-未配置,configuring-配置中,configured-已配置 SubsStatus *string `json:"SubsStatus,omitnil,omitempty" name:"SubsStatus"` // 订阅实例生命周期状态,可能的值有:normal-正常,isolating-隔离中,isolated-已隔离,offlining-下线中 Status *string `json:"Status,omitnil,omitempty" name:"Status"` // 订阅实例创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 订阅实例被隔离时间 IsolateTime *string `json:"IsolateTime,omitnil,omitempty" name:"IsolateTime"` // 订阅实例到期时间 ExpireTime *string `json:"ExpireTime,omitnil,omitempty" name:"ExpireTime"` // 订阅实例下线时间 OfflineTime *string `json:"OfflineTime,omitnil,omitempty" name:"OfflineTime"` // 订阅实例消费时间起点。 ConsumeStartTime *string `json:"ConsumeStartTime,omitnil,omitempty" name:"ConsumeStartTime"` // 订阅实例计费类型,1-小时计费,0-包年包月 PayType *int64 `json:"PayType,omitnil,omitempty" name:"PayType"` // 订阅通道Vip Vip *string `json:"Vip,omitnil,omitempty" name:"Vip"` // 订阅通道Port Vport *int64 `json:"Vport,omitnil,omitempty" name:"Vport"` // 订阅通道所在VpcId UniqVpcId *string `json:"UniqVpcId,omitnil,omitempty" name:"UniqVpcId"` // 订阅通道所在SubnetId UniqSubnetId *string `json:"UniqSubnetId,omitnil,omitempty" name:"UniqSubnetId"` // 当前SDK消费时间位点 SdkConsumedTime *string `json:"SdkConsumedTime,omitnil,omitempty" name:"SdkConsumedTime"` // 订阅SDK IP地址 SdkHost *string `json:"SdkHost,omitnil,omitempty" name:"SdkHost"` // 订阅对象类型0-全实例订阅,1-DDL数据订阅,2-DML结构订阅,3-DDL数据订阅+DML结构订阅 SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil,omitempty" name:"SubscribeObjectType"` // 订阅对象,当SubscribeObjectType 为0时,此字段为空数组 SubscribeObjects []*SubscribeObject `json:"SubscribeObjects,omitnil,omitempty" name:"SubscribeObjects"` // 修改时间 ModifyTime *string `json:"ModifyTime,omitnil,omitempty" name:"ModifyTime"` // 地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 订阅实例的标签 // 注意:此字段可能返回 null,表示取不到有效值。 Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 自动续费标识,0-不自动续费,1-自动续费 // 注意:此字段可能返回 null,表示取不到有效值。 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` // 数据订阅版本。老版订阅填txdts,kafka版填kafka SubscribeVersion *string `json:"SubscribeVersion,omitnil,omitempty" name:"SubscribeVersion"` // 错误信息 // 注意:此字段可能返回 null,表示取不到有效值。 Errors []*SubsErr `json:"Errors,omitnil,omitempty" name:"Errors"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeSubscribesRequest ¶
type DescribeSubscribesRequest struct { *tchttp.BaseRequest // 数据订阅的实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅的实例名称 SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` // 绑定数据库实例的ID InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 数据订阅实例的通道ID ChannelId *string `json:"ChannelId,omitnil,omitempty" name:"ChannelId"` // 计费模式筛选,可能的值:0-包年包月,1-按量计费 PayType *string `json:"PayType,omitnil,omitempty" name:"PayType"` // 订阅的数据库产品,如mysql Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中 Status []*string `json:"Status,omitnil,omitempty" name:"Status"` // 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置 SubsStatus []*string `json:"SubsStatus,omitnil,omitempty" name:"SubsStatus"` // 返回记录的起始偏移量,默认为0。请输入非负整数 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 单次返回的记录数量,默认20。请输入1到100的整数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 排序方向,可选的值为"DESC"和"ASC",默认为"DESC",按创建时间逆序排序 OrderDirection *string `json:"OrderDirection,omitnil,omitempty" name:"OrderDirection"` // 标签过滤条件 TagFilters []*TagFilter `json:"TagFilters,omitnil,omitempty" name:"TagFilters"` // 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅 SubscribeVersion *string `json:"SubscribeVersion,omitnil,omitempty" name:"SubscribeVersion"` }
func NewDescribeSubscribesRequest ¶
func NewDescribeSubscribesRequest() (request *DescribeSubscribesRequest)
func (*DescribeSubscribesRequest) FromJsonString ¶
func (r *DescribeSubscribesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSubscribesRequest) ToJsonString ¶
func (r *DescribeSubscribesRequest) ToJsonString() string
type DescribeSubscribesRequestParams ¶ added in v1.0.426
type DescribeSubscribesRequestParams struct { // 数据订阅的实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅的实例名称 SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` // 绑定数据库实例的ID InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 数据订阅实例的通道ID ChannelId *string `json:"ChannelId,omitnil,omitempty" name:"ChannelId"` // 计费模式筛选,可能的值:0-包年包月,1-按量计费 PayType *string `json:"PayType,omitnil,omitempty" name:"PayType"` // 订阅的数据库产品,如mysql Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中 Status []*string `json:"Status,omitnil,omitempty" name:"Status"` // 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置 SubsStatus []*string `json:"SubsStatus,omitnil,omitempty" name:"SubsStatus"` // 返回记录的起始偏移量,默认为0。请输入非负整数 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 单次返回的记录数量,默认20。请输入1到100的整数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 排序方向,可选的值为"DESC"和"ASC",默认为"DESC",按创建时间逆序排序 OrderDirection *string `json:"OrderDirection,omitnil,omitempty" name:"OrderDirection"` // 标签过滤条件 TagFilters []*TagFilter `json:"TagFilters,omitnil,omitempty" name:"TagFilters"` // 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅 SubscribeVersion *string `json:"SubscribeVersion,omitnil,omitempty" name:"SubscribeVersion"` }
Predefined struct for user
type DescribeSubscribesResponse ¶
type DescribeSubscribesResponse struct { *tchttp.BaseResponse Response *DescribeSubscribesResponseParams `json:"Response"` }
func NewDescribeSubscribesResponse ¶
func NewDescribeSubscribesResponse() (response *DescribeSubscribesResponse)
func (*DescribeSubscribesResponse) FromJsonString ¶
func (r *DescribeSubscribesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSubscribesResponse) ToJsonString ¶
func (r *DescribeSubscribesResponse) ToJsonString() string
type DescribeSubscribesResponseParams ¶ added in v1.0.426
type DescribeSubscribesResponseParams struct { // 符合查询条件的实例总数 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 数据订阅实例的信息列表 Items []*SubscribeInfo `json:"Items,omitnil,omitempty" name:"Items"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DstInfo ¶
type DstInfo struct { // 目标实例地域,如ap-guangzhou Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 目标实例ID,如cdb-jd92ijd8 InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 目标实例vip。已废弃,无需填写 Ip *string `json:"Ip,omitnil,omitempty" name:"Ip"` // 目标实例vport。已废弃,无需填写 Port *int64 `json:"Port,omitnil,omitempty" name:"Port"` // 目前只对MySQL有效。当为整实例迁移时,1-只读,0-可读写。 ReadOnly *int64 `json:"ReadOnly,omitnil,omitempty" name:"ReadOnly"` // 目标数据库账号 User *string `json:"User,omitnil,omitempty" name:"User"` // 目标数据库密码 Password *string `json:"Password,omitnil,omitempty" name:"Password"` }
type IsolateSubscribeRequest ¶
type IsolateSubscribeRequest struct { *tchttp.BaseRequest // 订阅实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
func NewIsolateSubscribeRequest ¶
func NewIsolateSubscribeRequest() (request *IsolateSubscribeRequest)
func (*IsolateSubscribeRequest) FromJsonString ¶
func (r *IsolateSubscribeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*IsolateSubscribeRequest) ToJsonString ¶
func (r *IsolateSubscribeRequest) ToJsonString() string
type IsolateSubscribeRequestParams ¶ added in v1.0.426
type IsolateSubscribeRequestParams struct { // 订阅实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
Predefined struct for user
type IsolateSubscribeResponse ¶
type IsolateSubscribeResponse struct { *tchttp.BaseResponse Response *IsolateSubscribeResponseParams `json:"Response"` }
func NewIsolateSubscribeResponse ¶
func NewIsolateSubscribeResponse() (response *IsolateSubscribeResponse)
func (*IsolateSubscribeResponse) FromJsonString ¶
func (r *IsolateSubscribeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*IsolateSubscribeResponse) ToJsonString ¶
func (r *IsolateSubscribeResponse) ToJsonString() string
type IsolateSubscribeResponseParams ¶ added in v1.0.426
type IsolateSubscribeResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type MigrateDetailInfo ¶
type MigrateDetailInfo struct { // 总步骤数 StepAll *int64 `json:"StepAll,omitnil,omitempty" name:"StepAll"` // 当前步骤 StepNow *int64 `json:"StepNow,omitnil,omitempty" name:"StepNow"` // 总进度,如:"10" Progress *string `json:"Progress,omitnil,omitempty" name:"Progress"` // 当前步骤进度,如:"1" CurrentStepProgress *string `json:"CurrentStepProgress,omitnil,omitempty" name:"CurrentStepProgress"` // 主从差距,MB;在增量同步阶段有效,目前支持产品为:redis和mysql MasterSlaveDistance *int64 `json:"MasterSlaveDistance,omitnil,omitempty" name:"MasterSlaveDistance"` // 主从差距,秒;在增量同步阶段有效,目前支持产品为:mysql SecondsBehindMaster *int64 `json:"SecondsBehindMaster,omitnil,omitempty" name:"SecondsBehindMaster"` // 步骤信息 StepInfo []*MigrateStepDetailInfo `json:"StepInfo,omitnil,omitempty" name:"StepInfo"` }
type MigrateJobInfo ¶
type MigrateJobInfo struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 迁移任务配置选项 MigrateOption *MigrateOption `json:"MigrateOption,omitnil,omitempty" name:"MigrateOption"` // 源实例数据库类型:mysql,redis,mongodb,postgresql,mariadb,percona SrcDatabaseType *string `json:"SrcDatabaseType,omitnil,omitempty" name:"SrcDatabaseType"` // 源实例接入类型,值包括:extranet(外网),cvm(cvm自建实例),dcg(专线接入的实例),vpncloud(云vpn接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例) SrcAccessType *string `json:"SrcAccessType,omitnil,omitempty" name:"SrcAccessType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfo *SrcInfo `json:"SrcInfo,omitnil,omitempty" name:"SrcInfo"` // 目标实例数据库类型:mysql,redis,mongodb,postgresql,mariadb,percona DstDatabaseType *string `json:"DstDatabaseType,omitnil,omitempty" name:"DstDatabaseType"` // 目标实例接入类型,目前支持:cdb(腾讯云数据库实例) DstAccessType *string `json:"DstAccessType,omitnil,omitempty" name:"DstAccessType"` // 目标实例信息 DstInfo *DstInfo `json:"DstInfo,omitnil,omitempty" name:"DstInfo"` // 需要迁移的源数据库表信息,如果需要迁移的是整个实例,该字段为[] DatabaseInfo *string `json:"DatabaseInfo,omitnil,omitempty" name:"DatabaseInfo"` // 任务创建(提交)时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 任务开始执行时间 StartTime *string `json:"StartTime,omitnil,omitempty" name:"StartTime"` // 任务执行结束时间 EndTime *string `json:"EndTime,omitnil,omitempty" name:"EndTime"` // 任务状态,取值为:1-创建中(Creating),3-校验中(Checking)4-校验通过(CheckPass),5-校验不通过(CheckNotPass),7-任务运行(Running),8-准备完成(ReadyComplete),9-任务成功(Success),10-任务失败(Failed),11-撤销中(Stopping),12-完成中(Completing) Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 任务详情 Detail *MigrateDetailInfo `json:"Detail,omitnil,omitempty" name:"Detail"` // 任务错误信息提示,当任务发生错误时,不为null或者空值 ErrorInfo []*ErrorInfo `json:"ErrorInfo,omitnil,omitempty" name:"ErrorInfo"` // 标签 // 注意:此字段可能返回 null,表示取不到有效值。 Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 源实例为集群时且接入为非cdb时源实例信息 // 注意:此字段可能返回 null,表示取不到有效值。 SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil,omitempty" name:"SrcInfoMulti"` }
type MigrateOption ¶
type MigrateOption struct { // 任务运行模式,值包括:1-立即执行,2-定时执行 RunMode *int64 `json:"RunMode,omitnil,omitempty" name:"RunMode"` // 期望执行时间,当runMode=2时,该字段必填,时间格式:yyyy-mm-dd hh:mm:ss ExpectTime *string `json:"ExpectTime,omitnil,omitempty" name:"ExpectTime"` // 数据迁移类型,值包括:1-结构迁移,2-全量迁移,3-全量+增量迁移 MigrateType *int64 `json:"MigrateType,omitnil,omitempty" name:"MigrateType"` // 迁移对象,1-整个实例,2-指定库表 MigrateObject *int64 `json:"MigrateObject,omitnil,omitempty" name:"MigrateObject"` // 抽样数据一致性检测参数,1-未配置,2-全量检测,3-抽样检测, 4-仅校验不一致表,5-不检测 ConsistencyType *int64 `json:"ConsistencyType,omitnil,omitempty" name:"ConsistencyType"` // 是否用源库Root账户覆盖目标库,值包括:0-不覆盖,1-覆盖,选择库表或者结构迁移时应该为0 IsOverrideRoot *int64 `json:"IsOverrideRoot,omitnil,omitempty" name:"IsOverrideRoot"` // 不同数据库用到的额外参数.以JSON格式描述. // Redis可定义如下的参数: // { // "ClientOutputBufferHardLimit":512, 从机缓冲区的硬性容量限制(MB) // "ClientOutputBufferSoftLimit":512, 从机缓冲区的软性容量限制(MB) // "ClientOutputBufferPersistTime":60, 从机缓冲区的软性限制持续时间(秒) // "ReplBacklogSize":512, 环形缓冲区容量限制(MB) // "ReplTimeout":120, 复制超时时间(秒) // } // MongoDB可定义如下的参数: // { // 'SrcAuthDatabase':'admin', // 'SrcAuthFlag': "1", // 'SrcAuthMechanism':"SCRAM-SHA-1" // } // MySQL暂不支持额外参数设置。 ExternParams *string `json:"ExternParams,omitnil,omitempty" name:"ExternParams"` // 仅用于“抽样数据一致性检测”,ConsistencyType配置为抽样检测时,必选 ConsistencyParams *ConsistencyParams `json:"ConsistencyParams,omitnil,omitempty" name:"ConsistencyParams"` }
type MigrateStepDetailInfo ¶
type MigrateStepDetailInfo struct { // 步骤序列 StepNo *int64 `json:"StepNo,omitnil,omitempty" name:"StepNo"` // 步骤展现名称 StepName *string `json:"StepName,omitnil,omitempty" name:"StepName"` // 步骤英文标识 StepId *string `json:"StepId,omitnil,omitempty" name:"StepId"` // 步骤状态:0-默认值,1-成功,2-失败,3-执行中,4-未执行 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 当前步骤开始的时间,格式为"yyyy-mm-dd hh:mm:ss",该字段不存在或者为空是无意义 // 注意:此字段可能返回 null,表示取不到有效值。 StartTime *string `json:"StartTime,omitnil,omitempty" name:"StartTime"` }
type ModifyMigrateJobRequest ¶
type ModifyMigrateJobRequest struct { *tchttp.BaseRequest // 待修改的数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 迁移任务配置选项 MigrateOption *MigrateOption `json:"MigrateOption,omitnil,omitempty" name:"MigrateOption"` // 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例) SrcAccessType *string `json:"SrcAccessType,omitnil,omitempty" name:"SrcAccessType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfo *SrcInfo `json:"SrcInfo,omitnil,omitempty" name:"SrcInfo"` // 目标实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例). 目前只支持cdb. DstAccessType *string `json:"DstAccessType,omitnil,omitempty" name:"DstAccessType"` // 目标实例信息, 其中目标实例地域不允许修改. DstInfo *DstInfo `json:"DstInfo,omitnil,omitempty" name:"DstInfo"` // 当选择'指定库表'迁移的时候, 需要设置待迁移的源数据库表信息,用符合json数组格式的字符串描述, 如下所例。 // // 对于database-table两级结构的数据库: // [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}] // 对于database-schema-table三级结构: // [{"Database":"db1","Schema":"s1","Table":["table1","table2"]},{"Database":"db1","Schema":"s2","Table":["table1","table2"]},{"Database":"db2","Schema":"s1","Table":["table1","table2"]},{"Database":"db3"},{"Database":"db4","Schema":"s1"}] // // 如果是'整个实例'的迁移模式,不需设置该字段 DatabaseInfo *string `json:"DatabaseInfo,omitnil,omitempty" name:"DatabaseInfo"` // 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点 SrcNodeType *string `json:"SrcNodeType,omitnil,omitempty" name:"SrcNodeType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil,omitempty" name:"SrcInfoMulti"` }
func NewModifyMigrateJobRequest ¶
func NewModifyMigrateJobRequest() (request *ModifyMigrateJobRequest)
func (*ModifyMigrateJobRequest) FromJsonString ¶
func (r *ModifyMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyMigrateJobRequest) ToJsonString ¶
func (r *ModifyMigrateJobRequest) ToJsonString() string
type ModifyMigrateJobRequestParams ¶ added in v1.0.426
type ModifyMigrateJobRequestParams struct { // 待修改的数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 数据迁移任务名称 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 迁移任务配置选项 MigrateOption *MigrateOption `json:"MigrateOption,omitnil,omitempty" name:"MigrateOption"` // 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例) SrcAccessType *string `json:"SrcAccessType,omitnil,omitempty" name:"SrcAccessType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfo *SrcInfo `json:"SrcInfo,omitnil,omitempty" name:"SrcInfo"` // 目标实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例). 目前只支持cdb. DstAccessType *string `json:"DstAccessType,omitnil,omitempty" name:"DstAccessType"` // 目标实例信息, 其中目标实例地域不允许修改. DstInfo *DstInfo `json:"DstInfo,omitnil,omitempty" name:"DstInfo"` // 当选择'指定库表'迁移的时候, 需要设置待迁移的源数据库表信息,用符合json数组格式的字符串描述, 如下所例。 // // 对于database-table两级结构的数据库: // [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}] // 对于database-schema-table三级结构: // [{"Database":"db1","Schema":"s1","Table":["table1","table2"]},{"Database":"db1","Schema":"s2","Table":["table1","table2"]},{"Database":"db2","Schema":"s1","Table":["table1","table2"]},{"Database":"db3"},{"Database":"db4","Schema":"s1"}] // // 如果是'整个实例'的迁移模式,不需设置该字段 DatabaseInfo *string `json:"DatabaseInfo,omitnil,omitempty" name:"DatabaseInfo"` // 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点 SrcNodeType *string `json:"SrcNodeType,omitnil,omitempty" name:"SrcNodeType"` // 源实例信息,具体内容跟迁移任务类型相关 SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil,omitempty" name:"SrcInfoMulti"` }
Predefined struct for user
type ModifyMigrateJobResponse ¶
type ModifyMigrateJobResponse struct { *tchttp.BaseResponse Response *ModifyMigrateJobResponseParams `json:"Response"` }
func NewModifyMigrateJobResponse ¶
func NewModifyMigrateJobResponse() (response *ModifyMigrateJobResponse)
func (*ModifyMigrateJobResponse) FromJsonString ¶
func (r *ModifyMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyMigrateJobResponse) ToJsonString ¶
func (r *ModifyMigrateJobResponse) ToJsonString() string
type ModifyMigrateJobResponseParams ¶ added in v1.0.426
type ModifyMigrateJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifySubscribeAutoRenewFlagRequest ¶
type ModifySubscribeAutoRenewFlagRequest struct { *tchttp.BaseRequest // 订阅实例ID,例如:subs-8uey736k SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 自动续费标识。1-自动续费,0-不自动续费 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` }
func NewModifySubscribeAutoRenewFlagRequest ¶
func NewModifySubscribeAutoRenewFlagRequest() (request *ModifySubscribeAutoRenewFlagRequest)
func (*ModifySubscribeAutoRenewFlagRequest) FromJsonString ¶
func (r *ModifySubscribeAutoRenewFlagRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeAutoRenewFlagRequest) ToJsonString ¶
func (r *ModifySubscribeAutoRenewFlagRequest) ToJsonString() string
type ModifySubscribeAutoRenewFlagRequestParams ¶ added in v1.0.426
type ModifySubscribeAutoRenewFlagRequestParams struct { // 订阅实例ID,例如:subs-8uey736k SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 自动续费标识。1-自动续费,0-不自动续费 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` }
Predefined struct for user
type ModifySubscribeAutoRenewFlagResponse ¶
type ModifySubscribeAutoRenewFlagResponse struct { *tchttp.BaseResponse Response *ModifySubscribeAutoRenewFlagResponseParams `json:"Response"` }
func NewModifySubscribeAutoRenewFlagResponse ¶
func NewModifySubscribeAutoRenewFlagResponse() (response *ModifySubscribeAutoRenewFlagResponse)
func (*ModifySubscribeAutoRenewFlagResponse) FromJsonString ¶
func (r *ModifySubscribeAutoRenewFlagResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeAutoRenewFlagResponse) ToJsonString ¶
func (r *ModifySubscribeAutoRenewFlagResponse) ToJsonString() string
type ModifySubscribeAutoRenewFlagResponseParams ¶ added in v1.0.426
type ModifySubscribeAutoRenewFlagResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifySubscribeConsumeTimeRequest ¶
type ModifySubscribeConsumeTimeRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 消费时间起点,也即是指定订阅数据的时间起点,时间格式如:Y-m-d h:m:s,取值范围为过去24小时之内 ConsumeStartTime *string `json:"ConsumeStartTime,omitnil,omitempty" name:"ConsumeStartTime"` }
func NewModifySubscribeConsumeTimeRequest ¶
func NewModifySubscribeConsumeTimeRequest() (request *ModifySubscribeConsumeTimeRequest)
func (*ModifySubscribeConsumeTimeRequest) FromJsonString ¶
func (r *ModifySubscribeConsumeTimeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeConsumeTimeRequest) ToJsonString ¶
func (r *ModifySubscribeConsumeTimeRequest) ToJsonString() string
type ModifySubscribeConsumeTimeRequestParams ¶ added in v1.0.426
type ModifySubscribeConsumeTimeRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 消费时间起点,也即是指定订阅数据的时间起点,时间格式如:Y-m-d h:m:s,取值范围为过去24小时之内 ConsumeStartTime *string `json:"ConsumeStartTime,omitnil,omitempty" name:"ConsumeStartTime"` }
Predefined struct for user
type ModifySubscribeConsumeTimeResponse ¶
type ModifySubscribeConsumeTimeResponse struct { *tchttp.BaseResponse Response *ModifySubscribeConsumeTimeResponseParams `json:"Response"` }
func NewModifySubscribeConsumeTimeResponse ¶
func NewModifySubscribeConsumeTimeResponse() (response *ModifySubscribeConsumeTimeResponse)
func (*ModifySubscribeConsumeTimeResponse) FromJsonString ¶
func (r *ModifySubscribeConsumeTimeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeConsumeTimeResponse) ToJsonString ¶
func (r *ModifySubscribeConsumeTimeResponse) ToJsonString() string
type ModifySubscribeConsumeTimeResponseParams ¶ added in v1.0.426
type ModifySubscribeConsumeTimeResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifySubscribeNameRequest ¶
type ModifySubscribeNameRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅实例的名称,长度限制为[1,60] SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` }
func NewModifySubscribeNameRequest ¶
func NewModifySubscribeNameRequest() (request *ModifySubscribeNameRequest)
func (*ModifySubscribeNameRequest) FromJsonString ¶
func (r *ModifySubscribeNameRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeNameRequest) ToJsonString ¶
func (r *ModifySubscribeNameRequest) ToJsonString() string
type ModifySubscribeNameRequestParams ¶ added in v1.0.426
type ModifySubscribeNameRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅实例的名称,长度限制为[1,60] SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` }
Predefined struct for user
type ModifySubscribeNameResponse ¶
type ModifySubscribeNameResponse struct { *tchttp.BaseResponse Response *ModifySubscribeNameResponseParams `json:"Response"` }
func NewModifySubscribeNameResponse ¶
func NewModifySubscribeNameResponse() (response *ModifySubscribeNameResponse)
func (*ModifySubscribeNameResponse) FromJsonString ¶
func (r *ModifySubscribeNameResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeNameResponse) ToJsonString ¶
func (r *ModifySubscribeNameResponse) ToJsonString() string
type ModifySubscribeNameResponseParams ¶ added in v1.0.426
type ModifySubscribeNameResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifySubscribeObjectsRequest ¶
type ModifySubscribeObjectsRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅的类型,可选的值有:0 - 全实例订阅;1 - 数据订阅;2 - 结构订阅;3 - 数据订阅+结构订阅 SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil,omitempty" name:"SubscribeObjectType"` // 订阅的数据库表信息 Objects []*SubscribeObject `json:"Objects,omitnil,omitempty" name:"Objects"` }
func NewModifySubscribeObjectsRequest ¶
func NewModifySubscribeObjectsRequest() (request *ModifySubscribeObjectsRequest)
func (*ModifySubscribeObjectsRequest) FromJsonString ¶
func (r *ModifySubscribeObjectsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeObjectsRequest) ToJsonString ¶
func (r *ModifySubscribeObjectsRequest) ToJsonString() string
type ModifySubscribeObjectsRequestParams ¶ added in v1.0.426
type ModifySubscribeObjectsRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅的类型,可选的值有:0 - 全实例订阅;1 - 数据订阅;2 - 结构订阅;3 - 数据订阅+结构订阅 SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil,omitempty" name:"SubscribeObjectType"` // 订阅的数据库表信息 Objects []*SubscribeObject `json:"Objects,omitnil,omitempty" name:"Objects"` }
Predefined struct for user
type ModifySubscribeObjectsResponse ¶
type ModifySubscribeObjectsResponse struct { *tchttp.BaseResponse Response *ModifySubscribeObjectsResponseParams `json:"Response"` }
func NewModifySubscribeObjectsResponse ¶
func NewModifySubscribeObjectsResponse() (response *ModifySubscribeObjectsResponse)
func (*ModifySubscribeObjectsResponse) FromJsonString ¶
func (r *ModifySubscribeObjectsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeObjectsResponse) ToJsonString ¶
func (r *ModifySubscribeObjectsResponse) ToJsonString() string
type ModifySubscribeObjectsResponseParams ¶ added in v1.0.426
type ModifySubscribeObjectsResponseParams struct { // 异步任务的ID AsyncRequestId *string `json:"AsyncRequestId,omitnil,omitempty" name:"AsyncRequestId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifySubscribeVipVportRequest ¶
type ModifySubscribeVipVportRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 指定目的子网,如果传此参数,DstIp必须在目的子网内 DstUniqSubnetId *string `json:"DstUniqSubnetId,omitnil,omitempty" name:"DstUniqSubnetId"` // 目标IP,与DstPort至少传一个 DstIp *string `json:"DstIp,omitnil,omitempty" name:"DstIp"` // 目标PORT,支持范围为:[1025-65535] DstPort *int64 `json:"DstPort,omitnil,omitempty" name:"DstPort"` }
func NewModifySubscribeVipVportRequest ¶
func NewModifySubscribeVipVportRequest() (request *ModifySubscribeVipVportRequest)
func (*ModifySubscribeVipVportRequest) FromJsonString ¶
func (r *ModifySubscribeVipVportRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeVipVportRequest) ToJsonString ¶
func (r *ModifySubscribeVipVportRequest) ToJsonString() string
type ModifySubscribeVipVportRequestParams ¶ added in v1.0.426
type ModifySubscribeVipVportRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 指定目的子网,如果传此参数,DstIp必须在目的子网内 DstUniqSubnetId *string `json:"DstUniqSubnetId,omitnil,omitempty" name:"DstUniqSubnetId"` // 目标IP,与DstPort至少传一个 DstIp *string `json:"DstIp,omitnil,omitempty" name:"DstIp"` // 目标PORT,支持范围为:[1025-65535] DstPort *int64 `json:"DstPort,omitnil,omitempty" name:"DstPort"` }
Predefined struct for user
type ModifySubscribeVipVportResponse ¶
type ModifySubscribeVipVportResponse struct { *tchttp.BaseResponse Response *ModifySubscribeVipVportResponseParams `json:"Response"` }
func NewModifySubscribeVipVportResponse ¶
func NewModifySubscribeVipVportResponse() (response *ModifySubscribeVipVportResponse)
func (*ModifySubscribeVipVportResponse) FromJsonString ¶
func (r *ModifySubscribeVipVportResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifySubscribeVipVportResponse) ToJsonString ¶
func (r *ModifySubscribeVipVportResponse) ToJsonString() string
type ModifySubscribeVipVportResponseParams ¶ added in v1.0.426
type ModifySubscribeVipVportResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type OfflineIsolatedSubscribeRequest ¶
type OfflineIsolatedSubscribeRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
func NewOfflineIsolatedSubscribeRequest ¶
func NewOfflineIsolatedSubscribeRequest() (request *OfflineIsolatedSubscribeRequest)
func (*OfflineIsolatedSubscribeRequest) FromJsonString ¶
func (r *OfflineIsolatedSubscribeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*OfflineIsolatedSubscribeRequest) ToJsonString ¶
func (r *OfflineIsolatedSubscribeRequest) ToJsonString() string
type OfflineIsolatedSubscribeRequestParams ¶ added in v1.0.426
type OfflineIsolatedSubscribeRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
Predefined struct for user
type OfflineIsolatedSubscribeResponse ¶
type OfflineIsolatedSubscribeResponse struct { *tchttp.BaseResponse Response *OfflineIsolatedSubscribeResponseParams `json:"Response"` }
func NewOfflineIsolatedSubscribeResponse ¶
func NewOfflineIsolatedSubscribeResponse() (response *OfflineIsolatedSubscribeResponse)
func (*OfflineIsolatedSubscribeResponse) FromJsonString ¶
func (r *OfflineIsolatedSubscribeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*OfflineIsolatedSubscribeResponse) ToJsonString ¶
func (r *OfflineIsolatedSubscribeResponse) ToJsonString() string
type OfflineIsolatedSubscribeResponseParams ¶ added in v1.0.426
type OfflineIsolatedSubscribeResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ResetSubscribeRequest ¶
type ResetSubscribeRequest struct { *tchttp.BaseRequest // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
func NewResetSubscribeRequest ¶
func NewResetSubscribeRequest() (request *ResetSubscribeRequest)
func (*ResetSubscribeRequest) FromJsonString ¶
func (r *ResetSubscribeRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ResetSubscribeRequest) ToJsonString ¶
func (r *ResetSubscribeRequest) ToJsonString() string
type ResetSubscribeRequestParams ¶ added in v1.0.426
type ResetSubscribeRequestParams struct { // 数据订阅实例的ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` }
Predefined struct for user
type ResetSubscribeResponse ¶
type ResetSubscribeResponse struct { *tchttp.BaseResponse Response *ResetSubscribeResponseParams `json:"Response"` }
func NewResetSubscribeResponse ¶
func NewResetSubscribeResponse() (response *ResetSubscribeResponse)
func (*ResetSubscribeResponse) FromJsonString ¶
func (r *ResetSubscribeResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ResetSubscribeResponse) ToJsonString ¶
func (r *ResetSubscribeResponse) ToJsonString() string
type ResetSubscribeResponseParams ¶ added in v1.0.426
type ResetSubscribeResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type SrcInfo ¶
type SrcInfo struct { // 阿里云AccessKey。源库是阿里云RDS5.6适用 AccessKey *string `json:"AccessKey,omitnil,omitempty" name:"AccessKey"` // 实例的IP地址 Ip *string `json:"Ip,omitnil,omitempty" name:"Ip"` // 实例的端口 Port *int64 `json:"Port,omitnil,omitempty" name:"Port"` // 实例的用户名 User *string `json:"User,omitnil,omitempty" name:"User"` // 实例的密码 Password *string `json:"Password,omitnil,omitempty" name:"Password"` // 阿里云RDS实例ID。源库是阿里云RDS5.6/5.6适用 RdsInstanceId *string `json:"RdsInstanceId,omitnil,omitempty" name:"RdsInstanceId"` // CVM实例短ID,格式如:ins-olgl39y8,与云服务器控制台页面显示的实例ID相同。如果是CVM自建实例,需要传递此字段 CvmInstanceId *string `json:"CvmInstanceId,omitnil,omitempty" name:"CvmInstanceId"` // 专线网关ID,格式如:dcg-0rxtqqxb UniqDcgId *string `json:"UniqDcgId,omitnil,omitempty" name:"UniqDcgId"` // 私有网络ID,格式如:vpc-92jblxto VpcId *string `json:"VpcId,omitnil,omitempty" name:"VpcId"` // 私有网络下的子网ID,格式如:subnet-3paxmkdz SubnetId *string `json:"SubnetId,omitnil,omitempty" name:"SubnetId"` // VPN网关ID,格式如:vpngw-9ghexg7q UniqVpnGwId *string `json:"UniqVpnGwId,omitnil,omitempty" name:"UniqVpnGwId"` // 数据库实例ID,格式如:cdb-powiqx8q InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 地域英文名,如:ap-guangzhou Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 当实例为RDS实例时,填写为aliyun, 其他情况均填写others Supplier *string `json:"Supplier,omitnil,omitempty" name:"Supplier"` // 云联网ID,如:ccn-afp6kltc // 注意:此字段可能返回 null,表示取不到有效值。 CcnId *string `json:"CcnId,omitnil,omitempty" name:"CcnId"` // 数据库版本,当实例为RDS实例时才有效,格式如:5.6或者5.7,默认为5.6 EngineVersion *string `json:"EngineVersion,omitnil,omitempty" name:"EngineVersion"` }
type StartMigrateJobRequest ¶
type StartMigrateJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
func NewStartMigrateJobRequest ¶
func NewStartMigrateJobRequest() (request *StartMigrateJobRequest)
func (*StartMigrateJobRequest) FromJsonString ¶
func (r *StartMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StartMigrateJobRequest) ToJsonString ¶
func (r *StartMigrateJobRequest) ToJsonString() string
type StartMigrateJobRequestParams ¶ added in v1.0.426
type StartMigrateJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
Predefined struct for user
type StartMigrateJobResponse ¶
type StartMigrateJobResponse struct { *tchttp.BaseResponse Response *StartMigrateJobResponseParams `json:"Response"` }
func NewStartMigrateJobResponse ¶
func NewStartMigrateJobResponse() (response *StartMigrateJobResponse)
func (*StartMigrateJobResponse) FromJsonString ¶
func (r *StartMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StartMigrateJobResponse) ToJsonString ¶
func (r *StartMigrateJobResponse) ToJsonString() string
type StartMigrateJobResponseParams ¶ added in v1.0.426
type StartMigrateJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type StopMigrateJobRequest ¶
type StopMigrateJobRequest struct { *tchttp.BaseRequest // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
func NewStopMigrateJobRequest ¶
func NewStopMigrateJobRequest() (request *StopMigrateJobRequest)
func (*StopMigrateJobRequest) FromJsonString ¶
func (r *StopMigrateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StopMigrateJobRequest) ToJsonString ¶
func (r *StopMigrateJobRequest) ToJsonString() string
type StopMigrateJobRequestParams ¶ added in v1.0.426
type StopMigrateJobRequestParams struct { // 数据迁移任务ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` }
Predefined struct for user
type StopMigrateJobResponse ¶
type StopMigrateJobResponse struct { *tchttp.BaseResponse Response *StopMigrateJobResponseParams `json:"Response"` }
func NewStopMigrateJobResponse ¶
func NewStopMigrateJobResponse() (response *StopMigrateJobResponse)
func (*StopMigrateJobResponse) FromJsonString ¶
func (r *StopMigrateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StopMigrateJobResponse) ToJsonString ¶
func (r *StopMigrateJobResponse) ToJsonString() string
type StopMigrateJobResponseParams ¶ added in v1.0.426
type StopMigrateJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type SubsErr ¶ added in v1.0.391
type SubsErr struct { // 错误信息 // 注意:此字段可能返回 null,表示取不到有效值。 Message *string `json:"Message,omitnil,omitempty" name:"Message"` }
type SubscribeInfo ¶
type SubscribeInfo struct { // 数据订阅的实例ID SubscribeId *string `json:"SubscribeId,omitnil,omitempty" name:"SubscribeId"` // 数据订阅实例的名称 SubscribeName *string `json:"SubscribeName,omitnil,omitempty" name:"SubscribeName"` // 数据订阅实例绑定的通道ID ChannelId *string `json:"ChannelId,omitnil,omitempty" name:"ChannelId"` // 数据订阅绑定实例对应的产品名称 Product *string `json:"Product,omitnil,omitempty" name:"Product"` // 数据订阅实例绑定的数据库实例ID InstanceId *string `json:"InstanceId,omitnil,omitempty" name:"InstanceId"` // 数据订阅实例绑定的数据库实例状态 InstanceStatus *string `json:"InstanceStatus,omitnil,omitempty" name:"InstanceStatus"` // 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置 SubsStatus *string `json:"SubsStatus,omitnil,omitempty" name:"SubsStatus"` // 上次修改时间 ModifyTime *string `json:"ModifyTime,omitnil,omitempty" name:"ModifyTime"` // 创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 隔离时间 IsolateTime *string `json:"IsolateTime,omitnil,omitempty" name:"IsolateTime"` // 到期时间 ExpireTime *string `json:"ExpireTime,omitnil,omitempty" name:"ExpireTime"` // 下线时间 OfflineTime *string `json:"OfflineTime,omitnil,omitempty" name:"OfflineTime"` // 最近一次修改的消费时间起点,如果从未修改则为零值 ConsumeStartTime *string `json:"ConsumeStartTime,omitnil,omitempty" name:"ConsumeStartTime"` // 自动续费标识。0-不自动续费,1-自动续费 // 注意:此字段可能返回 null,表示取不到有效值。 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` // 数据订阅实例所属地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 计费方式,0 - 包年包月,1 - 按量计费 PayType *int64 `json:"PayType,omitnil,omitempty" name:"PayType"` // 数据订阅实例的Vip Vip *string `json:"Vip,omitnil,omitempty" name:"Vip"` // 数据订阅实例的Vport Vport *int64 `json:"Vport,omitnil,omitempty" name:"Vport"` // 数据订阅实例Vip所在VPC的唯一ID UniqVpcId *string `json:"UniqVpcId,omitnil,omitempty" name:"UniqVpcId"` // 数据订阅实例Vip所在子网的唯一ID UniqSubnetId *string `json:"UniqSubnetId,omitnil,omitempty" name:"UniqSubnetId"` // 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中,offline - 已下线 Status *string `json:"Status,omitnil,omitempty" name:"Status"` // SDK最后一条确认消息的时间戳,如果SDK一直消费,也可以作为SDK当前消费时间点 SdkConsumedTime *string `json:"SdkConsumedTime,omitnil,omitempty" name:"SdkConsumedTime"` // 标签 // 注意:此字段可能返回 null,表示取不到有效值。 Tags []*TagItem `json:"Tags,omitnil,omitempty" name:"Tags"` // 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅 // 注意:此字段可能返回 null,表示取不到有效值。 SubscribeVersion *string `json:"SubscribeVersion,omitnil,omitempty" name:"SubscribeVersion"` }
type SubscribeObject ¶
type SubscribeObject struct { // 数据订阅对象的类型,0-数据库,1-数据库内的表 // 注意:此字段可能返回 null,表示取不到有效值。 ObjectsType *int64 `json:"ObjectsType,omitnil,omitempty" name:"ObjectsType"` // 订阅数据库的名称 // 注意:此字段可能返回 null,表示取不到有效值。 DatabaseName *string `json:"DatabaseName,omitnil,omitempty" name:"DatabaseName"` // 订阅数据库中表名称数组 // 注意:此字段可能返回 null,表示取不到有效值。 TableNames []*string `json:"TableNames,omitnil,omitempty" name:"TableNames"` }
type SubscribeRegionConf ¶
type SubscribeRegionConf struct { // 地域名称,如广州 // 注意:此字段可能返回 null,表示取不到有效值。 RegionName *string `json:"RegionName,omitnil,omitempty" name:"RegionName"` // 地区标识,如ap-guangzhou // 注意:此字段可能返回 null,表示取不到有效值。 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 地域名称,如华南地区 // 注意:此字段可能返回 null,表示取不到有效值。 Area *string `json:"Area,omitnil,omitempty" name:"Area"` // 是否为默认地域,0 - 不是,1 - 是的 // 注意:此字段可能返回 null,表示取不到有效值。 IsDefaultRegion *int64 `json:"IsDefaultRegion,omitnil,omitempty" name:"IsDefaultRegion"` // 当前地域的售卖情况,1 - 正常, 2-灰度,3 - 停售 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` }