Documentation ¶
Index ¶
- func DrsClientBuilder() *http_client.HcHttpClientBuilder
- func GenReqDefForBatchChangeData() *def.HttpRequestDef
- func GenReqDefForBatchCheckJobs() *def.HttpRequestDef
- func GenReqDefForBatchCheckResults() *def.HttpRequestDef
- func GenReqDefForBatchCreateJobs() *def.HttpRequestDef
- func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef
- func GenReqDefForBatchListJobDetails() *def.HttpRequestDef
- func GenReqDefForBatchListJobStatus() *def.HttpRequestDef
- func GenReqDefForBatchListProgresses() *def.HttpRequestDef
- func GenReqDefForBatchListRposAndRtos() *def.HttpRequestDef
- func GenReqDefForBatchListStructDetail() *def.HttpRequestDef
- func GenReqDefForBatchListStructProcess() *def.HttpRequestDef
- func GenReqDefForBatchResetPassword() *def.HttpRequestDef
- func GenReqDefForBatchRestoreTask() *def.HttpRequestDef
- func GenReqDefForBatchSetDefiner() *def.HttpRequestDef
- func GenReqDefForBatchSetObjects() *def.HttpRequestDef
- func GenReqDefForBatchSetSpeed() *def.HttpRequestDef
- func GenReqDefForBatchShowParams() *def.HttpRequestDef
- func GenReqDefForBatchStartJobs() *def.HttpRequestDef
- func GenReqDefForBatchStopJobs() *def.HttpRequestDef
- func GenReqDefForBatchSwitchover() *def.HttpRequestDef
- func GenReqDefForBatchUpdateJob() *def.HttpRequestDef
- func GenReqDefForBatchUpdateUser() *def.HttpRequestDef
- func GenReqDefForBatchValidateClustersConnections() *def.HttpRequestDef
- func GenReqDefForBatchValidateConnections() *def.HttpRequestDef
- func GenReqDefForCreateCompareTask() *def.HttpRequestDef
- func GenReqDefForListCompareResult() *def.HttpRequestDef
- func GenReqDefForListUsers() *def.HttpRequestDef
- func GenReqDefForShowJobList() *def.HttpRequestDef
- func GenReqDefForShowMonitoringData() *def.HttpRequestDef
- func GenReqDefForShowQuotas() *def.HttpRequestDef
- func GenReqDefForUpdateParams() *def.HttpRequestDef
- type DrsClient
- func (c *DrsClient) BatchChangeData(request *model.BatchChangeDataRequest) (*model.BatchChangeDataResponse, error)
- func (c *DrsClient) BatchCheckJobs(request *model.BatchCheckJobsRequest) (*model.BatchCheckJobsResponse, error)
- func (c *DrsClient) BatchCheckResults(request *model.BatchCheckResultsRequest) (*model.BatchCheckResultsResponse, error)
- func (c *DrsClient) BatchCreateJobs(request *model.BatchCreateJobsRequest) (*model.BatchCreateJobsResponse, error)
- func (c *DrsClient) BatchDeleteJobs(request *model.BatchDeleteJobsRequest) (*model.BatchDeleteJobsResponse, error)
- func (c *DrsClient) BatchListJobDetails(request *model.BatchListJobDetailsRequest) (*model.BatchListJobDetailsResponse, error)
- func (c *DrsClient) BatchListJobStatus(request *model.BatchListJobStatusRequest) (*model.BatchListJobStatusResponse, error)
- func (c *DrsClient) BatchListProgresses(request *model.BatchListProgressesRequest) (*model.BatchListProgressesResponse, error)
- func (c *DrsClient) BatchListRposAndRtos(request *model.BatchListRposAndRtosRequest) (*model.BatchListRposAndRtosResponse, error)
- func (c *DrsClient) BatchListStructDetail(request *model.BatchListStructDetailRequest) (*model.BatchListStructDetailResponse, error)
- func (c *DrsClient) BatchListStructProcess(request *model.BatchListStructProcessRequest) (*model.BatchListStructProcessResponse, error)
- func (c *DrsClient) BatchResetPassword(request *model.BatchResetPasswordRequest) (*model.BatchResetPasswordResponse, error)
- func (c *DrsClient) BatchRestoreTask(request *model.BatchRestoreTaskRequest) (*model.BatchRestoreTaskResponse, error)
- func (c *DrsClient) BatchSetDefiner(request *model.BatchSetDefinerRequest) (*model.BatchSetDefinerResponse, error)
- func (c *DrsClient) BatchSetObjects(request *model.BatchSetObjectsRequest) (*model.BatchSetObjectsResponse, error)
- func (c *DrsClient) BatchSetSpeed(request *model.BatchSetSpeedRequest) (*model.BatchSetSpeedResponse, error)
- func (c *DrsClient) BatchShowParams(request *model.BatchShowParamsRequest) (*model.BatchShowParamsResponse, error)
- func (c *DrsClient) BatchStartJobs(request *model.BatchStartJobsRequest) (*model.BatchStartJobsResponse, error)
- func (c *DrsClient) BatchStopJobs(request *model.BatchStopJobsRequest) (*model.BatchStopJobsResponse, error)
- func (c *DrsClient) BatchSwitchover(request *model.BatchSwitchoverRequest) (*model.BatchSwitchoverResponse, error)
- func (c *DrsClient) BatchUpdateJob(request *model.BatchUpdateJobRequest) (*model.BatchUpdateJobResponse, error)
- func (c *DrsClient) BatchUpdateUser(request *model.BatchUpdateUserRequest) (*model.BatchUpdateUserResponse, error)
- func (c *DrsClient) BatchValidateClustersConnections(request *model.BatchValidateClustersConnectionsRequest) (*model.BatchValidateClustersConnectionsResponse, error)
- func (c *DrsClient) BatchValidateConnections(request *model.BatchValidateConnectionsRequest) (*model.BatchValidateConnectionsResponse, error)
- func (c *DrsClient) CreateCompareTask(request *model.CreateCompareTaskRequest) (*model.CreateCompareTaskResponse, error)
- func (c *DrsClient) ListCompareResult(request *model.ListCompareResultRequest) (*model.ListCompareResultResponse, error)
- func (c *DrsClient) ListUsers(request *model.ListUsersRequest) (*model.ListUsersResponse, error)
- func (c *DrsClient) ShowJobList(request *model.ShowJobListRequest) (*model.ShowJobListResponse, error)
- func (c *DrsClient) ShowMonitoringData(request *model.ShowMonitoringDataRequest) (*model.ShowMonitoringDataResponse, error)
- func (c *DrsClient) ShowQuotas(request *model.ShowQuotasRequest) (*model.ShowQuotasResponse, error)
- func (c *DrsClient) UpdateParams(request *model.UpdateParamsRequest) (*model.UpdateParamsResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DrsClientBuilder ¶
func DrsClientBuilder() *http_client.HcHttpClientBuilder
func GenReqDefForBatchChangeData ¶
func GenReqDefForBatchChangeData() *def.HttpRequestDef
func GenReqDefForBatchCheckJobs ¶
func GenReqDefForBatchCheckJobs() *def.HttpRequestDef
func GenReqDefForBatchCheckResults ¶
func GenReqDefForBatchCheckResults() *def.HttpRequestDef
func GenReqDefForBatchCreateJobs ¶
func GenReqDefForBatchCreateJobs() *def.HttpRequestDef
func GenReqDefForBatchDeleteJobs ¶
func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef
func GenReqDefForBatchListJobDetails ¶
func GenReqDefForBatchListJobDetails() *def.HttpRequestDef
func GenReqDefForBatchListJobStatus ¶
func GenReqDefForBatchListJobStatus() *def.HttpRequestDef
func GenReqDefForBatchListProgresses ¶
func GenReqDefForBatchListProgresses() *def.HttpRequestDef
func GenReqDefForBatchListRposAndRtos ¶
func GenReqDefForBatchListRposAndRtos() *def.HttpRequestDef
func GenReqDefForBatchListStructDetail ¶
func GenReqDefForBatchListStructDetail() *def.HttpRequestDef
func GenReqDefForBatchListStructProcess ¶
func GenReqDefForBatchListStructProcess() *def.HttpRequestDef
func GenReqDefForBatchResetPassword ¶
func GenReqDefForBatchResetPassword() *def.HttpRequestDef
func GenReqDefForBatchRestoreTask ¶
func GenReqDefForBatchRestoreTask() *def.HttpRequestDef
func GenReqDefForBatchSetDefiner ¶
func GenReqDefForBatchSetDefiner() *def.HttpRequestDef
func GenReqDefForBatchSetObjects ¶
func GenReqDefForBatchSetObjects() *def.HttpRequestDef
func GenReqDefForBatchSetSpeed ¶
func GenReqDefForBatchSetSpeed() *def.HttpRequestDef
func GenReqDefForBatchShowParams ¶
func GenReqDefForBatchShowParams() *def.HttpRequestDef
func GenReqDefForBatchStartJobs ¶
func GenReqDefForBatchStartJobs() *def.HttpRequestDef
func GenReqDefForBatchStopJobs ¶
func GenReqDefForBatchStopJobs() *def.HttpRequestDef
func GenReqDefForBatchSwitchover ¶
func GenReqDefForBatchSwitchover() *def.HttpRequestDef
func GenReqDefForBatchUpdateJob ¶
func GenReqDefForBatchUpdateJob() *def.HttpRequestDef
func GenReqDefForBatchUpdateUser ¶
func GenReqDefForBatchUpdateUser() *def.HttpRequestDef
func GenReqDefForBatchValidateClustersConnections ¶
func GenReqDefForBatchValidateClustersConnections() *def.HttpRequestDef
func GenReqDefForBatchValidateConnections ¶
func GenReqDefForBatchValidateConnections() *def.HttpRequestDef
func GenReqDefForCreateCompareTask ¶
func GenReqDefForCreateCompareTask() *def.HttpRequestDef
func GenReqDefForListCompareResult ¶
func GenReqDefForListCompareResult() *def.HttpRequestDef
func GenReqDefForListUsers ¶
func GenReqDefForListUsers() *def.HttpRequestDef
func GenReqDefForShowJobList ¶
func GenReqDefForShowJobList() *def.HttpRequestDef
func GenReqDefForShowMonitoringData ¶
func GenReqDefForShowMonitoringData() *def.HttpRequestDef
func GenReqDefForShowQuotas ¶
func GenReqDefForShowQuotas() *def.HttpRequestDef
func GenReqDefForUpdateParams ¶
func GenReqDefForUpdateParams() *def.HttpRequestDef
Types ¶
type DrsClient ¶
type DrsClient struct {
HcClient *http_client.HcHttpClient
}
func NewDrsClient ¶
func NewDrsClient(hcClient *http_client.HcHttpClient) *DrsClient
func (*DrsClient) BatchChangeData ¶
func (c *DrsClient) BatchChangeData(request *model.BatchChangeDataRequest) (*model.BatchChangeDataResponse, error)
数据复制服务支持对同步的对象进行加工,即可以为选择的对象添加规则。
func (*DrsClient) BatchCheckJobs ¶
func (c *DrsClient) BatchCheckJobs(request *model.BatchCheckJobsRequest) (*model.BatchCheckJobsResponse, error)
批量预检查,校验是否可进行迁移。
func (*DrsClient) BatchCheckResults ¶
func (c *DrsClient) BatchCheckResults(request *model.BatchCheckResultsRequest) (*model.BatchCheckResultsResponse, error)
批量查询任务的预检查结果。
func (*DrsClient) BatchCreateJobs ¶
func (c *DrsClient) BatchCreateJobs(request *model.BatchCreateJobsRequest) (*model.BatchCreateJobsResponse, error)
根据请求参数不同,可以批量创建实时迁移、实时同步、实时灾备任务。
func (*DrsClient) BatchDeleteJobs ¶
func (c *DrsClient) BatchDeleteJobs(request *model.BatchDeleteJobsRequest) (*model.BatchDeleteJobsResponse, error)
批量结束任务或删除实时迁移、实时同步、实时灾备任务。
func (*DrsClient) BatchListJobDetails ¶
func (c *DrsClient) BatchListJobDetails(request *model.BatchListJobDetailsRequest) (*model.BatchListJobDetailsResponse, error)
根据任务ID批量查询任务详情。
func (*DrsClient) BatchListJobStatus ¶
func (c *DrsClient) BatchListJobStatus(request *model.BatchListJobStatusRequest) (*model.BatchListJobStatusResponse, error)
根据任务ID批量查询任务状态。
func (*DrsClient) BatchListProgresses ¶
func (c *DrsClient) BatchListProgresses(request *model.BatchListProgressesRequest) (*model.BatchListProgressesResponse, error)
根据任务ID批量查询全量进度、增量时延信息。
func (*DrsClient) BatchListRposAndRtos ¶
func (c *DrsClient) BatchListRposAndRtos(request *model.BatchListRposAndRtosRequest) (*model.BatchListRposAndRtosResponse, error)
批量查询RPO和RTO。
func (*DrsClient) BatchListStructDetail ¶
func (c *DrsClient) BatchListStructDetail(request *model.BatchListStructDetailRequest) (*model.BatchListStructDetailResponse, error)
根据任务ID批量查询灾备初始化对象详情。
func (*DrsClient) BatchListStructProcess ¶
func (c *DrsClient) BatchListStructProcess(request *model.BatchListStructProcessRequest) (*model.BatchListStructProcessResponse, error)
根据任务ID批量查询灾备初始化进度,虚拟id不支持查询。
func (*DrsClient) BatchResetPassword ¶
func (c *DrsClient) BatchResetPassword(request *model.BatchResetPasswordRequest) (*model.BatchResetPasswordResponse, error)
任务启动之后需要修改源库/目标库密码时调用此接口。
func (*DrsClient) BatchRestoreTask ¶
func (c *DrsClient) BatchRestoreTask(request *model.BatchRestoreTaskRequest) (*model.BatchRestoreTaskResponse, error)
在迁移过程中由于不确定因素导致迁移任务失败,可通过重试功能,重新提交迁移任务。
func (*DrsClient) BatchSetDefiner ¶
func (c *DrsClient) BatchSetDefiner(request *model.BatchSetDefinerRequest) (*model.BatchSetDefinerResponse, error)
批量设置Definer迁移是否迁移到到该用户下。 - 选择是:迁移后,所有源数据库对象的Definer都会迁移至该用户下,其他用户需要授权后才具有数据库对象权限。 - 选择否:迁移后,将保持源数据库对象Definer定义不变,选择此选项,需要配合下一步用户权限迁移功能,将源数据库的用户全部迁移,这样才能保持源数据库的权限体系完全不变。
func (*DrsClient) BatchSetObjects ¶
func (c *DrsClient) BatchSetObjects(request *model.BatchSetObjectsRequest) (*model.BatchSetObjectsResponse, error)
迁移之前,选择需要迁移的数据库或者表。
func (*DrsClient) BatchSetSpeed ¶
func (c *DrsClient) BatchSetSpeed(request *model.BatchSetSpeedRequest) (*model.BatchSetSpeedResponse, error)
批量设置任务限速,任务创建成功后默认不限速。 - 限速:自定义的最大迁移速度,迁移过程中的迁移速度将不会超过该速度。 - 不限速:对迁移速度不进行限制,通常会最大化使用源数据库的出口带宽。该流速模式同时会对源数据库造成读消耗,消耗取决于源数据库的出口带宽。比如:源数据库的出口带宽为100MB/s,假设高速模式使用了80%带宽,则迁移对源数据库将造成80MB/s的读操作IO消耗。
func (*DrsClient) BatchShowParams ¶
func (c *DrsClient) BatchShowParams(request *model.BatchShowParamsRequest) (*model.BatchShowParamsResponse, error)
在进行数据库迁移时,为了确保迁移成功后业务应用的使用不受影响,数据复制服务提供了参数对比功能帮助您进行源库和目标库参数一致性对比,此接口可以获取源库和目标库的数据库参数。
func (*DrsClient) BatchStartJobs ¶
func (c *DrsClient) BatchStartJobs(request *model.BatchStartJobsRequest) (*model.BatchStartJobsResponse, error)
批量启动实时迁移、同步、灾备任务。
func (*DrsClient) BatchStopJobs ¶
func (c *DrsClient) BatchStopJobs(request *model.BatchStopJobsRequest) (*model.BatchStopJobsResponse, error)
批量暂停任务。
func (*DrsClient) BatchSwitchover ¶
func (c *DrsClient) BatchSwitchover(request *model.BatchSwitchoverRequest) (*model.BatchSwitchoverResponse, error)
批量主备倒换。
func (*DrsClient) BatchUpdateJob ¶
func (c *DrsClient) BatchUpdateJob(request *model.BatchUpdateJobRequest) (*model.BatchUpdateJobResponse, error)
批量修改任务名称或描述,设置异常通知信息。
func (*DrsClient) BatchUpdateUser ¶
func (c *DrsClient) BatchUpdateUser(request *model.BatchUpdateUserRequest) (*model.BatchUpdateUserResponse, error)
数据库的迁移过程中,迁移用户需要进行单独处理,该接口可以批量设置需要迁移的用户和角色。
func (*DrsClient) BatchValidateClustersConnections ¶
func (c *DrsClient) BatchValidateClustersConnections(request *model.BatchValidateClustersConnectionsRequest) (*model.BatchValidateClustersConnectionsResponse, error)
批量测试连接(集群模式)。
func (*DrsClient) BatchValidateConnections ¶
func (c *DrsClient) BatchValidateConnections(request *model.BatchValidateConnectionsRequest) (*model.BatchValidateConnectionsResponse, error)
批量测试连接。
func (*DrsClient) CreateCompareTask ¶
func (c *DrsClient) CreateCompareTask(request *model.CreateCompareTaskRequest) (*model.CreateCompareTaskResponse, error)
创建对比任务。
func (*DrsClient) ListCompareResult ¶
func (c *DrsClient) ListCompareResult(request *model.ListCompareResultRequest) (*model.ListCompareResultResponse, error)
查询对比结果。
func (*DrsClient) ListUsers ¶
func (c *DrsClient) ListUsers(request *model.ListUsersRequest) (*model.ListUsersResponse, error)
数据库的迁移过程中,迁移用户需要进行单独处理,该接口可以查询源库的用户信息。
func (*DrsClient) ShowJobList ¶
func (c *DrsClient) ShowJobList(request *model.ShowJobListRequest) (*model.ShowJobListResponse, error)
查询租户任务列表,可以根据引擎类型,网络类型,任务状态,任务名称,任务ID进行查询。
func (*DrsClient) ShowMonitoringData ¶
func (c *DrsClient) ShowMonitoringData(request *model.ShowMonitoringDataRequest) (*model.ShowMonitoringDataResponse, error)
根据任务ID查询容灾监控数据。
func (*DrsClient) ShowQuotas ¶
func (c *DrsClient) ShowQuotas(request *model.ShowQuotasRequest) (*model.ShowQuotasResponse, error)
查询单租户在DRS服务下的配额信息。
func (*DrsClient) UpdateParams ¶
func (c *DrsClient) UpdateParams(request *model.UpdateParamsRequest) (*model.UpdateParamsResponse, error)
修改数据库参数。