v20180330

package
v3.0.459+incompatible Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// The current user is not allowed to perform this operation as the authentication failed.
	AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"

	// This operation is prohibited.
	FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"

	// Failed to start the task.
	FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed"

	// This operation cannot be performed due to status conflict.
	FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"

	// An internal error occurred.
	INTERNALERROR = "InternalError"

	// Failed to create the async task.
	INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError"

	// Internal scheduling system error.
	INTERNALERROR_CELERYERROR = "InternalError.CeleryError"

	// CGW system error.
	INTERNALERROR_CGWSYSTEMERROR = "InternalError.CgwSystemError"

	// Failed to access the database on the DTS platform.
	INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"

	// Migration tasks are in conflict.
	INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"

	// Locks are in conflict.
	INTERNALERROR_LOCKERROR = "InternalError.LockError"

	// Communication protocol error.
	INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"

	// Internal error.
	INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError"

	// Unknown internal error.
	INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError"

	// A parameter error occurred.
	INVALIDPARAMETER = "InvalidParameter"

	// Parameter value error.
	INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError"

	// The instance does not exist.
	INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound"

	// Incorrect parameter value.
	INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue"

	// The number of idle migration tasks exceeds the limit.
	LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"

	// Operation denied.
	OPERATIONDENIED = "OperationDenied"

	// The operation was denied as the condition was not met.
	OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError"

	// Task operation failure.
	OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError"

	// DTS does not support the current migration type.
	OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError"

	// This operation cannot be performed.
	OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"

	// The resource does not exist.
	RESOURCENOTFOUND = "ResourceNotFound"

	// Resource not found.
	RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"

	// The migration task does not exist.
	RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

	// The instance is not found.
	RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound"

	// Verification failed. Insufficient permissions.
	UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

	// Unsupported operation
	UNSUPPORTEDOPERATION = "UnsupportedOperation"
)
View Source 
const APIVersion = "2018-03-30"

Variables

This section is empty.

Functions

This section is empty.

Types

type ActivateSubscribeRequest 

type ActivateSubscribeRequest struct {
	*tchttp.BaseRequest

	// Subscription instance ID.
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Database Instance ID
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

	// Data subscription type. 0: full instance subscription, 1: data subscription, 2: structure subscription, 3: data subscription and structure subscription
	SubscribeObjectType *int64 `json:"SubscribeObjectType,omitempty" name:"SubscribeObjectType"`

	// Subscription object
	Objects *SubscribeObject `json:"Objects,omitempty" name:"Objects"`

	// Subnet of data subscription service, which is the subnet of the database instance by default.
	UniqSubnetId *string `json:"UniqSubnetId,omitempty" name:"UniqSubnetId"`

	// Subscription service port. Default value: 7507
	Vport *int64 `json:"Vport,omitempty" name:"Vport"`
}

func NewActivateSubscribeRequest 

func NewActivateSubscribeRequest() (request *ActivateSubscribeRequest)

func (*ActivateSubscribeRequest) FromJsonString 

func (r *ActivateSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ActivateSubscribeRequest) ToJsonString 

func (r *ActivateSubscribeRequest) ToJsonString() string

type ActivateSubscribeResponse 

type ActivateSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Data subscription configuration task ID.
		AsyncRequestId *string `json:"AsyncRequestId,omitempty" name:"AsyncRequestId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) ActivateSubscribe 

func (c *Client) ActivateSubscribe(request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)

ActivateSubscribe This API is used to configure a data subscription, which can be called only for subscription instances in unconfigured status.

error code that may be returned: 

INTERNALERROR = "InternalError"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) ActivateSubscribeWithContext 

func (c *Client) ActivateSubscribeWithContext(ctx context.Context, request *ActivateSubscribeRequest) (response *ActivateSubscribeResponse, err error)

ActivateSubscribe This API is used to configure a data subscription, which can be called only for subscription instances in unconfigured status.

error code that may be returned: 

INTERNALERROR = "InternalError"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) CompleteMigrateJob 

func (c *Client) CompleteMigrateJob(request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)

CompleteMigrateJob This API (CompleteMigrateJob) is used to complete a data migration task.

For tasks in incremental migration mode, you need to call this API before migration gets ready, so as to stop migrating incremental data.

If the task status queried through the (DescribeMigrateJobs) API is ready (status=8), you can call this API to complete the migration task.

error code that may be returned: 

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_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CompleteMigrateJobWithContext 

func (c *Client) CompleteMigrateJobWithContext(ctx context.Context, request *CompleteMigrateJobRequest) (response *CompleteMigrateJobResponse, err error)

CompleteMigrateJob This API (CompleteMigrateJob) is used to complete a data migration task.

For tasks in incremental migration mode, you need to call this API before migration gets ready, so as to stop migrating incremental data.

If the task status queried through the (DescribeMigrateJobs) API is ready (status=8), you can call this API to complete the migration task.

error code that may be returned: 

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_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CreateMigrateCheckJob 

func (c *Client) CreateMigrateCheckJob(request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)

CreateMigrateCheckJob This API is used to create a migration check task.

Before migration, you should call this API to create a check. Migration will start only if the check succeeds. You can view the check result through the `DescribeMigrateCheckJob` API.

After successful check, if the migration task needs to be modified, a new check task should be created and migration will begin only after the new check succeeds.

For a finance zone link, use the domain name https://dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError"
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"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CreateMigrateCheckJobWithContext 

func (c *Client) CreateMigrateCheckJobWithContext(ctx context.Context, request *CreateMigrateCheckJobRequest) (response *CreateMigrateCheckJobResponse, err error)

CreateMigrateCheckJob This API is used to create a migration check task.

Before migration, you should call this API to create a check. Migration will start only if the check succeeds. You can view the check result through the `DescribeMigrateCheckJob` API.

After successful check, if the migration task needs to be modified, a new check task should be created and migration will begin only after the new check succeeds.

For a finance zone link, use the domain name https://dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError"
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"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CreateMigrateJob 

func (c *Client) CreateMigrateJob(request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)

CreateMigrateJob This API (CreateMigrateJob) is used to create a data migration task.

For a finance zone linkage, please use the domain name dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CreateMigrateJobWithContext 

func (c *Client) CreateMigrateJobWithContext(ctx context.Context, request *CreateMigrateJobRequest) (response *CreateMigrateJobResponse, err error)

CreateMigrateJob This API (CreateMigrateJob) is used to create a data migration task.

For a finance zone linkage, please use the domain name dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) CreateSubscribe 

func (c *Client) CreateSubscribe(request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)

CreateSubscribe This API is used to create a data subscription instance.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"

func (*Client) CreateSubscribeWithContext 

func (c *Client) CreateSubscribeWithContext(ctx context.Context, request *CreateSubscribeRequest) (response *CreateSubscribeResponse, err error)

CreateSubscribe This API is used to create a data subscription instance.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"

func (*Client) DeleteMigrateJob 

func (c *Client) DeleteMigrateJob(request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)

DeleteMigrateJob This API (DeleteMigrationJob) is used to delete a data migration task. If the task status queried through the DescribeMigrateJobs API is checking (status=3), running (status=7), ready (status=8), canceling (status=11), or completing (status=12), the task cannot be deleted.

error code that may be returned: 

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_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError"
OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) DeleteMigrateJobWithContext 

func (c *Client) DeleteMigrateJobWithContext(ctx context.Context, request *DeleteMigrateJobRequest) (response *DeleteMigrateJobResponse, err error)

DeleteMigrateJob This API (DeleteMigrationJob) is used to delete a data migration task. If the task status queried through the DescribeMigrateJobs API is checking (status=3), running (status=7), ready (status=8), canceling (status=11), or completing (status=12), the task cannot be deleted.

error code that may be returned: 

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_JOBOPERATIONDENIEDERROR = "OperationDenied.JobOperationDeniedError"
OPERATIONDENIED_MIGRATESERVICESUPPORTERROR = "OperationDenied.MigrateServiceSupportError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) DescribeAsyncRequestInfo 

func (c *Client) DescribeAsyncRequestInfo(request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)

DescribeAsyncRequestInfo This API is used to query the execution result of a task.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeAsyncRequestInfoWithContext 

func (c *Client) DescribeAsyncRequestInfoWithContext(ctx context.Context, request *DescribeAsyncRequestInfoRequest) (response *DescribeAsyncRequestInfoResponse, err error)

DescribeAsyncRequestInfo This API is used to query the execution result of a task.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED_BIZOPERATIONDENIEDERROR = "OperationDenied.BizOperationDeniedError"
OPERATIONDENIED_OPERATIONDENIED = "OperationDenied.OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeMigrateCheckJob 

func (c *Client) DescribeMigrateCheckJob(request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)

DescribeMigrateCheckJob This API is used to get the check result and query check status and progress after a check is created.

If the check succeeds, you can call the StartMigrateJob API to start migration.

If the check fails, the reason can be queried. Please modify the migration configuration or adjust relevant parameters of the source/target instances through the ModifyMigrateJob API based on the error message.

error code that may be returned: 

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 

func (c *Client) DescribeMigrateCheckJobWithContext(ctx context.Context, request *DescribeMigrateCheckJobRequest) (response *DescribeMigrateCheckJobResponse, err error)

DescribeMigrateCheckJob This API is used to get the check result and query check status and progress after a check is created.

If the check succeeds, you can call the StartMigrateJob API to start migration.

If the check fails, the reason can be queried. Please modify the migration configuration or adjust relevant parameters of the source/target instances through the ModifyMigrateJob API based on the error message.

error code that may be returned: 

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 This API is used to query data migration tasks.

For a finance zone linkage, please use the domain name https://dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError"
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError"
INVALIDPARAMETER = "InvalidParameter"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) DescribeMigrateJobsWithContext 

func (c *Client) DescribeMigrateJobsWithContext(ctx context.Context, request *DescribeMigrateJobsRequest) (response *DescribeMigrateJobsResponse, err error)

DescribeMigrateJobs This API is used to query data migration tasks.

For a finance zone linkage, please use the domain name https://dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INTERNALERROR_UNDEFINEDERROR = "InternalError.UndefinedError"
INTERNALERROR_UNKNOWNERROR = "InternalError.UnknownError"
INVALIDPARAMETER = "InvalidParameter"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) DescribeRegionConf 

func (c *Client) DescribeRegionConf(request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)

DescribeRegionConf This API is used to query the purchasable subscription instance regions.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeRegionConfWithContext 

func (c *Client) DescribeRegionConfWithContext(ctx context.Context, request *DescribeRegionConfRequest) (response *DescribeRegionConfResponse, err error)

DescribeRegionConf This API is used to query the purchasable subscription instance regions.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) DescribeSubscribeConf 

func (c *Client) DescribeSubscribeConf(request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)

DescribeSubscribeConf This API is used to query the subscription instance configuration.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound"

func (*Client) DescribeSubscribeConfWithContext 

func (c *Client) DescribeSubscribeConfWithContext(ctx context.Context, request *DescribeSubscribeConfRequest) (response *DescribeSubscribeConfResponse, err error)

DescribeSubscribeConf This API is used to query the subscription instance configuration.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETERVALUE_INVALIDPARAMETERVALUE = "InvalidParameterValue.InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
RESOURCENOTFOUND_RESOURCENOTFOUND = "ResourceNotFound.ResourceNotFound"

func (*Client) DescribeSubscribes 

func (c *Client) DescribeSubscribes(request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)

DescribeSubscribes This API is used to get the information list of data subscription instances. Pagination is enabled by default with 20 results returned each time.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"

func (*Client) DescribeSubscribesWithContext 

func (c *Client) DescribeSubscribesWithContext(ctx context.Context, request *DescribeSubscribesRequest) (response *DescribeSubscribesResponse, err error)

DescribeSubscribes This API is used to get the information list of data subscription instances. Pagination is enabled by default with 20 results returned each time.

error code that may be returned: 

AUTHFAILURE_UNAUTHORIZEDOPERATIONERROR = "AuthFailure.UnauthorizedOperationError"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"

func (*Client) IsolateSubscribe 

func (c *Client) IsolateSubscribe(request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)

IsolateSubscribe This API is used to isolate an hourly billed subscription instance. After this API is called, the instance will become unavailable and billing will stop for it.

error code that may be returned: 

INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) IsolateSubscribeWithContext 

func (c *Client) IsolateSubscribeWithContext(ctx context.Context, request *IsolateSubscribeRequest) (response *IsolateSubscribeResponse, err error)

IsolateSubscribe This API is used to isolate an hourly billed subscription instance. After this API is called, the instance will become unavailable and billing will stop for it.

error code that may be returned: 

INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_BIZINVALIDPARAMETERVALUEERROR = "InvalidParameter.BizInvalidParameterValueError"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) ModifyMigrateJob 

func (c *Client) ModifyMigrateJob(request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)

ModifyMigrateJob This API (ModifyMigrateJob) is used to modify a data migration task.

If the status of a migration task is creating (status=1), check succeeded (status=4), check failed (status=5), or migration failed (status=10), this API can be called to modify the task, but the type of the source and target instances and the region of the target instance cannot be modified.

For a finance zone linkage, please use the domain name dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) ModifyMigrateJobWithContext 

func (c *Client) ModifyMigrateJobWithContext(ctx context.Context, request *ModifyMigrateJobRequest) (response *ModifyMigrateJobResponse, err error)

ModifyMigrateJob This API (ModifyMigrateJob) is used to modify a data migration task.

If the status of a migration task is creating (status=1), check succeeded (status=4), check failed (status=5), or migration failed (status=10), this API can be called to modify the task, but the type of the source and target instances and the region of the target instance cannot be modified.

For a finance zone linkage, please use the domain name dts.ap-shenzhen-fsi.tencentcloudapi.com.

error code that may be returned: 

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) ModifySubscribeConsumeTime 

func (c *Client) ModifySubscribeConsumeTime(request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)

ModifySubscribeConsumeTime This API is used to modify the consumption time point of a data subscription channel.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifySubscribeConsumeTimeWithContext 

func (c *Client) ModifySubscribeConsumeTimeWithContext(ctx context.Context, request *ModifySubscribeConsumeTimeRequest) (response *ModifySubscribeConsumeTimeResponse, err error)

ModifySubscribeConsumeTime This API is used to modify the consumption time point of a data subscription channel.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifySubscribeName 

func (c *Client) ModifySubscribeName(request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)

ModifySubscribeName This API is used to rename a data subscription instance.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifySubscribeNameWithContext 

func (c *Client) ModifySubscribeNameWithContext(ctx context.Context, request *ModifySubscribeNameRequest) (response *ModifySubscribeNameResponse, err error)

ModifySubscribeName This API is used to rename a data subscription instance.

error code that may be returned: 

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifySubscribeObjects 

func (c *Client) ModifySubscribeObjects(request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)

ModifySubscribeObjects This API is used to modify the subscription rule of a data subscription channel.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"

func (*Client) ModifySubscribeObjectsWithContext 

func (c *Client) ModifySubscribeObjectsWithContext(ctx context.Context, request *ModifySubscribeObjectsRequest) (response *ModifySubscribeObjectsResponse, err error)

ModifySubscribeObjects This API is used to modify the subscription rule of a data subscription channel.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_BIZRESOURCENOTFOUNDERROR = "ResourceNotFound.BizResourceNotFoundError"

func (*Client) ModifySubscribeVipVport 

func (c *Client) ModifySubscribeVipVport(request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)

ModifySubscribeVipVport This API is used to modify the IP and port number of a data subscription instance.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ModifySubscribeVipVportWithContext 

func (c *Client) ModifySubscribeVipVportWithContext(ctx context.Context, request *ModifySubscribeVipVportRequest) (response *ModifySubscribeVipVportResponse, err error)

ModifySubscribeVipVport This API is used to modify the IP and port number of a data subscription instance.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) OfflineIsolatedSubscribe 

func (c *Client) OfflineIsolatedSubscribe(request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)

OfflineIsolatedSubscribe This API is used to deactivate an isolated data subscription instance.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) OfflineIsolatedSubscribeWithContext 

func (c *Client) OfflineIsolatedSubscribeWithContext(ctx context.Context, request *OfflineIsolatedSubscribeRequest) (response *OfflineIsolatedSubscribeResponse, err error)

OfflineIsolatedSubscribe This API is used to deactivate an isolated data subscription instance.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ResetSubscribe 

func (c *Client) ResetSubscribe(request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)

ResetSubscribe This API is used to reset a data subscription instance. Once reset, an activated instance can be bound to other database instances through the `ActivateSubscribe` API.

error code that may be returned: 

FAILEDOPERATION_STATUSINCONFLICT = "FailedOperation.StatusInConflict"
INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) ResetSubscribeWithContext 

func (c *Client) ResetSubscribeWithContext(ctx context.Context, request *ResetSubscribeRequest) (response *ResetSubscribeResponse, err error)

ResetSubscribe This API is used to reset a data subscription instance. Once reset, an activated instance can be bound to other database instances through the `ActivateSubscribe` API.

error code that may be returned: 

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 This API (StartMigrationJob) is used to start a migration task. After the API is called, non-scheduled migration tasks will start the migration immediately, while scheduled tasks will start the countdown.

Before calling this API, be sure to use the CreateMigrateCheckJob API to check the data migration task, which can be started only if its status queried through the DescribeMigrateJobs API is check succeeded (status=4).

error code that may be returned: 

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_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"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) StartMigrateJobWithContext 

func (c *Client) StartMigrateJobWithContext(ctx context.Context, request *StartMigrateJobRequest) (response *StartMigrateJobResponse, err error)

StartMigrateJob This API (StartMigrationJob) is used to start a migration task. After the API is called, non-scheduled migration tasks will start the migration immediately, while scheduled tasks will start the countdown.

Before calling this API, be sure to use the CreateMigrateCheckJob API to check the data migration task, which can be started only if its status queried through the DescribeMigrateJobs API is check succeeded (status=4).

error code that may be returned: 

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_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"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"
UNAUTHORIZEDOPERATION_NOTENOUGHPRIVILEGES = "UnauthorizedOperation.NotEnoughPrivileges"

func (*Client) StopMigrateJob 

func (c *Client) StopMigrateJob(request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)

StopMigrateJob This API (StopMigrateJob) is used to cancel a data migration task.

During migration, this API can be used to cancel migration if the task status queried through the DescribeMigrateJobs API is running (status=7) or ready (status=8), and the migration task will fail.

error code that may be returned: 

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 

func (c *Client) StopMigrateJobWithContext(ctx context.Context, request *StopMigrateJobRequest) (response *StopMigrateJobResponse, err error)

StopMigrateJob This API (StopMigrateJob) is used to cancel a data migration task.

During migration, this API can be used to cancel migration if the task status queried through the DescribeMigrateJobs API is running (status=7) or ready (status=8), and the migration task will fail.

error code that may be returned: 

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

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// The way to complete the task, which is supported only for legacy MySQL migration task. waitForSync: wait for the source-replica lag to become 0 before stopping; immediately: complete immediately without waiting for source-replica sync. Default value: waitForSync
	CompleteMode *string `json:"CompleteMode,omitempty" name:"CompleteMode"`
}

func NewCompleteMigrateJobRequest 

func NewCompleteMigrateJobRequest() (request *CompleteMigrateJobRequest)

func (*CompleteMigrateJobRequest) FromJsonString 

func (r *CompleteMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CompleteMigrateJobRequest) ToJsonString 

func (r *CompleteMigrateJobRequest) ToJsonString() string

type CompleteMigrateJobResponse 

type CompleteMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ConsistencyParams 

type ConsistencyParams struct {

	// Data content check parameter, which refers to the proportion of the rows selected for data comparison in all the rows of the table. Value: an integer between 1 and 100.
	SelectRowsPerTable *int64 `json:"SelectRowsPerTable,omitempty" name:"SelectRowsPerTable"`

	// Data content check parameter, which refers to the proportion of the tables selected for data detection in all the tables. Value: an integer between 1 and 100.
	TablesSelectAll *int64 `json:"TablesSelectAll,omitempty" name:"TablesSelectAll"`

	// Data quantity check parameter, which checks whether the numbers of rows are identical. It refers to the proportion of the tables selected for quantity check in all the tables. Value: an integer between 1 and 100.
	TablesSelectCount *int64 `json:"TablesSelectCount,omitempty" name:"TablesSelectCount"`
}

type CreateMigrateCheckJobRequest 

type CreateMigrateCheckJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewCreateMigrateCheckJobRequest 

func NewCreateMigrateCheckJobRequest() (request *CreateMigrateCheckJobRequest)

func (*CreateMigrateCheckJobRequest) FromJsonString 

func (r *CreateMigrateCheckJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateMigrateCheckJobRequest) ToJsonString 

func (r *CreateMigrateCheckJobRequest) ToJsonString() string

type CreateMigrateCheckJobResponse 

type CreateMigrateCheckJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 CreateMigrateJobRequest 

type CreateMigrateJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Migration task configuration options
	MigrateOption *MigrateOption `json:"MigrateOption,omitempty" name:"MigrateOption"`

	// Source instance database type, which currently supports MySQL, Redis, MongoDB, PostgreSQL, MariaDB, Percona, and SQL Server. For more information on the supported types in a specific region, see the migration task creation page in the console.
	SrcDatabaseType *string `json:"SrcDatabaseType,omitempty" name:"SrcDatabaseType"`

	// Source instance access type. Valid values: extranet (public network), cvm (CVM-based self-created instance), dcg (Direct Connect-enabled instance), vpncloud (Tencent Cloud VPN-enabled instance), cdb (TencentDB instance), ccn (CCN instance)
	SrcAccessType *string `json:"SrcAccessType,omitempty" name:"SrcAccessType"`

	// Source instance information, which is correlated with the migration task type
	SrcInfo *SrcInfo `json:"SrcInfo,omitempty" name:"SrcInfo"`

	// Target instance access type, which currently supports MySQL, Redis, MongoDB, PostgreSQL, MariaDB, and Percona, SQL Server, and TDSQL-C for MySQL. For more information on the supported types in a specific region, see the migration task creation page in the console.
	DstDatabaseType *string `json:"DstDatabaseType,omitempty" name:"DstDatabaseType"`

	// Target instance access type, which currently only supports cdb (TencentDB instance)
	DstAccessType *string `json:"DstAccessType,omitempty" name:"DstAccessType"`

	// Destination instance information
	DstInfo *DstInfo `json:"DstInfo,omitempty" name:"DstInfo"`

	// Information of the source table to be migrated, which is described in JSON string format. It is required if MigrateOption.MigrateObject is 2 (migrating the specified table).
	// For databases with a database-table structure:
	// [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}]
	// For databases with a database-schema-table structure:
	// [{"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,omitempty" name:"DatabaseInfo"`

	// Tag of the instance to be migrated.
	Tags []*TagItem `json:"Tags,omitempty" name:"Tags"`

	// Source instance type. `simple`: Primary/Secondary node; `cluster`: Cluster node. If this field is left empty, the value defaults to primary/secondary node.
	SrcNodeType *string `json:"SrcNodeType,omitempty" name:"SrcNodeType"`

	// Source instance information, which is correlated with the migration task type.
	SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitempty" name:"SrcInfoMulti"`
}

func NewCreateMigrateJobRequest 

func NewCreateMigrateJobRequest() (request *CreateMigrateJobRequest)

func (*CreateMigrateJobRequest) FromJsonString 

func (r *CreateMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateMigrateJobRequest) ToJsonString 

func (r *CreateMigrateJobRequest) ToJsonString() string

type CreateMigrateJobResponse 

type CreateMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Data migration task ID
		JobId *string `json:"JobId,omitempty" name:"JobId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 CreateSubscribeRequest 

type CreateSubscribeRequest struct {
	*tchttp.BaseRequest

	// Subscribed database type. Currently, MySQL is supported
	Product *string `json:"Product,omitempty" name:"Product"`

	// Instance billing mode, which is always 1 (hourly billing),
	PayType *int64 `json:"PayType,omitempty" name:"PayType"`

	// Purchase duration in months, which is required if `PayType` is 0. Maximum value: 120 (this field is not required of global site users and is better to be hidden)
	Duration *int64 `json:"Duration,omitempty" name:"Duration"`

	// Quantity. Default value: 1. Maximum value: 10
	Count *int64 `json:"Count,omitempty" name:"Count"`

	// Whether to auto-renew. Default value: 0. This flag does not take effect for hourly billed instances (this field should be hidden from global site users)
	AutoRenew *int64 `json:"AutoRenew,omitempty" name:"AutoRenew"`

	// Instance resource tags
	Tags []*TagItem `json:"Tags,omitempty" name:"Tags"`

	// A custom instance name.
	Name *string `json:"Name,omitempty" name:"Name"`
}

func NewCreateSubscribeRequest 

func NewCreateSubscribeRequest() (request *CreateSubscribeRequest)

func (*CreateSubscribeRequest) FromJsonString 

func (r *CreateSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateSubscribeRequest) ToJsonString 

func (r *CreateSubscribeRequest) ToJsonString() string

type CreateSubscribeResponse 

type CreateSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Data subscription instance ID array
		// Note: this field may return null, indicating that no valid values can be obtained.
		SubscribeIds []*string `json:"SubscribeIds,omitempty" name:"SubscribeIds"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DeleteMigrateJobRequest 

type DeleteMigrateJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewDeleteMigrateJobRequest 

func NewDeleteMigrateJobRequest() (request *DeleteMigrateJobRequest)

func (*DeleteMigrateJobRequest) FromJsonString 

func (r *DeleteMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteMigrateJobRequest) ToJsonString 

func (r *DeleteMigrateJobRequest) ToJsonString() string

type DeleteMigrateJobResponse 

type DeleteMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DescribeAsyncRequestInfoRequest 

type DescribeAsyncRequestInfoRequest struct {
	*tchttp.BaseRequest

	// Task ID
	AsyncRequestId *string `json:"AsyncRequestId,omitempty" name:"AsyncRequestId"`
}

func NewDescribeAsyncRequestInfoRequest 

func NewDescribeAsyncRequestInfoRequest() (request *DescribeAsyncRequestInfoRequest)

func (*DescribeAsyncRequestInfoRequest) FromJsonString 

func (r *DescribeAsyncRequestInfoRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeAsyncRequestInfoRequest) ToJsonString 

func (r *DescribeAsyncRequestInfoRequest) ToJsonString() string

type DescribeAsyncRequestInfoResponse 

type DescribeAsyncRequestInfoResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Task execution result information
		Info *string `json:"Info,omitempty" name:"Info"`

		// Task execution status. Valid values: success, failed, running
		Status *string `json:"Status,omitempty" name:"Status"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DescribeMigrateCheckJobRequest 

type DescribeMigrateCheckJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewDescribeMigrateCheckJobRequest 

func NewDescribeMigrateCheckJobRequest() (request *DescribeMigrateCheckJobRequest)

func (*DescribeMigrateCheckJobRequest) FromJsonString 

func (r *DescribeMigrateCheckJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeMigrateCheckJobRequest) ToJsonString 

func (r *DescribeMigrateCheckJobRequest) ToJsonString() string

type DescribeMigrateCheckJobResponse 

type DescribeMigrateCheckJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Check task status: unavailable, starting, running, finished
		Status *string `json:"Status,omitempty" name:"Status"`

		// Task error code
		ErrorCode *int64 `json:"ErrorCode,omitempty" name:"ErrorCode"`

		// Task error message
		ErrorMessage *string `json:"ErrorMessage,omitempty" name:"ErrorMessage"`

		// Check task progress. For example, "30" means 30% completed
		Progress *string `json:"Progress,omitempty" name:"Progress"`

		// Whether the check succeeds. 0: no; 1: yes; 3: not checked
		CheckFlag *int64 `json:"CheckFlag,omitempty" name:"CheckFlag"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DescribeMigrateJobsRequest 

type DescribeMigrateJobsRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Data migration task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Sort by field. Value range: JobId, Status, JobName, MigrateType, RunMode, CreateTime
	Order *string `json:"Order,omitempty" name:"Order"`

	// Sorting order. Value range: ASC (ascending), DESC (descending)
	OrderSeq *string `json:"OrderSeq,omitempty" name:"OrderSeq"`

	// Offset. Default value: 0
	Offset *uint64 `json:"Offset,omitempty" name:"Offset"`

	// Number of the returned instances. Value range: [1, 100]. Default value: 20
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// Tag filter.
	TagFilters []*TagFilter `json:"TagFilters,omitempty" name:"TagFilters"`
}

func NewDescribeMigrateJobsRequest 

func NewDescribeMigrateJobsRequest() (request *DescribeMigrateJobsRequest)

func (*DescribeMigrateJobsRequest) FromJsonString 

func (r *DescribeMigrateJobsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeMigrateJobsRequest) ToJsonString 

func (r *DescribeMigrateJobsRequest) ToJsonString() string

type DescribeMigrateJobsResponse 

type DescribeMigrateJobsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of tasks
		TotalCount *uint64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Array of task details
		JobList []*MigrateJobInfo `json:"JobList,omitempty" name:"JobList"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 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 DescribeRegionConfResponse 

type DescribeRegionConfResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of purchasable regions
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Purchasable region details
		Items []*SubscribeRegionConf `json:"Items,omitempty" name:"Items"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DescribeSubscribeConfRequest 

type DescribeSubscribeConfRequest struct {
	*tchttp.BaseRequest

	// Subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`
}

func NewDescribeSubscribeConfRequest 

func NewDescribeSubscribeConfRequest() (request *DescribeSubscribeConfRequest)

func (*DescribeSubscribeConfRequest) FromJsonString 

func (r *DescribeSubscribeConfRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscribeConfRequest) ToJsonString 

func (r *DescribeSubscribeConfRequest) ToJsonString() string

type DescribeSubscribeConfResponse 

type DescribeSubscribeConfResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Subscription instance ID
		SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

		// Subscription instance name
		SubscribeName *string `json:"SubscribeName,omitempty" name:"SubscribeName"`

		// Subscription channel
		ChannelId *string `json:"ChannelId,omitempty" name:"ChannelId"`

		// Subscribed database type
		Product *string `json:"Product,omitempty" name:"Product"`

		// Subscribed instance
		InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

		// Subscribed instance status. Valid values: running, offline, isolate
		InstanceStatus *string `json:"InstanceStatus,omitempty" name:"InstanceStatus"`

		// Subscription instance status. Valid values: unconfigure, configuring, configured
		SubsStatus *string `json:"SubsStatus,omitempty" name:"SubsStatus"`

		// Subscription instance lifecycle status. Valid values: normal, isolating, isolated, offlining
		Status *string `json:"Status,omitempty" name:"Status"`

		// Subscription instance creation time
		CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

		// Subscription instance isolation time
		IsolateTime *string `json:"IsolateTime,omitempty" name:"IsolateTime"`

		// Subscription instance expiration time
		ExpireTime *string `json:"ExpireTime,omitempty" name:"ExpireTime"`

		// Subscription instance deactivation time
		OfflineTime *string `json:"OfflineTime,omitempty" name:"OfflineTime"`

		// Consumption starting time point of subscription instance
		ConsumeStartTime *string `json:"ConsumeStartTime,omitempty" name:"ConsumeStartTime"`

		// Subscription instance billing mode. 1: hourly billing
		PayType *int64 `json:"PayType,omitempty" name:"PayType"`

		// Subscription channel VIP
		Vip *string `json:"Vip,omitempty" name:"Vip"`

		// Subscription channel port
		Vport *int64 `json:"Vport,omitempty" name:"Vport"`

		// Subscription channel `VpcId`
		UniqVpcId *string `json:"UniqVpcId,omitempty" name:"UniqVpcId"`

		// Subscription channel `SubnetId`
		UniqSubnetId *string `json:"UniqSubnetId,omitempty" name:"UniqSubnetId"`

		// Current SDK consumption time point
		SdkConsumedTime *string `json:"SdkConsumedTime,omitempty" name:"SdkConsumedTime"`

		// Subscription SDK IP address
		SdkHost *string `json:"SdkHost,omitempty" name:"SdkHost"`

		// Subscription object type. 0: full instance subscription, 1: DDL data subscription, 2: DML structure subscription, 3: DDL data subscription + DML structure subscription
		SubscribeObjectType *int64 `json:"SubscribeObjectType,omitempty" name:"SubscribeObjectType"`

		// Subscription object, which is an empty array if `SubscribeObjectType` is 0
		SubscribeObjects []*SubscribeObject `json:"SubscribeObjects,omitempty" name:"SubscribeObjects"`

		// Modification time
		ModifyTime *string `json:"ModifyTime,omitempty" name:"ModifyTime"`

		// Region
		Region *string `json:"Region,omitempty" name:"Region"`

		// Tags of the subscription
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		Tags []*TagItem `json:"Tags,omitempty" name:"Tags"`

		// Whether auto-renewal is enabled. 0: do not enable, 1: enable
		// Note: this field may return `null`, indicating that no valid values can be obtained.
		AutoRenewFlag *int64 `json:"AutoRenewFlag,omitempty" name:"AutoRenewFlag"`

		// Data subscription edition. `txdts`: Legacy edition; `kafka`: Kafka edition.
		SubscribeVersion *string `json:"SubscribeVersion,omitempty" name:"SubscribeVersion"`

		// Error message.
		// Note: This field may return `null`, indicating that no valid values can be obtained.
		Errors []*SubsErr `json:"Errors,omitempty" name:"Errors"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DescribeSubscribesRequest 

type DescribeSubscribesRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Data subscription instance name
	SubscribeName *string `json:"SubscribeName,omitempty" name:"SubscribeName"`

	// ID of bound database instance
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

	// Data subscription instance channel ID
	ChannelId *string `json:"ChannelId,omitempty" name:"ChannelId"`

	// Billing mode filter. Default value: 1 (pay-as-you-go)
	PayType *string `json:"PayType,omitempty" name:"PayType"`

	// Subscribed database product, such as MySQL
	Product *string `json:"Product,omitempty" name:"Product"`

	// Data subscription instance status. Valid values: creating, normal, isolating, isolated, offlining
	Status []*string `json:"Status,omitempty" name:"Status"`

	// Data subscription instance configuration status. Valid values: unconfigure, configuring, configured
	SubsStatus []*string `json:"SubsStatus,omitempty" name:"SubsStatus"`

	// Starting offset of returned results
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// Number of results to be returned at a time
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// Sorting order. Valid values: DESC, ASC. Default value: DESC, indicating descending by creation time
	OrderDirection *string `json:"OrderDirection,omitempty" name:"OrderDirection"`

	// Tag filtering condition
	TagFilters []*TagFilter `json:"TagFilters,omitempty" name:"TagFilters"`

	// Subscription instance edition. `txdts`: legacy data subscription; `kafka`: data subscription in Kafka edition
	SubscribeVersion *string `json:"SubscribeVersion,omitempty" name:"SubscribeVersion"`
}

func NewDescribeSubscribesRequest 

func NewDescribeSubscribesRequest() (request *DescribeSubscribesRequest)

func (*DescribeSubscribesRequest) FromJsonString 

func (r *DescribeSubscribesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSubscribesRequest) ToJsonString 

func (r *DescribeSubscribesRequest) ToJsonString() string

type DescribeSubscribesResponse 

type DescribeSubscribesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Number of eligible instances.
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// Information list of data subscription instances
		Items []*SubscribeInfo `json:"Items,omitempty" name:"Items"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 DstInfo 

type DstInfo struct {

	// Target instance ID, such as cdb-jd92ijd8
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

	// Target instance region, such as ap-guangzhou
	Region *string `json:"Region,omitempty" name:"Region"`

	// Target instance VIP, which has been disused and does not need to be entered
	Ip *string `json:"Ip,omitempty" name:"Ip"`

	// Target instance Vport, which has been disused and does not need to be entered
	Port *int64 `json:"Port,omitempty" name:"Port"`

	// Only valid for MySQL currently. For instance-level migration, the value range is: 1 (read-only), 0 (read/write)
	ReadOnly *int64 `json:"ReadOnly,omitempty" name:"ReadOnly"`

	// Target database account
	User *string `json:"User,omitempty" name:"User"`

	// Target database password
	Password *string `json:"Password,omitempty" name:"Password"`
}

type ErrorInfo 

type ErrorInfo struct {

	// Specific error log, including error code and error message
	ErrorLog *string `json:"ErrorLog,omitempty" name:"ErrorLog"`

	// Help document URL corresponding to error
	HelpDoc *string `json:"HelpDoc,omitempty" name:"HelpDoc"`
}

type IsolateSubscribeRequest 

type IsolateSubscribeRequest struct {
	*tchttp.BaseRequest

	// Subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`
}

func NewIsolateSubscribeRequest 

func NewIsolateSubscribeRequest() (request *IsolateSubscribeRequest)

func (*IsolateSubscribeRequest) FromJsonString 

func (r *IsolateSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*IsolateSubscribeRequest) ToJsonString 

func (r *IsolateSubscribeRequest) ToJsonString() string

type IsolateSubscribeResponse 

type IsolateSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 MigrateDetailInfo 

type MigrateDetailInfo struct {

	// Total number of steps
	StepAll *int64 `json:"StepAll,omitempty" name:"StepAll"`

	// Current step
	StepNow *int64 `json:"StepNow,omitempty" name:"StepNow"`

	// Overall progress, such as "10"
	Progress *string `json:"Progress,omitempty" name:"Progress"`

	// Progress of current step, such as "1"
	CurrentStepProgress *string `json:"CurrentStepProgress,omitempty" name:"CurrentStepProgress"`

	// Master/slave lag in MB, which is valid during incremental sync and currently supported by TencentDB for Redis and MySQL
	MasterSlaveDistance *int64 `json:"MasterSlaveDistance,omitempty" name:"MasterSlaveDistance"`

	// Master/slave lag in seconds, which is valid during incremental sync and currently supported by TencentDB for MySQL
	SecondsBehindMaster *int64 `json:"SecondsBehindMaster,omitempty" name:"SecondsBehindMaster"`

	// Step information
	StepInfo []*MigrateStepDetailInfo `json:"StepInfo,omitempty" name:"StepInfo"`
}

type MigrateJobInfo 

type MigrateJobInfo struct {

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Data migration task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Migration task configuration options
	MigrateOption *MigrateOption `json:"MigrateOption,omitempty" name:"MigrateOption"`

	// Source instance database type: MySQL, Redis, MongoDB, PostgreSQL, MariaDB, Percona
	SrcDatabaseType *string `json:"SrcDatabaseType,omitempty" name:"SrcDatabaseType"`

	// Source instance access type. Value range: extranet (public network), cvm (CVM-created instance), dcg (Direct Connect-enabled instance), vpncloud (Tencent Cloud VPN-enabled instance), cdb (TencentDB instance), ccn (CCN instances)
	SrcAccessType *string `json:"SrcAccessType,omitempty" name:"SrcAccessType"`

	// Source instance information, which is correlated with the migration task type
	SrcInfo *SrcInfo `json:"SrcInfo,omitempty" name:"SrcInfo"`

	// Target instance access type: MySQL, Redis, MongoDB, PostgreSQL, MariaDB, Percona
	DstDatabaseType *string `json:"DstDatabaseType,omitempty" name:"DstDatabaseType"`

	// Target instance access type, which currently only supports cdb (TencentDB instance)
	DstAccessType *string `json:"DstAccessType,omitempty" name:"DstAccessType"`

	// Target instance information
	DstInfo *DstInfo `json:"DstInfo,omitempty" name:"DstInfo"`

	// Information of the source table to be migrated. If the entire instance is to be migrated, this field should be []
	DatabaseInfo *string `json:"DatabaseInfo,omitempty" name:"DatabaseInfo"`

	// Task creation/submission time
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Task start time
	StartTime *string `json:"StartTime,omitempty" name:"StartTime"`

	// Task end time
	EndTime *string `json:"EndTime,omitempty" name:"EndTime"`

	// Task status. Value range: 1 (Creating), 3 (Checking), 4 (CheckPass), 5 (CheckNotPass), 7 (Running), 8 (ReadyComplete), 9 (Success), 10 (Failed), 11 (Stopping), 12 (Completing)
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// Task details
	Detail *MigrateDetailInfo `json:"Detail,omitempty" name:"Detail"`

	// Prompt message for task error, which is not null or empty when an error occurs with the task
	ErrorInfo []*ErrorInfo `json:"ErrorInfo,omitempty" name:"ErrorInfo"`

	// Tag
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	Tags []*TagItem `json:"Tags,omitempty" name:"Tags"`

	// Information of the source instance, a cluster edition instance whose access type is not `cdb`.
	// Note: This field may return `null`, indicating that no valid values can be obtained.
	SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitempty" name:"SrcInfoMulti"`
}

type MigrateOption 

type MigrateOption struct {

	// Task operation mode. Value range: 1 (immediate execution), 2 (scheduled execution)
	RunMode *int64 `json:"RunMode,omitempty" name:"RunMode"`

	// Expected execution time in the format of yyyy-mm-dd hh:mm:ss. If runMode=2, this field is required
	ExpectTime *string `json:"ExpectTime,omitempty" name:"ExpectTime"`

	// Data migration type. Value range: 1 (structural migration), 2 (full migration), 3 (full + incremental migration)
	MigrateType *int64 `json:"MigrateType,omitempty" name:"MigrateType"`

	// Migration subject. 1: entire instance; 2: specified table
	MigrateObject *int64 `json:"MigrateObject,omitempty" name:"MigrateObject"`

	// Parameter of spot data consistency check. 1: not configured; 2: full check; 3: spot check; 4: check inconsistent tables only; 5: no check
	ConsistencyType *int64 `json:"ConsistencyType,omitempty" name:"ConsistencyType"`

	// Whether to overwrite the target database with the root account of the source database. Value range: 0 (no), 1 (yes). This value should be 0 for table or structural migration
	IsOverrideRoot *int64 `json:"IsOverrideRoot,omitempty" name:"IsOverrideRoot"`

	// Additional parameters for different databases, which are described in JSON format.
	// The following parameters can be defined for Redis:
	// {
	// 	"ClientOutputBufferHardLimit":512, 	Hard capacity limit of slave buffer (MB)
	// 	"ClientOutputBufferSoftLimit":512, 	Soft capacity limit of slave buffer (MB)
	// 	"ClientOutputBufferPersistTime":60, Soft limit duration of slave buffer (s)
	// 	"ReplBacklogSize":512, 	Circular buffer capacity limit (MB)
	// 	"ReplTimeout":120, 		Replication timeout period (s)
	// }
	// The following parameters can be defined for MongoDB:
	// {
	// 	'SrcAuthDatabase':'admin',
	// 	'SrcAuthFlag': "1",
	// 	'SrcAuthMechanism':"SCRAM-SHA-1"
	// }
	// MySQL currently does not support configuring additional parameters.
	ExternParams *string `json:"ExternParams,omitempty" name:"ExternParams"`

	// Only used for "spot data consistency check". It is required if ConsistencyType is spot check
	ConsistencyParams *ConsistencyParams `json:"ConsistencyParams,omitempty" name:"ConsistencyParams"`
}

type MigrateStepDetailInfo 

type MigrateStepDetailInfo struct {

	// Step number
	StepNo *int64 `json:"StepNo,omitempty" name:"StepNo"`

	// Step name
	StepName *string `json:"StepName,omitempty" name:"StepName"`

	// Step ID
	StepId *string `json:"StepId,omitempty" name:"StepId"`

	// Step status. Value range: 0 (default), 1 (succeeded), 2 (failed), 3 (in progress), 4 (not started)
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// Start time of current step in the format of `yyyy-mm-dd hh:mm:ss`. This field is meaningless if it does not exist or is empty
	// Note: this field may return null, indicating that no valid values can be obtained.
	StartTime *string `json:"StartTime,omitempty" name:"StartTime"`
}

type ModifyMigrateJobRequest 

type ModifyMigrateJobRequest struct {
	*tchttp.BaseRequest

	// ID of the data migration task to be modified
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Data migration task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Migration task configuration options
	MigrateOption *MigrateOption `json:"MigrateOption,omitempty" name:"MigrateOption"`

	// Source instance access type. Valid values: extranet (public network), cvm (CVM-based self-created instance), dcg (Direct Connect-enabled instance), vpncloud (Tencent Cloud VPN-enabled instance), cdb (TencentDB instance)
	SrcAccessType *string `json:"SrcAccessType,omitempty" name:"SrcAccessType"`

	// Source instance information, which is correlated with the migration task type
	SrcInfo *SrcInfo `json:"SrcInfo,omitempty" name:"SrcInfo"`

	// Target instance access type. Valid values: extranet (public network), cvm (CVM-based self-created instance), dcg (Direct Connect-enabled instance), vpncloud (Tencent Cloud VPN-enabled instance), cdb (TencentDB instance). Currently, only `cdb` is supported
	DstAccessType *string `json:"DstAccessType,omitempty" name:"DstAccessType"`

	// Target instance information. The region where the target instance is located cannot be modified.
	DstInfo *DstInfo `json:"DstInfo,omitempty" name:"DstInfo"`

	// When migrating the specified table, you need to set the information of the source database table to be migrated, which should be described in JSON string format. Below are examples.
	//
	// For databases with a database-table structure:
	// [{"Database":"db1","Table":["table1","table2"]},{"Database":"db2"}]
	// For databases with a database-schema-table structure:
	// [{"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"}]
	//
	// This field does not need to be set when the entire instance is to be migrated
	DatabaseInfo *string `json:"DatabaseInfo,omitempty" name:"DatabaseInfo"`

	// Source instance type. `simple`: Primary/Secondary node; `cluster`: Cluster node. If this field is left empty, the value defaults to primary/secondary node.
	SrcNodeType *string `json:"SrcNodeType,omitempty" name:"SrcNodeType"`

	// Source instance information, which is correlated with the migration task type.
	SrcInfoMulti []*SrcInfo `json:"SrcInfoMulti,omitempty" name:"SrcInfoMulti"`
}

func NewModifyMigrateJobRequest 

func NewModifyMigrateJobRequest() (request *ModifyMigrateJobRequest)

func (*ModifyMigrateJobRequest) FromJsonString 

func (r *ModifyMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifyMigrateJobRequest) ToJsonString 

func (r *ModifyMigrateJobRequest) ToJsonString() string

type ModifyMigrateJobResponse 

type ModifyMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ModifySubscribeConsumeTimeRequest 

type ModifySubscribeConsumeTimeRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Consumption starting time point in the format of `Y-m-d h:m:s`, i.e., the starting time point for data subscription. Value range: within the last 24 hours
	ConsumeStartTime *string `json:"ConsumeStartTime,omitempty" name:"ConsumeStartTime"`
}

func NewModifySubscribeConsumeTimeRequest 

func NewModifySubscribeConsumeTimeRequest() (request *ModifySubscribeConsumeTimeRequest)

func (*ModifySubscribeConsumeTimeRequest) FromJsonString 

func (r *ModifySubscribeConsumeTimeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscribeConsumeTimeRequest) ToJsonString 

func (r *ModifySubscribeConsumeTimeRequest) ToJsonString() string

type ModifySubscribeConsumeTimeResponse 

type ModifySubscribeConsumeTimeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ModifySubscribeNameRequest 

type ModifySubscribeNameRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Data subscription instance name. Length limit: [1,60]
	SubscribeName *string `json:"SubscribeName,omitempty" name:"SubscribeName"`
}

func NewModifySubscribeNameRequest 

func NewModifySubscribeNameRequest() (request *ModifySubscribeNameRequest)

func (*ModifySubscribeNameRequest) FromJsonString 

func (r *ModifySubscribeNameRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscribeNameRequest) ToJsonString 

func (r *ModifySubscribeNameRequest) ToJsonString() string

type ModifySubscribeNameResponse 

type ModifySubscribeNameResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ModifySubscribeObjectsRequest 

type ModifySubscribeObjectsRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Data subscription type. Valid values: 0 (full instance subscription), 1 (data subscription), 2 (structure subscription), 3 (data subscription + structure subscription)
	SubscribeObjectType *int64 `json:"SubscribeObjectType,omitempty" name:"SubscribeObjectType"`

	// Information of subscribed table
	Objects []*SubscribeObject `json:"Objects,omitempty" name:"Objects"`
}

func NewModifySubscribeObjectsRequest 

func NewModifySubscribeObjectsRequest() (request *ModifySubscribeObjectsRequest)

func (*ModifySubscribeObjectsRequest) FromJsonString 

func (r *ModifySubscribeObjectsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscribeObjectsRequest) ToJsonString 

func (r *ModifySubscribeObjectsRequest) ToJsonString() string

type ModifySubscribeObjectsResponse 

type ModifySubscribeObjectsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// Async task ID
		AsyncRequestId *string `json:"AsyncRequestId,omitempty" name:"AsyncRequestId"`

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ModifySubscribeVipVportRequest 

type ModifySubscribeVipVportRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Specified destination subnet. If this parameter is passed in, `DstIp` must be in the destination subnet
	DstUniqSubnetId *string `json:"DstUniqSubnetId,omitempty" name:"DstUniqSubnetId"`

	// Target IP. Either this field or `DstPort` must be passed in
	DstIp *string `json:"DstIp,omitempty" name:"DstIp"`

	// Target port. Value range: [1025-65535]
	DstPort *int64 `json:"DstPort,omitempty" name:"DstPort"`
}

func NewModifySubscribeVipVportRequest 

func NewModifySubscribeVipVportRequest() (request *ModifySubscribeVipVportRequest)

func (*ModifySubscribeVipVportRequest) FromJsonString 

func (r *ModifySubscribeVipVportRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ModifySubscribeVipVportRequest) ToJsonString 

func (r *ModifySubscribeVipVportRequest) ToJsonString() string

type ModifySubscribeVipVportResponse 

type ModifySubscribeVipVportResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 OfflineIsolatedSubscribeRequest 

type OfflineIsolatedSubscribeRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`
}

func NewOfflineIsolatedSubscribeRequest 

func NewOfflineIsolatedSubscribeRequest() (request *OfflineIsolatedSubscribeRequest)

func (*OfflineIsolatedSubscribeRequest) FromJsonString 

func (r *OfflineIsolatedSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*OfflineIsolatedSubscribeRequest) ToJsonString 

func (r *OfflineIsolatedSubscribeRequest) ToJsonString() string

type OfflineIsolatedSubscribeResponse 

type OfflineIsolatedSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 ResetSubscribeRequest 

type ResetSubscribeRequest struct {
	*tchttp.BaseRequest

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`
}

func NewResetSubscribeRequest 

func NewResetSubscribeRequest() (request *ResetSubscribeRequest)

func (*ResetSubscribeRequest) FromJsonString 

func (r *ResetSubscribeRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ResetSubscribeRequest) ToJsonString 

func (r *ResetSubscribeRequest) ToJsonString() string

type ResetSubscribeResponse 

type ResetSubscribeResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 SrcInfo 

type SrcInfo struct {

	// Alibaba Cloud AccessKey, which is applicable if the source database is an Alibaba Cloud ApsaraDB for RDS 5.6 instance
	AccessKey *string `json:"AccessKey,omitempty" name:"AccessKey"`

	// Instance IP address
	Ip *string `json:"Ip,omitempty" name:"Ip"`

	// Instance port
	Port *int64 `json:"Port,omitempty" name:"Port"`

	// Instance username
	User *string `json:"User,omitempty" name:"User"`

	// Instance password
	Password *string `json:"Password,omitempty" name:"Password"`

	// Alibaba Cloud ApsaraDB for RDS instance ID, which is applicable if the source database is an Alibaba Cloud ApsaraDB for RDS 5.6/5.7 instance
	RdsInstanceId *string `json:"RdsInstanceId,omitempty" name:"RdsInstanceId"`

	// Short CVM instance ID in the format of `ins-olgl39y8`. It is the same as the instance ID displayed on the CVM Console page. For CVM-based self-created instances, this field needs to be passed in
	CvmInstanceId *string `json:"CvmInstanceId,omitempty" name:"CvmInstanceId"`

	// Direct Connect gateway ID in the format of dcg-0rxtqqxb
	UniqDcgId *string `json:"UniqDcgId,omitempty" name:"UniqDcgId"`

	// VPC ID in the format of vpc-92jblxto
	VpcId *string `json:"VpcId,omitempty" name:"VpcId"`

	// VPC Subnet ID in the format of subnet-3paxmkdz
	SubnetId *string `json:"SubnetId,omitempty" name:"SubnetId"`

	// VPN gateway ID in the format of vpngw-9ghexg7q
	UniqVpnGwId *string `json:"UniqVpnGwId,omitempty" name:"UniqVpnGwId"`

	// Database instance ID in the format of cdb-powiqx8q
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

	// Region name, such as ap-guangzhou
	Region *string `json:"Region,omitempty" name:"Region"`

	// For Alibaba Cloud ApsaraDB for RDS instances, enter "aliyun"; otherwise, enter "others"
	Supplier *string `json:"Supplier,omitempty" name:"Supplier"`

	// CCN instance ID, such as ccn-afp6kltc
	// Note: This field may return null, indicating that no valid values can be obtained.
	CcnId *string `json:"CcnId,omitempty" name:"CcnId"`

	// Database version. This parameter is valid only when the instance is an RDS instance. Value: 5.6 or 5.7. Default value: 5.6
	EngineVersion *string `json:"EngineVersion,omitempty" name:"EngineVersion"`
}

type StartMigrateJobRequest 

type StartMigrateJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewStartMigrateJobRequest 

func NewStartMigrateJobRequest() (request *StartMigrateJobRequest)

func (*StartMigrateJobRequest) FromJsonString 

func (r *StartMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*StartMigrateJobRequest) ToJsonString 

func (r *StartMigrateJobRequest) ToJsonString() string

type StartMigrateJobResponse 

type StartMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 StopMigrateJobRequest 

type StopMigrateJobRequest struct {
	*tchttp.BaseRequest

	// Data migration task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewStopMigrateJobRequest 

func NewStopMigrateJobRequest() (request *StopMigrateJobRequest)

func (*StopMigrateJobRequest) FromJsonString 

func (r *StopMigrateJobRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*StopMigrateJobRequest) ToJsonString 

func (r *StopMigrateJobRequest) ToJsonString() string

type StopMigrateJobResponse 

type StopMigrateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// The unique request ID, which is returned for each request. RequestId is required for locating a problem.
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `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 SubsErr 

type SubsErr struct {

	// Error message.
	// Note: This field may return `null`, indicating that no valid values can be obtained.
	Message *string `json:"Message,omitempty" name:"Message"`
}

type SubscribeInfo 

type SubscribeInfo struct {

	// Data subscription instance ID
	SubscribeId *string `json:"SubscribeId,omitempty" name:"SubscribeId"`

	// Data subscription instance name
	SubscribeName *string `json:"SubscribeName,omitempty" name:"SubscribeName"`

	// ID of channel bound to data subscription instance
	ChannelId *string `json:"ChannelId,omitempty" name:"ChannelId"`

	// Name of product bound to data subscription instance
	Product *string `json:"Product,omitempty" name:"Product"`

	// ID of database instance bound to data subscription instance
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`

	// Status of database instance bound to data subscription instance
	InstanceStatus *string `json:"InstanceStatus,omitempty" name:"InstanceStatus"`

	// Data subscription instance configuration status. Valid values: unconfigure, configuring, configured
	SubsStatus *string `json:"SubsStatus,omitempty" name:"SubsStatus"`

	// Last modified time
	ModifyTime *string `json:"ModifyTime,omitempty" name:"ModifyTime"`

	// Creation time
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// Isolation time
	IsolateTime *string `json:"IsolateTime,omitempty" name:"IsolateTime"`

	// Expiration time
	ExpireTime *string `json:"ExpireTime,omitempty" name:"ExpireTime"`

	// Deactivation time
	OfflineTime *string `json:"OfflineTime,omitempty" name:"OfflineTime"`

	// Last modified consumption starting time point. If it has never been modified, this field is 0
	ConsumeStartTime *string `json:"ConsumeStartTime,omitempty" name:"ConsumeStartTime"`

	// Data subscription instance region
	Region *string `json:"Region,omitempty" name:"Region"`

	// Billing mode. 1: pay-as-you-go
	PayType *int64 `json:"PayType,omitempty" name:"PayType"`

	// Data subscription instance VIP
	Vip *string `json:"Vip,omitempty" name:"Vip"`

	// Data subscription instance Vport
	Vport *int64 `json:"Vport,omitempty" name:"Vport"`

	// Unique ID of the VPC where the data subscription instance VIP resides
	UniqVpcId *string `json:"UniqVpcId,omitempty" name:"UniqVpcId"`

	// Unique ID of the subnet where the data subscription instance VIP resides
	UniqSubnetId *string `json:"UniqSubnetId,omitempty" name:"UniqSubnetId"`

	// Data subscription instance status. Valid values: creating, normal, isolating, isolated, offlining, offline
	Status *string `json:"Status,omitempty" name:"Status"`

	// Timestamp of the last message confirmed by the SDK. If the SDK keeps consuming, this field can also be used as the current consumption time point of the SDK
	SdkConsumedTime *string `json:"SdkConsumedTime,omitempty" name:"SdkConsumedTime"`

	// Tag
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	Tags []*TagItem `json:"Tags,omitempty" name:"Tags"`

	// Whether auto-renewal is enabled. 0: do not enable; 1: enable
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	AutoRenewFlag *int64 `json:"AutoRenewFlag,omitempty" name:"AutoRenewFlag"`

	// Subscription instance edition. ·`txdts`: legacy data subscription; `kafka`: data subscription in Kafka edition
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	SubscribeVersion *string `json:"SubscribeVersion,omitempty" name:"SubscribeVersion"`
}

type SubscribeObject 

type SubscribeObject struct {

	// Data subscription object type. 0: database, 1: database table
	// Note: this field may return null, indicating that no valid values can be obtained.
	ObjectsType *int64 `json:"ObjectsType,omitempty" name:"ObjectsType"`

	// Name of subscribed database
	// Note: this field may return null, indicating that no valid values can be obtained.
	DatabaseName *string `json:"DatabaseName,omitempty" name:"DatabaseName"`

	// Array of table names in subscribed database
	// Note: this field may return null, indicating that no valid values can be obtained.
	TableNames []*string `json:"TableNames,omitempty" name:"TableNames"`
}

type SubscribeRegionConf 

type SubscribeRegionConf struct {

	// Region name, such as Guangzhou
	// Note: this field may return null, indicating that no valid values can be obtained.
	RegionName *string `json:"RegionName,omitempty" name:"RegionName"`

	// Region ID, such as ap-guangzhou
	// Note: this field may return null, indicating that no valid values can be obtained.
	Region *string `json:"Region,omitempty" name:"Region"`

	// Region name, such as South China
	// Note: this field may return null, indicating that no valid values can be obtained.
	Area *string `json:"Area,omitempty" name:"Area"`

	// Whether it is the default region. 0: no, 1: yes
	// Note: this field may return null, indicating that no valid values can be obtained.
	IsDefaultRegion *int64 `json:"IsDefaultRegion,omitempty" name:"IsDefaultRegion"`

	// Purchasable status of current region. 1: normal, 2: beta test, 3: not purchasable
	// Note: this field may return null, indicating that no valid values can be obtained.
	Status *int64 `json:"Status,omitempty" name:"Status"`
}

type TagFilter 

type TagFilter struct {

	// Tag key value
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// Tag value
	TagValue []*string `json:"TagValue,omitempty" name:"TagValue"`
}

type TagItem 

type TagItem struct {

	// Tag key value
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// Tag value
	// Note: this field may return `null`, indicating that no valid values can be obtained.
	TagValue *string `json:"TagValue,omitempty" name:"TagValue"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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