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" name:"SubscribeId"`
// 数据库实例ID
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 数据订阅类型0-全实例订阅,1数据订阅,2结构订阅,3数据订阅与结构订阅
SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil" name:"SubscribeObjectType"`
// 订阅对象
Objects *SubscribeObject `json:"Objects,omitnil" name:"Objects"`
// 数据订阅服务所在子网。默认为数据库实例所在的子网内。
UniqSubnetId *string `json:"UniqSubnetId,omitnil" name:"UniqSubnetId"`
// 订阅服务端口;默认为7507
Vport *int64 `json:"Vport,omitnil" 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" name:"SubscribeId"`
// 数据库实例ID
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 数据订阅类型0-全实例订阅,1数据订阅,2结构订阅,3数据订阅与结构订阅
SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil" name:"SubscribeObjectType"`
// 订阅对象
Objects *SubscribeObject `json:"Objects,omitnil" name:"Objects"`
// 数据订阅服务所在子网。默认为数据库实例所在的子网内。
UniqSubnetId *string `json:"UniqSubnetId,omitnil" name:"UniqSubnetId"`
// 订阅服务端口;默认为7507
Vport *int64 `json:"Vport,omitnil" 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" name:"AsyncRequestId"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" 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" 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" 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" name:"JobId"`
// 完成任务的方式,仅支持旧版MySQL迁移任务。waitForSync-等待主从差距为0才停止,immediately-立即完成,不会等待主从差距一致。默认为waitForSync
CompleteMode *string `json:"CompleteMode,omitnil" 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" name:"JobId"`
// 完成任务的方式,仅支持旧版MySQL迁移任务。waitForSync-等待主从差距为0才停止,immediately-立即完成,不会等待主从差距一致。默认为waitForSync
CompleteMode *string `json:"CompleteMode,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ConsistencyParams ¶
type ConsistencyParams struct {
// 数据内容检测参数。表中选出用来数据对比的行,占表的总行数的百分比。取值范围是整数[1-100]
SelectRowsPerTable *int64 `json:"SelectRowsPerTable,omitnil" name:"SelectRowsPerTable"`
// 数据内容检测参数。迁移库表中,要进行数据内容检测的表,占所有表的百分比。取值范围是整数[1-100]
TablesSelectAll *int64 `json:"TablesSelectAll,omitnil" name:"TablesSelectAll"`
// 数据数量检测,检测表行数是否一致。迁移库表中,要进行数据数量检测的表,占所有表的百分比。取值范围是整数[1-100]
TablesSelectCount *int64 `json:"TablesSelectCount,omitnil" name:"TablesSelectCount"`
}
type CreateMigrateCheckJobRequest ¶
type CreateMigrateCheckJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type CreateMigrateJobRequest ¶
type CreateMigrateJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 迁移任务配置选项
MigrateOption *MigrateOption `json:"MigrateOption,omitnil" name:"MigrateOption"`
// 源实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver 不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。
SrcDatabaseType *string `json:"SrcDatabaseType,omitnil" name:"SrcDatabaseType"`
// 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例)
SrcAccessType *string `json:"SrcAccessType,omitnil" name:"SrcAccessType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfo *SrcInfo `json:"SrcInfo,omitnil" name:"SrcInfo"`
// 目标实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver,cynosdbmysql。不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。
DstDatabaseType *string `json:"DstDatabaseType,omitnil" name:"DstDatabaseType"`
// 目标实例接入类型,目前支持:cdb(腾讯云数据库实例)
DstAccessType *string `json:"DstAccessType,omitnil" name:"DstAccessType"`
// 目标实例信息
DstInfo *DstInfo `json:"DstInfo,omitnil" 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" name:"DatabaseInfo"`
// 迁移实例的tag
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点
SrcNodeType *string `json:"SrcNodeType,omitnil" name:"SrcNodeType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil" 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" name:"JobName"`
// 迁移任务配置选项
MigrateOption *MigrateOption `json:"MigrateOption,omitnil" name:"MigrateOption"`
// 源实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver 不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。
SrcDatabaseType *string `json:"SrcDatabaseType,omitnil" name:"SrcDatabaseType"`
// 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例)
SrcAccessType *string `json:"SrcAccessType,omitnil" name:"SrcAccessType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfo *SrcInfo `json:"SrcInfo,omitnil" name:"SrcInfo"`
// 目标实例数据库类型,目前支持:mysql,redis,mongodb,postgresql,mariadb,percona,sqlserver,cynosdbmysql。不同地域数据库类型的具体支持情况,请参考控制台创建迁移页面。
DstDatabaseType *string `json:"DstDatabaseType,omitnil" name:"DstDatabaseType"`
// 目标实例接入类型,目前支持:cdb(腾讯云数据库实例)
DstAccessType *string `json:"DstAccessType,omitnil" name:"DstAccessType"`
// 目标实例信息
DstInfo *DstInfo `json:"DstInfo,omitnil" 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" name:"DatabaseInfo"`
// 迁移实例的tag
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点
SrcNodeType *string `json:"SrcNodeType,omitnil" name:"SrcNodeType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil" 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" name:"JobId"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type CreateSubscribeRequest ¶
type CreateSubscribeRequest struct {
*tchttp.BaseRequest
// 订阅的数据库类型,目前支持的有 mysql
Product *string `json:"Product,omitnil" name:"Product"`
// 实例付费类型,1小时计费,0包年包月
PayType *int64 `json:"PayType,omitnil" name:"PayType"`
// 购买时长。PayType为0时必填。单位为月,最大支持120
Duration *int64 `json:"Duration,omitnil" name:"Duration"`
// 购买数量,默认为1,最大为10
Count *int64 `json:"Count,omitnil" name:"Count"`
// 是否自动续费,0表示不自动续费,1表示自动续费,默认为0。小时计费实例设置该标识无效。
AutoRenew *int64 `json:"AutoRenew,omitnil" name:"AutoRenew"`
// 实例资源标签
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 用户自定义实例名
Name *string `json:"Name,omitnil" 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" name:"Product"`
// 实例付费类型,1小时计费,0包年包月
PayType *int64 `json:"PayType,omitnil" name:"PayType"`
// 购买时长。PayType为0时必填。单位为月,最大支持120
Duration *int64 `json:"Duration,omitnil" name:"Duration"`
// 购买数量,默认为1,最大为10
Count *int64 `json:"Count,omitnil" name:"Count"`
// 是否自动续费,0表示不自动续费,1表示自动续费,默认为0。小时计费实例设置该标识无效。
AutoRenew *int64 `json:"AutoRenew,omitnil" name:"AutoRenew"`
// 实例资源标签
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 用户自定义实例名
Name *string `json:"Name,omitnil" 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" name:"SubscribeIds"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DeleteMigrateJobRequest ¶
type DeleteMigrateJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DescribeAsyncRequestInfoRequest ¶
type DescribeAsyncRequestInfoRequest struct {
*tchttp.BaseRequest
// 任务 ID
AsyncRequestId *string `json:"AsyncRequestId,omitnil" 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" 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" name:"Info"`
// 任务执行状态,可能的值有:success,failed,running
Status *string `json:"Status,omitnil" name:"Status"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DescribeMigrateCheckJobRequest ¶
type DescribeMigrateCheckJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" 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" 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" name:"Status"`
// 任务的错误码
ErrorCode *int64 `json:"ErrorCode,omitnil" name:"ErrorCode"`
// 任务的错误信息
ErrorMessage *string `json:"ErrorMessage,omitnil" name:"ErrorMessage"`
// Check任务总进度,如:"30"表示30%
Progress *string `json:"Progress,omitnil" name:"Progress"`
// 校验是否通过,0-未通过,1-校验通过, 3-未校验
CheckFlag *int64 `json:"CheckFlag,omitnil" name:"CheckFlag"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DescribeMigrateJobsRequest ¶
type DescribeMigrateJobsRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" name:"JobId"`
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 排序字段,可以取值为JobId、Status、JobName、MigrateType、RunMode、CreateTime
Order *string `json:"Order,omitnil" name:"Order"`
// 排序方式,升序为ASC,降序为DESC
OrderSeq *string `json:"OrderSeq,omitnil" name:"OrderSeq"`
// 偏移量,默认为0
Offset *uint64 `json:"Offset,omitnil" name:"Offset"`
// 返回实例数量,默认20,有效区间[1,100]
Limit *uint64 `json:"Limit,omitnil" name:"Limit"`
// 标签过滤条件
TagFilters []*TagFilter `json:"TagFilters,omitnil" 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" name:"JobId"`
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 排序字段,可以取值为JobId、Status、JobName、MigrateType、RunMode、CreateTime
Order *string `json:"Order,omitnil" name:"Order"`
// 排序方式,升序为ASC,降序为DESC
OrderSeq *string `json:"OrderSeq,omitnil" name:"OrderSeq"`
// 偏移量,默认为0
Offset *uint64 `json:"Offset,omitnil" name:"Offset"`
// 返回实例数量,默认20,有效区间[1,100]
Limit *uint64 `json:"Limit,omitnil" name:"Limit"`
// 标签过滤条件
TagFilters []*TagFilter `json:"TagFilters,omitnil" 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" name:"TotalCount"`
// 任务详情数组
JobList []*MigrateJobInfo `json:"JobList,omitnil" name:"JobList"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" 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" name:"TotalCount"`
// 可售卖地域详情
Items []*SubscribeRegionConf `json:"Items,omitnil" name:"Items"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DescribeSubscribeConfRequest ¶
type DescribeSubscribeConfRequest struct {
*tchttp.BaseRequest
// 订阅实例ID
SubscribeId *string `json:"SubscribeId,omitnil" 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" 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" name:"SubscribeId"`
// 订阅实例名称
SubscribeName *string `json:"SubscribeName,omitnil" name:"SubscribeName"`
// 订阅通道
ChannelId *string `json:"ChannelId,omitnil" name:"ChannelId"`
// 订阅数据库类型
Product *string `json:"Product,omitnil" name:"Product"`
// 被订阅的实例
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 被订阅的实例的状态,可能的值有running,offline,isolate
InstanceStatus *string `json:"InstanceStatus,omitnil" name:"InstanceStatus"`
// 订阅实例状态,可能的值有unconfigure-未配置,configuring-配置中,configured-已配置
SubsStatus *string `json:"SubsStatus,omitnil" name:"SubsStatus"`
// 订阅实例生命周期状态,可能的值有:normal-正常,isolating-隔离中,isolated-已隔离,offlining-下线中
Status *string `json:"Status,omitnil" name:"Status"`
// 订阅实例创建时间
CreateTime *string `json:"CreateTime,omitnil" name:"CreateTime"`
// 订阅实例被隔离时间
IsolateTime *string `json:"IsolateTime,omitnil" name:"IsolateTime"`
// 订阅实例到期时间
ExpireTime *string `json:"ExpireTime,omitnil" name:"ExpireTime"`
// 订阅实例下线时间
OfflineTime *string `json:"OfflineTime,omitnil" name:"OfflineTime"`
// 订阅实例消费时间起点。
ConsumeStartTime *string `json:"ConsumeStartTime,omitnil" name:"ConsumeStartTime"`
// 订阅实例计费类型,1-小时计费,0-包年包月
PayType *int64 `json:"PayType,omitnil" name:"PayType"`
// 订阅通道Vip
Vip *string `json:"Vip,omitnil" name:"Vip"`
// 订阅通道Port
Vport *int64 `json:"Vport,omitnil" name:"Vport"`
// 订阅通道所在VpcId
UniqVpcId *string `json:"UniqVpcId,omitnil" name:"UniqVpcId"`
// 订阅通道所在SubnetId
UniqSubnetId *string `json:"UniqSubnetId,omitnil" name:"UniqSubnetId"`
// 当前SDK消费时间位点
SdkConsumedTime *string `json:"SdkConsumedTime,omitnil" name:"SdkConsumedTime"`
// 订阅SDK IP地址
SdkHost *string `json:"SdkHost,omitnil" name:"SdkHost"`
// 订阅对象类型0-全实例订阅,1-DDL数据订阅,2-DML结构订阅,3-DDL数据订阅+DML结构订阅
SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil" name:"SubscribeObjectType"`
// 订阅对象,当SubscribeObjectType 为0时,此字段为空数组
SubscribeObjects []*SubscribeObject `json:"SubscribeObjects,omitnil" name:"SubscribeObjects"`
// 修改时间
ModifyTime *string `json:"ModifyTime,omitnil" name:"ModifyTime"`
// 地域
Region *string `json:"Region,omitnil" name:"Region"`
// 订阅实例的标签
// 注意:此字段可能返回 null,表示取不到有效值。
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 自动续费标识,0-不自动续费,1-自动续费
// 注意:此字段可能返回 null,表示取不到有效值。
AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil" name:"AutoRenewFlag"`
// 数据订阅版本。老版订阅填txdts,kafka版填kafka
SubscribeVersion *string `json:"SubscribeVersion,omitnil" name:"SubscribeVersion"`
// 错误信息
// 注意:此字段可能返回 null,表示取不到有效值。
Errors []*SubsErr `json:"Errors,omitnil" name:"Errors"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DescribeSubscribesRequest ¶
type DescribeSubscribesRequest struct {
*tchttp.BaseRequest
// 数据订阅的实例ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 数据订阅的实例名称
SubscribeName *string `json:"SubscribeName,omitnil" name:"SubscribeName"`
// 绑定数据库实例的ID
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 数据订阅实例的通道ID
ChannelId *string `json:"ChannelId,omitnil" name:"ChannelId"`
// 计费模式筛选,可能的值:0-包年包月,1-按量计费
PayType *string `json:"PayType,omitnil" name:"PayType"`
// 订阅的数据库产品,如mysql
Product *string `json:"Product,omitnil" name:"Product"`
// 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中
Status []*string `json:"Status,omitnil" name:"Status"`
// 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置
SubsStatus []*string `json:"SubsStatus,omitnil" name:"SubsStatus"`
// 返回记录的起始偏移量,默认为0。请输入非负整数
Offset *int64 `json:"Offset,omitnil" name:"Offset"`
// 单次返回的记录数量,默认20。请输入1到100的整数
Limit *int64 `json:"Limit,omitnil" name:"Limit"`
// 排序方向,可选的值为"DESC"和"ASC",默认为"DESC",按创建时间逆序排序
OrderDirection *string `json:"OrderDirection,omitnil" name:"OrderDirection"`
// 标签过滤条件
TagFilters []*TagFilter `json:"TagFilters,omitnil" name:"TagFilters"`
// 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅
SubscribeVersion *string `json:"SubscribeVersion,omitnil" 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" name:"SubscribeId"`
// 数据订阅的实例名称
SubscribeName *string `json:"SubscribeName,omitnil" name:"SubscribeName"`
// 绑定数据库实例的ID
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 数据订阅实例的通道ID
ChannelId *string `json:"ChannelId,omitnil" name:"ChannelId"`
// 计费模式筛选,可能的值:0-包年包月,1-按量计费
PayType *string `json:"PayType,omitnil" name:"PayType"`
// 订阅的数据库产品,如mysql
Product *string `json:"Product,omitnil" name:"Product"`
// 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中
Status []*string `json:"Status,omitnil" name:"Status"`
// 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置
SubsStatus []*string `json:"SubsStatus,omitnil" name:"SubsStatus"`
// 返回记录的起始偏移量,默认为0。请输入非负整数
Offset *int64 `json:"Offset,omitnil" name:"Offset"`
// 单次返回的记录数量,默认20。请输入1到100的整数
Limit *int64 `json:"Limit,omitnil" name:"Limit"`
// 排序方向,可选的值为"DESC"和"ASC",默认为"DESC",按创建时间逆序排序
OrderDirection *string `json:"OrderDirection,omitnil" name:"OrderDirection"`
// 标签过滤条件
TagFilters []*TagFilter `json:"TagFilters,omitnil" name:"TagFilters"`
// 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅
SubscribeVersion *string `json:"SubscribeVersion,omitnil" 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" name:"TotalCount"`
// 数据订阅实例的信息列表
Items []*SubscribeInfo `json:"Items,omitnil" name:"Items"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type DstInfo ¶
type DstInfo struct {
// 目标实例地域,如ap-guangzhou
Region *string `json:"Region,omitnil" name:"Region"`
// 目标实例ID,如cdb-jd92ijd8
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 目标实例vip。已废弃,无需填写
Ip *string `json:"Ip,omitnil" name:"Ip"`
// 目标实例vport。已废弃,无需填写
Port *int64 `json:"Port,omitnil" name:"Port"`
// 目前只对MySQL有效。当为整实例迁移时,1-只读,0-可读写。
ReadOnly *int64 `json:"ReadOnly,omitnil" name:"ReadOnly"`
// 目标数据库账号
User *string `json:"User,omitnil" name:"User"`
// 目标数据库密码
Password *string `json:"Password,omitnil" name:"Password"`
}
type IsolateSubscribeRequest ¶
type IsolateSubscribeRequest struct {
*tchttp.BaseRequest
// 订阅实例ID
SubscribeId *string `json:"SubscribeId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type MigrateDetailInfo ¶
type MigrateDetailInfo struct {
// 总步骤数
StepAll *int64 `json:"StepAll,omitnil" name:"StepAll"`
// 当前步骤
StepNow *int64 `json:"StepNow,omitnil" name:"StepNow"`
// 总进度,如:"10"
Progress *string `json:"Progress,omitnil" name:"Progress"`
// 当前步骤进度,如:"1"
CurrentStepProgress *string `json:"CurrentStepProgress,omitnil" name:"CurrentStepProgress"`
// 主从差距,MB;在增量同步阶段有效,目前支持产品为:redis和mysql
MasterSlaveDistance *int64 `json:"MasterSlaveDistance,omitnil" name:"MasterSlaveDistance"`
// 主从差距,秒;在增量同步阶段有效,目前支持产品为:mysql
SecondsBehindMaster *int64 `json:"SecondsBehindMaster,omitnil" name:"SecondsBehindMaster"`
// 步骤信息
StepInfo []*MigrateStepDetailInfo `json:"StepInfo,omitnil" name:"StepInfo"`
}
type MigrateJobInfo ¶
type MigrateJobInfo struct {
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" name:"JobId"`
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 迁移任务配置选项
MigrateOption *MigrateOption `json:"MigrateOption,omitnil" name:"MigrateOption"`
// 源实例数据库类型:mysql,redis,mongodb,postgresql,mariadb,percona
SrcDatabaseType *string `json:"SrcDatabaseType,omitnil" name:"SrcDatabaseType"`
// 源实例接入类型,值包括:extranet(外网),cvm(cvm自建实例),dcg(专线接入的实例),vpncloud(云vpn接入的实例),cdb(腾讯云数据库实例),ccn(云联网实例)
SrcAccessType *string `json:"SrcAccessType,omitnil" name:"SrcAccessType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfo *SrcInfo `json:"SrcInfo,omitnil" name:"SrcInfo"`
// 目标实例数据库类型:mysql,redis,mongodb,postgresql,mariadb,percona
DstDatabaseType *string `json:"DstDatabaseType,omitnil" name:"DstDatabaseType"`
// 目标实例接入类型,目前支持:cdb(腾讯云数据库实例)
DstAccessType *string `json:"DstAccessType,omitnil" name:"DstAccessType"`
// 目标实例信息
DstInfo *DstInfo `json:"DstInfo,omitnil" name:"DstInfo"`
// 需要迁移的源数据库表信息,如果需要迁移的是整个实例,该字段为[]
DatabaseInfo *string `json:"DatabaseInfo,omitnil" name:"DatabaseInfo"`
// 任务创建(提交)时间
CreateTime *string `json:"CreateTime,omitnil" name:"CreateTime"`
// 任务开始执行时间
StartTime *string `json:"StartTime,omitnil" name:"StartTime"`
// 任务执行结束时间
EndTime *string `json:"EndTime,omitnil" 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" name:"Status"`
// 任务详情
Detail *MigrateDetailInfo `json:"Detail,omitnil" name:"Detail"`
// 任务错误信息提示,当任务发生错误时,不为null或者空值
ErrorInfo []*ErrorInfo `json:"ErrorInfo,omitnil" name:"ErrorInfo"`
// 标签
// 注意:此字段可能返回 null,表示取不到有效值。
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 源实例为集群时且接入为非cdb时源实例信息
// 注意:此字段可能返回 null,表示取不到有效值。
SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil" name:"SrcInfoMulti"`
}
type MigrateOption ¶
type MigrateOption struct {
// 任务运行模式,值包括:1-立即执行,2-定时执行
RunMode *int64 `json:"RunMode,omitnil" name:"RunMode"`
// 期望执行时间,当runMode=2时,该字段必填,时间格式:yyyy-mm-dd hh:mm:ss
ExpectTime *string `json:"ExpectTime,omitnil" name:"ExpectTime"`
// 数据迁移类型,值包括:1-结构迁移,2-全量迁移,3-全量+增量迁移
MigrateType *int64 `json:"MigrateType,omitnil" name:"MigrateType"`
// 迁移对象,1-整个实例,2-指定库表
MigrateObject *int64 `json:"MigrateObject,omitnil" name:"MigrateObject"`
// 抽样数据一致性检测参数,1-未配置,2-全量检测,3-抽样检测, 4-仅校验不一致表,5-不检测
ConsistencyType *int64 `json:"ConsistencyType,omitnil" name:"ConsistencyType"`
// 是否用源库Root账户覆盖目标库,值包括:0-不覆盖,1-覆盖,选择库表或者结构迁移时应该为0
IsOverrideRoot *int64 `json:"IsOverrideRoot,omitnil" 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" name:"ExternParams"`
// 仅用于“抽样数据一致性检测”,ConsistencyType配置为抽样检测时,必选
ConsistencyParams *ConsistencyParams `json:"ConsistencyParams,omitnil" name:"ConsistencyParams"`
}
type MigrateStepDetailInfo ¶
type MigrateStepDetailInfo struct {
// 步骤序列
StepNo *int64 `json:"StepNo,omitnil" name:"StepNo"`
// 步骤展现名称
StepName *string `json:"StepName,omitnil" name:"StepName"`
// 步骤英文标识
StepId *string `json:"StepId,omitnil" name:"StepId"`
// 步骤状态:0-默认值,1-成功,2-失败,3-执行中,4-未执行
Status *int64 `json:"Status,omitnil" name:"Status"`
// 当前步骤开始的时间,格式为"yyyy-mm-dd hh:mm:ss",该字段不存在或者为空是无意义
// 注意:此字段可能返回 null,表示取不到有效值。
StartTime *string `json:"StartTime,omitnil" name:"StartTime"`
}
type ModifyMigrateJobRequest ¶
type ModifyMigrateJobRequest struct {
*tchttp.BaseRequest
// 待修改的数据迁移任务ID
JobId *string `json:"JobId,omitnil" name:"JobId"`
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 迁移任务配置选项
MigrateOption *MigrateOption `json:"MigrateOption,omitnil" name:"MigrateOption"`
// 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例)
SrcAccessType *string `json:"SrcAccessType,omitnil" name:"SrcAccessType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfo *SrcInfo `json:"SrcInfo,omitnil" name:"SrcInfo"`
// 目标实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例). 目前只支持cdb.
DstAccessType *string `json:"DstAccessType,omitnil" name:"DstAccessType"`
// 目标实例信息, 其中目标实例地域不允许修改.
DstInfo *DstInfo `json:"DstInfo,omitnil" 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" name:"DatabaseInfo"`
// 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点
SrcNodeType *string `json:"SrcNodeType,omitnil" name:"SrcNodeType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil" 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" name:"JobId"`
// 数据迁移任务名称
JobName *string `json:"JobName,omitnil" name:"JobName"`
// 迁移任务配置选项
MigrateOption *MigrateOption `json:"MigrateOption,omitnil" name:"MigrateOption"`
// 源实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例)
SrcAccessType *string `json:"SrcAccessType,omitnil" name:"SrcAccessType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfo *SrcInfo `json:"SrcInfo,omitnil" name:"SrcInfo"`
// 目标实例接入类型,值包括:extranet(外网),cvm(CVM自建实例),dcg(专线接入的实例),vpncloud(云VPN接入的实例),cdb(云上CDB实例). 目前只支持cdb.
DstAccessType *string `json:"DstAccessType,omitnil" name:"DstAccessType"`
// 目标实例信息, 其中目标实例地域不允许修改.
DstInfo *DstInfo `json:"DstInfo,omitnil" 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" name:"DatabaseInfo"`
// 源实例类型: ""或者"simple":主从节点,"cluster": 集群节点
SrcNodeType *string `json:"SrcNodeType,omitnil" name:"SrcNodeType"`
// 源实例信息,具体内容跟迁移任务类型相关
SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ModifySubscribeAutoRenewFlagRequest ¶
type ModifySubscribeAutoRenewFlagRequest struct {
*tchttp.BaseRequest
// 订阅实例ID,例如:subs-8uey736k
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 自动续费标识。1-自动续费,0-不自动续费
AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil" 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" name:"SubscribeId"`
// 自动续费标识。1-自动续费,0-不自动续费
AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ModifySubscribeConsumeTimeRequest ¶
type ModifySubscribeConsumeTimeRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 消费时间起点,也即是指定订阅数据的时间起点,时间格式如:Y-m-d h:m:s,取值范围为过去24小时之内
ConsumeStartTime *string `json:"ConsumeStartTime,omitnil" 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" name:"SubscribeId"`
// 消费时间起点,也即是指定订阅数据的时间起点,时间格式如:Y-m-d h:m:s,取值范围为过去24小时之内
ConsumeStartTime *string `json:"ConsumeStartTime,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ModifySubscribeNameRequest ¶
type ModifySubscribeNameRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 数据订阅实例的名称,长度限制为[1,60]
SubscribeName *string `json:"SubscribeName,omitnil" 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" name:"SubscribeId"`
// 数据订阅实例的名称,长度限制为[1,60]
SubscribeName *string `json:"SubscribeName,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ModifySubscribeObjectsRequest ¶
type ModifySubscribeObjectsRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 数据订阅的类型,可选的值有:0 - 全实例订阅;1 - 数据订阅;2 - 结构订阅;3 - 数据订阅+结构订阅
SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil" name:"SubscribeObjectType"`
// 订阅的数据库表信息
Objects []*SubscribeObject `json:"Objects,omitnil" 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" name:"SubscribeId"`
// 数据订阅的类型,可选的值有:0 - 全实例订阅;1 - 数据订阅;2 - 结构订阅;3 - 数据订阅+结构订阅
SubscribeObjectType *int64 `json:"SubscribeObjectType,omitnil" name:"SubscribeObjectType"`
// 订阅的数据库表信息
Objects []*SubscribeObject `json:"Objects,omitnil" 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" name:"AsyncRequestId"`
// 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ModifySubscribeVipVportRequest ¶
type ModifySubscribeVipVportRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 指定目的子网,如果传此参数,DstIp必须在目的子网内
DstUniqSubnetId *string `json:"DstUniqSubnetId,omitnil" name:"DstUniqSubnetId"`
// 目标IP,与DstPort至少传一个
DstIp *string `json:"DstIp,omitnil" name:"DstIp"`
// 目标PORT,支持范围为:[1025-65535]
DstPort *int64 `json:"DstPort,omitnil" 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" name:"SubscribeId"`
// 指定目的子网,如果传此参数,DstIp必须在目的子网内
DstUniqSubnetId *string `json:"DstUniqSubnetId,omitnil" name:"DstUniqSubnetId"`
// 目标IP,与DstPort至少传一个
DstIp *string `json:"DstIp,omitnil" name:"DstIp"`
// 目标PORT,支持范围为:[1025-65535]
DstPort *int64 `json:"DstPort,omitnil" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type OfflineIsolatedSubscribeRequest ¶
type OfflineIsolatedSubscribeRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type ResetSubscribeRequest ¶
type ResetSubscribeRequest struct {
*tchttp.BaseRequest
// 数据订阅实例的ID
SubscribeId *string `json:"SubscribeId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type SrcInfo ¶
type SrcInfo struct {
// 阿里云AccessKey。源库是阿里云RDS5.6适用
AccessKey *string `json:"AccessKey,omitnil" name:"AccessKey"`
// 实例的IP地址
Ip *string `json:"Ip,omitnil" name:"Ip"`
// 实例的端口
Port *int64 `json:"Port,omitnil" name:"Port"`
// 实例的用户名
User *string `json:"User,omitnil" name:"User"`
// 实例的密码
Password *string `json:"Password,omitnil" name:"Password"`
// 阿里云RDS实例ID。源库是阿里云RDS5.6/5.6适用
RdsInstanceId *string `json:"RdsInstanceId,omitnil" name:"RdsInstanceId"`
// CVM实例短ID,格式如:ins-olgl39y8,与云服务器控制台页面显示的实例ID相同。如果是CVM自建实例,需要传递此字段
CvmInstanceId *string `json:"CvmInstanceId,omitnil" name:"CvmInstanceId"`
// 专线网关ID,格式如:dcg-0rxtqqxb
UniqDcgId *string `json:"UniqDcgId,omitnil" name:"UniqDcgId"`
// 私有网络ID,格式如:vpc-92jblxto
VpcId *string `json:"VpcId,omitnil" name:"VpcId"`
// 私有网络下的子网ID,格式如:subnet-3paxmkdz
SubnetId *string `json:"SubnetId,omitnil" name:"SubnetId"`
// VPN网关ID,格式如:vpngw-9ghexg7q
UniqVpnGwId *string `json:"UniqVpnGwId,omitnil" name:"UniqVpnGwId"`
// 数据库实例ID,格式如:cdb-powiqx8q
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 地域英文名,如:ap-guangzhou
Region *string `json:"Region,omitnil" name:"Region"`
// 当实例为RDS实例时,填写为aliyun, 其他情况均填写others
Supplier *string `json:"Supplier,omitnil" name:"Supplier"`
// 云联网ID,如:ccn-afp6kltc
// 注意:此字段可能返回 null,表示取不到有效值。
CcnId *string `json:"CcnId,omitnil" name:"CcnId"`
// 数据库版本,当实例为RDS实例时才有效,格式如:5.6或者5.7,默认为5.6
EngineVersion *string `json:"EngineVersion,omitnil" name:"EngineVersion"`
}
type StartMigrateJobRequest ¶
type StartMigrateJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type StopMigrateJobRequest ¶
type StopMigrateJobRequest struct {
*tchttp.BaseRequest
// 数据迁移任务ID
JobId *string `json:"JobId,omitnil" 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" 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 *string `json:"RequestId,omitnil" name:"RequestId"`
}
Predefined struct for user
type SubsErr ¶ added in v1.0.391
type SubsErr struct {
// 错误信息
// 注意:此字段可能返回 null,表示取不到有效值。
Message *string `json:"Message,omitnil" name:"Message"`
}
type SubscribeInfo ¶
type SubscribeInfo struct {
// 数据订阅的实例ID
SubscribeId *string `json:"SubscribeId,omitnil" name:"SubscribeId"`
// 数据订阅实例的名称
SubscribeName *string `json:"SubscribeName,omitnil" name:"SubscribeName"`
// 数据订阅实例绑定的通道ID
ChannelId *string `json:"ChannelId,omitnil" name:"ChannelId"`
// 数据订阅绑定实例对应的产品名称
Product *string `json:"Product,omitnil" name:"Product"`
// 数据订阅实例绑定的数据库实例ID
InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
// 数据订阅实例绑定的数据库实例状态
InstanceStatus *string `json:"InstanceStatus,omitnil" name:"InstanceStatus"`
// 数据订阅实例的配置状态,unconfigure - 未配置, configuring - 配置中,configured - 已配置
SubsStatus *string `json:"SubsStatus,omitnil" name:"SubsStatus"`
// 上次修改时间
ModifyTime *string `json:"ModifyTime,omitnil" name:"ModifyTime"`
// 创建时间
CreateTime *string `json:"CreateTime,omitnil" name:"CreateTime"`
// 隔离时间
IsolateTime *string `json:"IsolateTime,omitnil" name:"IsolateTime"`
// 到期时间
ExpireTime *string `json:"ExpireTime,omitnil" name:"ExpireTime"`
// 下线时间
OfflineTime *string `json:"OfflineTime,omitnil" name:"OfflineTime"`
// 最近一次修改的消费时间起点,如果从未修改则为零值
ConsumeStartTime *string `json:"ConsumeStartTime,omitnil" name:"ConsumeStartTime"`
// 数据订阅实例所属地域
Region *string `json:"Region,omitnil" name:"Region"`
// 计费方式,0 - 包年包月,1 - 按量计费
PayType *int64 `json:"PayType,omitnil" name:"PayType"`
// 数据订阅实例的Vip
Vip *string `json:"Vip,omitnil" name:"Vip"`
// 数据订阅实例的Vport
Vport *int64 `json:"Vport,omitnil" name:"Vport"`
// 数据订阅实例Vip所在VPC的唯一ID
UniqVpcId *string `json:"UniqVpcId,omitnil" name:"UniqVpcId"`
// 数据订阅实例Vip所在子网的唯一ID
UniqSubnetId *string `json:"UniqSubnetId,omitnil" name:"UniqSubnetId"`
// 数据订阅实例的状态,creating - 创建中,normal - 正常运行,isolating - 隔离中,isolated - 已隔离,offlining - 下线中,offline - 已下线
Status *string `json:"Status,omitnil" name:"Status"`
// SDK最后一条确认消息的时间戳,如果SDK一直消费,也可以作为SDK当前消费时间点
SdkConsumedTime *string `json:"SdkConsumedTime,omitnil" name:"SdkConsumedTime"`
// 标签
// 注意:此字段可能返回 null,表示取不到有效值。
Tags []*TagItem `json:"Tags,omitnil" name:"Tags"`
// 自动续费标识。0-不自动续费,1-自动续费
// 注意:此字段可能返回 null,表示取不到有效值。
AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil" name:"AutoRenewFlag"`
// 订阅实例版本;txdts-旧版数据订阅,kafka-kafka版本数据订阅
// 注意:此字段可能返回 null,表示取不到有效值。
SubscribeVersion *string `json:"SubscribeVersion,omitnil" name:"SubscribeVersion"`
}
type SubscribeObject ¶
type SubscribeObject struct {
// 数据订阅对象的类型,0-数据库,1-数据库内的表
// 注意:此字段可能返回 null,表示取不到有效值。
ObjectsType *int64 `json:"ObjectsType,omitnil" name:"ObjectsType"`
// 订阅数据库的名称
// 注意:此字段可能返回 null,表示取不到有效值。
DatabaseName *string `json:"DatabaseName,omitnil" name:"DatabaseName"`
// 订阅数据库中表名称数组
// 注意:此字段可能返回 null,表示取不到有效值。
TableNames []*string `json:"TableNames,omitnil" name:"TableNames"`
}
type SubscribeRegionConf ¶
type SubscribeRegionConf struct {
// 地域名称,如广州
// 注意:此字段可能返回 null,表示取不到有效值。
RegionName *string `json:"RegionName,omitnil" name:"RegionName"`
// 地区标识,如ap-guangzhou
// 注意:此字段可能返回 null,表示取不到有效值。
Region *string `json:"Region,omitnil" name:"Region"`
// 地域名称,如华南地区
// 注意:此字段可能返回 null,表示取不到有效值。
Area *string `json:"Area,omitnil" name:"Area"`
// 是否为默认地域,0 - 不是,1 - 是的
// 注意:此字段可能返回 null,表示取不到有效值。
IsDefaultRegion *int64 `json:"IsDefaultRegion,omitnil" name:"IsDefaultRegion"`
// 当前地域的售卖情况,1 - 正常, 2-灰度,3 - 停售
// 注意:此字段可能返回 null,表示取不到有效值。
Status *int64 `json:"Status,omitnil" name:"Status"`
}