v5

package
v0.1.73 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DrsClientBuilder 

func DrsClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForBatchCreateJobsAsync 

func GenReqDefForBatchCreateJobsAsync() *def.HttpRequestDef

func GenReqDefForBatchDeleteJobsById 

func GenReqDefForBatchDeleteJobsById() *def.HttpRequestDef

func GenReqDefForBatchExecuteJobActions 

func GenReqDefForBatchExecuteJobActions() *def.HttpRequestDef

func GenReqDefForBatchStopJobsAction added in v0.1.58 

func GenReqDefForBatchStopJobsAction() *def.HttpRequestDef

func GenReqDefForBatchTagAction added in v0.1.58 

func GenReqDefForBatchTagAction() *def.HttpRequestDef

func GenReqDefForCheckDataFilter added in v0.1.58 

func GenReqDefForCheckDataFilter() *def.HttpRequestDef

func GenReqDefForCollectColumns added in v0.1.58 

func GenReqDefForCollectColumns() *def.HttpRequestDef

func GenReqDefForCollectDbObjectsAsync added in v0.1.21 

func GenReqDefForCollectDbObjectsAsync() *def.HttpRequestDef

func GenReqDefForCollectDbObjectsInfo added in v0.1.58 

func GenReqDefForCollectDbObjectsInfo() *def.HttpRequestDef

func GenReqDefForCollectPositionAsync added in v0.1.64 

func GenReqDefForCollectPositionAsync() *def.HttpRequestDef

func GenReqDefForCommitAsyncJob 

func GenReqDefForCommitAsyncJob() *def.HttpRequestDef

func GenReqDefForCopyJob added in v0.1.49 

func GenReqDefForCopyJob() *def.HttpRequestDef

func GenReqDefForCreateJob 

func GenReqDefForCreateJob() *def.HttpRequestDef

func GenReqDefForDeleteJdbcDriver added in v0.1.68 

func GenReqDefForDeleteJdbcDriver() *def.HttpRequestDef

func GenReqDefForDeleteJob 

func GenReqDefForDeleteJob() *def.HttpRequestDef

func GenReqDefForDownloadBatchCreateTemplate added in v0.1.49 

func GenReqDefForDownloadBatchCreateTemplate() *def.HttpRequestDef

func GenReqDefForDownloadDbObjectTemplate 

func GenReqDefForDownloadDbObjectTemplate() *def.HttpRequestDef

func GenReqDefForExecuteJobAction 

func GenReqDefForExecuteJobAction() *def.HttpRequestDef

func GenReqDefForExportOperationInfo added in v0.1.58 

func GenReqDefForExportOperationInfo() *def.HttpRequestDef

func GenReqDefForImportBatchCreateJobs added in v0.1.49 

func GenReqDefForImportBatchCreateJobs() *def.HttpRequestDef

func GenReqDefForListAsyncJobDetail 

func GenReqDefForListAsyncJobDetail() *def.HttpRequestDef

func GenReqDefForListAsyncJobs 

func GenReqDefForListAsyncJobs() *def.HttpRequestDef

func GenReqDefForListDbObjects 

func GenReqDefForListDbObjects() *def.HttpRequestDef

func GenReqDefForListJdbcDrivers added in v0.1.68 

func GenReqDefForListJdbcDrivers() *def.HttpRequestDef

func GenReqDefForListJobs 

func GenReqDefForListJobs() *def.HttpRequestDef
func GenReqDefForListLinks() *def.HttpRequestDef

func GenReqDefForListProjectTags added in v0.1.58 

func GenReqDefForListProjectTags() *def.HttpRequestDef

func GenReqDefForShowActions added in v0.1.49 

func GenReqDefForShowActions() *def.HttpRequestDef

func GenReqDefForShowColumnInfoResult added in v0.1.58 

func GenReqDefForShowColumnInfoResult() *def.HttpRequestDef

func GenReqDefForShowComparePolicy added in v0.1.49 

func GenReqDefForShowComparePolicy() *def.HttpRequestDef

func GenReqDefForShowDataFilteringResult added in v0.1.58 

func GenReqDefForShowDataFilteringResult() *def.HttpRequestDef

func GenReqDefForShowDataProcessingRulesResult added in v0.1.58 

func GenReqDefForShowDataProcessingRulesResult() *def.HttpRequestDef

func GenReqDefForShowDataProgress added in v0.1.58 

func GenReqDefForShowDataProgress() *def.HttpRequestDef

func GenReqDefForShowDbObjectCollectionStatus added in v0.1.21 

func GenReqDefForShowDbObjectCollectionStatus() *def.HttpRequestDef

func GenReqDefForShowDbObjectTemplateProgress 

func GenReqDefForShowDbObjectTemplateProgress() *def.HttpRequestDef

func GenReqDefForShowDbObjectTemplateResult 

func GenReqDefForShowDbObjectTemplateResult() *def.HttpRequestDef

func GenReqDefForShowDbObjectsList added in v0.1.58 

func GenReqDefForShowDbObjectsList() *def.HttpRequestDef

func GenReqDefForShowDirtyData added in v0.1.49 

func GenReqDefForShowDirtyData() *def.HttpRequestDef

func GenReqDefForShowEnterpriseProject added in v0.1.49 

func GenReqDefForShowEnterpriseProject() *def.HttpRequestDef

func GenReqDefForShowHealthCompareJobList added in v0.1.49 

func GenReqDefForShowHealthCompareJobList() *def.HttpRequestDef

func GenReqDefForShowIncrementComponentsDetail added in v0.1.58 

func GenReqDefForShowIncrementComponentsDetail() *def.HttpRequestDef

func GenReqDefForShowInstanceTags added in v0.1.58 

func GenReqDefForShowInstanceTags() *def.HttpRequestDef

func GenReqDefForShowJobDetail 

func GenReqDefForShowJobDetail() *def.HttpRequestDef

func GenReqDefForShowMetering added in v0.1.49 

func GenReqDefForShowMetering() *def.HttpRequestDef

func GenReqDefForShowMonitorData added in v0.1.58 

func GenReqDefForShowMonitorData() *def.HttpRequestDef

func GenReqDefForShowObjectMapping added in v0.1.49 

func GenReqDefForShowObjectMapping() *def.HttpRequestDef

func GenReqDefForShowPositionResult added in v0.1.64 

func GenReqDefForShowPositionResult() *def.HttpRequestDef

func GenReqDefForShowProgressData added in v0.1.49 

func GenReqDefForShowProgressData() *def.HttpRequestDef

func GenReqDefForShowSupportObjectType added in v0.1.58 

func GenReqDefForShowSupportObjectType() *def.HttpRequestDef

func GenReqDefForShowUpdateObjectSavingStatus added in v0.1.21 

func GenReqDefForShowUpdateObjectSavingStatus() *def.HttpRequestDef

func GenReqDefForStopJobAction added in v0.1.58 

func GenReqDefForStopJobAction() *def.HttpRequestDef

func GenReqDefForSyncJdbcDriver added in v0.1.68 

func GenReqDefForSyncJdbcDriver() *def.HttpRequestDef

func GenReqDefForUpdateBatchAsyncJobs 

func GenReqDefForUpdateBatchAsyncJobs() *def.HttpRequestDef

func GenReqDefForUpdateDataProgress added in v0.1.58 

func GenReqDefForUpdateDataProgress() *def.HttpRequestDef

func GenReqDefForUpdateJob 

func GenReqDefForUpdateJob() *def.HttpRequestDef

func GenReqDefForUpdateStartPosition added in v0.1.58 

func GenReqDefForUpdateStartPosition() *def.HttpRequestDef

func GenReqDefForUploadDbObjectTemplate 

func GenReqDefForUploadDbObjectTemplate() *def.HttpRequestDef

func GenReqDefForUploadJdbcDriver added in v0.1.68 

func GenReqDefForUploadJdbcDriver() *def.HttpRequestDef

func GenReqDefForValidateJobName added in v0.1.49 

func GenReqDefForValidateJobName() *def.HttpRequestDef

Types

type BatchCreateJobsAsyncInvoker 

type BatchCreateJobsAsyncInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateJobsAsyncInvoker) Invoke 

func (i *BatchCreateJobsAsyncInvoker) Invoke() (*model.BatchCreateJobsAsyncResponse, error)

type BatchDeleteJobsByIdInvoker 

type BatchDeleteJobsByIdInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteJobsByIdInvoker) Invoke 

func (i *BatchDeleteJobsByIdInvoker) Invoke() (*model.BatchDeleteJobsByIdResponse, error)

type BatchExecuteJobActionsInvoker 

type BatchExecuteJobActionsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchExecuteJobActionsInvoker) Invoke 

func (i *BatchExecuteJobActionsInvoker) Invoke() (*model.BatchExecuteJobActionsResponse, error)

type BatchStopJobsActionInvoker added in v0.1.58 

type BatchStopJobsActionInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchStopJobsActionInvoker) Invoke added in v0.1.58 

func (i *BatchStopJobsActionInvoker) Invoke() (*model.BatchStopJobsActionResponse, error)

type BatchTagActionInvoker added in v0.1.58 

type BatchTagActionInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchTagActionInvoker) Invoke added in v0.1.58 

func (i *BatchTagActionInvoker) Invoke() (*model.BatchTagActionResponse, error)

type CheckDataFilterInvoker added in v0.1.58 

type CheckDataFilterInvoker struct {
	*invoker.BaseInvoker
}

func (*CheckDataFilterInvoker) Invoke added in v0.1.58 

func (i *CheckDataFilterInvoker) Invoke() (*model.CheckDataFilterResponse, error)

type CollectColumnsInvoker added in v0.1.58 

type CollectColumnsInvoker struct {
	*invoker.BaseInvoker
}

func (*CollectColumnsInvoker) Invoke added in v0.1.58 

func (i *CollectColumnsInvoker) Invoke() (*model.CollectColumnsResponse, error)

type CollectDbObjectsAsyncInvoker added in v0.1.21 

type CollectDbObjectsAsyncInvoker struct {
	*invoker.BaseInvoker
}

func (*CollectDbObjectsAsyncInvoker) Invoke added in v0.1.21 

func (i *CollectDbObjectsAsyncInvoker) Invoke() (*model.CollectDbObjectsAsyncResponse, error)

type CollectDbObjectsInfoInvoker added in v0.1.58 

type CollectDbObjectsInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*CollectDbObjectsInfoInvoker) Invoke added in v0.1.58 

func (i *CollectDbObjectsInfoInvoker) Invoke() (*model.CollectDbObjectsInfoResponse, error)

type CollectPositionAsyncInvoker added in v0.1.64 

type CollectPositionAsyncInvoker struct {
	*invoker.BaseInvoker
}

func (*CollectPositionAsyncInvoker) Invoke added in v0.1.64 

func (i *CollectPositionAsyncInvoker) Invoke() (*model.CollectPositionAsyncResponse, error)

type CommitAsyncJobInvoker 

type CommitAsyncJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CommitAsyncJobInvoker) Invoke 

func (i *CommitAsyncJobInvoker) Invoke() (*model.CommitAsyncJobResponse, error)

type CopyJobInvoker added in v0.1.49 

type CopyJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CopyJobInvoker) Invoke added in v0.1.49 

func (i *CopyJobInvoker) Invoke() (*model.CopyJobResponse, error)

type CreateJobInvoker 

type CreateJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateJobInvoker) Invoke 

func (i *CreateJobInvoker) Invoke() (*model.CreateJobResponse, error)

type DeleteJdbcDriverInvoker added in v0.1.68 

type DeleteJdbcDriverInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteJdbcDriverInvoker) Invoke added in v0.1.68 

func (i *DeleteJdbcDriverInvoker) Invoke() (*model.DeleteJdbcDriverResponse, error)

type DeleteJobInvoker 

type DeleteJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteJobInvoker) Invoke 

func (i *DeleteJobInvoker) Invoke() (*model.DeleteJobResponse, error)

type DownloadBatchCreateTemplateInvoker added in v0.1.49 

type DownloadBatchCreateTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*DownloadBatchCreateTemplateInvoker) Invoke added in v0.1.49 

func (i *DownloadBatchCreateTemplateInvoker) Invoke() (*model.DownloadBatchCreateTemplateResponse, error)

type DownloadDbObjectTemplateInvoker 

type DownloadDbObjectTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*DownloadDbObjectTemplateInvoker) Invoke 

func (i *DownloadDbObjectTemplateInvoker) Invoke() (*model.DownloadDbObjectTemplateResponse, error)

type DrsClient 

type DrsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewDrsClient 

func NewDrsClient(hcClient *http_client.HcHttpClient) *DrsClient

func (*DrsClient) BatchCreateJobsAsync 

func (c *DrsClient) BatchCreateJobsAsync(request *model.BatchCreateJobsAsyncRequest) (*model.BatchCreateJobsAsyncResponse, error)

BatchCreateJobsAsync 批量异步创建任务

批量异步创建任务，根据请求参数不同，可以批量异步创建实时迁移、实时同步、实时灾备等任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) BatchCreateJobsAsyncInvoker 

func (c *DrsClient) BatchCreateJobsAsyncInvoker(request *model.BatchCreateJobsAsyncRequest) *BatchCreateJobsAsyncInvoker

BatchCreateJobsAsyncInvoker 批量异步创建任务

func (*DrsClient) BatchDeleteJobsById 

func (c *DrsClient) BatchDeleteJobsById(request *model.BatchDeleteJobsByIdRequest) (*model.BatchDeleteJobsByIdResponse, error)

BatchDeleteJobsById 批量删除任务

批量删除租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) BatchDeleteJobsByIdInvoker 

func (c *DrsClient) BatchDeleteJobsByIdInvoker(request *model.BatchDeleteJobsByIdRequest) *BatchDeleteJobsByIdInvoker

BatchDeleteJobsByIdInvoker 批量删除任务

func (*DrsClient) BatchExecuteJobActions 

func (c *DrsClient) BatchExecuteJobActions(request *model.BatchExecuteJobActionsRequest) (*model.BatchExecuteJobActionsResponse, error)

BatchExecuteJobActions 批量操作指定ID任务

批量操作租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) BatchExecuteJobActionsInvoker 

func (c *DrsClient) BatchExecuteJobActionsInvoker(request *model.BatchExecuteJobActionsRequest) *BatchExecuteJobActionsInvoker

BatchExecuteJobActionsInvoker 批量操作指定ID任务

func (*DrsClient) BatchStopJobsAction added in v0.1.58 

func (c *DrsClient) BatchStopJobsAction(request *model.BatchStopJobsActionRequest) (*model.BatchStopJobsActionResponse, error)

BatchStopJobsAction 批量结束任务

批量结束租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) BatchStopJobsActionInvoker added in v0.1.58 

func (c *DrsClient) BatchStopJobsActionInvoker(request *model.BatchStopJobsActionRequest) *BatchStopJobsActionInvoker

BatchStopJobsActionInvoker 批量结束任务

func (*DrsClient) BatchTagAction added in v0.1.58 

func (c *DrsClient) BatchTagAction(request *model.BatchTagActionRequest) (*model.BatchTagActionResponse, error)

BatchTagAction 批量添加或删除资源标签

批量添加删除资源标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) BatchTagActionInvoker added in v0.1.58 

func (c *DrsClient) BatchTagActionInvoker(request *model.BatchTagActionRequest) *BatchTagActionInvoker

BatchTagActionInvoker 批量添加或删除资源标签

func (*DrsClient) CheckDataFilter added in v0.1.58 

func (c *DrsClient) CheckDataFilter(request *model.CheckDataFilterRequest) (*model.CheckDataFilterResponse, error)

CheckDataFilter 数据过滤规则校验

数据过滤规则校验

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CheckDataFilterInvoker added in v0.1.58 

func (c *DrsClient) CheckDataFilterInvoker(request *model.CheckDataFilterRequest) *CheckDataFilterInvoker

CheckDataFilterInvoker 数据过滤规则校验

func (*DrsClient) CollectColumns added in v0.1.58 

func (c *DrsClient) CollectColumns(request *model.CollectColumnsRequest) (*model.CollectColumnsResponse, error)

CollectColumns 采集指定数据库表的列信息

采集指定数据库表的列信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CollectColumnsInvoker added in v0.1.58 

func (c *DrsClient) CollectColumnsInvoker(request *model.CollectColumnsRequest) *CollectColumnsInvoker

CollectColumnsInvoker 采集指定数据库表的列信息

func (*DrsClient) CollectDbObjectsAsync added in v0.1.21 

func (c *DrsClient) CollectDbObjectsAsync(request *model.CollectDbObjectsAsyncRequest) (*model.CollectDbObjectsAsyncResponse, error)

CollectDbObjectsAsync 提交查询数据库对象信息

提交查询数据库对象信息。例如： - 当type取值为source时，表示查询源库库表信息。 - 当源库库表信息有变化时，则type取值为source，is_refresh取值为true。 - 当已同步到目标库的库表信息过大，需要提前将数据加载到缓存中时，type取值为synchronized。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CollectDbObjectsAsyncInvoker added in v0.1.21 

func (c *DrsClient) CollectDbObjectsAsyncInvoker(request *model.CollectDbObjectsAsyncRequest) *CollectDbObjectsAsyncInvoker

CollectDbObjectsAsyncInvoker 提交查询数据库对象信息

func (*DrsClient) CollectDbObjectsInfo added in v0.1.58 

func (c *DrsClient) CollectDbObjectsInfo(request *model.CollectDbObjectsInfoRequest) (*model.CollectDbObjectsInfoResponse, error)

CollectDbObjectsInfo 提交查询数据库对象信息

提交查询数据库对象信息。例如： - 当type取值为source时，表示查询源库库表信息。 - 当源库库表信息有变化时，则type取值为source，is_refresh取值为true。 - 当已同步到目标库的库表信息过大，需要提前将数据加载到缓存中时，type取值为synchronized。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CollectDbObjectsInfoInvoker added in v0.1.58 

func (c *DrsClient) CollectDbObjectsInfoInvoker(request *model.CollectDbObjectsInfoRequest) *CollectDbObjectsInfoInvoker

CollectDbObjectsInfoInvoker 提交查询数据库对象信息

func (*DrsClient) CollectPositionAsync added in v0.1.64 

func (c *DrsClient) CollectPositionAsync(request *model.CollectPositionAsyncRequest) (*model.CollectPositionAsyncResponse, error)

CollectPositionAsync 采集数据库位点信息

采集数据库位点信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CollectPositionAsyncInvoker added in v0.1.64 

func (c *DrsClient) CollectPositionAsyncInvoker(request *model.CollectPositionAsyncRequest) *CollectPositionAsyncInvoker

CollectPositionAsyncInvoker 采集数据库位点信息

func (*DrsClient) CommitAsyncJob 

func (c *DrsClient) CommitAsyncJob(request *model.CommitAsyncJobRequest) (*model.CommitAsyncJobResponse, error)

CommitAsyncJob 提交批量创建异步任务

提交批量创建异步任务，当批量异步任务创建或更新参数后，系统会自动开始进行参数校验，待所有任务成功完成参数校验后并且无报错时，可调用此接口开始创建DRS任务实例。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CommitAsyncJobInvoker 

func (c *DrsClient) CommitAsyncJobInvoker(request *model.CommitAsyncJobRequest) *CommitAsyncJobInvoker

CommitAsyncJobInvoker 提交批量创建异步任务

func (*DrsClient) CopyJob added in v0.1.49 

func (c *DrsClient) CopyJob(request *model.CopyJobRequest) (*model.CopyJobResponse, error)

CopyJob 克隆任务

DRS支持通过克隆功能，快速复制现有同步任务的配置。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CopyJobInvoker added in v0.1.49 

func (c *DrsClient) CopyJobInvoker(request *model.CopyJobRequest) *CopyJobInvoker

CopyJobInvoker 克隆任务

func (*DrsClient) CreateJob 

func (c *DrsClient) CreateJob(request *model.CreateJobRequest) (*model.CreateJobResponse, error)

CreateJob 创建任务

创建单个任务，根据请求参数不同，可以创建单个实时迁移、实时同步、实时灾备等任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) CreateJobInvoker 

func (c *DrsClient) CreateJobInvoker(request *model.CreateJobRequest) *CreateJobInvoker

CreateJobInvoker 创建任务

func (*DrsClient) DeleteJdbcDriver added in v0.1.68 

func (c *DrsClient) DeleteJdbcDriver(request *model.DeleteJdbcDriverRequest) (*model.DeleteJdbcDriverResponse, error)

DeleteJdbcDriver 删除驱动文件

删除驱动文件。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) DeleteJdbcDriverInvoker added in v0.1.68 

func (c *DrsClient) DeleteJdbcDriverInvoker(request *model.DeleteJdbcDriverRequest) *DeleteJdbcDriverInvoker

DeleteJdbcDriverInvoker 删除驱动文件

func (*DrsClient) DeleteJob 

func (c *DrsClient) DeleteJob(request *model.DeleteJobRequest) (*model.DeleteJobResponse, error)

DeleteJob 删除指定ID任务

删除租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) DeleteJobInvoker 

func (c *DrsClient) DeleteJobInvoker(request *model.DeleteJobRequest) *DeleteJobInvoker

DeleteJobInvoker 删除指定ID任务

func (*DrsClient) DownloadBatchCreateTemplate added in v0.1.49 

func (c *DrsClient) DownloadBatchCreateTemplate(request *model.DownloadBatchCreateTemplateRequest) (*model.DownloadBatchCreateTemplateResponse, error)

DownloadBatchCreateTemplate 下载批量导入任务模板

下载批量导入任务模板

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) DownloadBatchCreateTemplateInvoker added in v0.1.49 

func (c *DrsClient) DownloadBatchCreateTemplateInvoker(request *model.DownloadBatchCreateTemplateRequest) *DownloadBatchCreateTemplateInvoker

DownloadBatchCreateTemplateInvoker 下载批量导入任务模板

func (*DrsClient) DownloadDbObjectTemplate 

func (c *DrsClient) DownloadDbObjectTemplate(request *model.DownloadDbObjectTemplateRequest) (*model.DownloadDbObjectTemplateResponse, error)

DownloadDbObjectTemplate 对象选择（文件导入 - 模板下载）

对象选择（文件导入 - 模板下载）。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) DownloadDbObjectTemplateInvoker 

func (c *DrsClient) DownloadDbObjectTemplateInvoker(request *model.DownloadDbObjectTemplateRequest) *DownloadDbObjectTemplateInvoker

DownloadDbObjectTemplateInvoker 对象选择（文件导入 - 模板下载）

func (*DrsClient) ExecuteJobAction 

func (c *DrsClient) ExecuteJobAction(request *model.ExecuteJobActionRequest) (*model.ExecuteJobActionResponse, error)

ExecuteJobAction 操作指定ID任务

操作租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ExecuteJobActionInvoker 

func (c *DrsClient) ExecuteJobActionInvoker(request *model.ExecuteJobActionRequest) *ExecuteJobActionInvoker

ExecuteJobActionInvoker 操作指定ID任务

func (*DrsClient) ExportOperationInfo added in v0.1.58 

func (c *DrsClient) ExportOperationInfo(request *model.ExportOperationInfoRequest) (*model.ExportOperationInfoResponse, error)

ExportOperationInfo 导出任务操作统计信息

导出指定任务操作统计信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ExportOperationInfoInvoker added in v0.1.58 

func (c *DrsClient) ExportOperationInfoInvoker(request *model.ExportOperationInfoRequest) *ExportOperationInfoInvoker

ExportOperationInfoInvoker 导出任务操作统计信息

func (*DrsClient) ImportBatchCreateJobs added in v0.1.49 

func (c *DrsClient) ImportBatchCreateJobs(request *model.ImportBatchCreateJobsRequest) (*model.ImportBatchCreateJobsResponse, error)

ImportBatchCreateJobs 批量导入任务

批量导入任务

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ImportBatchCreateJobsInvoker added in v0.1.49 

func (c *DrsClient) ImportBatchCreateJobsInvoker(request *model.ImportBatchCreateJobsRequest) *ImportBatchCreateJobsInvoker

ImportBatchCreateJobsInvoker 批量导入任务

func (*DrsClient) ListAsyncJobDetail 

func (c *DrsClient) ListAsyncJobDetail(request *model.ListAsyncJobDetailRequest) (*model.ListAsyncJobDetailResponse, error)

ListAsyncJobDetail 查询指定ID批量异步任务详情

查询租户指定ID批量异步任务详情，默认为任务的“create_time”降序排序获取结果，支持分页查询。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListAsyncJobDetailInvoker 

func (c *DrsClient) ListAsyncJobDetailInvoker(request *model.ListAsyncJobDetailRequest) *ListAsyncJobDetailInvoker

ListAsyncJobDetailInvoker 查询指定ID批量异步任务详情

func (*DrsClient) ListAsyncJobs 

func (c *DrsClient) ListAsyncJobs(request *model.ListAsyncJobsRequest) (*model.ListAsyncJobsResponse, error)

ListAsyncJobs 查询批量异步创建的任务列表

查询租户批量异步创建的任务列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListAsyncJobsInvoker 

func (c *DrsClient) ListAsyncJobsInvoker(request *model.ListAsyncJobsRequest) *ListAsyncJobsInvoker

ListAsyncJobsInvoker 查询批量异步创建的任务列表

func (*DrsClient) ListDbObjects 

func (c *DrsClient) ListDbObjects(request *model.ListDbObjectsRequest) (*model.ListDbObjectsResponse, error)

ListDbObjects 查询数据库对象信息

查询数据库对象信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListDbObjectsInvoker 

func (c *DrsClient) ListDbObjectsInvoker(request *model.ListDbObjectsRequest) *ListDbObjectsInvoker

ListDbObjectsInvoker 查询数据库对象信息

func (*DrsClient) ListJdbcDrivers added in v0.1.68 

func (c *DrsClient) ListJdbcDrivers(request *model.ListJdbcDriversRequest) (*model.ListJdbcDriversResponse, error)

ListJdbcDrivers 查询驱动文件列表

查询驱动文件列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListJdbcDriversInvoker added in v0.1.68 

func (c *DrsClient) ListJdbcDriversInvoker(request *model.ListJdbcDriversRequest) *ListJdbcDriversInvoker

ListJdbcDriversInvoker 查询驱动文件列表

func (*DrsClient) ListJobs 

func (c *DrsClient) ListJobs(request *model.ListJobsRequest) (*model.ListJobsResponse, error)

ListJobs 查询任务列表

查询租户任务列表，可以根据企业项目，引擎类型，网络类型，任务状态，任务名称，任务ID进行查询。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListJobsInvoker 

func (c *DrsClient) ListJobsInvoker(request *model.ListJobsRequest) *ListJobsInvoker

ListJobsInvoker 查询任务列表 

func (c *DrsClient) ListLinks(request *model.ListLinksRequest) (*model.ListLinksResponse, error)

ListLinks 查询可用链路信息

根据参数不同，可查询实时迁移、实时同步、实时灾备等可用链路信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListLinksInvoker 

func (c *DrsClient) ListLinksInvoker(request *model.ListLinksRequest) *ListLinksInvoker

ListLinksInvoker 查询可用链路信息

func (*DrsClient) ListProjectTags added in v0.1.58 

func (c *DrsClient) ListProjectTags(request *model.ListProjectTagsRequest) (*model.ListProjectTagsResponse, error)

ListProjectTags 查询项目标签

查询指定project ID下不同任务类型的所有标签集合。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ListProjectTagsInvoker added in v0.1.58 

func (c *DrsClient) ListProjectTagsInvoker(request *model.ListProjectTagsRequest) *ListProjectTagsInvoker

ListProjectTagsInvoker 查询项目标签

func (*DrsClient) ShowActions added in v0.1.49 

func (c *DrsClient) ShowActions(request *model.ShowActionsRequest) (*model.ShowActionsResponse, error)

ShowActions 获取指定任务操作信息

获取指定任务允许、不允许、当前操作信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowActionsInvoker added in v0.1.49 

func (c *DrsClient) ShowActionsInvoker(request *model.ShowActionsRequest) *ShowActionsInvoker

ShowActionsInvoker 获取指定任务操作信息

func (*DrsClient) ShowColumnInfoResult added in v0.1.58 

func (c *DrsClient) ShowColumnInfoResult(request *model.ShowColumnInfoResultRequest) (*model.ShowColumnInfoResultResponse, error)

ShowColumnInfoResult 获取指定数据库表列信息

获取指定数据库表列信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowColumnInfoResultInvoker added in v0.1.58 

func (c *DrsClient) ShowColumnInfoResultInvoker(request *model.ShowColumnInfoResultRequest) *ShowColumnInfoResultInvoker

ShowColumnInfoResultInvoker 获取指定数据库表列信息

func (*DrsClient) ShowComparePolicy added in v0.1.49 

func (c *DrsClient) ShowComparePolicy(request *model.ShowComparePolicyRequest) (*model.ShowComparePolicyResponse, error)

ShowComparePolicy 查询对比策略

查询对比策略。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowComparePolicyInvoker added in v0.1.49 

func (c *DrsClient) ShowComparePolicyInvoker(request *model.ShowComparePolicyRequest) *ShowComparePolicyInvoker

ShowComparePolicyInvoker 查询对比策略

func (*DrsClient) ShowDataFilteringResult added in v0.1.58 

func (c *DrsClient) ShowDataFilteringResult(request *model.ShowDataFilteringResultRequest) (*model.ShowDataFilteringResultResponse, error)

ShowDataFilteringResult 获取数据过滤校验结果

获取数据过滤校验结果

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDataFilteringResultInvoker added in v0.1.58 

func (c *DrsClient) ShowDataFilteringResultInvoker(request *model.ShowDataFilteringResultRequest) *ShowDataFilteringResultInvoker

ShowDataFilteringResultInvoker 获取数据过滤校验结果

func (*DrsClient) ShowDataProcessingRulesResult added in v0.1.58 

func (c *DrsClient) ShowDataProcessingRulesResult(request *model.ShowDataProcessingRulesResultRequest) (*model.ShowDataProcessingRulesResultResponse, error)

ShowDataProcessingRulesResult 获取指定任务数据加工规则更新结果

获取指定任务数据加工规则更新结果

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDataProcessingRulesResultInvoker added in v0.1.58 

func (c *DrsClient) ShowDataProcessingRulesResultInvoker(request *model.ShowDataProcessingRulesResultRequest) *ShowDataProcessingRulesResultInvoker

ShowDataProcessingRulesResultInvoker 获取指定任务数据加工规则更新结果

func (*DrsClient) ShowDataProgress added in v0.1.58 

func (c *DrsClient) ShowDataProgress(request *model.ShowDataProgressRequest) (*model.ShowDataProgressResponse, error)

ShowDataProgress 查询数据加工规则

查询数据加工规则:包含数据库表的映射信息、列信息、数据过滤信息、附加列信息、DDL以及DML信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDataProgressInvoker added in v0.1.58 

func (c *DrsClient) ShowDataProgressInvoker(request *model.ShowDataProgressRequest) *ShowDataProgressInvoker

ShowDataProgressInvoker 查询数据加工规则

func (*DrsClient) ShowDbObjectCollectionStatus added in v0.1.21 

func (c *DrsClient) ShowDbObjectCollectionStatus(request *model.ShowDbObjectCollectionStatusRequest) (*model.ShowDbObjectCollectionStatusResponse, error)

ShowDbObjectCollectionStatus 获取提交查询数据库对象信息的结果

获取提交查询数据库对象信息的结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDbObjectCollectionStatusInvoker added in v0.1.21 

func (c *DrsClient) ShowDbObjectCollectionStatusInvoker(request *model.ShowDbObjectCollectionStatusRequest) *ShowDbObjectCollectionStatusInvoker

ShowDbObjectCollectionStatusInvoker 获取提交查询数据库对象信息的结果

func (*DrsClient) ShowDbObjectTemplateProgress 

func (c *DrsClient) ShowDbObjectTemplateProgress(request *model.ShowDbObjectTemplateProgressRequest) (*model.ShowDbObjectTemplateProgressResponse, error)

ShowDbObjectTemplateProgress 对象选择（文件导入 - 进度查询）

对象选择（文件导入 - 进度查询）。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDbObjectTemplateProgressInvoker 

func (c *DrsClient) ShowDbObjectTemplateProgressInvoker(request *model.ShowDbObjectTemplateProgressRequest) *ShowDbObjectTemplateProgressInvoker

ShowDbObjectTemplateProgressInvoker 对象选择（文件导入 - 进度查询）

func (*DrsClient) ShowDbObjectTemplateResult 

func (c *DrsClient) ShowDbObjectTemplateResult(request *model.ShowDbObjectTemplateResultRequest) (*model.ShowDbObjectTemplateResultResponse, error)

ShowDbObjectTemplateResult 对象选择（文件导入 - 获取导入结果）

对象选择（文件导入 - 获取导入结果）。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDbObjectTemplateResultInvoker 

func (c *DrsClient) ShowDbObjectTemplateResultInvoker(request *model.ShowDbObjectTemplateResultRequest) *ShowDbObjectTemplateResultInvoker

ShowDbObjectTemplateResultInvoker 对象选择（文件导入 - 获取导入结果）

func (*DrsClient) ShowDbObjectsList added in v0.1.58 

func (c *DrsClient) ShowDbObjectsList(request *model.ShowDbObjectsListRequest) (*model.ShowDbObjectsListResponse, error)

ShowDbObjectsList 查询数据库对象信息

查询数据库对象信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDbObjectsListInvoker added in v0.1.58 

func (c *DrsClient) ShowDbObjectsListInvoker(request *model.ShowDbObjectsListRequest) *ShowDbObjectsListInvoker

ShowDbObjectsListInvoker 查询数据库对象信息

func (*DrsClient) ShowDirtyData added in v0.1.49 

func (c *DrsClient) ShowDirtyData(request *model.ShowDirtyDataRequest) (*model.ShowDirtyDataResponse, error)

ShowDirtyData 查询异常数据列表

查询异常数据列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowDirtyDataInvoker added in v0.1.49 

func (c *DrsClient) ShowDirtyDataInvoker(request *model.ShowDirtyDataRequest) *ShowDirtyDataInvoker

ShowDirtyDataInvoker 查询异常数据列表

func (*DrsClient) ShowEnterpriseProject added in v0.1.49 

func (c *DrsClient) ShowEnterpriseProject(request *model.ShowEnterpriseProjectRequest) (*model.ShowEnterpriseProjectResponse, error)

ShowEnterpriseProject 查询企业项目列表

查询企业项目列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowEnterpriseProjectInvoker added in v0.1.49 

func (c *DrsClient) ShowEnterpriseProjectInvoker(request *model.ShowEnterpriseProjectRequest) *ShowEnterpriseProjectInvoker

ShowEnterpriseProjectInvoker 查询企业项目列表

func (*DrsClient) ShowHealthCompareJobList added in v0.1.49 

func (c *DrsClient) ShowHealthCompareJobList(request *model.ShowHealthCompareJobListRequest) (*model.ShowHealthCompareJobListResponse, error)

ShowHealthCompareJobList 查询健康对比列表

查询健康对比列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowHealthCompareJobListInvoker added in v0.1.49 

func (c *DrsClient) ShowHealthCompareJobListInvoker(request *model.ShowHealthCompareJobListRequest) *ShowHealthCompareJobListInvoker

ShowHealthCompareJobListInvoker 查询健康对比列表

func (*DrsClient) ShowIncrementComponentsDetail added in v0.1.58 

func (c *DrsClient) ShowIncrementComponentsDetail(request *model.ShowIncrementComponentsDetailRequest) (*model.ShowIncrementComponentsDetailResponse, error)

ShowIncrementComponentsDetail 查询增量组件详情

查询任务同步的增量组件的详细信息，实时同步任务，任务模式为增量或者全量+增量才支持。具体介绍可以参考：[查询同步进度](https://support.huaweicloud.com/realtimesyn-drs/drs_10_0007.html) - 支持的引擎：oracle-to-gaussdbv5，oracle-to-gaussdbv5ha，gaussdbv5，gaussdbv5-to-mysql，gaussdbv5-to-gaussdbv5ha，gaussdbv5ha，gaussdbv5ha-to-gaussdbv5，gaussdbv5-to-dws，gaussdbv5ha-to-dws，gaussdbv5-to-oracle，gaussdbv5ha-to-oracle，oracle-to-dws，oracle-to-mysql

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowIncrementComponentsDetailInvoker added in v0.1.58 

func (c *DrsClient) ShowIncrementComponentsDetailInvoker(request *model.ShowIncrementComponentsDetailRequest) *ShowIncrementComponentsDetailInvoker

ShowIncrementComponentsDetailInvoker 查询增量组件详情

func (*DrsClient) ShowInstanceTags added in v0.1.58 

func (c *DrsClient) ShowInstanceTags(request *model.ShowInstanceTagsRequest) (*model.ShowInstanceTagsResponse, error)

ShowInstanceTags 查询资源标签

查询指定实例的标签信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowInstanceTagsInvoker added in v0.1.58 

func (c *DrsClient) ShowInstanceTagsInvoker(request *model.ShowInstanceTagsRequest) *ShowInstanceTagsInvoker

ShowInstanceTagsInvoker 查询资源标签

func (*DrsClient) ShowJobDetail 

func (c *DrsClient) ShowJobDetail(request *model.ShowJobDetailRequest) (*model.ShowJobDetailResponse, error)

ShowJobDetail 查询任务详情

查询任务详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowJobDetailInvoker 

func (c *DrsClient) ShowJobDetailInvoker(request *model.ShowJobDetailRequest) *ShowJobDetailInvoker

ShowJobDetailInvoker 查询任务详情

func (*DrsClient) ShowMetering added in v0.1.49 

func (c *DrsClient) ShowMetering(request *model.ShowMeteringRequest) (*model.ShowMeteringResponse, error)

ShowMetering 获取任务价格信息

获取询价接口的参数。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowMeteringInvoker added in v0.1.49 

func (c *DrsClient) ShowMeteringInvoker(request *model.ShowMeteringRequest) *ShowMeteringInvoker

ShowMeteringInvoker 获取任务价格信息

func (*DrsClient) ShowMonitorData added in v0.1.58 

func (c *DrsClient) ShowMonitorData(request *model.ShowMonitorDataRequest) (*model.ShowMonitorDataResponse, error)

ShowMonitorData 查询监控数据

获取任务监控数据。 - Cassandra灾备不支持。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowMonitorDataInvoker added in v0.1.58 

func (c *DrsClient) ShowMonitorDataInvoker(request *model.ShowMonitorDataRequest) *ShowMonitorDataInvoker

ShowMonitorDataInvoker 查询监控数据

func (*DrsClient) ShowObjectMapping added in v0.1.49 

func (c *DrsClient) ShowObjectMapping(request *model.ShowObjectMappingRequest) (*model.ShowObjectMappingResponse, error)

ShowObjectMapping 查询同步映射列表

查询实时同步映射关系包括对象选择时的库映射、schema映射、表映射和数据加工时的列映射。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowObjectMappingInvoker added in v0.1.49 

func (c *DrsClient) ShowObjectMappingInvoker(request *model.ShowObjectMappingRequest) *ShowObjectMappingInvoker

ShowObjectMappingInvoker 查询同步映射列表

func (*DrsClient) ShowPositionResult added in v0.1.64 

func (c *DrsClient) ShowPositionResult(request *model.ShowPositionResultRequest) (*model.ShowPositionResultResponse, error)

ShowPositionResult 获取查询数据库位点的结果

获取查询数据库位点的结果

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowPositionResultInvoker added in v0.1.64 

func (c *DrsClient) ShowPositionResultInvoker(request *model.ShowPositionResultRequest) *ShowPositionResultInvoker

ShowPositionResultInvoker 获取查询数据库位点的结果

func (*DrsClient) ShowProgressData added in v0.1.49 

func (c *DrsClient) ShowProgressData(request *model.ShowProgressDataRequest) (*model.ShowProgressDataResponse, error)

ShowProgressData 查询数据级流式对比列表

查询不同迁移对象类型的迁移进度。 说明： - 目前仅MySQL->MySQL、MySQL->GaussDB(for MySQL)、MongoDB->DDS、DDS->MongoDB的迁移支持查看迁移明细。 - 在任务未结束前，不能修改源库和目标库的所有用户、密码和用户权限等。 - 全量、增量完成不代表任务结束，如果存在触发器和事件将会进行迁移。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowProgressDataInvoker added in v0.1.49 

func (c *DrsClient) ShowProgressDataInvoker(request *model.ShowProgressDataRequest) *ShowProgressDataInvoker

ShowProgressDataInvoker 查询数据级流式对比列表

func (*DrsClient) ShowSupportObjectType added in v0.1.58 

func (c *DrsClient) ShowSupportObjectType(request *model.ShowSupportObjectTypeRequest) (*model.ShowSupportObjectTypeResponse, error)

ShowSupportObjectType 查询是否支持对象选择和列映射

查询任务支持的对象选择类型、列映射、支持搜索的对象类型等信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowSupportObjectTypeInvoker added in v0.1.58 

func (c *DrsClient) ShowSupportObjectTypeInvoker(request *model.ShowSupportObjectTypeRequest) *ShowSupportObjectTypeInvoker

ShowSupportObjectTypeInvoker 查询是否支持对象选择和列映射

func (*DrsClient) ShowUpdateObjectSavingStatus added in v0.1.21 

func (c *DrsClient) ShowUpdateObjectSavingStatus(request *model.ShowUpdateObjectSavingStatusRequest) (*model.ShowUpdateObjectSavingStatusResponse, error)

ShowUpdateObjectSavingStatus 获取对象保存进度

获取对象保存进度。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ShowUpdateObjectSavingStatusInvoker added in v0.1.21 

func (c *DrsClient) ShowUpdateObjectSavingStatusInvoker(request *model.ShowUpdateObjectSavingStatusRequest) *ShowUpdateObjectSavingStatusInvoker

ShowUpdateObjectSavingStatusInvoker 获取对象保存进度

func (*DrsClient) StopJobAction added in v0.1.58 

func (c *DrsClient) StopJobAction(request *model.StopJobActionRequest) (*model.StopJobActionResponse, error)

StopJobAction 结束任务

结束租户指定ID任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) StopJobActionInvoker added in v0.1.58 

func (c *DrsClient) StopJobActionInvoker(request *model.StopJobActionRequest) *StopJobActionInvoker

StopJobActionInvoker 结束任务

func (*DrsClient) SyncJdbcDriver added in v0.1.68 

func (c *DrsClient) SyncJdbcDriver(request *model.SyncJdbcDriverRequest) (*model.SyncJdbcDriverResponse, error)

SyncJdbcDriver 同步驱动文件

同步驱动文件。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) SyncJdbcDriverInvoker added in v0.1.68 

func (c *DrsClient) SyncJdbcDriverInvoker(request *model.SyncJdbcDriverRequest) *SyncJdbcDriverInvoker

SyncJdbcDriverInvoker 同步驱动文件

func (*DrsClient) UpdateBatchAsyncJobs 

func (c *DrsClient) UpdateBatchAsyncJobs(request *model.UpdateBatchAsyncJobsRequest) (*model.UpdateBatchAsyncJobsResponse, error)

UpdateBatchAsyncJobs 更新指定ID批量异步任务详情

更新租户指定ID批量异步任务详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UpdateBatchAsyncJobsInvoker 

func (c *DrsClient) UpdateBatchAsyncJobsInvoker(request *model.UpdateBatchAsyncJobsRequest) *UpdateBatchAsyncJobsInvoker

UpdateBatchAsyncJobsInvoker 更新指定ID批量异步任务详情

func (*DrsClient) UpdateDataProgress added in v0.1.58 

func (c *DrsClient) UpdateDataProgress(request *model.UpdateDataProgressRequest) (*model.UpdateDataProgressResponse, error)

UpdateDataProgress 更新指定任务数据加工规则

更新指定任务数据加工规则

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UpdateDataProgressInvoker added in v0.1.58 

func (c *DrsClient) UpdateDataProgressInvoker(request *model.UpdateDataProgressRequest) *UpdateDataProgressInvoker

UpdateDataProgressInvoker 更新指定任务数据加工规则

func (*DrsClient) UpdateJob 

func (c *DrsClient) UpdateJob(request *model.UpdateJobRequest) (*model.UpdateJobResponse, error)

UpdateJob 更新指定ID任务详情

更新租户指定ID任务详情。 当type取值为db_object， 进行异步处理。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UpdateJobInvoker 

func (c *DrsClient) UpdateJobInvoker(request *model.UpdateJobRequest) *UpdateJobInvoker

UpdateJobInvoker 更新指定ID任务详情

func (*DrsClient) UpdateStartPosition added in v0.1.58 

func (c *DrsClient) UpdateStartPosition(request *model.UpdateStartPositionRequest) (*model.UpdateStartPositionResponse, error)

UpdateStartPosition 更新增量任务启动位点

更新增量任务的启动位点。 - 仅engine_type为mysql,mysql-to-dws,mysql-to-taurus,taurus,mysql-to-oracle,taurus-to-oracle,taurus-to-mysql,mysql-to-kafka,taurus-to-kafka,mongodb-to-kafka,mongodb且为单增量实时同步任务支持。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UpdateStartPositionInvoker added in v0.1.58 

func (c *DrsClient) UpdateStartPositionInvoker(request *model.UpdateStartPositionRequest) *UpdateStartPositionInvoker

UpdateStartPositionInvoker 更新增量任务启动位点

func (*DrsClient) UploadDbObjectTemplate 

func (c *DrsClient) UploadDbObjectTemplate(request *model.UploadDbObjectTemplateRequest) (*model.UploadDbObjectTemplateResponse, error)

UploadDbObjectTemplate 对象选择（文件导入 - 模板上传）

对象选择（文件导入 - 模板上传）。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UploadDbObjectTemplateInvoker 

func (c *DrsClient) UploadDbObjectTemplateInvoker(request *model.UploadDbObjectTemplateRequest) *UploadDbObjectTemplateInvoker

UploadDbObjectTemplateInvoker 对象选择（文件导入 - 模板上传）

func (*DrsClient) UploadJdbcDriver added in v0.1.68 

func (c *DrsClient) UploadJdbcDriver(request *model.UploadJdbcDriverRequest) (*model.UploadJdbcDriverResponse, error)

UploadJdbcDriver 上传驱动文件

上传驱动文件。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) UploadJdbcDriverInvoker added in v0.1.68 

func (c *DrsClient) UploadJdbcDriverInvoker(request *model.UploadJdbcDriverRequest) *UploadJdbcDriverInvoker

UploadJdbcDriverInvoker 上传驱动文件

func (*DrsClient) ValidateJobName added in v0.1.49 

func (c *DrsClient) ValidateJobName(request *model.ValidateJobNameRequest) (*model.ValidateJobNameResponse, error)

ValidateJobName 任务名称校验

创建任务时对任务名称进行校验。

Please refer to HUAWEI cloud API Explorer for details.

func (*DrsClient) ValidateJobNameInvoker added in v0.1.49 

func (c *DrsClient) ValidateJobNameInvoker(request *model.ValidateJobNameRequest) *ValidateJobNameInvoker

ValidateJobNameInvoker 任务名称校验

type ExecuteJobActionInvoker 

type ExecuteJobActionInvoker struct {
	*invoker.BaseInvoker
}

func (*ExecuteJobActionInvoker) Invoke 

func (i *ExecuteJobActionInvoker) Invoke() (*model.ExecuteJobActionResponse, error)

type ExportOperationInfoInvoker added in v0.1.58 

type ExportOperationInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportOperationInfoInvoker) Invoke added in v0.1.58 

func (i *ExportOperationInfoInvoker) Invoke() (*model.ExportOperationInfoResponse, error)

type ImportBatchCreateJobsInvoker added in v0.1.49 

type ImportBatchCreateJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ImportBatchCreateJobsInvoker) Invoke added in v0.1.49 

func (i *ImportBatchCreateJobsInvoker) Invoke() (*model.ImportBatchCreateJobsResponse, error)

type ListAsyncJobDetailInvoker 

type ListAsyncJobDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAsyncJobDetailInvoker) Invoke 

func (i *ListAsyncJobDetailInvoker) Invoke() (*model.ListAsyncJobDetailResponse, error)

type ListAsyncJobsInvoker 

type ListAsyncJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAsyncJobsInvoker) Invoke 

func (i *ListAsyncJobsInvoker) Invoke() (*model.ListAsyncJobsResponse, error)

type ListDbObjectsInvoker 

type ListDbObjectsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDbObjectsInvoker) Invoke 

func (i *ListDbObjectsInvoker) Invoke() (*model.ListDbObjectsResponse, error)

type ListJdbcDriversInvoker added in v0.1.68 

type ListJdbcDriversInvoker struct {
	*invoker.BaseInvoker
}

func (*ListJdbcDriversInvoker) Invoke added in v0.1.68 

func (i *ListJdbcDriversInvoker) Invoke() (*model.ListJdbcDriversResponse, error)

type ListJobsInvoker 

type ListJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListJobsInvoker) Invoke 

func (i *ListJobsInvoker) Invoke() (*model.ListJobsResponse, error)

type ListLinksInvoker 

type ListLinksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListLinksInvoker) Invoke 

func (i *ListLinksInvoker) Invoke() (*model.ListLinksResponse, error)

type ListProjectTagsInvoker added in v0.1.58 

type ListProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListProjectTagsInvoker) Invoke added in v0.1.58 

func (i *ListProjectTagsInvoker) Invoke() (*model.ListProjectTagsResponse, error)

type ShowActionsInvoker added in v0.1.49 

type ShowActionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowActionsInvoker) Invoke added in v0.1.49 

func (i *ShowActionsInvoker) Invoke() (*model.ShowActionsResponse, error)

type ShowColumnInfoResultInvoker added in v0.1.58 

type ShowColumnInfoResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowColumnInfoResultInvoker) Invoke added in v0.1.58 

func (i *ShowColumnInfoResultInvoker) Invoke() (*model.ShowColumnInfoResultResponse, error)

type ShowComparePolicyInvoker added in v0.1.49 

type ShowComparePolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowComparePolicyInvoker) Invoke added in v0.1.49 

func (i *ShowComparePolicyInvoker) Invoke() (*model.ShowComparePolicyResponse, error)

type ShowDataFilteringResultInvoker added in v0.1.58 

type ShowDataFilteringResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDataFilteringResultInvoker) Invoke added in v0.1.58 

func (i *ShowDataFilteringResultInvoker) Invoke() (*model.ShowDataFilteringResultResponse, error)

type ShowDataProcessingRulesResultInvoker added in v0.1.58 

type ShowDataProcessingRulesResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDataProcessingRulesResultInvoker) Invoke added in v0.1.58 

func (i *ShowDataProcessingRulesResultInvoker) Invoke() (*model.ShowDataProcessingRulesResultResponse, error)

type ShowDataProgressInvoker added in v0.1.58 

type ShowDataProgressInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDataProgressInvoker) Invoke added in v0.1.58 

func (i *ShowDataProgressInvoker) Invoke() (*model.ShowDataProgressResponse, error)

type ShowDbObjectCollectionStatusInvoker added in v0.1.21 

type ShowDbObjectCollectionStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDbObjectCollectionStatusInvoker) Invoke added in v0.1.21 

func (i *ShowDbObjectCollectionStatusInvoker) Invoke() (*model.ShowDbObjectCollectionStatusResponse, error)

type ShowDbObjectTemplateProgressInvoker 

type ShowDbObjectTemplateProgressInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDbObjectTemplateProgressInvoker) Invoke 

func (i *ShowDbObjectTemplateProgressInvoker) Invoke() (*model.ShowDbObjectTemplateProgressResponse, error)

type ShowDbObjectTemplateResultInvoker 

type ShowDbObjectTemplateResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDbObjectTemplateResultInvoker) Invoke 

func (i *ShowDbObjectTemplateResultInvoker) Invoke() (*model.ShowDbObjectTemplateResultResponse, error)

type ShowDbObjectsListInvoker added in v0.1.58 

type ShowDbObjectsListInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDbObjectsListInvoker) Invoke added in v0.1.58 

func (i *ShowDbObjectsListInvoker) Invoke() (*model.ShowDbObjectsListResponse, error)

type ShowDirtyDataInvoker added in v0.1.49 

type ShowDirtyDataInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDirtyDataInvoker) Invoke added in v0.1.49 

func (i *ShowDirtyDataInvoker) Invoke() (*model.ShowDirtyDataResponse, error)

type ShowEnterpriseProjectInvoker added in v0.1.49 

type ShowEnterpriseProjectInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEnterpriseProjectInvoker) Invoke added in v0.1.49 

func (i *ShowEnterpriseProjectInvoker) Invoke() (*model.ShowEnterpriseProjectResponse, error)

type ShowHealthCompareJobListInvoker added in v0.1.49 

type ShowHealthCompareJobListInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowHealthCompareJobListInvoker) Invoke added in v0.1.49 

func (i *ShowHealthCompareJobListInvoker) Invoke() (*model.ShowHealthCompareJobListResponse, error)

type ShowIncrementComponentsDetailInvoker added in v0.1.58 

type ShowIncrementComponentsDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowIncrementComponentsDetailInvoker) Invoke added in v0.1.58 

func (i *ShowIncrementComponentsDetailInvoker) Invoke() (*model.ShowIncrementComponentsDetailResponse, error)

type ShowInstanceTagsInvoker added in v0.1.58 

type ShowInstanceTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceTagsInvoker) Invoke added in v0.1.58 

func (i *ShowInstanceTagsInvoker) Invoke() (*model.ShowInstanceTagsResponse, error)

type ShowJobDetailInvoker 

type ShowJobDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobDetailInvoker) Invoke 

func (i *ShowJobDetailInvoker) Invoke() (*model.ShowJobDetailResponse, error)

type ShowMeteringInvoker added in v0.1.49 

type ShowMeteringInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMeteringInvoker) Invoke added in v0.1.49 

func (i *ShowMeteringInvoker) Invoke() (*model.ShowMeteringResponse, error)

type ShowMonitorDataInvoker added in v0.1.58 

type ShowMonitorDataInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMonitorDataInvoker) Invoke added in v0.1.58 

func (i *ShowMonitorDataInvoker) Invoke() (*model.ShowMonitorDataResponse, error)

type ShowObjectMappingInvoker added in v0.1.49 

type ShowObjectMappingInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowObjectMappingInvoker) Invoke added in v0.1.49 

func (i *ShowObjectMappingInvoker) Invoke() (*model.ShowObjectMappingResponse, error)

type ShowPositionResultInvoker added in v0.1.64 

type ShowPositionResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPositionResultInvoker) Invoke added in v0.1.64 

func (i *ShowPositionResultInvoker) Invoke() (*model.ShowPositionResultResponse, error)

type ShowProgressDataInvoker added in v0.1.49 

type ShowProgressDataInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowProgressDataInvoker) Invoke added in v0.1.49 

func (i *ShowProgressDataInvoker) Invoke() (*model.ShowProgressDataResponse, error)

type ShowSupportObjectTypeInvoker added in v0.1.58 

type ShowSupportObjectTypeInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSupportObjectTypeInvoker) Invoke added in v0.1.58 

func (i *ShowSupportObjectTypeInvoker) Invoke() (*model.ShowSupportObjectTypeResponse, error)

type ShowUpdateObjectSavingStatusInvoker added in v0.1.21 

type ShowUpdateObjectSavingStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowUpdateObjectSavingStatusInvoker) Invoke added in v0.1.21 

func (i *ShowUpdateObjectSavingStatusInvoker) Invoke() (*model.ShowUpdateObjectSavingStatusResponse, error)

type StopJobActionInvoker added in v0.1.58 

type StopJobActionInvoker struct {
	*invoker.BaseInvoker
}

func (*StopJobActionInvoker) Invoke added in v0.1.58 

func (i *StopJobActionInvoker) Invoke() (*model.StopJobActionResponse, error)

type SyncJdbcDriverInvoker added in v0.1.68 

type SyncJdbcDriverInvoker struct {
	*invoker.BaseInvoker
}

func (*SyncJdbcDriverInvoker) Invoke added in v0.1.68 

func (i *SyncJdbcDriverInvoker) Invoke() (*model.SyncJdbcDriverResponse, error)

type UpdateBatchAsyncJobsInvoker 

type UpdateBatchAsyncJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateBatchAsyncJobsInvoker) Invoke 

func (i *UpdateBatchAsyncJobsInvoker) Invoke() (*model.UpdateBatchAsyncJobsResponse, error)

type UpdateDataProgressInvoker added in v0.1.58 

type UpdateDataProgressInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataProgressInvoker) Invoke added in v0.1.58 

func (i *UpdateDataProgressInvoker) Invoke() (*model.UpdateDataProgressResponse, error)

type UpdateJobInvoker 

type UpdateJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateJobInvoker) Invoke 

func (i *UpdateJobInvoker) Invoke() (*model.UpdateJobResponse, error)

type UpdateStartPositionInvoker added in v0.1.58 

type UpdateStartPositionInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateStartPositionInvoker) Invoke added in v0.1.58 

func (i *UpdateStartPositionInvoker) Invoke() (*model.UpdateStartPositionResponse, error)

type UploadDbObjectTemplateInvoker 

type UploadDbObjectTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadDbObjectTemplateInvoker) Invoke 

func (i *UploadDbObjectTemplateInvoker) Invoke() (*model.UploadDbObjectTemplateResponse, error)

type UploadJdbcDriverInvoker added in v0.1.68 

type UploadJdbcDriverInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadJdbcDriverInvoker) Invoke added in v0.1.68 

func (i *UploadJdbcDriverInvoker) Invoke() (*model.UploadJdbcDriverResponse, error)

type ValidateJobNameInvoker added in v0.1.49 

type ValidateJobNameInvoker struct {
	*invoker.BaseInvoker
}

func (*ValidateJobNameInvoker) Invoke added in v0.1.49 

func (i *ValidateJobNameInvoker) Invoke() (*model.ValidateJobNameResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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