v20180330

package
v3.0.325+incompatible Latest Latest
Warning

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

Go to latest
Published: Nov 15, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (

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

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

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

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

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

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

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

	// The current instance type does not support this operation.
	UNSUPPORTEDOPERATION_ACTIONNOTSUPPORT = "UnsupportedOperation.ActionNotSupport"
)
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_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"
INVALIDPARAMETER = "InvalidParameter"
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.

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"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
OPERATIONDENIED = "OperationDenied"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

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:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
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) CreateSyncCheckJob

func (c *Client) CreateSyncCheckJob(request *CreateSyncCheckJobRequest) (response *CreateSyncCheckJobResponse, err error)

CreateSyncCheckJob Before the StartSyncJob API is called to start disaster recovery sync, this API should be called first to create a check. Data sync can start only if the check succeeds. You can view the check result through the DescribeSyncCheckJob API.

Sync can begin only if the check succeeds.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_LOCKERROR = "InternalError.LockError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
INVALIDPARAMETER_INSTANCENOTFOUND = "InvalidParameter.InstanceNotFound"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

func (*Client) CreateSyncJob

func (c *Client) CreateSyncJob(request *CreateSyncJobRequest) (response *CreateSyncJobResponse, err error)

CreateSyncJob This API (CreateSyncJob) is used to create a disaster recovery sync task.

After successful creation, check can be initiated through the CreateSyncCheckJob API. The sync task can be started through the StartSyncJob API only if the check succeeds.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"

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_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

func (*Client) DeleteSyncJob

func (c *Client) DeleteSyncJob(request *DeleteSyncJobRequest) (response *DeleteSyncJobResponse, err error)

DeleteSyncJob This API is used to delete a disaster recovery sync task. Sync tasks that are running cannot be deleted.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

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

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:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
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) 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_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:

INTERNALERROR = "InternalError"
INVALIDPARAMETER = "InvalidParameter"

func (*Client) DescribeSyncCheckJob

func (c *Client) DescribeSyncCheckJob(request *DescribeSyncCheckJobRequest) (response *DescribeSyncCheckJobResponse, err error)

DescribeSyncCheckJob This API is used to get the check result after a disaster recovery sync check task is created through the CreateSyncCheckJob API. Check status and progress can be queried.

If the check succeeds, you can call the StartSyncJob API to start the sync task.

If the check fails, the reason will be returned. You can modify the configuration through the ModifySyncJob API and initiate check again.

It takes about 30 seconds to complete the check task. If the returned status is not "finished", the check has not been completed, and this API needs to be polled.

If Status=finished and CheckFlag=1, the check succeeds.

If Status=finished and CheckFlag !=1, the check fails.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

func (*Client) DescribeSyncJobs

func (c *Client) DescribeSyncJobs(request *DescribeSyncJobsRequest) (response *DescribeSyncJobsResponse, err error)

DescribeSyncJobs This API is used to query disaster recovery sync tasks initiated on the DTS platform.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
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"
RESOURCENOTFOUND = "ResourceNotFound"
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) 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) 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) 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"

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) ModifySyncJob

func (c *Client) ModifySyncJob(request *ModifySyncJobRequest) (response *ModifySyncJobResponse, err error)

ModifySyncJob This API is used to modify a disaster recovery sync task.

If the status of a sync task is creating, created, check succeeded, or check failed, this API can be called to modify the task.

The information of the source and target instances cannot be modified, but the task name and the tables to be synced can.

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"

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) 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) 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"
INVALIDPARAMETER = "InvalidParameter"
LIMITEXCEEDED_MAXUNUSEDJOBS = "LimitExceeded.MaxUnusedJobs"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

func (*Client) StartSyncJob

func (c *Client) StartSyncJob(request *StartSyncJobRequest) (response *StartSyncJobResponse, err error)

StartSyncJob This API is used to start a disaster recovery sync task after it is successfully checked through the CreateSyncCheckJob and DescribeSyncCheckJob APIs.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed"
INTERNALERROR_ADDTASKERROR = "InternalError.AddTaskError"
INTERNALERROR_DATABASEERROR = "InternalError.DatabaseError"
INTERNALERROR_DUPLICATEJOB = "InternalError.DuplicateJob"
INTERNALERROR_LOCKERROR = "InternalError.LockError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

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"
INVALIDPARAMETER = "InvalidParameter"
RESOURCENOTFOUND_JOBNOTEXIST = "ResourceNotFound.JobNotExist"

func (*Client) SwitchDrToMaster

func (c *Client) SwitchDrToMaster(request *SwitchDrToMasterRequest) (response *SwitchDrToMasterResponse, err error)

SwitchDrToMaster This API is used to promote a disaster recovery instance to a master instance, which will stop sync from the original master instance and end the master/slave relationship.

error code that may be returned:

FAILEDOPERATION_NOTALLOWOPERATION = "FailedOperation.NotAllowOperation"
FAILEDOPERATION_STARTJOBFAILED = "FailedOperation.StartJobFailed"
INTERNALERROR = "InternalError"
INTERNALERROR_CGWSYSTEMERROR = "InternalError.CgwSystemError"
INTERNALERROR_PROTOCOLERROR = "InternalError.ProtocolError"
INVALIDPARAMETER = "InvalidParameter"
UNSUPPORTEDOPERATION = "UnsupportedOperation"
UNSUPPORTEDOPERATION_ACTIONNOTSUPPORT = "UnsupportedOperation.ActionNotSupport"

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, and Percona. 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. 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"`
}

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

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 CreateSyncCheckJobRequest

type CreateSyncCheckJobRequest struct {
	*tchttp.BaseRequest

	// Disaster recovery sync task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewCreateSyncCheckJobRequest

func NewCreateSyncCheckJobRequest() (request *CreateSyncCheckJobRequest)

func (*CreateSyncCheckJobRequest) FromJsonString

func (r *CreateSyncCheckJobRequest) 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 (*CreateSyncCheckJobRequest) ToJsonString

func (r *CreateSyncCheckJobRequest) ToJsonString() string

type CreateSyncCheckJobResponse

type CreateSyncCheckJobResponse 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 NewCreateSyncCheckJobResponse

func NewCreateSyncCheckJobResponse() (response *CreateSyncCheckJobResponse)

func (*CreateSyncCheckJobResponse) FromJsonString

func (r *CreateSyncCheckJobResponse) 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 (*CreateSyncCheckJobResponse) ToJsonString

func (r *CreateSyncCheckJobResponse) ToJsonString() string

type CreateSyncJobRequest

type CreateSyncJobRequest struct {
	*tchttp.BaseRequest

	// Disaster recovery sync task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Configuration options of a disaster recovery sync task
	SyncOption *SyncOption `json:"SyncOption,omitempty" name:"SyncOption"`

	// Source instance database type, which currently only supports mysql
	SrcDatabaseType *string `json:"SrcDatabaseType,omitempty" name:"SrcDatabaseType"`

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

	// Source instance information
	SrcInfo *SyncInstanceInfo `json:"SrcInfo,omitempty" name:"SrcInfo"`

	// Target instance access type, which currently only supports mysql
	DstDatabaseType *string `json:"DstDatabaseType,omitempty" name:"DstDatabaseType"`

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

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

	// Information of the source table to be synced, which is described in JSON string format.
	// For databases with a database-table structure:
	// [{Database:db1,Table:[table1,table2]},{Database:db2}]
	DatabaseInfo *string `json:"DatabaseInfo,omitempty" name:"DatabaseInfo"`
}

func NewCreateSyncJobRequest

func NewCreateSyncJobRequest() (request *CreateSyncJobRequest)

func (*CreateSyncJobRequest) FromJsonString

func (r *CreateSyncJobRequest) 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 (*CreateSyncJobRequest) ToJsonString

func (r *CreateSyncJobRequest) ToJsonString() string

type CreateSyncJobResponse

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

		// Disaster recovery sync 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 NewCreateSyncJobResponse

func NewCreateSyncJobResponse() (response *CreateSyncJobResponse)

func (*CreateSyncJobResponse) FromJsonString

func (r *CreateSyncJobResponse) 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 (*CreateSyncJobResponse) ToJsonString

func (r *CreateSyncJobResponse) 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 DeleteSyncJobRequest

type DeleteSyncJobRequest struct {
	*tchttp.BaseRequest

	// ID of the disaster recovery sync task to be deleted
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewDeleteSyncJobRequest

func NewDeleteSyncJobRequest() (request *DeleteSyncJobRequest)

func (*DeleteSyncJobRequest) FromJsonString

func (r *DeleteSyncJobRequest) 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 (*DeleteSyncJobRequest) ToJsonString

func (r *DeleteSyncJobRequest) ToJsonString() string

type DeleteSyncJobResponse

type DeleteSyncJobResponse 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 NewDeleteSyncJobResponse

func NewDeleteSyncJobResponse() (response *DeleteSyncJobResponse)

func (*DeleteSyncJobResponse) FromJsonString

func (r *DeleteSyncJobResponse) 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 (*DeleteSyncJobResponse) ToJsonString

func (r *DeleteSyncJobResponse) 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"`

		// 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 DescribeSyncCheckJobRequest

type DescribeSyncCheckJobRequest struct {
	*tchttp.BaseRequest

	// ID of the disaster recovery sync task to be queried
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewDescribeSyncCheckJobRequest

func NewDescribeSyncCheckJobRequest() (request *DescribeSyncCheckJobRequest)

func (*DescribeSyncCheckJobRequest) FromJsonString

func (r *DescribeSyncCheckJobRequest) 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 (*DescribeSyncCheckJobRequest) ToJsonString

func (r *DescribeSyncCheckJobRequest) ToJsonString() string

type DescribeSyncCheckJobResponse

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

		// Task check status: starting, running, finished
		Status *string `json:"Status,omitempty" name:"Status"`

		// Code of the task check result
		ErrorCode *int64 `json:"ErrorCode,omitempty" name:"ErrorCode"`

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

		// Description of a task execution step
		StepInfo []*SyncCheckStepInfo `json:"StepInfo,omitempty" name:"StepInfo"`

		// Check flag. 0: checking; 1: successfully 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 NewDescribeSyncCheckJobResponse

func NewDescribeSyncCheckJobResponse() (response *DescribeSyncCheckJobResponse)

func (*DescribeSyncCheckJobResponse) FromJsonString

func (r *DescribeSyncCheckJobResponse) 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 (*DescribeSyncCheckJobResponse) ToJsonString

func (r *DescribeSyncCheckJobResponse) ToJsonString() string

type DescribeSyncJobsRequest

type DescribeSyncJobsRequest struct {
	*tchttp.BaseRequest

	// Disaster recovery sync task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Disaster recovery sync task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Sort by field. Value range: JobId, Status, JobName, 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"`
}

func NewDescribeSyncJobsRequest

func NewDescribeSyncJobsRequest() (request *DescribeSyncJobsRequest)

func (*DescribeSyncJobsRequest) FromJsonString

func (r *DescribeSyncJobsRequest) 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 (*DescribeSyncJobsRequest) ToJsonString

func (r *DescribeSyncJobsRequest) ToJsonString() string

type DescribeSyncJobsResponse

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

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

		// Array of task details
		JobList []*SyncJobInfo `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 NewDescribeSyncJobsResponse

func NewDescribeSyncJobsResponse() (response *DescribeSyncJobsResponse)

func (*DescribeSyncJobsResponse) FromJsonString

func (r *DescribeSyncJobsResponse) 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 (*DescribeSyncJobsResponse) ToJsonString

func (r *DescribeSyncJobsResponse) 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"`
}

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

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 ModifySyncJobRequest

type ModifySyncJobRequest struct {
	*tchttp.BaseRequest

	// ID of the disaster recovery sync task to be modified
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Name of the disaster recovery sync task
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Configuration options of a disaster recovery sync task
	SyncOption *SyncOption `json:"SyncOption,omitempty" name:"SyncOption"`

	// When syncing the specified table, you need to set the information of the source table to be synced, 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"}]
	DatabaseInfo *string `json:"DatabaseInfo,omitempty" name:"DatabaseInfo"`
}

func NewModifySyncJobRequest

func NewModifySyncJobRequest() (request *ModifySyncJobRequest)

func (*ModifySyncJobRequest) FromJsonString

func (r *ModifySyncJobRequest) 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 (*ModifySyncJobRequest) ToJsonString

func (r *ModifySyncJobRequest) ToJsonString() string

type ModifySyncJobResponse

type ModifySyncJobResponse 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 NewModifySyncJobResponse

func NewModifySyncJobResponse() (response *ModifySyncJobResponse)

func (*ModifySyncJobResponse) FromJsonString

func (r *ModifySyncJobResponse) 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 (*ModifySyncJobResponse) ToJsonString

func (r *ModifySyncJobResponse) 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 StartSyncJobRequest

type StartSyncJobRequest struct {
	*tchttp.BaseRequest

	// Disaster recovery sync task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewStartSyncJobRequest

func NewStartSyncJobRequest() (request *StartSyncJobRequest)

func (*StartSyncJobRequest) FromJsonString

func (r *StartSyncJobRequest) 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 (*StartSyncJobRequest) ToJsonString

func (r *StartSyncJobRequest) ToJsonString() string

type StartSyncJobResponse

type StartSyncJobResponse 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 NewStartSyncJobResponse

func NewStartSyncJobResponse() (response *StartSyncJobResponse)

func (*StartSyncJobResponse) FromJsonString

func (r *StartSyncJobResponse) 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 (*StartSyncJobResponse) ToJsonString

func (r *StartSyncJobResponse) 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 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 SwitchDrToMasterRequest

type SwitchDrToMasterRequest struct {
	*tchttp.BaseRequest

	// Disaster recovery instance information
	DstInfo *SyncInstanceInfo `json:"DstInfo,omitempty" name:"DstInfo"`

	// Database type (such as MySQL)
	DatabaseType *string `json:"DatabaseType,omitempty" name:"DatabaseType"`
}

func NewSwitchDrToMasterRequest

func NewSwitchDrToMasterRequest() (request *SwitchDrToMasterRequest)

func (*SwitchDrToMasterRequest) FromJsonString

func (r *SwitchDrToMasterRequest) 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 (*SwitchDrToMasterRequest) ToJsonString

func (r *SwitchDrToMasterRequest) ToJsonString() string

type SwitchDrToMasterResponse

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

		// Backend async task request 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 NewSwitchDrToMasterResponse

func NewSwitchDrToMasterResponse() (response *SwitchDrToMasterResponse)

func (*SwitchDrToMasterResponse) FromJsonString

func (r *SwitchDrToMasterResponse) 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 (*SwitchDrToMasterResponse) ToJsonString

func (r *SwitchDrToMasterResponse) ToJsonString() string

type SyncCheckStepInfo

type SyncCheckStepInfo struct {

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

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

	// Code of the step execution result
	StepCode *int64 `json:"StepCode,omitempty" name:"StepCode"`

	// Message about the step execution result
	StepMessage *string `json:"StepMessage,omitempty" name:"StepMessage"`
}

type SyncDetailInfo

type SyncDetailInfo struct {

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

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

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

	// Progress of the current step
	CurrentStepProgress *string `json:"CurrentStepProgress,omitempty" name:"CurrentStepProgress"`

	// Master/slave delay in MB
	MasterSlaveDistance *int64 `json:"MasterSlaveDistance,omitempty" name:"MasterSlaveDistance"`

	// Master/slave delay in seconds
	SecondsBehindMaster *int64 `json:"SecondsBehindMaster,omitempty" name:"SecondsBehindMaster"`

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

type SyncInstanceInfo

type SyncInstanceInfo struct {

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

	// Short instance ID
	InstanceId *string `json:"InstanceId,omitempty" name:"InstanceId"`
}

type SyncJobInfo

type SyncJobInfo struct {

	// Disaster recovery task ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Disaster recovery task name
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// Task sync
	SyncOption *SyncOption `json:"SyncOption,omitempty" name:"SyncOption"`

	// Source access type
	SrcAccessType *string `json:"SrcAccessType,omitempty" name:"SrcAccessType"`

	// Source data type
	SrcDatabaseType *string `json:"SrcDatabaseType,omitempty" name:"SrcDatabaseType"`

	// Source instance information
	SrcInfo *SyncInstanceInfo `json:"SrcInfo,omitempty" name:"SrcInfo"`

	// Disaster recovery access type
	DstAccessType *string `json:"DstAccessType,omitempty" name:"DstAccessType"`

	// Disaster recovery data type
	DstDatabaseType *string `json:"DstDatabaseType,omitempty" name:"DstDatabaseType"`

	// Disaster recovery instance information
	DstInfo *SyncInstanceInfo `json:"DstInfo,omitempty" name:"DstInfo"`

	// Task information
	Detail *SyncDetailInfo `json:"Detail,omitempty" name:"Detail"`

	// Task status
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// Table to be migrated
	DatabaseInfo *string `json:"DatabaseInfo,omitempty" name:"DatabaseInfo"`

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

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

	// End time
	EndTime *string `json:"EndTime,omitempty" name:"EndTime"`
}

type SyncOption

type SyncOption struct {

	// Sync object. 1: entire instance; 2: specified table
	SyncObject *uint64 `json:"SyncObject,omitempty" name:"SyncObject"`

	// Sync start configuration. 1: start immediately
	RunMode *uint64 `json:"RunMode,omitempty" name:"RunMode"`

	// Sync mode. 3: full + incremental sync
	SyncType *uint64 `json:"SyncType,omitempty" name:"SyncType"`

	// Data consistency check. 1: no configuration required
	ConsistencyType *uint64 `json:"ConsistencyType,omitempty" name:"ConsistencyType"`
}

type SyncStepDetailInfo

type SyncStepDetailInfo struct {

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

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

	// Whether it can be stopped
	CanStop *int64 `json:"CanStop,omitempty" name:"CanStop"`

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL