model

package
v0.1.39 Latest Latest
Warning

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

Go to latest
Published: May 11, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlarmNotifyInfo

type AlarmNotifyInfo struct {

	// 订阅延迟时间(单位为s)
	DelayTime *int64 `json:"delay_time,omitempty"`

	// rto延迟时间
	RtoDelay *int64 `json:"rto_delay,omitempty"`

	// rpo延迟时间
	RpoDelay *int64 `json:"rpo_delay,omitempty"`

	// 异常告警是否通知用户
	AlarmToUser *bool `json:"alarm_to_user,omitempty"`

	// 收件方式与信息体
	Subscriptions *[]SubscriptionInfo `json:"subscriptions,omitempty"`
}

异常通知信息

func (AlarmNotifyInfo) String

func (o AlarmNotifyInfo) String() string

type AzInfoResp added in v0.0.94

type AzInfoResp struct {

	// 可用区标识代码
	Code *string `json:"code,omitempty"`

	// 可用区名称
	Name *string `json:"name,omitempty"`

	// 可用区状态
	Status *string `json:"status,omitempty"`
}

可用区信息

func (AzInfoResp) String added in v0.0.94

func (o AzInfoResp) String() string

type BatchChangeDataRequest

type BatchChangeDataRequest struct {

	// 请求语言类型
	XLanguage *BatchChangeDataRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchDataTransformationReq `json:"body,omitempty"`
}

Request Object

func (BatchChangeDataRequest) String

func (o BatchChangeDataRequest) String() string

type BatchChangeDataRequestXLanguage

type BatchChangeDataRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchChangeDataRequestXLanguage) MarshalJSON

func (c BatchChangeDataRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchChangeDataRequestXLanguage) UnmarshalJSON

func (c *BatchChangeDataRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchChangeDataRequestXLanguage) Value added in v0.0.90

type BatchChangeDataRequestXLanguageEnum

type BatchChangeDataRequestXLanguageEnum struct {
	EN_US BatchChangeDataRequestXLanguage
	ZH_CN BatchChangeDataRequestXLanguage
}

func GetBatchChangeDataRequestXLanguageEnum

func GetBatchChangeDataRequestXLanguageEnum() BatchChangeDataRequestXLanguageEnum

type BatchChangeDataResponse

type BatchChangeDataResponse struct {

	// 批量数据加工响应列表
	Results *[]DataTransformationResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchChangeDataResponse) String

func (o BatchChangeDataResponse) String() string

type BatchCheckJobsRequest

type BatchCheckJobsRequest struct {

	// 请求语言类型
	XLanguage *BatchCheckJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchPrecheckReq `json:"body,omitempty"`
}

Request Object

func (BatchCheckJobsRequest) String

func (o BatchCheckJobsRequest) String() string

type BatchCheckJobsRequestXLanguage

type BatchCheckJobsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchCheckJobsRequestXLanguage) MarshalJSON

func (c BatchCheckJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchCheckJobsRequestXLanguage) UnmarshalJSON

func (c *BatchCheckJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchCheckJobsRequestXLanguage) Value added in v0.0.90

type BatchCheckJobsRequestXLanguageEnum

type BatchCheckJobsRequestXLanguageEnum struct {
	EN_US BatchCheckJobsRequestXLanguage
	ZH_CN BatchCheckJobsRequestXLanguage
}

func GetBatchCheckJobsRequestXLanguageEnum

func GetBatchCheckJobsRequestXLanguageEnum() BatchCheckJobsRequestXLanguageEnum

type BatchCheckJobsResponse

type BatchCheckJobsResponse struct {

	// 预检查响应体
	Results *[]PostPreCheckResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchCheckJobsResponse) String

func (o BatchCheckJobsResponse) String() string

type BatchCheckResultsRequest

type BatchCheckResultsRequest struct {

	// 请求语言类型
	XLanguage *BatchCheckResultsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryPrecheckResultReq `json:"body,omitempty"`
}

Request Object

func (BatchCheckResultsRequest) String

func (o BatchCheckResultsRequest) String() string

type BatchCheckResultsRequestXLanguage

type BatchCheckResultsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchCheckResultsRequestXLanguage) MarshalJSON

func (c BatchCheckResultsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchCheckResultsRequestXLanguage) UnmarshalJSON

func (c *BatchCheckResultsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchCheckResultsRequestXLanguage) Value added in v0.0.90

type BatchCheckResultsRequestXLanguageEnum

type BatchCheckResultsRequestXLanguageEnum struct {
	EN_US BatchCheckResultsRequestXLanguage
	ZH_CN BatchCheckResultsRequestXLanguage
}

func GetBatchCheckResultsRequestXLanguageEnum

func GetBatchCheckResultsRequestXLanguageEnum() BatchCheckResultsRequestXLanguageEnum

type BatchCheckResultsResponse

type BatchCheckResultsResponse struct {

	// 批量查询预检查结果响应体集合。
	Results *[]QueryPreCheckResp `json:"results,omitempty"`

	// 总记录数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchCheckResultsResponse) String

func (o BatchCheckResultsResponse) String() string

type BatchCreateJobReq

type BatchCreateJobReq struct {

	// 创建任务请求体
	Jobs []CreateJobReq `json:"jobs"`
}

批量创建实时迁移任务请求体

func (BatchCreateJobReq) String

func (o BatchCreateJobReq) String() string

type BatchCreateJobsRequest

type BatchCreateJobsRequest struct {

	// 请求语言类型
	XLanguage *BatchCreateJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchCreateJobReq `json:"body,omitempty"`
}

Request Object

func (BatchCreateJobsRequest) String

func (o BatchCreateJobsRequest) String() string

type BatchCreateJobsRequestXLanguage

type BatchCreateJobsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchCreateJobsRequestXLanguage) MarshalJSON

func (c BatchCreateJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchCreateJobsRequestXLanguage) UnmarshalJSON

func (c *BatchCreateJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchCreateJobsRequestXLanguage) Value added in v0.0.90

type BatchCreateJobsRequestXLanguageEnum

type BatchCreateJobsRequestXLanguageEnum struct {
	EN_US BatchCreateJobsRequestXLanguage
	ZH_CN BatchCreateJobsRequestXLanguage
}

func GetBatchCreateJobsRequestXLanguageEnum

func GetBatchCreateJobsRequestXLanguageEnum() BatchCreateJobsRequestXLanguageEnum

type BatchCreateJobsResponse

type BatchCreateJobsResponse struct {

	// 批量创建任务的响应体集合。
	Results *[]CreateJobResp `json:"results,omitempty"`

	// 总记录数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchCreateJobsResponse) String

func (o BatchCreateJobsResponse) String() string

type BatchDataTransformationReq

type BatchDataTransformationReq struct {

	// 批量数据加工规则请求列表
	Jobs []CheckDataTransformationReq `json:"jobs"`
}

批量数据加工规则请求体

func (BatchDataTransformationReq) String

type BatchDeleteJobReq

type BatchDeleteJobReq struct {

	// 批量结束与删除任务请求列表
	Jobs []DeleteJobReq `json:"jobs"`
}

批量结束与删除在线迁移任务请求体

func (BatchDeleteJobReq) String

func (o BatchDeleteJobReq) String() string

type BatchDeleteJobsRequest

type BatchDeleteJobsRequest struct {

	// 请求语言类型
	XLanguage *BatchDeleteJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchDeleteJobReq `json:"body,omitempty"`
}

Request Object

func (BatchDeleteJobsRequest) String

func (o BatchDeleteJobsRequest) String() string

type BatchDeleteJobsRequestXLanguage

type BatchDeleteJobsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchDeleteJobsRequestXLanguage) MarshalJSON

func (c BatchDeleteJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchDeleteJobsRequestXLanguage) UnmarshalJSON

func (c *BatchDeleteJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchDeleteJobsRequestXLanguage) Value added in v0.0.90

type BatchDeleteJobsRequestXLanguageEnum

type BatchDeleteJobsRequestXLanguageEnum struct {
	EN_US BatchDeleteJobsRequestXLanguage
	ZH_CN BatchDeleteJobsRequestXLanguage
}

func GetBatchDeleteJobsRequestXLanguageEnum

func GetBatchDeleteJobsRequestXLanguageEnum() BatchDeleteJobsRequestXLanguageEnum

type BatchDeleteJobsResponse

type BatchDeleteJobsResponse struct {

	// 批量结束任务或删除任务的响应体集合。
	Results *[]DeleteJobResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchDeleteJobsResponse) String

func (o BatchDeleteJobsResponse) String() string

type BatchImportSmnInfoReq added in v0.0.84

type BatchImportSmnInfoReq struct {

	// 任务信息
	Jobs []SelectedSetAlarmTaskReq `json:"jobs"`

	AlarmNotifyInfo *BatchSetAlarmNotifyInfo `json:"alarm_notify_info"`
}

录入、修改收件方式与信息请求体。

func (BatchImportSmnInfoReq) String added in v0.0.84

func (o BatchImportSmnInfoReq) String() string

type BatchJobActionReq

type BatchJobActionReq struct {

	// 执行操作
	Action BatchJobActionReqAction `json:"action"`

	// 任务ID(集群模式 取父任务的任务id)
	JobId string `json:"job_id"`

	// 操作对应的参数(API参考文档-批量测试连接-集群模式-property字段数据结构说明)[字段说明参考](https://support.huaweicloud.com/api-drs/zh-cn_topic_0295171516.html)
	Property string `json:"property"`
}

任务动作请求体

func (BatchJobActionReq) String

func (o BatchJobActionReq) String() string

type BatchJobActionReqAction

type BatchJobActionReqAction struct {
	// contains filtered or unexported fields
}

func (BatchJobActionReqAction) MarshalJSON

func (c BatchJobActionReqAction) MarshalJSON() ([]byte, error)

func (*BatchJobActionReqAction) UnmarshalJSON

func (c *BatchJobActionReqAction) UnmarshalJSON(b []byte) error

func (BatchJobActionReqAction) Value added in v0.0.90

func (c BatchJobActionReqAction) Value() string

type BatchJobActionReqActionEnum

type BatchJobActionReqActionEnum struct {
	TEST_CONNECTION BatchJobActionReqAction
}

func GetBatchJobActionReqActionEnum

func GetBatchJobActionReqActionEnum() BatchJobActionReqActionEnum

type BatchLimitSpeedReq

type BatchLimitSpeedReq struct {

	// 灾备限速设置信息
	SpeedLimits []LimitSpeedReq `json:"speed_limits"`
}

func (BatchLimitSpeedReq) String

func (o BatchLimitSpeedReq) String() string

type BatchListJobDetailsRequest

type BatchListJobDetailsRequest struct {

	// 请求语言类型
	XLanguage *BatchListJobDetailsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryJobReqPage `json:"body,omitempty"`
}

Request Object

func (BatchListJobDetailsRequest) String

type BatchListJobDetailsRequestXLanguage

type BatchListJobDetailsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListJobDetailsRequestXLanguage) MarshalJSON

func (c BatchListJobDetailsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListJobDetailsRequestXLanguage) UnmarshalJSON

func (c *BatchListJobDetailsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListJobDetailsRequestXLanguage) Value added in v0.0.90

type BatchListJobDetailsRequestXLanguageEnum

type BatchListJobDetailsRequestXLanguageEnum struct {
	EN_US BatchListJobDetailsRequestXLanguage
	ZH_CN BatchListJobDetailsRequestXLanguage
}

func GetBatchListJobDetailsRequestXLanguageEnum

func GetBatchListJobDetailsRequestXLanguageEnum() BatchListJobDetailsRequestXLanguageEnum

type BatchListJobDetailsResponse

type BatchListJobDetailsResponse struct {

	// 任务数量
	Count *int32 `json:"count,omitempty"`

	// 任务详细信息
	Results        *[]QueryJobResp `json:"results,omitempty"`
	HttpStatusCode int             `json:"-"`
}

Response Object

func (BatchListJobDetailsResponse) String

type BatchListJobStatusRequest

type BatchListJobStatusRequest struct {

	// 请求语言类型
	XLanguage *BatchListJobStatusRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryJobReqPage `json:"body,omitempty"`
}

Request Object

func (BatchListJobStatusRequest) String

func (o BatchListJobStatusRequest) String() string

type BatchListJobStatusRequestXLanguage

type BatchListJobStatusRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListJobStatusRequestXLanguage) MarshalJSON

func (c BatchListJobStatusRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListJobStatusRequestXLanguage) UnmarshalJSON

func (c *BatchListJobStatusRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListJobStatusRequestXLanguage) Value added in v0.0.90

type BatchListJobStatusRequestXLanguageEnum

type BatchListJobStatusRequestXLanguageEnum struct {
	EN_US BatchListJobStatusRequestXLanguage
	ZH_CN BatchListJobStatusRequestXLanguage
}

func GetBatchListJobStatusRequestXLanguageEnum

func GetBatchListJobStatusRequestXLanguageEnum() BatchListJobStatusRequestXLanguageEnum

type BatchListJobStatusResponse

type BatchListJobStatusResponse struct {

	// 任务状态信息
	Results *[]QueryJobStatusResp `json:"results,omitempty"`

	// 返回任务数量
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchListJobStatusResponse) String

type BatchListProgressesRequest

type BatchListProgressesRequest struct {

	// 请求语言类型
	XLanguage *BatchListProgressesRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryProgressReq `json:"body,omitempty"`
}

Request Object

func (BatchListProgressesRequest) String

type BatchListProgressesRequestXLanguage

type BatchListProgressesRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListProgressesRequestXLanguage) MarshalJSON

func (c BatchListProgressesRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListProgressesRequestXLanguage) UnmarshalJSON

func (c *BatchListProgressesRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListProgressesRequestXLanguage) Value added in v0.0.90

type BatchListProgressesRequestXLanguageEnum

type BatchListProgressesRequestXLanguageEnum struct {
	EN_US BatchListProgressesRequestXLanguage
	ZH_CN BatchListProgressesRequestXLanguage
}

func GetBatchListProgressesRequestXLanguageEnum

func GetBatchListProgressesRequestXLanguageEnum() BatchListProgressesRequestXLanguageEnum

type BatchListProgressesResponse

type BatchListProgressesResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量查询迁移进度的响应体集合
	Results        *[]QueryProgressResp `json:"results,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (BatchListProgressesResponse) String

type BatchListRposAndRtosRequest

type BatchListRposAndRtosRequest struct {

	// 请求语言类型
	XLanguage *BatchListRposAndRtosRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryRpoAndRtoReq `json:"body,omitempty"`
}

Request Object

func (BatchListRposAndRtosRequest) String

type BatchListRposAndRtosRequestXLanguage

type BatchListRposAndRtosRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListRposAndRtosRequestXLanguage) MarshalJSON

func (c BatchListRposAndRtosRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListRposAndRtosRequestXLanguage) UnmarshalJSON

func (c *BatchListRposAndRtosRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListRposAndRtosRequestXLanguage) Value added in v0.0.90

type BatchListRposAndRtosRequestXLanguageEnum

type BatchListRposAndRtosRequestXLanguageEnum struct {
	EN_US BatchListRposAndRtosRequestXLanguage
	ZH_CN BatchListRposAndRtosRequestXLanguage
}

func GetBatchListRposAndRtosRequestXLanguageEnum

func GetBatchListRposAndRtosRequestXLanguageEnum() BatchListRposAndRtosRequestXLanguageEnum

type BatchListRposAndRtosResponse

type BatchListRposAndRtosResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量查询RPO&RTO的响应体集合
	Results        *[]QueryRpoAndRtoResp `json:"results,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (BatchListRposAndRtosResponse) String

type BatchListStructDetailRequest

type BatchListStructDetailRequest struct {

	// 数据库支持迁移对象类型
	Type BatchListStructDetailRequestType `json:"type"`

	// 请求语言类型
	XLanguage *BatchListStructDetailRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryJobReqPage `json:"body,omitempty"`
}

Request Object

func (BatchListStructDetailRequest) String

type BatchListStructDetailRequestType

type BatchListStructDetailRequestType struct {
	// contains filtered or unexported fields
}

func (BatchListStructDetailRequestType) MarshalJSON

func (c BatchListStructDetailRequestType) MarshalJSON() ([]byte, error)

func (*BatchListStructDetailRequestType) UnmarshalJSON

func (c *BatchListStructDetailRequestType) UnmarshalJSON(b []byte) error

func (BatchListStructDetailRequestType) Value added in v0.0.90

type BatchListStructDetailRequestXLanguage

type BatchListStructDetailRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListStructDetailRequestXLanguage) MarshalJSON

func (c BatchListStructDetailRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListStructDetailRequestXLanguage) UnmarshalJSON

func (c *BatchListStructDetailRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListStructDetailRequestXLanguage) Value added in v0.0.90

type BatchListStructDetailRequestXLanguageEnum

type BatchListStructDetailRequestXLanguageEnum struct {
	EN_US BatchListStructDetailRequestXLanguage
	ZH_CN BatchListStructDetailRequestXLanguage
}

func GetBatchListStructDetailRequestXLanguageEnum

func GetBatchListStructDetailRequestXLanguageEnum() BatchListStructDetailRequestXLanguageEnum

type BatchListStructDetailResponse

type BatchListStructDetailResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量查询灾备初始化对象详情返回列表
	Results        *[]QueryStructDetailResp `json:"results,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

Response Object

func (BatchListStructDetailResponse) String

type BatchListStructProcessRequest

type BatchListStructProcessRequest struct {

	// 请求语言类型
	XLanguage *BatchListStructProcessRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryJobReq `json:"body,omitempty"`
}

Request Object

func (BatchListStructProcessRequest) String

type BatchListStructProcessRequestXLanguage

type BatchListStructProcessRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchListStructProcessRequestXLanguage) MarshalJSON

func (c BatchListStructProcessRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchListStructProcessRequestXLanguage) UnmarshalJSON

func (c *BatchListStructProcessRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchListStructProcessRequestXLanguage) Value added in v0.0.90

type BatchListStructProcessRequestXLanguageEnum

type BatchListStructProcessRequestXLanguageEnum struct {
	EN_US BatchListStructProcessRequestXLanguage
	ZH_CN BatchListStructProcessRequestXLanguage
}

func GetBatchListStructProcessRequestXLanguageEnum

func GetBatchListStructProcessRequestXLanguageEnum() BatchListStructProcessRequestXLanguageEnum

type BatchListStructProcessResponse

type BatchListStructProcessResponse struct {

	// 批量查询灾备初始化进度返回列表
	Results *[]QueryStructProcessResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchListStructProcessResponse) String

type BatchModifyJobReq

type BatchModifyJobReq struct {

	// 修改任务请求体
	Jobs []ModifyJobReq `json:"jobs"`
}

批量修改任务请求体

func (BatchModifyJobReq) String

func (o BatchModifyJobReq) String() string

type BatchModifyPwdReq

type BatchModifyPwdReq struct {

	// 批量修改数据库密码信息列表
	Jobs []ModifyPwdEndPoint `json:"jobs"`
}

func (BatchModifyPwdReq) String

func (o BatchModifyPwdReq) String() string

type BatchPauseJobReq

type BatchPauseJobReq struct {

	// 不能包含空对象。 集合中的job_id取值严格匹配UUID规则。
	Jobs []PauseInfo `json:"jobs"`
}

批量暂停任务请求体

func (BatchPauseJobReq) String

func (o BatchPauseJobReq) String() string

type BatchPrecheckReq

type BatchPrecheckReq struct {

	// 批量预检查请求列表
	Jobs []PreCheckInfo `json:"jobs"`
}

批量预检查请求体

func (BatchPrecheckReq) String

func (o BatchPrecheckReq) String() string

type BatchQueryJobReq

type BatchQueryJobReq struct {

	// 查询任务请求体
	Jobs []string `json:"jobs"`
}

查询任务请求体

func (BatchQueryJobReq) String

func (o BatchQueryJobReq) String() string

type BatchQueryJobReqPage

type BatchQueryJobReqPage struct {

	// 批量查询任务详情
	Jobs []string `json:"jobs"`

	PageReq *PageReq `json:"page_req,omitempty"`
}

带分页的批量查询任务详情请求体

func (BatchQueryJobReqPage) String

func (o BatchQueryJobReqPage) String() string

type BatchQueryParamReq

type BatchQueryParamReq struct {

	// 查询任务ID集合。
	Jobs []string `json:"jobs"`

	// 是否重新获取数据库参数,1代表是,0代表否(从缓存中获取),第一次调用时请设置为1。
	Refresh string `json:"refresh"`
}

func (BatchQueryParamReq) String

func (o BatchQueryParamReq) String() string

type BatchQueryPrecheckResultReq

type BatchQueryPrecheckResultReq struct {

	// 批量查询预检查结果请求列表。 约束:不能包含空对象。集合中的元素取值严格匹配UUID规则。任务id不能重复。
	Jobs []string `json:"jobs"`
}

批量查询预检查结果请求体

func (BatchQueryPrecheckResultReq) String

type BatchQueryProgressReq

type BatchQueryProgressReq struct {

	// 批量查询进度任务ID请求列表
	Jobs []string `json:"jobs"`
}

批量查询同步进度的请求体

func (BatchQueryProgressReq) String

func (o BatchQueryProgressReq) String() string

type BatchQueryRpoAndRtoReq

type BatchQueryRpoAndRtoReq struct {

	// 批量查询RPO和RTO的任务详情ID请求列表
	Jobs []string `json:"jobs"`
}

批量查询RPO和RTO的请求体

func (BatchQueryRpoAndRtoReq) String

func (o BatchQueryRpoAndRtoReq) String() string

type BatchReplaceDefinerReq

type BatchReplaceDefinerReq struct {

	// 批量设置replaceDefiner请求列表
	Jobs []ReplaceDefinerInfo `json:"jobs"`
}

批量设置replaceDefiner请求体

func (BatchReplaceDefinerReq) String

func (o BatchReplaceDefinerReq) String() string

type BatchResetPasswordRequest

type BatchResetPasswordRequest struct {

	// 请求语言类型
	XLanguage *BatchResetPasswordRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchModifyPwdReq `json:"body,omitempty"`
}

Request Object

func (BatchResetPasswordRequest) String

func (o BatchResetPasswordRequest) String() string

type BatchResetPasswordRequestXLanguage

type BatchResetPasswordRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchResetPasswordRequestXLanguage) MarshalJSON

func (c BatchResetPasswordRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchResetPasswordRequestXLanguage) UnmarshalJSON

func (c *BatchResetPasswordRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchResetPasswordRequestXLanguage) Value added in v0.0.90

type BatchResetPasswordRequestXLanguageEnum

type BatchResetPasswordRequestXLanguageEnum struct {
	EN_US BatchResetPasswordRequestXLanguage
	ZH_CN BatchResetPasswordRequestXLanguage
}

func GetBatchResetPasswordRequestXLanguageEnum

func GetBatchResetPasswordRequestXLanguageEnum() BatchResetPasswordRequestXLanguageEnum

type BatchResetPasswordResponse

type BatchResetPasswordResponse struct {
	Results *[]ModifyDbPwdResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchResetPasswordResponse) String

type BatchRestoreTaskRequest

type BatchRestoreTaskRequest struct {

	// 请求语言类型
	XLanguage *BatchRestoreTaskRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchRetryReq `json:"body,omitempty"`
}

Request Object

func (BatchRestoreTaskRequest) String

func (o BatchRestoreTaskRequest) String() string

type BatchRestoreTaskRequestXLanguage

type BatchRestoreTaskRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchRestoreTaskRequestXLanguage) MarshalJSON

func (c BatchRestoreTaskRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchRestoreTaskRequestXLanguage) UnmarshalJSON

func (c *BatchRestoreTaskRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchRestoreTaskRequestXLanguage) Value added in v0.0.90

type BatchRestoreTaskRequestXLanguageEnum

type BatchRestoreTaskRequestXLanguageEnum struct {
	EN_US BatchRestoreTaskRequestXLanguage
	ZH_CN BatchRestoreTaskRequestXLanguage
}

func GetBatchRestoreTaskRequestXLanguageEnum

func GetBatchRestoreTaskRequestXLanguageEnum() BatchRestoreTaskRequestXLanguageEnum

type BatchRestoreTaskResponse

type BatchRestoreTaskResponse struct {

	// 批量续传返回列表
	Results *[]RetryTaskResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchRestoreTaskResponse) String

func (o BatchRestoreTaskResponse) String() string

type BatchRetryReq

type BatchRetryReq struct {

	// 批量续传任务请求列表
	Jobs []RetryInfo `json:"jobs"`
}

批量续传任务请求列表

func (BatchRetryReq) String

func (o BatchRetryReq) String() string

type BatchSetAlarmNotifyInfo added in v0.0.84

type BatchSetAlarmNotifyInfo struct {

	// 手动输入手机号、邮箱模式时填写
	Subscriptions *[]SubscriptionInfo `json:"subscriptions,omitempty"`

	// 主题资源标识
	TopicUrn *string `json:"topic_urn,omitempty"`

	// 订阅延迟时间
	DelayTime *int64 `json:"delay_time,omitempty"`

	// rto延迟时间
	RtoDelay *int64 `json:"rto_delay,omitempty"`

	// rpo延迟时间
	RpoDelay *int64 `json:"rpo_delay,omitempty"`

	// 异常告警是否通知用户,不填默认为false
	AlarmToUser *bool `json:"alarm_to_user,omitempty"`
}

修改收件方式与信息体

func (BatchSetAlarmNotifyInfo) String added in v0.0.84

func (o BatchSetAlarmNotifyInfo) String() string

type BatchSetDefinerRequest

type BatchSetDefinerRequest struct {

	// 请求语言类型
	XLanguage *BatchSetDefinerRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchReplaceDefinerReq `json:"body,omitempty"`
}

Request Object

func (BatchSetDefinerRequest) String

func (o BatchSetDefinerRequest) String() string

type BatchSetDefinerRequestXLanguage

type BatchSetDefinerRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSetDefinerRequestXLanguage) MarshalJSON

func (c BatchSetDefinerRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSetDefinerRequestXLanguage) UnmarshalJSON

func (c *BatchSetDefinerRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSetDefinerRequestXLanguage) Value added in v0.0.90

type BatchSetDefinerRequestXLanguageEnum

type BatchSetDefinerRequestXLanguageEnum struct {
	EN_US BatchSetDefinerRequestXLanguage
	ZH_CN BatchSetDefinerRequestXLanguage
}

func GetBatchSetDefinerRequestXLanguageEnum

func GetBatchSetDefinerRequestXLanguageEnum() BatchSetDefinerRequestXLanguageEnum

type BatchSetDefinerResponse

type BatchSetDefinerResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量修改任务返回列表
	Results        *[]ModifyJobResp `json:"results,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (BatchSetDefinerResponse) String

func (o BatchSetDefinerResponse) String() string

type BatchSetObjectsRequest

type BatchSetObjectsRequest struct {

	// 请求语言类型
	XLanguage *BatchSetObjectsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchUpdateDatabaseObjectReq `json:"body,omitempty"`
}

Request Object

func (BatchSetObjectsRequest) String

func (o BatchSetObjectsRequest) String() string

type BatchSetObjectsRequestXLanguage

type BatchSetObjectsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSetObjectsRequestXLanguage) MarshalJSON

func (c BatchSetObjectsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSetObjectsRequestXLanguage) UnmarshalJSON

func (c *BatchSetObjectsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSetObjectsRequestXLanguage) Value added in v0.0.90

type BatchSetObjectsRequestXLanguageEnum

type BatchSetObjectsRequestXLanguageEnum struct {
	EN_US BatchSetObjectsRequestXLanguage
	ZH_CN BatchSetObjectsRequestXLanguage
}

func GetBatchSetObjectsRequestXLanguageEnum

func GetBatchSetObjectsRequestXLanguageEnum() BatchSetObjectsRequestXLanguageEnum

type BatchSetObjectsResponse

type BatchSetObjectsResponse struct {

	// 总数
	AllCounts *int64 `json:"all_counts,omitempty"`

	// 批量对象选择响应列表
	Results        *[]DatabaseObjectResp `json:"results,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (BatchSetObjectsResponse) String

func (o BatchSetObjectsResponse) String() string

type BatchSetPolicyRequest added in v0.0.63

type BatchSetPolicyRequest struct {

	// 请求语言类型。
	XLanguage *BatchSetPolicyRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchSetupSyncPolicyReq `json:"body,omitempty"`
}

Request Object

func (BatchSetPolicyRequest) String added in v0.0.63

func (o BatchSetPolicyRequest) String() string

type BatchSetPolicyRequestXLanguage added in v0.0.63

type BatchSetPolicyRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSetPolicyRequestXLanguage) MarshalJSON added in v0.0.63

func (c BatchSetPolicyRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSetPolicyRequestXLanguage) UnmarshalJSON added in v0.0.63

func (c *BatchSetPolicyRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSetPolicyRequestXLanguage) Value added in v0.0.90

type BatchSetPolicyRequestXLanguageEnum added in v0.0.63

type BatchSetPolicyRequestXLanguageEnum struct {
	EN_US BatchSetPolicyRequestXLanguage
	ZH_CN BatchSetPolicyRequestXLanguage
}

func GetBatchSetPolicyRequestXLanguageEnum added in v0.0.63

func GetBatchSetPolicyRequestXLanguageEnum() BatchSetPolicyRequestXLanguageEnum

type BatchSetPolicyResponse added in v0.0.63

type BatchSetPolicyResponse struct {

	// 批量设置同步策略响应体
	Results *[]SyncPolicyResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchSetPolicyResponse) String added in v0.0.63

func (o BatchSetPolicyResponse) String() string

type BatchSetSmnRequest added in v0.0.84

type BatchSetSmnRequest struct {

	// 请求语言类型
	XLanguage *BatchSetSmnRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchImportSmnInfoReq `json:"body,omitempty"`
}

Request Object

func (BatchSetSmnRequest) String added in v0.0.84

func (o BatchSetSmnRequest) String() string

type BatchSetSmnRequestXLanguage added in v0.0.84

type BatchSetSmnRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSetSmnRequestXLanguage) MarshalJSON added in v0.0.84

func (c BatchSetSmnRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSetSmnRequestXLanguage) UnmarshalJSON added in v0.0.84

func (c *BatchSetSmnRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSetSmnRequestXLanguage) Value added in v0.0.90

type BatchSetSmnRequestXLanguageEnum added in v0.0.84

type BatchSetSmnRequestXLanguageEnum struct {
	EN_US BatchSetSmnRequestXLanguage
	ZH_CN BatchSetSmnRequestXLanguage
}

func GetBatchSetSmnRequestXLanguageEnum added in v0.0.84

func GetBatchSetSmnRequestXLanguageEnum() BatchSetSmnRequestXLanguageEnum

type BatchSetSmnResponse added in v0.0.84

type BatchSetSmnResponse struct {
	Results *[]ImportSmnResp `json:"results,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchSetSmnResponse) String added in v0.0.84

func (o BatchSetSmnResponse) String() string

type BatchSetSpeedRequest

type BatchSetSpeedRequest struct {

	// 请求语言类型
	XLanguage *BatchSetSpeedRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchLimitSpeedReq `json:"body,omitempty"`
}

Request Object

func (BatchSetSpeedRequest) String

func (o BatchSetSpeedRequest) String() string

type BatchSetSpeedRequestXLanguage

type BatchSetSpeedRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSetSpeedRequestXLanguage) MarshalJSON

func (c BatchSetSpeedRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSetSpeedRequestXLanguage) UnmarshalJSON

func (c *BatchSetSpeedRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSetSpeedRequestXLanguage) Value added in v0.0.90

type BatchSetSpeedRequestXLanguageEnum

type BatchSetSpeedRequestXLanguageEnum struct {
	EN_US BatchSetSpeedRequestXLanguage
	ZH_CN BatchSetSpeedRequestXLanguage
}

func GetBatchSetSpeedRequestXLanguageEnum

func GetBatchSetSpeedRequestXLanguageEnum() BatchSetSpeedRequestXLanguageEnum

type BatchSetSpeedResponse

type BatchSetSpeedResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量修改任务返回列表
	Results        *[]ModifyJobResp `json:"results,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (BatchSetSpeedResponse) String

func (o BatchSetSpeedResponse) String() string

type BatchSetupSyncPolicyReq added in v0.0.63

type BatchSetupSyncPolicyReq struct {

	// 批量设置同步策略请求列表。
	Jobs []SyncPolicyReq `json:"jobs"`
}

批量设置同步策略请求体

func (BatchSetupSyncPolicyReq) String added in v0.0.63

func (o BatchSetupSyncPolicyReq) String() string

type BatchShowParamsRequest

type BatchShowParamsRequest struct {

	// 请求语言类型
	XLanguage *BatchShowParamsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryParamReq `json:"body,omitempty"`
}

Request Object

func (BatchShowParamsRequest) String

func (o BatchShowParamsRequest) String() string

type BatchShowParamsRequestXLanguage

type BatchShowParamsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchShowParamsRequestXLanguage) MarshalJSON

func (c BatchShowParamsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchShowParamsRequestXLanguage) UnmarshalJSON

func (c *BatchShowParamsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchShowParamsRequestXLanguage) Value added in v0.0.90

type BatchShowParamsRequestXLanguageEnum

type BatchShowParamsRequestXLanguageEnum struct {
	EN_US BatchShowParamsRequestXLanguage
	ZH_CN BatchShowParamsRequestXLanguage
}

func GetBatchShowParamsRequestXLanguageEnum

func GetBatchShowParamsRequestXLanguageEnum() BatchShowParamsRequestXLanguageEnum

type BatchShowParamsResponse

type BatchShowParamsResponse struct {

	// 查询数据库参数响应体
	ParamsList *[]QueryDbParamsResp `json:"params_list,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchShowParamsResponse) String

func (o BatchShowParamsResponse) String() string

type BatchSpecialTestConnectionReq

type BatchSpecialTestConnectionReq struct {

	// 集群批量测试连接任务请求列表
	Jobs []BatchJobActionReq `json:"jobs"`
}

集群批量测试连接任务请求体

func (BatchSpecialTestConnectionReq) String

type BatchStartJobReq

type BatchStartJobReq struct {

	// 批量启动任务请求列表。
	Jobs []StartInfo `json:"jobs"`
}

批量启动任务请求体。

func (BatchStartJobReq) String

func (o BatchStartJobReq) String() string

type BatchStartJobsRequest

type BatchStartJobsRequest struct {

	// 请求语言类型
	XLanguage *BatchStartJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchStartJobReq `json:"body,omitempty"`
}

Request Object

func (BatchStartJobsRequest) String

func (o BatchStartJobsRequest) String() string

type BatchStartJobsRequestXLanguage

type BatchStartJobsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchStartJobsRequestXLanguage) MarshalJSON

func (c BatchStartJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchStartJobsRequestXLanguage) UnmarshalJSON

func (c *BatchStartJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchStartJobsRequestXLanguage) Value added in v0.0.90

type BatchStartJobsRequestXLanguageEnum

type BatchStartJobsRequestXLanguageEnum struct {
	EN_US BatchStartJobsRequestXLanguage
	ZH_CN BatchStartJobsRequestXLanguage
}

func GetBatchStartJobsRequestXLanguageEnum

func GetBatchStartJobsRequestXLanguageEnum() BatchStartJobsRequestXLanguageEnum

type BatchStartJobsResponse

type BatchStartJobsResponse struct {

	// 批量启动实时灾备任务返回列表。
	Results *[]StartJobResp `json:"results,omitempty"`

	// 总数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchStartJobsResponse) String

func (o BatchStartJobsResponse) String() string

type BatchStopJobsRequest

type BatchStopJobsRequest struct {

	// 请求语言类型
	XLanguage *BatchStopJobsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchPauseJobReq `json:"body,omitempty"`
}

Request Object

func (BatchStopJobsRequest) String

func (o BatchStopJobsRequest) String() string

type BatchStopJobsRequestXLanguage

type BatchStopJobsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchStopJobsRequestXLanguage) MarshalJSON

func (c BatchStopJobsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchStopJobsRequestXLanguage) UnmarshalJSON

func (c *BatchStopJobsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchStopJobsRequestXLanguage) Value added in v0.0.90

type BatchStopJobsRequestXLanguageEnum

type BatchStopJobsRequestXLanguageEnum struct {
	EN_US BatchStopJobsRequestXLanguage
	ZH_CN BatchStopJobsRequestXLanguage
}

func GetBatchStopJobsRequestXLanguageEnum

func GetBatchStopJobsRequestXLanguageEnum() BatchStopJobsRequestXLanguageEnum

type BatchStopJobsResponse

type BatchStopJobsResponse struct {

	// 批量暂停返回列表
	Results *[]PauseJobResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchStopJobsResponse) String

func (o BatchStopJobsResponse) String() string

type BatchSwitchoverReq

type BatchSwitchoverReq struct {

	// 批量主备调换的任务详情ID请求列表
	Jobs []string `json:"jobs"`
}

批量主备倒换请求体

func (BatchSwitchoverReq) String

func (o BatchSwitchoverReq) String() string

type BatchSwitchoverRequest

type BatchSwitchoverRequest struct {

	// 请求语言类型
	XLanguage *BatchSwitchoverRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchSwitchoverReq `json:"body,omitempty"`
}

Request Object

func (BatchSwitchoverRequest) String

func (o BatchSwitchoverRequest) String() string

type BatchSwitchoverRequestXLanguage

type BatchSwitchoverRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchSwitchoverRequestXLanguage) MarshalJSON

func (c BatchSwitchoverRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchSwitchoverRequestXLanguage) UnmarshalJSON

func (c *BatchSwitchoverRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchSwitchoverRequestXLanguage) Value added in v0.0.90

type BatchSwitchoverRequestXLanguageEnum

type BatchSwitchoverRequestXLanguageEnum struct {
	EN_US BatchSwitchoverRequestXLanguage
	ZH_CN BatchSwitchoverRequestXLanguage
}

func GetBatchSwitchoverRequestXLanguageEnum

func GetBatchSwitchoverRequestXLanguageEnum() BatchSwitchoverRequestXLanguageEnum

type BatchSwitchoverResponse

type BatchSwitchoverResponse struct {

	// 批量主备倒换任务返回列表
	Results *[]SwitchoverResp `json:"results,omitempty"`

	// 总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchSwitchoverResponse) String

func (o BatchSwitchoverResponse) String() string

type BatchTestConnectionReq

type BatchTestConnectionReq struct {

	// 批量测试连接请求列表。
	Jobs []TestEndPoint `json:"jobs"`
}

批量测试连接任务请求体

func (BatchTestConnectionReq) String

func (o BatchTestConnectionReq) String() string

type BatchUpdateDatabaseObjectReq

type BatchUpdateDatabaseObjectReq struct {

	// 批量更新数据库对象请求任务ID列表
	Jobs []UpdateDatabaseObjectReq `json:"jobs"`
}

批量更新数据库对象选择消息体

func (BatchUpdateDatabaseObjectReq) String

type BatchUpdateJobRequest

type BatchUpdateJobRequest struct {

	// 请求语言类型
	XLanguage *BatchUpdateJobRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchModifyJobReq `json:"body,omitempty"`
}

Request Object

func (BatchUpdateJobRequest) String

func (o BatchUpdateJobRequest) String() string

type BatchUpdateJobRequestXLanguage

type BatchUpdateJobRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchUpdateJobRequestXLanguage) MarshalJSON

func (c BatchUpdateJobRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchUpdateJobRequestXLanguage) UnmarshalJSON

func (c *BatchUpdateJobRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchUpdateJobRequestXLanguage) Value added in v0.0.90

type BatchUpdateJobRequestXLanguageEnum

type BatchUpdateJobRequestXLanguageEnum struct {
	EN_US BatchUpdateJobRequestXLanguage
	ZH_CN BatchUpdateJobRequestXLanguage
}

func GetBatchUpdateJobRequestXLanguageEnum

func GetBatchUpdateJobRequestXLanguageEnum() BatchUpdateJobRequestXLanguageEnum

type BatchUpdateJobResponse

type BatchUpdateJobResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 批量修改任务返回列表
	Results        *[]ModifyJobResp `json:"results,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (BatchUpdateJobResponse) String

func (o BatchUpdateJobResponse) String() string

type BatchUpdateSrcUserReq

type BatchUpdateSrcUserReq struct {

	// 批量更新迁移用户请求列表
	Jobs []UpdateUserReq `json:"jobs"`
}

批量更新迁移用户请求体

func (BatchUpdateSrcUserReq) String

func (o BatchUpdateSrcUserReq) String() string

type BatchUpdateUserRequest

type BatchUpdateUserRequest struct {

	// 请求语言类型
	XLanguage *BatchUpdateUserRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchUpdateSrcUserReq `json:"body,omitempty"`
}

Request Object

func (BatchUpdateUserRequest) String

func (o BatchUpdateUserRequest) String() string

type BatchUpdateUserRequestXLanguage

type BatchUpdateUserRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchUpdateUserRequestXLanguage) MarshalJSON

func (c BatchUpdateUserRequestXLanguage) MarshalJSON() ([]byte, error)

func (*BatchUpdateUserRequestXLanguage) UnmarshalJSON

func (c *BatchUpdateUserRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchUpdateUserRequestXLanguage) Value added in v0.0.90

type BatchUpdateUserRequestXLanguageEnum

type BatchUpdateUserRequestXLanguageEnum struct {
	EN_US BatchUpdateUserRequestXLanguage
	ZH_CN BatchUpdateUserRequestXLanguage
}

func GetBatchUpdateUserRequestXLanguageEnum

func GetBatchUpdateUserRequestXLanguageEnum() BatchUpdateUserRequestXLanguageEnum

type BatchUpdateUserResponse

type BatchUpdateUserResponse struct {

	// 总数
	AllCounts *int32 `json:"all_counts,omitempty"`

	// 迁移用户信息
	Results        *[]QueryUserResp `json:"results,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (BatchUpdateUserResponse) String

func (o BatchUpdateUserResponse) String() string

type BatchValidateClustersConnectionsRequest

type BatchValidateClustersConnectionsRequest struct {

	// 请求语言类型
	XLanguage *BatchValidateClustersConnectionsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchSpecialTestConnectionReq `json:"body,omitempty"`
}

Request Object

func (BatchValidateClustersConnectionsRequest) String

type BatchValidateClustersConnectionsRequestXLanguage

type BatchValidateClustersConnectionsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchValidateClustersConnectionsRequestXLanguage) MarshalJSON

func (*BatchValidateClustersConnectionsRequestXLanguage) UnmarshalJSON

func (BatchValidateClustersConnectionsRequestXLanguage) Value added in v0.0.90

type BatchValidateClustersConnectionsResponse

type BatchValidateClustersConnectionsResponse struct {

	// 批量测试连接响应体集合。
	Results *[]CheckJobResp `json:"results,omitempty"`

	// 总记录数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchValidateClustersConnectionsResponse) String

type BatchValidateConnectionsRequest

type BatchValidateConnectionsRequest struct {

	// 请求语言类型
	XLanguage *BatchValidateConnectionsRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchTestConnectionReq `json:"body,omitempty"`
}

Request Object

func (BatchValidateConnectionsRequest) String

type BatchValidateConnectionsRequestXLanguage

type BatchValidateConnectionsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (BatchValidateConnectionsRequestXLanguage) MarshalJSON

func (*BatchValidateConnectionsRequestXLanguage) UnmarshalJSON

func (c *BatchValidateConnectionsRequestXLanguage) UnmarshalJSON(b []byte) error

func (BatchValidateConnectionsRequestXLanguage) Value added in v0.0.90

type BatchValidateConnectionsRequestXLanguageEnum

type BatchValidateConnectionsRequestXLanguageEnum struct {
	EN_US BatchValidateConnectionsRequestXLanguage
	ZH_CN BatchValidateConnectionsRequestXLanguage
}

func GetBatchValidateConnectionsRequestXLanguageEnum

func GetBatchValidateConnectionsRequestXLanguageEnum() BatchValidateConnectionsRequestXLanguageEnum

type BatchValidateConnectionsResponse

type BatchValidateConnectionsResponse struct {

	// 批量测试连接响应体集合。
	Results *[]CheckJobResp `json:"results,omitempty"`

	// 总记录数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (BatchValidateConnectionsResponse) String

type CheckDataTransformationReq

type CheckDataTransformationReq struct {

	// 任务id
	JobId *string `json:"job_id,omitempty"`

	// 对象信息,生成加工规则时需要填写。
	ObjectInfo *[]DatabaseObjectVo `json:"object_info,omitempty"`

	TransformationInfo *TransformationInfo `json:"transformation_info"`

	ConfigTransformation *ConfigTransformationVo `json:"config_transformation,omitempty"`
}

校验数据加工规则请求体

func (CheckDataTransformationReq) String

type CheckJobResp

type CheckJobResp struct {

	// 任务id。
	Id string `json:"id"`

	// 测试结果。 - true:成功 - false:失败
	Status CheckJobRespStatus `json:"status"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 是否成功
	Success *bool `json:"success,omitempty"`
}

响应体

func (CheckJobResp) String

func (o CheckJobResp) String() string

type CheckJobRespStatus

type CheckJobRespStatus struct {
	// contains filtered or unexported fields
}

func (CheckJobRespStatus) MarshalJSON

func (c CheckJobRespStatus) MarshalJSON() ([]byte, error)

func (*CheckJobRespStatus) UnmarshalJSON

func (c *CheckJobRespStatus) UnmarshalJSON(b []byte) error

func (CheckJobRespStatus) Value added in v0.0.90

func (c CheckJobRespStatus) Value() string

type CheckJobRespStatusEnum

type CheckJobRespStatusEnum struct {
	TRUE  CheckJobRespStatus
	FALSE CheckJobRespStatus
}

func GetCheckJobRespStatusEnum

func GetCheckJobRespStatusEnum() CheckJobRespStatusEnum

type ChildrenJobInfo

type ChildrenJobInfo struct {

	// 计费字段
	BillingTag bool `json:"billing_tag"`

	// 任务创建时间
	CreateTime string `json:"create_time"`

	// 复制场景
	DbUseType ChildrenJobInfoDbUseType `json:"db_use_type"`

	// 任务描述
	Description string `json:"description"`

	// 引擎类型
	EngineType ChildrenJobInfoEngineType `json:"engine_type"`

	// 任务失败原因
	ErrorMsg string `json:"error_msg"`

	// 任务id
	Id string `json:"id"`

	// 迁移方向
	JobDirection ChildrenJobInfoJobDirection `json:"job_direction"`

	// 任务名称
	Name string `json:"name"`

	// 网络类型
	NetType ChildrenJobInfoNetType `json:"net_type"`

	// 新框架
	NodeNewFramework bool `json:"node_newFramework"`

	// 任务状态。 - CREATING:创建中 - CREATE_FAILED:创建失败 - CONFIGURATION:配置中 - STARTJOBING:启动中 - WAITING_FOR_START:等待启动中 - START_JOB_FAILED:启动失败 - PAUSING:已暂停 - FULL_TRANSFER_STARTED:全量开始,灾备场景下为初始化 - FULL_TRANSFER_FAILED:全量失败,灾备场景下为初始化失败 - FULL_TRANSFER_COMPLETE:全量完成,灾备场景下为初始化完成 - INCRE_TRANSFER_STARTED:增量开始,灾备场景下为灾备中 - INCRE_TRANSFER_FAILED:增量失败,灾备场景下为灾备异常 - RELEASE_RESOURCE_STARTED:结束任务中 - RELEASE_RESOURCE_FAILED:结束任务失败 - RELEASE_RESOURCE_COMPLETE:已结束 - REBUILD_NODE_STARTED:故障恢复中 - REBUILD_NODE_FAILED:故障恢复失败 - CHANGE_JOB_STARTED:任务变更中 - CHANGE_JOB_FAILED:任务变更失败 - DELETED:已删除 - CHILD_TRANSFER_STARTING:再编辑子任务启动中 - CHILD_TRANSFER_STARTED:再编辑子任务迁移中 - CHILD_TRANSFER_COMPLETE:再编辑子任务迁移完成 - CHILD_TRANSFER_FAILED:再编辑子任务迁移失败 - RELEASE_CHILD_TRANSFER_STARTED:再编辑子任务结束中 - RELEASE_CHILD_TRANSFER_COMPLETE:再编辑子任务已结束 - NODE_UPGRADE_START:升级开始 - NODE_UPGRADE_COMPLETE:升级完成 - NODE_UPGRADE_FAILED:升级失败
	Status ChildrenJobInfoStatus `json:"status"`

	// 迁移模式
	TaskType ChildrenJobInfoTaskType `json:"task_type"`

	JobAction *JobActionResp `json:"job_action,omitempty"`
}

子任务信息体

func (ChildrenJobInfo) String

func (o ChildrenJobInfo) String() string

type ChildrenJobInfoDbUseType

type ChildrenJobInfoDbUseType struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoDbUseType) MarshalJSON

func (c ChildrenJobInfoDbUseType) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoDbUseType) UnmarshalJSON

func (c *ChildrenJobInfoDbUseType) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoDbUseType) Value added in v0.0.90

func (c ChildrenJobInfoDbUseType) Value() string

type ChildrenJobInfoDbUseTypeEnum

type ChildrenJobInfoDbUseTypeEnum struct {
	MIGRATION        ChildrenJobInfoDbUseType
	SYNC             ChildrenJobInfoDbUseType
	CLOUD_DATA_GUARD ChildrenJobInfoDbUseType
}

func GetChildrenJobInfoDbUseTypeEnum

func GetChildrenJobInfoDbUseTypeEnum() ChildrenJobInfoDbUseTypeEnum

type ChildrenJobInfoEngineType

type ChildrenJobInfoEngineType struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoEngineType) MarshalJSON

func (c ChildrenJobInfoEngineType) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoEngineType) UnmarshalJSON

func (c *ChildrenJobInfoEngineType) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoEngineType) Value added in v0.0.90

type ChildrenJobInfoEngineTypeEnum

type ChildrenJobInfoEngineTypeEnum struct {
	CLOUD_DATA_GUARD_CASSANDRA       ChildrenJobInfoEngineType
	CLOUD_DATA_GUARD_DDM             ChildrenJobInfoEngineType
	CLOUD_DATA_GUARD_TAURUS_TO_MYSQL ChildrenJobInfoEngineType
	CLOUD_DATA_GUARD_MYSQL           ChildrenJobInfoEngineType
	CLOUD_DATA_GUARD_MYSQL_TO_TAURUS ChildrenJobInfoEngineType
}

func GetChildrenJobInfoEngineTypeEnum

func GetChildrenJobInfoEngineTypeEnum() ChildrenJobInfoEngineTypeEnum

type ChildrenJobInfoJobDirection

type ChildrenJobInfoJobDirection struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoJobDirection) MarshalJSON

func (c ChildrenJobInfoJobDirection) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoJobDirection) UnmarshalJSON

func (c *ChildrenJobInfoJobDirection) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoJobDirection) Value added in v0.0.90

type ChildrenJobInfoJobDirectionEnum

type ChildrenJobInfoJobDirectionEnum struct {
	UP     ChildrenJobInfoJobDirection
	DOWN   ChildrenJobInfoJobDirection
	NO_DBS ChildrenJobInfoJobDirection
}

func GetChildrenJobInfoJobDirectionEnum

func GetChildrenJobInfoJobDirectionEnum() ChildrenJobInfoJobDirectionEnum

type ChildrenJobInfoNetType

type ChildrenJobInfoNetType struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoNetType) MarshalJSON

func (c ChildrenJobInfoNetType) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoNetType) UnmarshalJSON

func (c *ChildrenJobInfoNetType) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoNetType) Value added in v0.0.90

func (c ChildrenJobInfoNetType) Value() string

type ChildrenJobInfoNetTypeEnum

type ChildrenJobInfoNetTypeEnum struct {
	VPC ChildrenJobInfoNetType
	VPN ChildrenJobInfoNetType
	EIP ChildrenJobInfoNetType
}

func GetChildrenJobInfoNetTypeEnum

func GetChildrenJobInfoNetTypeEnum() ChildrenJobInfoNetTypeEnum

type ChildrenJobInfoStatus added in v0.1.8

type ChildrenJobInfoStatus struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoStatus) MarshalJSON added in v0.1.8

func (c ChildrenJobInfoStatus) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoStatus) UnmarshalJSON added in v0.1.8

func (c *ChildrenJobInfoStatus) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoStatus) Value added in v0.1.8

func (c ChildrenJobInfoStatus) Value() string

type ChildrenJobInfoStatusEnum added in v0.1.8

type ChildrenJobInfoStatusEnum struct {
	CREATING                        ChildrenJobInfoStatus
	CREATE_FAILED                   ChildrenJobInfoStatus
	CONFIGURATION                   ChildrenJobInfoStatus
	STARTJOBING                     ChildrenJobInfoStatus
	WAITING_FOR_START               ChildrenJobInfoStatus
	START_JOB_FAILED                ChildrenJobInfoStatus
	PAUSING                         ChildrenJobInfoStatus
	FULL_TRANSFER_STARTED           ChildrenJobInfoStatus
	FULL_TRANSFER_FAILED            ChildrenJobInfoStatus
	FULL_TRANSFER_COMPLETE          ChildrenJobInfoStatus
	INCRE_TRANSFER_STARTED          ChildrenJobInfoStatus
	INCRE_TRANSFER_FAILED           ChildrenJobInfoStatus
	RELEASE_RESOURCE_STARTED        ChildrenJobInfoStatus
	RELEASE_RESOURCE_FAILED         ChildrenJobInfoStatus
	RELEASE_RESOURCE_COMPLETE       ChildrenJobInfoStatus
	REBUILD_NODE_STARTED            ChildrenJobInfoStatus
	REBUILD_NODE_FAILED             ChildrenJobInfoStatus
	CHANGE_JOB_STARTED              ChildrenJobInfoStatus
	CHANGE_JOB_FAILED               ChildrenJobInfoStatus
	DELETED                         ChildrenJobInfoStatus
	CHILD_TRANSFER_STARTING         ChildrenJobInfoStatus
	CHILD_TRANSFER_STARTED          ChildrenJobInfoStatus
	CHILD_TRANSFER_COMPLETE         ChildrenJobInfoStatus
	CHILD_TRANSFER_FAILED           ChildrenJobInfoStatus
	RELEASE_CHILD_TRANSFER_STARTED  ChildrenJobInfoStatus
	RELEASE_CHILD_TRANSFER_COMPLETE ChildrenJobInfoStatus
	NODE_UPGRADE_START              ChildrenJobInfoStatus
	NODE_UPGRADE_COMPLETE           ChildrenJobInfoStatus
	NODE_UPGRADE_FAILED             ChildrenJobInfoStatus
}

func GetChildrenJobInfoStatusEnum added in v0.1.8

func GetChildrenJobInfoStatusEnum() ChildrenJobInfoStatusEnum

type ChildrenJobInfoTaskType

type ChildrenJobInfoTaskType struct {
	// contains filtered or unexported fields
}

func (ChildrenJobInfoTaskType) MarshalJSON

func (c ChildrenJobInfoTaskType) MarshalJSON() ([]byte, error)

func (*ChildrenJobInfoTaskType) UnmarshalJSON

func (c *ChildrenJobInfoTaskType) UnmarshalJSON(b []byte) error

func (ChildrenJobInfoTaskType) Value added in v0.0.90

func (c ChildrenJobInfoTaskType) Value() string

type ChildrenJobInfoTaskTypeEnum

type ChildrenJobInfoTaskTypeEnum struct {
	FULL_TRANS      ChildrenJobInfoTaskType
	FULL_INCR_TRANS ChildrenJobInfoTaskType
	INCR_TRANS      ChildrenJobInfoTaskType
}

func GetChildrenJobInfoTaskTypeEnum

func GetChildrenJobInfoTaskTypeEnum() ChildrenJobInfoTaskTypeEnum

type CompareObjectInfo

type CompareObjectInfo struct {

	// 库名。
	DbName string `json:"db_name"`

	// 该库下的表名列表。
	TableName *[]string `json:"table_name,omitempty"`
}

func (CompareObjectInfo) String

func (o CompareObjectInfo) String() string

type CompareObjectInfoWithToken

type CompareObjectInfoWithToken struct {

	// 库名。
	DbName string `json:"db_name"`

	// 该库下的表信息列表(带token)。
	TableNameWithToken *[]CompareTableInfoWithToken `json:"table_name_with_token,omitempty"`
}

func (CompareObjectInfoWithToken) String

type CompareTableInfoWithToken

type CompareTableInfoWithToken struct {

	// 表名。
	TableName string `json:"table_name"`

	// 该表的min token。
	MinToken *string `json:"min_token,omitempty"`

	// 该表的max token。
	MaxToken *string `json:"max_token,omitempty"`
}

func (CompareTableInfoWithToken) String

func (o CompareTableInfoWithToken) String() string

type CompareTaskList

type CompareTaskList struct {

	// 对比任务的id。
	CompareTaskId string `json:"compare_task_id"`

	// 对比任务的类型。
	CompareType string `json:"compare_type"`

	// 对比任务的状态。 - RUNNING-运行中 - WAITING_FOR_RUNNING-等待启动中 - SUCCESSFUL-完成 - FAILED-失败 - CANCELLED-已取消 - TIMEOUT_INTERRUPT-超时中断 - FULL_DOING-全量校验中 - INCRE_DOING-增量校验中
	CompareTaskStatus CompareTaskListCompareTaskStatus `json:"compare_task_status"`

	// 对比开始时间。
	CreateTime string `json:"create_time"`

	// 对比结束时间。
	EndTime *string `json:"end_time,omitempty"`
}

func (CompareTaskList) String

func (o CompareTaskList) String() string

type CompareTaskListCompareTaskStatus

type CompareTaskListCompareTaskStatus struct {
	// contains filtered or unexported fields
}

func (CompareTaskListCompareTaskStatus) MarshalJSON

func (c CompareTaskListCompareTaskStatus) MarshalJSON() ([]byte, error)

func (*CompareTaskListCompareTaskStatus) UnmarshalJSON

func (c *CompareTaskListCompareTaskStatus) UnmarshalJSON(b []byte) error

func (CompareTaskListCompareTaskStatus) Value added in v0.0.90

type CompareTaskListResult

type CompareTaskListResult struct {

	// 对比任务列表。
	CompareTaskList *[]CompareTaskList `json:"compare_task_list,omitempty"`

	// 对比任务列表总数。
	CompareTaskListCount *int32 `json:"compare_task_list_count,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`
}

func (CompareTaskListResult) String

func (o CompareTaskListResult) String() string

type ConfigTransformationVo

type ConfigTransformationVo struct {

	// 库名.表名。
	DbTableName string `json:"db_table_name"`

	// 库名。长度限制256。
	DbName string `json:"db_name"`

	// 表名。长度限制256。
	TableName string `json:"table_name"`

	// 列名。长度限制256。
	ColNames string `json:"col_names"`

	// 主键或唯一索引。长度限制256。
	PrimKeyOrIndex string `json:"prim_key_or_index"`

	// 优化查询所需的索引。长度限制256。
	Indexs string `json:"indexs"`

	// 过滤条件。长度限制256。
	Values string `json:"values"`
}

数据同步配置库规则信息体

func (ConfigTransformationVo) String

func (o ConfigTransformationVo) String() string

type ContentCompareDetail

type ContentCompareDetail struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 目标库名称。
	TargetDbName string `json:"target_db_name"`

	// 源库的表名称。
	SourceTableName string `json:"source_table_name"`

	// 目标库的表名称。
	TargetTableName string `json:"target_table_name"`

	// 源库的表的行数。
	SourceRowNum int32 `json:"source_row_num"`

	// 目标库的表的行数。
	TargetRowNum int32 `json:"target_row_num"`

	// 源库的表和目标库的表的差异值。
	DiffRowNum int32 `json:"diff_row_num"`

	// 行对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	LineCompareResult *ContentCompareDetailLineCompareResult `json:"line_compare_result,omitempty"`

	// 内容对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	ContentCompareResult ContentCompareDetailContentCompareResult `json:"content_compare_result"`

	// 附加信息。
	Message *string `json:"message,omitempty"`
}

内容对比结果详情。

func (ContentCompareDetail) String

func (o ContentCompareDetail) String() string

type ContentCompareDetailContentCompareResult

type ContentCompareDetailContentCompareResult struct {
	// contains filtered or unexported fields
}

func (ContentCompareDetailContentCompareResult) MarshalJSON

func (*ContentCompareDetailContentCompareResult) UnmarshalJSON

func (c *ContentCompareDetailContentCompareResult) UnmarshalJSON(b []byte) error

func (ContentCompareDetailContentCompareResult) Value added in v0.0.90

type ContentCompareDetailLineCompareResult

type ContentCompareDetailLineCompareResult struct {
	// contains filtered or unexported fields
}

func (ContentCompareDetailLineCompareResult) MarshalJSON

func (c ContentCompareDetailLineCompareResult) MarshalJSON() ([]byte, error)

func (*ContentCompareDetailLineCompareResult) UnmarshalJSON

func (c *ContentCompareDetailLineCompareResult) UnmarshalJSON(b []byte) error

func (ContentCompareDetailLineCompareResult) Value added in v0.0.90

type ContentCompareDiff

type ContentCompareDiff struct {

	// 查询目标库的SQL。
	TargetSelectSql *string `json:"target_select_sql,omitempty"`

	// 查询源库的SQL。
	SourceSelectSql *string `json:"source_select_sql,omitempty"`

	// 源库KEY值列表。
	SourceKeyValue []string `json:"source_key_value"`

	// 目标库KEY值列表。
	TargetKeyValue []string `json:"target_key_value"`
}

func (ContentCompareDiff) String

func (o ContentCompareDiff) String() string

type ContentCompareResult

type ContentCompareResult struct {

	// 内容对比的任务id。
	CompareTaskId string `json:"compare_task_id"`

	// 内容对比结果概览。
	ContentCompareOverview *[]ContentCompareResultOverview `json:"content_compare_overview,omitempty"`

	// 内容对比结果概览总数。
	ContentCompareOverviewCount *int32 `json:"content_compare_overview_count,omitempty"`

	// 内容对比结果详情。
	ContentCompareDetails *[]ContentCompareResultDetails `json:"content_compare_details,omitempty"`

	// 内容对比结果差异。
	ContentCompareDiffs *[]ContentCompareResultDiffs `json:"content_compare_diffs,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (ContentCompareResult) String

func (o ContentCompareResult) String() string

type ContentCompareResultDetails

type ContentCompareResultDetails struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 该库的表的内容对比详情。
	ContentCompareDetail []ContentCompareDetail `json:"content_compare_detail"`

	// 内容对比结果详情总数。
	ContentCompareDetailCount int32 `json:"content_compare_detail_count"`

	// 该库的表的内容对比详情(无法对比的表)。
	ContentUncompareDetail *[]ContentCompareDetail `json:"content_uncompare_detail,omitempty"`

	// 内容对比结果详情总数(无法对比的表)。
	ContentUncompareDetailCount int32 `json:"content_uncompare_detail_count"`
}

func (ContentCompareResultDetails) String

type ContentCompareResultDiffs

type ContentCompareResultDiffs struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 源库的表名称。
	SourceTableName string `json:"source_table_name"`

	// 内容对比结果差异。
	ContentCompareDiff []ContentCompareDiff `json:"content_compare_diff"`

	// 内容对比结果差异总数。
	ContentCompareDiffCount int32 `json:"content_compare_diff_count"`
}

func (ContentCompareResultDiffs) String

func (o ContentCompareResultDiffs) String() string

type ContentCompareResultOverview

type ContentCompareResultOverview struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 目标库名称。
	TargetDbName string `json:"target_db_name"`

	// 对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	ContentCompareResult ContentCompareResultOverviewContentCompareResult `json:"content_compare_result"`
}

func (ContentCompareResultOverview) String

type ContentCompareResultOverviewContentCompareResult

type ContentCompareResultOverviewContentCompareResult struct {
	// contains filtered or unexported fields
}

func (ContentCompareResultOverviewContentCompareResult) MarshalJSON

func (*ContentCompareResultOverviewContentCompareResult) UnmarshalJSON

func (ContentCompareResultOverviewContentCompareResult) Value added in v0.0.90

type CreateCompareTaskReq

type CreateCompareTaskReq struct {

	// 任务id。
	JobId string `json:"job_id"`

	// 对象级对比类型,取值为空代表不创建对象级对比。object_level_compare_type和data_level_compare_info都为空时,只查询已创建的对比任务列表。
	ObjectLevelCompareType *CreateCompareTaskReqObjectLevelCompareType `json:"object_level_compare_type,omitempty"`

	DataLevelCompareInfo *CreateDataLevelCompareReq `json:"data_level_compare_info,omitempty"`
}

func (CreateCompareTaskReq) String

func (o CreateCompareTaskReq) String() string

type CreateCompareTaskReqObjectLevelCompareType

type CreateCompareTaskReqObjectLevelCompareType struct {
	// contains filtered or unexported fields
}

func (CreateCompareTaskReqObjectLevelCompareType) MarshalJSON

func (*CreateCompareTaskReqObjectLevelCompareType) UnmarshalJSON

func (CreateCompareTaskReqObjectLevelCompareType) Value added in v0.0.90

type CreateCompareTaskReqObjectLevelCompareTypeEnum

type CreateCompareTaskReqObjectLevelCompareTypeEnum struct {
	OBJECTS CreateCompareTaskReqObjectLevelCompareType
}

func GetCreateCompareTaskReqObjectLevelCompareTypeEnum

func GetCreateCompareTaskReqObjectLevelCompareTypeEnum() CreateCompareTaskReqObjectLevelCompareTypeEnum

type CreateCompareTaskRequest

type CreateCompareTaskRequest struct {

	// 请求语言类型
	XLanguage *CreateCompareTaskRequestXLanguage `json:"X-Language,omitempty"`

	Body *CreateCompareTaskReq `json:"body,omitempty"`
}

Request Object

func (CreateCompareTaskRequest) String

func (o CreateCompareTaskRequest) String() string

type CreateCompareTaskRequestXLanguage

type CreateCompareTaskRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (CreateCompareTaskRequestXLanguage) MarshalJSON

func (c CreateCompareTaskRequestXLanguage) MarshalJSON() ([]byte, error)

func (*CreateCompareTaskRequestXLanguage) UnmarshalJSON

func (c *CreateCompareTaskRequestXLanguage) UnmarshalJSON(b []byte) error

func (CreateCompareTaskRequestXLanguage) Value added in v0.0.90

type CreateCompareTaskRequestXLanguageEnum

type CreateCompareTaskRequestXLanguageEnum struct {
	EN_US CreateCompareTaskRequestXLanguage
	ZH_CN CreateCompareTaskRequestXLanguage
}

func GetCreateCompareTaskRequestXLanguageEnum

func GetCreateCompareTaskRequestXLanguageEnum() CreateCompareTaskRequestXLanguageEnum

type CreateCompareTaskResponse

type CreateCompareTaskResponse struct {

	// 任务id。
	JobId *string `json:"job_id,omitempty"`

	ObjectLevelCompareCreateResult *CreateCompareTaskResult `json:"object_level_compare_create_result,omitempty"`

	DataLevelCompareCreateResult *CreateCompareTaskResult `json:"data_level_compare_create_result,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateCompareTaskResponse) String

func (o CreateCompareTaskResponse) String() string

type CreateCompareTaskResult

type CreateCompareTaskResult struct {

	// 对比任务创建成功后,返回对比任务的id,用于查询该对比任务的结果。
	CompareTaskId *string `json:"compare_task_id,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (CreateCompareTaskResult) String

func (o CreateCompareTaskResult) String() string

type CreateDataLevelCompareReq

type CreateDataLevelCompareReq struct {

	// 一个任务只允许有一个未完成的数据级对比任务,该字段决定对未完成数据级对比任务的处理方式。cancel-取消后重新创建,keep-保持未完成的不再创建。
	ConflictPolicy CreateDataLevelCompareReqConflictPolicy `json:"conflict_policy"`

	// 数据级对比类型,lines-行对比,contents-内容对比。
	CompareType CreateDataLevelCompareReqCompareType `json:"compare_type"`

	// 数据级对比模式,取值为空时需要在compare_object_infos或者compare_object_infos_with_token传对象信息,quick_comparison-快速对比,需要加入该功能的白名单才能使用。
	CompareMode *CreateDataLevelCompareReqCompareMode `json:"compare_mode,omitempty"`

	// 对比任务启动时间,取值为空代表立即启动。
	StartTime *string `json:"start_time,omitempty"`

	// 数据级对比的对象。非“快速对比”模式时,compare_object_infos和compare_object_infos_with_token根据链路二选一传值,不允许都为空。
	CompareObjectInfos *[]CompareObjectInfo `json:"compare_object_infos,omitempty"`

	// 数据级对比的对象(Cassandra灾备专用,带token信息)。非“快速对比”模式时,compare_object_infos和compare_object_infos_with_token根据链路二选一传值,不允许都为空。
	CompareObjectInfosWithToken *[]CompareObjectInfoWithToken `json:"compare_object_infos_with_token,omitempty"`
}

func (CreateDataLevelCompareReq) String

func (o CreateDataLevelCompareReq) String() string

type CreateDataLevelCompareReqCompareMode

type CreateDataLevelCompareReqCompareMode struct {
	// contains filtered or unexported fields
}

func (CreateDataLevelCompareReqCompareMode) MarshalJSON

func (c CreateDataLevelCompareReqCompareMode) MarshalJSON() ([]byte, error)

func (*CreateDataLevelCompareReqCompareMode) UnmarshalJSON

func (c *CreateDataLevelCompareReqCompareMode) UnmarshalJSON(b []byte) error

func (CreateDataLevelCompareReqCompareMode) Value added in v0.0.90

type CreateDataLevelCompareReqCompareModeEnum

type CreateDataLevelCompareReqCompareModeEnum struct {
	QUICK_COMPARISON CreateDataLevelCompareReqCompareMode
}

func GetCreateDataLevelCompareReqCompareModeEnum

func GetCreateDataLevelCompareReqCompareModeEnum() CreateDataLevelCompareReqCompareModeEnum

type CreateDataLevelCompareReqCompareType

type CreateDataLevelCompareReqCompareType struct {
	// contains filtered or unexported fields
}

func (CreateDataLevelCompareReqCompareType) MarshalJSON

func (c CreateDataLevelCompareReqCompareType) MarshalJSON() ([]byte, error)

func (*CreateDataLevelCompareReqCompareType) UnmarshalJSON

func (c *CreateDataLevelCompareReqCompareType) UnmarshalJSON(b []byte) error

func (CreateDataLevelCompareReqCompareType) Value added in v0.0.90

type CreateDataLevelCompareReqCompareTypeEnum

type CreateDataLevelCompareReqCompareTypeEnum struct {
	LINES    CreateDataLevelCompareReqCompareType
	CONTENTS CreateDataLevelCompareReqCompareType
}

func GetCreateDataLevelCompareReqCompareTypeEnum

func GetCreateDataLevelCompareReqCompareTypeEnum() CreateDataLevelCompareReqCompareTypeEnum

type CreateDataLevelCompareReqConflictPolicy

type CreateDataLevelCompareReqConflictPolicy struct {
	// contains filtered or unexported fields
}

func (CreateDataLevelCompareReqConflictPolicy) MarshalJSON

func (c CreateDataLevelCompareReqConflictPolicy) MarshalJSON() ([]byte, error)

func (*CreateDataLevelCompareReqConflictPolicy) UnmarshalJSON

func (c *CreateDataLevelCompareReqConflictPolicy) UnmarshalJSON(b []byte) error

func (CreateDataLevelCompareReqConflictPolicy) Value added in v0.0.90

type CreateDataLevelCompareReqConflictPolicyEnum

type CreateDataLevelCompareReqConflictPolicyEnum struct {
	CANCEL CreateDataLevelCompareReqConflictPolicy
	KEEP   CreateDataLevelCompareReqConflictPolicy
}

func GetCreateDataLevelCompareReqConflictPolicyEnum

func GetCreateDataLevelCompareReqConflictPolicyEnum() CreateDataLevelCompareReqConflictPolicyEnum

type CreateJobReq

type CreateJobReq struct {

	// 是否绑定eip,网络类型为eip时必填且为true
	BindEip *bool `json:"bind_eip,omitempty"`

	// 迁移场景,migration-实时迁移,sync-实时同步,cloudDataGuard-实时灾备
	DbUseType CreateJobReqDbUseType `json:"db_use_type"`

	// 任务名称,约束:任务名称在4位到50位之间,不区分大小写,可以包含字母、数字、中划线或下划线,不能包括其他特殊字符。
	Name string `json:"name"`

	// 任务描述。  **约束**:任务描述不能超过256位,且不能包含!<>&'\"\\特殊字符。
	Description *string `json:"description,omitempty"`

	// 引擎类型 - mysql:迁移,同步使用 - mongodb:迁移使用 - cloudDataGuard-mysql:灾备使用 - gaussdbv5,postgresql:同步使用
	EngineType CreateJobReqEngineType `json:"engine_type"`

	// 指定目标实例是否限制为只读,MySQL迁移和灾备,且job_direction为up时设置有效。(灾备场景下,单主灾备且本云为备为必填且为true,不填默认设置为true)。
	IsTargetReadonly *bool `json:"is_target_readonly,omitempty"`

	// 迁移方向,up :入云 ,灾备场景时对应本云为备,down:出云,灾备场景时对应本云为主,non-dbs:自建
	JobDirection CreateJobReqJobDirection `json:"job_direction"`

	// - db_use_type 是cloudDataGuard时,必填,灾备类型是双主灾备时 muti_write取值true, 否则为false。 - db_use_type 是其他类型时,muti_write是非必选参数
	MultiWrite *bool `json:"multi_write,omitempty"`

	// 网络类型
	NetType CreateJobReqNetType `json:"net_type"`

	// 节点个数。MongoDB数据库时对应源端分片个数,源库为集群时必填,[1-32],MySQL双主灾备时会默认设置为2。
	NodeNum *int32 `json:"node_num,omitempty"`

	// 规格类型。
	NodeType CreateJobReqNodeType `json:"node_type"`

	SourceEndpoint *Endpoint `json:"source_endpoint"`

	TargetEndpoint *Endpoint `json:"target_endpoint"`

	// 标签信息。
	Tags *[]ResourceTag `json:"tags,omitempty"`

	// 迁移模式,FULL_TRANS 全量,FULL_INCR_TRANS 全量+增量,INCR_TRANS 增量,灾备场景单主灾备仅支持全量加增量(FULL_INCR_TRANS)
	TaskType CreateJobReqTaskType `json:"task_type"`

	// DRS实例所在子网ID,对应目标库相同VPC下已创建的子网(subnet)的网络ID,UUID格式。
	CustomizeSutnetId string `json:"customize_sutnet_id"`

	// 产品id。
	ProductId *string `json:"product_id,omitempty"`

	// 企业项目,不填默认为default,key值必须为_sys_enterprise_project_id,value为企业项目ID,只能有一个企业项目。
	SysTags *[]ResourceTag `json:"sys_tags,omitempty"`

	// 任务处于异常状态一段时间后,将会自动结束,单位为天。(范围14-100),不传默认为14天。
	ExpiredDays *string `json:"expired_days,omitempty"`

	// 主备任务主任务所在可用区code,可以通过查询规格未售罄的可用区接口获取 - master_az和slave_az同时填写时生效 - 目前支持mysql,gaussdbv5ha-to-kafka
	MasterAz *string `json:"master_az,omitempty"`

	// 主备任务备任务所在可用区code,可以通过查询规格未售罄的可用区接口获取 - master_az和slave_az同时填写时生效 - 目前支持mysql,gaussdbv5ha-to-kafka
	SlaveAz *string `json:"slave_az,omitempty"`

	// 计费模式,不填默认为按需计费。 取值范围: - period:包年包月。 - on_demand:按需计费。
	ChargingMode *CreateJobReqChargingMode `json:"charging_mode,omitempty"`

	PeriodOrder *PeriodOrderInfo `json:"period_order,omitempty"`
}

创建任务请求体

func (CreateJobReq) String

func (o CreateJobReq) String() string

type CreateJobReqChargingMode added in v0.1.20

type CreateJobReqChargingMode struct {
	// contains filtered or unexported fields
}

func (CreateJobReqChargingMode) MarshalJSON added in v0.1.20

func (c CreateJobReqChargingMode) MarshalJSON() ([]byte, error)

func (*CreateJobReqChargingMode) UnmarshalJSON added in v0.1.20

func (c *CreateJobReqChargingMode) UnmarshalJSON(b []byte) error

func (CreateJobReqChargingMode) Value added in v0.1.20

func (c CreateJobReqChargingMode) Value() string

type CreateJobReqChargingModeEnum added in v0.1.20

type CreateJobReqChargingModeEnum struct {
	PERIOD    CreateJobReqChargingMode
	ON_DEMAND CreateJobReqChargingMode
}

func GetCreateJobReqChargingModeEnum added in v0.1.20

func GetCreateJobReqChargingModeEnum() CreateJobReqChargingModeEnum

type CreateJobReqDbUseType

type CreateJobReqDbUseType struct {
	// contains filtered or unexported fields
}

func (CreateJobReqDbUseType) MarshalJSON

func (c CreateJobReqDbUseType) MarshalJSON() ([]byte, error)

func (*CreateJobReqDbUseType) UnmarshalJSON

func (c *CreateJobReqDbUseType) UnmarshalJSON(b []byte) error

func (CreateJobReqDbUseType) Value added in v0.0.90

func (c CreateJobReqDbUseType) Value() string

type CreateJobReqDbUseTypeEnum

type CreateJobReqDbUseTypeEnum struct {
	MIGRATION        CreateJobReqDbUseType
	SYNC             CreateJobReqDbUseType
	CLOUD_DATA_GUARD CreateJobReqDbUseType
}

func GetCreateJobReqDbUseTypeEnum

func GetCreateJobReqDbUseTypeEnum() CreateJobReqDbUseTypeEnum

type CreateJobReqEngineType

type CreateJobReqEngineType struct {
	// contains filtered or unexported fields
}

func (CreateJobReqEngineType) MarshalJSON

func (c CreateJobReqEngineType) MarshalJSON() ([]byte, error)

func (*CreateJobReqEngineType) UnmarshalJSON

func (c *CreateJobReqEngineType) UnmarshalJSON(b []byte) error

func (CreateJobReqEngineType) Value added in v0.0.90

func (c CreateJobReqEngineType) Value() string

type CreateJobReqEngineTypeEnum

type CreateJobReqEngineTypeEnum struct {
	MYSQL                  CreateJobReqEngineType
	MONGODB                CreateJobReqEngineType
	CLOUD_DATA_GUARD_MYSQL CreateJobReqEngineType
	GAUSSDBV5              CreateJobReqEngineType
	POSTGRESQL             CreateJobReqEngineType
}

func GetCreateJobReqEngineTypeEnum

func GetCreateJobReqEngineTypeEnum() CreateJobReqEngineTypeEnum

type CreateJobReqJobDirection

type CreateJobReqJobDirection struct {
	// contains filtered or unexported fields
}

func (CreateJobReqJobDirection) MarshalJSON

func (c CreateJobReqJobDirection) MarshalJSON() ([]byte, error)

func (*CreateJobReqJobDirection) UnmarshalJSON

func (c *CreateJobReqJobDirection) UnmarshalJSON(b []byte) error

func (CreateJobReqJobDirection) Value added in v0.0.90

func (c CreateJobReqJobDirection) Value() string

type CreateJobReqJobDirectionEnum

type CreateJobReqJobDirectionEnum struct {
	UP      CreateJobReqJobDirection
	DOWN    CreateJobReqJobDirection
	NON_DBS CreateJobReqJobDirection
}

func GetCreateJobReqJobDirectionEnum

func GetCreateJobReqJobDirectionEnum() CreateJobReqJobDirectionEnum

type CreateJobReqNetType

type CreateJobReqNetType struct {
	// contains filtered or unexported fields
}

func (CreateJobReqNetType) MarshalJSON

func (c CreateJobReqNetType) MarshalJSON() ([]byte, error)

func (*CreateJobReqNetType) UnmarshalJSON

func (c *CreateJobReqNetType) UnmarshalJSON(b []byte) error

func (CreateJobReqNetType) Value added in v0.0.90

func (c CreateJobReqNetType) Value() string

type CreateJobReqNetTypeEnum

type CreateJobReqNetTypeEnum struct {
	VPN CreateJobReqNetType
	VPC CreateJobReqNetType
	EIP CreateJobReqNetType
}

func GetCreateJobReqNetTypeEnum

func GetCreateJobReqNetTypeEnum() CreateJobReqNetTypeEnum

type CreateJobReqNodeType

type CreateJobReqNodeType struct {
	// contains filtered or unexported fields
}

func (CreateJobReqNodeType) MarshalJSON

func (c CreateJobReqNodeType) MarshalJSON() ([]byte, error)

func (*CreateJobReqNodeType) UnmarshalJSON

func (c *CreateJobReqNodeType) UnmarshalJSON(b []byte) error

func (CreateJobReqNodeType) Value added in v0.0.90

func (c CreateJobReqNodeType) Value() string

type CreateJobReqNodeTypeEnum

type CreateJobReqNodeTypeEnum struct {
	HIGH CreateJobReqNodeType
}

func GetCreateJobReqNodeTypeEnum

func GetCreateJobReqNodeTypeEnum() CreateJobReqNodeTypeEnum

type CreateJobReqTaskType

type CreateJobReqTaskType struct {
	// contains filtered or unexported fields
}

func (CreateJobReqTaskType) MarshalJSON

func (c CreateJobReqTaskType) MarshalJSON() ([]byte, error)

func (*CreateJobReqTaskType) UnmarshalJSON

func (c *CreateJobReqTaskType) UnmarshalJSON(b []byte) error

func (CreateJobReqTaskType) Value added in v0.0.90

func (c CreateJobReqTaskType) Value() string

type CreateJobReqTaskTypeEnum

type CreateJobReqTaskTypeEnum struct {
	FULL_TRANS      CreateJobReqTaskType
	FULL_INCR_TRANS CreateJobReqTaskType
	INCR_TRANS      CreateJobReqTaskType
}

func GetCreateJobReqTaskTypeEnum

func GetCreateJobReqTaskTypeEnum() CreateJobReqTaskTypeEnum

type CreateJobResp

type CreateJobResp struct {

	// 任务ID
	Id string `json:"id"`

	// 任务名称
	Name *string `json:"name,omitempty"`

	// 任务状态
	Status *string `json:"status,omitempty"`

	// 创建时间,时间戳
	CreateTime *string `json:"create_time,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 子任务ID,有子任务时返回该字段。
	ChildIds *[]string `json:"child_ids,omitempty"`
}

创建任务响应体

func (CreateJobResp) String

func (o CreateJobResp) String() string

type DataTransformationInfo added in v0.1.39

type DataTransformationInfo struct {
	TransformationInfo *TransformationInfo `json:"transformation_info,omitempty"`

	ConfigTransformation *ConfigTransformationVo `json:"config_transformation,omitempty"`

	// 数据加工对象。
	DataTransformationObjectInfos *[]DataTransformationObjectVo `json:"data_transformation_object_infos,omitempty"`
}

数据加工详情

func (DataTransformationInfo) String added in v0.1.39

func (o DataTransformationInfo) String() string

type DataTransformationObjectVo added in v0.1.39

type DataTransformationObjectVo struct {

	// 数据库对象、数据库表名称和过滤类型名称,例如格式为db1-*-*-tb1-*-*---conditionFilter--。
	Id *string `json:"id,omitempty"`

	// contentConditionalFilter:普通行过滤配置; configConditionalFilter:高级行过滤配置。
	DataTransformationType *string `json:"data_transformation_type,omitempty"`

	// 库名称。
	DbName *string `json:"db_name,omitempty"`

	// schema名称。
	SchemaName *string `json:"schema_name,omitempty"`

	// 表名称。
	TableName *string `json:"table_name,omitempty"`
}

数据加工对象

func (DataTransformationObjectVo) String added in v0.1.39

type DataTransformationResp

type DataTransformationResp struct {

	// 任务id
	Id *string `json:"id,omitempty"`

	// 状态
	Status *DataTransformationRespStatus `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

数据加工返回体

func (DataTransformationResp) String

func (o DataTransformationResp) String() string

type DataTransformationRespStatus

type DataTransformationRespStatus struct {
	// contains filtered or unexported fields
}

func (DataTransformationRespStatus) MarshalJSON

func (c DataTransformationRespStatus) MarshalJSON() ([]byte, error)

func (*DataTransformationRespStatus) UnmarshalJSON

func (c *DataTransformationRespStatus) UnmarshalJSON(b []byte) error

func (DataTransformationRespStatus) Value added in v0.0.90

type DataTransformationRespStatusEnum

type DataTransformationRespStatusEnum struct {
	SUCCESS DataTransformationRespStatus
	FAILED  DataTransformationRespStatus
}

func GetDataTransformationRespStatusEnum

func GetDataTransformationRespStatusEnum() DataTransformationRespStatusEnum

type DatabaseInfo

type DatabaseInfo struct {

	// object_type为database时,为库名;object_type为table或者view时,字段值参考示例。
	Id *string `json:"id,omitempty"`

	// object_type为table或view时需要填写,为库名
	ParentId *string `json:"parent_id,omitempty"`

	// 类型
	ObjectType *DatabaseInfoObjectType `json:"object_type,omitempty"`

	// 数据库对象名称,库名、表名、视图名
	ObjectName *string `json:"object_name,omitempty"`

	// 别名,映射的新名称。
	ObjectAliasName *string `json:"object_alias_name,omitempty"`

	// 是否选中,值为true会进行迁移,false该数据库对象不会迁移,partial为迁移库下面的部分表,不填默认为false
	Select *string `json:"select,omitempty"`
}

数据库对象选择信息

func (DatabaseInfo) String

func (o DatabaseInfo) String() string

type DatabaseInfoObjectType

type DatabaseInfoObjectType struct {
	// contains filtered or unexported fields
}

func (DatabaseInfoObjectType) MarshalJSON

func (c DatabaseInfoObjectType) MarshalJSON() ([]byte, error)

func (*DatabaseInfoObjectType) UnmarshalJSON

func (c *DatabaseInfoObjectType) UnmarshalJSON(b []byte) error

func (DatabaseInfoObjectType) Value added in v0.0.90

func (c DatabaseInfoObjectType) Value() string

type DatabaseInfoObjectTypeEnum

type DatabaseInfoObjectTypeEnum struct {
	DATABASE DatabaseInfoObjectType
	TABLE    DatabaseInfoObjectType
	SCHEMA   DatabaseInfoObjectType
	VIEW     DatabaseInfoObjectType
}

func GetDatabaseInfoObjectTypeEnum

func GetDatabaseInfoObjectTypeEnum() DatabaseInfoObjectTypeEnum

type DatabaseObjectInfo added in v0.1.20

type DatabaseObjectInfo struct {

	// type为database时,为库名;type为table或者view时,字段值参考示例
	Id *string `json:"id,omitempty"`

	// type为table或view时需要填写,为库名
	ParentId *string `json:"parent_id,omitempty"`

	// 类型。
	Type *string `json:"type,omitempty"`

	// 数据库对象名称,库名、表名、视图名
	Name *string `json:"name,omitempty"`

	// 别名,映射的新名称
	AliasName *string `json:"alias_name,omitempty"`
}

数据库对象信息

func (DatabaseObjectInfo) String added in v0.1.20

func (o DatabaseObjectInfo) String() string

type DatabaseObjectResp

type DatabaseObjectResp struct {

	// 任务ID
	JobId *string `json:"job_id,omitempty"`

	// 选择对象任务成功标志
	Status *bool `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

对象选择返回体

func (DatabaseObjectResp) String

func (o DatabaseObjectResp) String() string

type DatabaseObjectVo

type DatabaseObjectVo struct {

	// 数据库对象和数据库表名称,例如格式为hec-*-*-drs_test1。
	Id *string `json:"id,omitempty"`

	// 是否选择高级配置,值为true。
	Select *string `json:"select,omitempty"`
}

数据库对象信息体

func (DatabaseObjectVo) String

func (o DatabaseObjectVo) String() string

type DefaultRootDb

type DefaultRootDb struct {

	// 库名。
	DbName *string `json:"db_name,omitempty"`

	// 编码格式。
	DbEncoding *string `json:"db_encoding,omitempty"`
}

目标实例根节点库信息体

func (DefaultRootDb) String

func (o DefaultRootDb) String() string

type DeleteJobReq

type DeleteJobReq struct {

	// terminate:结束迁移任务,force_terminate:强制结束迁移任务,delete:删除迁移任务
	DeleteType DeleteJobReqDeleteType `json:"delete_type"`

	// 任务ID
	JobId string `json:"job_id"`
}

删除在线迁移任务请求体

func (DeleteJobReq) String

func (o DeleteJobReq) String() string

type DeleteJobReqDeleteType

type DeleteJobReqDeleteType struct {
	// contains filtered or unexported fields
}

func (DeleteJobReqDeleteType) MarshalJSON

func (c DeleteJobReqDeleteType) MarshalJSON() ([]byte, error)

func (*DeleteJobReqDeleteType) UnmarshalJSON

func (c *DeleteJobReqDeleteType) UnmarshalJSON(b []byte) error

func (DeleteJobReqDeleteType) Value added in v0.0.90

func (c DeleteJobReqDeleteType) Value() string

type DeleteJobReqDeleteTypeEnum

type DeleteJobReqDeleteTypeEnum struct {
	TERMINATE       DeleteJobReqDeleteType
	FORCE_TERMINATE DeleteJobReqDeleteType
	DELETE          DeleteJobReqDeleteType
}

func GetDeleteJobReqDeleteTypeEnum

func GetDeleteJobReqDeleteTypeEnum() DeleteJobReqDeleteTypeEnum

type DeleteJobResp

type DeleteJobResp struct {

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 状态
	Status *DeleteJobRespStatus `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

删除或者结束任务返回体

func (DeleteJobResp) String

func (o DeleteJobResp) String() string

type DeleteJobRespStatus

type DeleteJobRespStatus struct {
	// contains filtered or unexported fields
}

func (DeleteJobRespStatus) MarshalJSON

func (c DeleteJobRespStatus) MarshalJSON() ([]byte, error)

func (*DeleteJobRespStatus) UnmarshalJSON

func (c *DeleteJobRespStatus) UnmarshalJSON(b []byte) error

func (DeleteJobRespStatus) Value added in v0.0.90

func (c DeleteJobRespStatus) Value() string

type DeleteJobRespStatusEnum

type DeleteJobRespStatusEnum struct {
	SUCCESS DeleteJobRespStatus
	FAILED  DeleteJobRespStatus
}

func GetDeleteJobRespStatusEnum

func GetDeleteJobRespStatusEnum() DeleteJobRespStatusEnum

type Endpoint

type Endpoint struct {

	// 数据库类型,测试连接之后修改调用时必填。
	DbType *EndpointDbType `json:"db_type,omitempty"`

	// 数据库所在可用区azCode
	AzCode *string `json:"az_code,omitempty"`

	// RDS实例所在Region,数据库为RDS实例时必填(灾备场景下job_direction为down时source_endpoint中该值为必填,job_direction为up时target_endpoint中该值为必填)。
	Region *string `json:"region,omitempty"`

	// RDS实例ID,数据库为RDS实例必填(灾备场景下job_direction为down时source_endpoint中该值为必填,job_direction为up时target_endpoint中该值为必填)。
	InstId *string `json:"inst_id,omitempty"`

	// 数据库所在的虚拟私有云id
	VpcId *string `json:"vpc_id,omitempty"`

	// 数据库所在的子网id
	SubnetId *string `json:"subnet_id,omitempty"`

	// 数据库所在的安全组id。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// RDS实例projectId
	ProjectId *string `json:"project_id,omitempty"`

	// 服务名serviceName,源库为oracle场景时必填。约束:不能超过128位,不能包含!<>&'\"\\特殊字符。待还原数据库名称是指备份文件中包含的数据库名称,当您选择部分数据库恢复时,需要选择恢复一个或者多个数据库。
	DbName *string `json:"db_name,omitempty"`

	// 数据库密码。
	DbPassword *string `json:"db_password,omitempty"`

	// 数据库端口。约束:输入范围为1-65535之间的整数。
	DbPort *int32 `json:"db_port,omitempty"`

	// 数据库用户。
	DbUser *string `json:"db_user,omitempty"`

	// RDS实例名称。
	InstName *string `json:"inst_name,omitempty"`

	// 数据库ip
	Ip *string `json:"ip,omitempty"`

	// mongo ha模式。
	MongoHaMode *string `json:"mongo_ha_mode,omitempty"`

	// MRS集群运行模式,取值: - 0普通集群 - 1安全集群
	SafeMode *int32 `json:"safe_mode,omitempty"`

	// SSL证书密码,证书文件后缀为.p12
	SslCertPassword *string `json:"ssl_cert_password,omitempty"`

	// SSL证书内容checksum值,后端校验,源库安全连接必选。
	SslCertCheckSum *string `json:"ssl_cert_check_sum,omitempty"`

	// SSL证书内容,用base64加密
	SslCertKey *string `json:"ssl_cert_key,omitempty"`

	// SSL证书名字
	SslCertName *string `json:"ssl_cert_name,omitempty"`

	// 是否SSL安全连接。
	SslLink *bool `json:"ssl_link,omitempty"`

	// kafka topic名称
	Topic *string `json:"topic,omitempty"`

	// MongDB集群4.0及以上版本,当集群实例无法获取到分片节点的IP时,source_endpoint中需要填写,值为:Sharding4.0+。
	ClusterMode *EndpointClusterMode `json:"cluster_mode,omitempty"`
}

数据库信息体

func (Endpoint) String

func (o Endpoint) String() string

type EndpointClusterMode

type EndpointClusterMode struct {
	// contains filtered or unexported fields
}

func (EndpointClusterMode) MarshalJSON

func (c EndpointClusterMode) MarshalJSON() ([]byte, error)

func (*EndpointClusterMode) UnmarshalJSON

func (c *EndpointClusterMode) UnmarshalJSON(b []byte) error

func (EndpointClusterMode) Value added in v0.0.90

func (c EndpointClusterMode) Value() string

type EndpointClusterModeEnum

type EndpointClusterModeEnum struct {
	SHARDING4_0 EndpointClusterMode
}

func GetEndpointClusterModeEnum

func GetEndpointClusterModeEnum() EndpointClusterModeEnum

type EndpointDbType

type EndpointDbType struct {
	// contains filtered or unexported fields
}

func (EndpointDbType) MarshalJSON

func (c EndpointDbType) MarshalJSON() ([]byte, error)

func (*EndpointDbType) UnmarshalJSON

func (c *EndpointDbType) UnmarshalJSON(b []byte) error

func (EndpointDbType) Value added in v0.0.90

func (c EndpointDbType) Value() string

type EndpointDbTypeEnum

type EndpointDbTypeEnum struct {
	MYSQL       EndpointDbType
	MONGODB     EndpointDbType
	GAUSSDBV5   EndpointDbType
	POSTGRESQL  EndpointDbType
	KAFKA       EndpointDbType
	GAUSSDBV5HA EndpointDbType
}

func GetEndpointDbTypeEnum

func GetEndpointDbTypeEnum() EndpointDbTypeEnum

type EndpointVo

type EndpointVo struct {

	// 数据库id。
	Id *string `json:"id,omitempty"`

	// 对象id。
	ObjId *string `json:"obj_id,omitempty"`

	// RDS实例名称。
	InstanceName *string `json:"instance_name,omitempty"`

	// 数据库类型
	DbType *EndpointVoDbType `json:"db_type,omitempty"`

	// 数据库用户。
	DbUser *string `json:"db_user,omitempty"`

	// 数据库密码。
	DbPassword *string `json:"db_password,omitempty"`

	// 管理IP。
	ManageIp *string `json:"manage_ip,omitempty"`

	// 流量IP。
	TrafficIp *string `json:"traffic_ip,omitempty"`

	// 数据库端口。
	DbPort *int32 `json:"db_port,omitempty"`

	// RDS实例所在region。
	Region *string `json:"region,omitempty"`

	// 创建日期,格式yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedAt *string `json:"created_at,omitempty"`

	// 修改日期,格式yyyy-MM-dd'T'HH:mm:ss'Z'
	UpdatedAt *string `json:"updated_at,omitempty"`

	// 迁移实例所在的私有IP。
	Ip *string `json:"ip,omitempty"`

	// 迁移实例所在的公网IP。
	PublicIp *string `json:"public_ip,omitempty"`

	// 可用区azCode。
	AzCode *string `json:"az_code,omitempty"`

	// 源库所在的安全组id。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 源库所在的子网id。
	SubnetId *string `json:"subnet_id,omitempty"`

	// 源库所在的虚拟私有云id。
	VpcId *string `json:"vpc_id,omitempty"`

	// 迁移实例的磁盘大小。
	VolumeSize *int64 `json:"volume_size,omitempty"`

	// 全量迁移用户密码,密文。
	FullTransUserPwd *string `json:"full_trans_user_pwd,omitempty"`

	// 增量迁移用户密码,密文。
	IncrementTransUserPwd *string `json:"increment_trans_user_pwd,omitempty"`

	// 是否SSL安全连接。
	SslLink *bool `json:"ssl_link,omitempty"`

	// SSL证书内容。
	SslCertKey *string `json:"ssl_cert_key,omitempty"`

	// SSL证书名字。
	SslCertName *string `json:"ssl_cert_name,omitempty"`

	// SSL证书内容checksum值。
	SslCertCheckSum *string `json:"ssl_cert_check_sum,omitempty"`

	// SSL证书密码,密文。
	SslCertPassword *string `json:"ssl_cert_password,omitempty"`

	// 数据库版本。
	DbVersion *string `json:"db_version,omitempty"`

	// mongoHa模式。 - Sharding 集群 - ReplicaSet 副本集 - ReplicaSingle 单节点
	MongoHaMode *EndpointVoMongoHaMode `json:"mongo_ha_mode,omitempty"`

	// RDS实例projectId。
	ProjectId *string `json:"project_id,omitempty"`

	// 集群模式。 - Single:单节点RDS - Ha:主备RDS - GR:金融版RDS - Sharding:mongodb 集群或DDM的模式,均默认为分片 - Sharding4.0+:mongodb 集群版本4.0+,默认为不分片 - ReplicaSet:mongodb 副本集,Replica RDS只读副本 - ReplicaSingle:mongodb 单节点 - Cluster:集群 - Independent:gaussdbv5 independent模式 - Combined:gaussdbv5 Combined模式 - Distributed :分布式taurus - NoSharding:非集群模式
	ClusterMode *EndpointVoClusterMode `json:"cluster_mode,omitempty"`

	// RDS实例id。
	InstanceId *string `json:"instance_id,omitempty"`

	// Oracle服务名serviceName。
	DbName *string `json:"db_name,omitempty"`

	// mrskafka topic名称。
	Topic *string `json:"topic,omitempty"`

	// MRSkafka是否开启kerberos认证 - 0非安全认证 - 1安全认证
	SafeMode *int32 `json:"safe_mode,omitempty"`

	KerberosVo *KerberosVo `json:"kerberos_vo,omitempty"`

	// 多写数据库Id。
	MultiWriteDbId *string `json:"multi_write_db_id,omitempty"`
}

数据库信息

func (EndpointVo) String

func (o EndpointVo) String() string

type EndpointVoClusterMode

type EndpointVoClusterMode struct {
	// contains filtered or unexported fields
}

func (EndpointVoClusterMode) MarshalJSON

func (c EndpointVoClusterMode) MarshalJSON() ([]byte, error)

func (*EndpointVoClusterMode) UnmarshalJSON

func (c *EndpointVoClusterMode) UnmarshalJSON(b []byte) error

func (EndpointVoClusterMode) Value added in v0.0.90

func (c EndpointVoClusterMode) Value() string

type EndpointVoDbType

type EndpointVoDbType struct {
	// contains filtered or unexported fields
}

func (EndpointVoDbType) MarshalJSON

func (c EndpointVoDbType) MarshalJSON() ([]byte, error)

func (*EndpointVoDbType) UnmarshalJSON

func (c *EndpointVoDbType) UnmarshalJSON(b []byte) error

func (EndpointVoDbType) Value added in v0.0.90

func (c EndpointVoDbType) Value() string

type EndpointVoDbTypeEnum

type EndpointVoDbTypeEnum struct {
	MYSQL   EndpointVoDbType
	MONGODB EndpointVoDbType
}

func GetEndpointVoDbTypeEnum

func GetEndpointVoDbTypeEnum() EndpointVoDbTypeEnum

type EndpointVoMongoHaMode

type EndpointVoMongoHaMode struct {
	// contains filtered or unexported fields
}

func (EndpointVoMongoHaMode) MarshalJSON

func (c EndpointVoMongoHaMode) MarshalJSON() ([]byte, error)

func (*EndpointVoMongoHaMode) UnmarshalJSON

func (c *EndpointVoMongoHaMode) UnmarshalJSON(b []byte) error

func (EndpointVoMongoHaMode) Value added in v0.0.90

func (c EndpointVoMongoHaMode) Value() string

type EndpointVoMongoHaModeEnum

type EndpointVoMongoHaModeEnum struct {
	SHARDING       EndpointVoMongoHaMode
	REPLICA_SET    EndpointVoMongoHaMode
	REPLICA_SINGLE EndpointVoMongoHaMode
}

func GetEndpointVoMongoHaModeEnum

func GetEndpointVoMongoHaModeEnum() EndpointVoMongoHaModeEnum

type GetDataTransformationResp added in v0.1.39

type GetDataTransformationResp struct {

	// 数据加工总数。
	TotalCount *int64 `json:"total_count,omitempty"`

	// 数据过滤配置信息。
	FilterConditions *[]DataTransformationInfo `json:"filter_conditions,omitempty"`
}

数据加工行过滤配置信息

func (GetDataTransformationResp) String added in v0.1.39

func (o GetDataTransformationResp) String() string

type ImportSmnResp added in v0.0.84

type ImportSmnResp struct {

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 状态
	Status *string `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

录入SMN返回体

func (ImportSmnResp) String added in v0.0.84

func (o ImportSmnResp) String() string

type InstInfo

type InstInfo struct {

	// 引擎类型
	EngineType *InstInfoEngineType `json:"engine_type,omitempty"`

	// 实例类型
	InstType *InstInfoInstType `json:"inst_type,omitempty"`

	// 迁移实例所在的私有IP
	Ip *string `json:"ip,omitempty"`

	// 迁移实例所在的公网IP
	PublicIp *string `json:"public_ip,omitempty"`

	// 迁移实例任务定时启动时间
	StartTime *string `json:"start_time,omitempty"`

	// 迁移实例的状态
	Status *InstInfoStatus `json:"status,omitempty"`

	// 迁移实例的磁盘大小
	VolumeSize *int32 `json:"volume_size,omitempty"`
}

迁移实例信息体

func (InstInfo) String

func (o InstInfo) String() string

type InstInfoEngineType

type InstInfoEngineType struct {
	// contains filtered or unexported fields
}

func (InstInfoEngineType) MarshalJSON

func (c InstInfoEngineType) MarshalJSON() ([]byte, error)

func (*InstInfoEngineType) UnmarshalJSON

func (c *InstInfoEngineType) UnmarshalJSON(b []byte) error

func (InstInfoEngineType) Value added in v0.0.90

func (c InstInfoEngineType) Value() string

type InstInfoEngineTypeEnum

type InstInfoEngineTypeEnum struct {
	MYSQL                  InstInfoEngineType
	MONGODB                InstInfoEngineType
	CLOUD_DATA_GUARD_MYSQL InstInfoEngineType
}

func GetInstInfoEngineTypeEnum

func GetInstInfoEngineTypeEnum() InstInfoEngineTypeEnum

type InstInfoInstType

type InstInfoInstType struct {
	// contains filtered or unexported fields
}

func (InstInfoInstType) MarshalJSON

func (c InstInfoInstType) MarshalJSON() ([]byte, error)

func (*InstInfoInstType) UnmarshalJSON

func (c *InstInfoInstType) UnmarshalJSON(b []byte) error

func (InstInfoInstType) Value added in v0.0.90

func (c InstInfoInstType) Value() string

type InstInfoInstTypeEnum

type InstInfoInstTypeEnum struct {
	HIGH InstInfoInstType
}

func GetInstInfoInstTypeEnum

func GetInstInfoInstTypeEnum() InstInfoInstTypeEnum

type InstInfoStatus

type InstInfoStatus struct {
	// contains filtered or unexported fields
}

func (InstInfoStatus) MarshalJSON

func (c InstInfoStatus) MarshalJSON() ([]byte, error)

func (*InstInfoStatus) UnmarshalJSON

func (c *InstInfoStatus) UnmarshalJSON(b []byte) error

func (InstInfoStatus) Value added in v0.0.90

func (c InstInfoStatus) Value() string

type InstInfoStatusEnum

type InstInfoStatusEnum struct {
	ACTIVE  InstInfoStatus
	DELETED InstInfoStatus
}

func GetInstInfoStatusEnum

func GetInstInfoStatusEnum() InstInfoStatusEnum

type JobActionResp added in v0.1.37

type JobActionResp struct {

	// 任务可操作命令集合。 取值: CREATE:创建任务 CHOOSE_OBJECT:选择对象 PRE_CHECK:预检查 CHANGE_MODE:修改任务模式 FREE_RESOURCE:释放资源 MODIFY_DB_CONFIG:修改数据库配置 RESET_DB_PWD:重置数据库密码(源库、目标库) MODIFY_CONFIGURATION:修改任务配置 PAUSE:暂停任务 START:启动任务 CHANGE:修改任务 RETRY:重试任务 RESET:重置任务 DELETE:删除任务 QUERY_PRE_CHECK:预检查 SWITCH_OVER:容灾倒换 START_INCR:CASSANDRA启动增量任务 MODIFY_TASK_NUMBER:CASSANDRA修改线程数配置 CONTINUE_JOB:oracle-GaussDB分布式:启动失败或者停止的任务 STOP_JOB:oracle-GaussDB分布式:停止任务 CONTINUE_CAPTURE:oracle-GaussDB分布式:启动抓取 STOP_CAPTURE:oracle-GaussDB分布式:停止抓取 CONTINUE_APPLY:oracle-GaussDB分布式:启动回放 STOP_APPLY:oracle-GaussDB分布式:停止回放 PAY_ORDER:包年包月支付订单 UNSUBSCRIBE:包年包月退订 TO_PERIOD:转包周期 TO_RENEW:包周期续费 ORDER_INFO:订单详情 CHANGE_FLAVOR:规格变更 CLONE:克隆任务
	AvailableActions *[]JobActionRespAvailableActions `json:"available_actions,omitempty"`

	// 任务不可操作命令集合。 取值: CREATE:创建任务 CHOOSE_OBJECT:选择对象 PRE_CHECK:预检查 CHANGE_MODE:修改任务模式 FREE_RESOURCE:释放资源 MODIFY_DB_CONFIG:修改数据库配置 RESET_DB_PWD:重置数据库密码(源库、目标库) MODIFY_CONFIGURATION:修改任务配置 PAUSE:暂停任务 START:启动任务 CHANGE:修改任务 RETRY:重试任务 RESET:重置任务 DELETE:删除任务 QUERY_PRE_CHECK:预检查 SWITCH_OVER:容灾倒换 START_INCR:CASSANDRA启动增量任务 MODIFY_TASK_NUMBER:CASSANDRA修改线程数配置 CONTINUE_JOB:oracle-GaussDB分布式:启动失败或者停止的任务 STOP_JOB:oracle-GaussDB分布式:停止任务 CONTINUE_CAPTURE:oracle-GaussDB分布式:启动抓取 STOP_CAPTURE:oracle-GaussDB分布式:停止抓取 CONTINUE_APPLY:oracle-GaussDB分布式:启动回放 STOP_APPLY:oracle-GaussDB分布式:停止回放 PAY_ORDER:包年包月支付订单 UNSUBSCRIBE:包年包月退订 TO_PERIOD:转包周期 TO_RENEW:包周期续费 ORDER_INFO:订单详情 CHANGE_FLAVOR:规格变更 CLONE:克隆任务
	UnavailableActions *[]JobActionRespUnavailableActions `json:"unavailable_actions,omitempty"`

	// 示例: SWITCH_OVER:灾备倒换中 STOP_JOB:任务暂停中
	CurrentAction *JobActionRespCurrentAction `json:"current_action,omitempty"`
}

func (JobActionResp) String added in v0.1.37

func (o JobActionResp) String() string

type JobActionRespAvailableActions added in v0.1.37

type JobActionRespAvailableActions struct {
	// contains filtered or unexported fields
}

func (JobActionRespAvailableActions) MarshalJSON added in v0.1.37

func (c JobActionRespAvailableActions) MarshalJSON() ([]byte, error)

func (*JobActionRespAvailableActions) UnmarshalJSON added in v0.1.37

func (c *JobActionRespAvailableActions) UnmarshalJSON(b []byte) error

func (JobActionRespAvailableActions) Value added in v0.1.37

type JobActionRespAvailableActionsEnum added in v0.1.37

func GetJobActionRespAvailableActionsEnum added in v0.1.37

func GetJobActionRespAvailableActionsEnum() JobActionRespAvailableActionsEnum

type JobActionRespCurrentAction added in v0.1.37

type JobActionRespCurrentAction struct {
	// contains filtered or unexported fields
}

func (JobActionRespCurrentAction) MarshalJSON added in v0.1.37

func (c JobActionRespCurrentAction) MarshalJSON() ([]byte, error)

func (*JobActionRespCurrentAction) UnmarshalJSON added in v0.1.37

func (c *JobActionRespCurrentAction) UnmarshalJSON(b []byte) error

func (JobActionRespCurrentAction) Value added in v0.1.37

type JobActionRespCurrentActionEnum added in v0.1.37

type JobActionRespCurrentActionEnum struct {
	SWITCH_OVER JobActionRespCurrentAction
	STOP_JOB    JobActionRespCurrentAction
}

func GetJobActionRespCurrentActionEnum added in v0.1.37

func GetJobActionRespCurrentActionEnum() JobActionRespCurrentActionEnum

type JobActionRespUnavailableActions added in v0.1.37

type JobActionRespUnavailableActions struct {
	// contains filtered or unexported fields
}

func (JobActionRespUnavailableActions) MarshalJSON added in v0.1.37

func (c JobActionRespUnavailableActions) MarshalJSON() ([]byte, error)

func (*JobActionRespUnavailableActions) UnmarshalJSON added in v0.1.37

func (c *JobActionRespUnavailableActions) UnmarshalJSON(b []byte) error

func (JobActionRespUnavailableActions) Value added in v0.1.37

type JobActionRespUnavailableActionsEnum added in v0.1.37

type JobActionRespUnavailableActionsEnum struct {
	CREATE                   JobActionRespUnavailableActions
	CHOOSE_OBJECT            JobActionRespUnavailableActions
	PRE_CHECK                JobActionRespUnavailableActions
	CHANGE_MODE              JobActionRespUnavailableActions
	FREE_RESOURCE            JobActionRespUnavailableActions
	MODIFY_DB_CONFIG         JobActionRespUnavailableActions
	RESET_DB_PWD             JobActionRespUnavailableActions
	MODIFY_CONFIGURATION     JobActionRespUnavailableActions
	PAUSE                    JobActionRespUnavailableActions
	START                    JobActionRespUnavailableActions
	CHANGE                   JobActionRespUnavailableActions
	RETRY                    JobActionRespUnavailableActions
	RESET                    JobActionRespUnavailableActions
	DELETE                   JobActionRespUnavailableActions
	QUERY_PRE_CHECK          JobActionRespUnavailableActions
	SWITCH_OVER              JobActionRespUnavailableActions
	MODIFY_SPECIFICATION_ID  JobActionRespUnavailableActions
	JUMP_RETRY               JobActionRespUnavailableActions
	START_INCR               JobActionRespUnavailableActions
	MODIFY_TASK_NUMBER       JobActionRespUnavailableActions
	CONTINUE_JOB             JobActionRespUnavailableActions
	STOP_JOB                 JobActionRespUnavailableActions
	CONTINUE_CAPTURE         JobActionRespUnavailableActions
	STOP_CAPTURE             JobActionRespUnavailableActions
	CONTINUE_APPLY           JobActionRespUnavailableActions
	API_CONFIGURATION_ACTION JobActionRespUnavailableActions
	STOP_APPLY               JobActionRespUnavailableActions
	PAY_ORDER                JobActionRespUnavailableActions
	UNSUBSCRIBE              JobActionRespUnavailableActions
	TO_PERIOD                JobActionRespUnavailableActions
	TO_RENEW                 JobActionRespUnavailableActions
	ORDER_INFO               JobActionRespUnavailableActions
	CHANGE_FLAVOR            JobActionRespUnavailableActions
	CLONE                    JobActionRespUnavailableActions
}

func GetJobActionRespUnavailableActionsEnum added in v0.1.37

func GetJobActionRespUnavailableActionsEnum() JobActionRespUnavailableActionsEnum

type JobInfo

type JobInfo struct {

	// 任务id
	Id string `json:"id"`

	// 任务名称
	Name string `json:"name"`

	// 任务状态。 - CREATING:创建中 - CREATE_FAILED:创建失败 - CONFIGURATION:配置中 - STARTJOBING:启动中 - WAITING_FOR_START:等待启动中 - START_JOB_FAILED:启动失败 - PAUSING:已暂停 - FULL_TRANSFER_STARTED:全量开始,灾备场景下为初始化 - FULL_TRANSFER_FAILED:全量失败,灾备场景下为初始化失败 - FULL_TRANSFER_COMPLETE:全量完成,灾备场景下为初始化完成 - INCRE_TRANSFER_STARTED:增量开始,灾备场景下为灾备中 - INCRE_TRANSFER_FAILED:增量失败,灾备场景下为灾备异常 - RELEASE_RESOURCE_STARTED:结束任务中 - RELEASE_RESOURCE_FAILED:结束任务失败 - RELEASE_RESOURCE_COMPLETE:已结束 - REBUILD_NODE_STARTED:故障恢复中 - REBUILD_NODE_FAILED:故障恢复失败 - CHANGE_JOB_STARTED:任务变更中 - CHANGE_JOB_FAILED:任务变更失败 - DELETED:已删除 - CHILD_TRANSFER_STARTING:再编辑子任务启动中 - CHILD_TRANSFER_STARTED:再编辑子任务迁移中 - CHILD_TRANSFER_COMPLETE:再编辑子任务迁移完成 - CHILD_TRANSFER_FAILED:再编辑子任务迁移失败 - RELEASE_CHILD_TRANSFER_STARTED:再编辑子任务结束中 - RELEASE_CHILD_TRANSFER_COMPLETE:再编辑子任务已结束 - NODE_UPGRADE_START:升级开始 - NODE_UPGRADE_COMPLETE:升级完成 - NODE_UPGRADE_FAILED:升级失败
	Status JobInfoStatus `json:"status"`

	// 任务描述
	Description string `json:"description"`

	// 任务创建时间
	CreateTime string `json:"create_time"`

	// 引擎类型
	EngineType JobInfoEngineType `json:"engine_type"`

	// 网络类型
	NetType JobInfoNetType `json:"net_type"`

	// 计费字段
	BillingTag bool `json:"billing_tag"`

	// 迁移方向
	JobDirection JobInfoJobDirection `json:"job_direction"`

	// 迁移场景。 - migration:实时迁移 - sync:实时同步 - cloudDataGuard:实时灾备
	DbUseType JobInfoDbUseType `json:"db_use_type"`

	// 迁移模式。 - FULL_TRANS 全量 - FULL_INCR_TRANS 全量+增量 - INCR_TRANS 增量
	TaskType JobInfoTaskType `json:"task_type"`

	// 子任务信息体
	Children *[]ChildrenJobInfo `json:"children,omitempty"`

	// 是否新框架
	NodeNewFramework bool `json:"node_newFramework"`

	JobAction *JobActionResp `json:"job_action,omitempty"`
}

在线迁移任务列表信息体

func (JobInfo) String

func (o JobInfo) String() string

type JobInfoDbUseType

type JobInfoDbUseType struct {
	// contains filtered or unexported fields
}

func (JobInfoDbUseType) MarshalJSON

func (c JobInfoDbUseType) MarshalJSON() ([]byte, error)

func (*JobInfoDbUseType) UnmarshalJSON

func (c *JobInfoDbUseType) UnmarshalJSON(b []byte) error

func (JobInfoDbUseType) Value added in v0.0.90

func (c JobInfoDbUseType) Value() string

type JobInfoDbUseTypeEnum

type JobInfoDbUseTypeEnum struct {
	MIGRATION        JobInfoDbUseType
	SYNC             JobInfoDbUseType
	CLOUD_DATA_GUARD JobInfoDbUseType
}

func GetJobInfoDbUseTypeEnum

func GetJobInfoDbUseTypeEnum() JobInfoDbUseTypeEnum

type JobInfoEngineType

type JobInfoEngineType struct {
	// contains filtered or unexported fields
}

func (JobInfoEngineType) MarshalJSON

func (c JobInfoEngineType) MarshalJSON() ([]byte, error)

func (*JobInfoEngineType) UnmarshalJSON

func (c *JobInfoEngineType) UnmarshalJSON(b []byte) error

func (JobInfoEngineType) Value added in v0.0.90

func (c JobInfoEngineType) Value() string

type JobInfoEngineTypeEnum

type JobInfoEngineTypeEnum struct {
	CLOUD_DATA_GUARD_CASSANDRA       JobInfoEngineType
	CLOUD_DATA_GUARD_DDM             JobInfoEngineType
	CLOUD_DATA_GUARD_TAURUS_TO_MYSQL JobInfoEngineType
	CLOUD_DATA_GUARD_MYSQL           JobInfoEngineType
	CLOUD_DATA_GUARD_MYSQL_TO_TAURUS JobInfoEngineType
}

func GetJobInfoEngineTypeEnum

func GetJobInfoEngineTypeEnum() JobInfoEngineTypeEnum

type JobInfoJobDirection

type JobInfoJobDirection struct {
	// contains filtered or unexported fields
}

func (JobInfoJobDirection) MarshalJSON

func (c JobInfoJobDirection) MarshalJSON() ([]byte, error)

func (*JobInfoJobDirection) UnmarshalJSON

func (c *JobInfoJobDirection) UnmarshalJSON(b []byte) error

func (JobInfoJobDirection) Value added in v0.0.90

func (c JobInfoJobDirection) Value() string

type JobInfoJobDirectionEnum

type JobInfoJobDirectionEnum struct {
	UP   JobInfoJobDirection
	DOWN JobInfoJobDirection
}

func GetJobInfoJobDirectionEnum

func GetJobInfoJobDirectionEnum() JobInfoJobDirectionEnum

type JobInfoNetType

type JobInfoNetType struct {
	// contains filtered or unexported fields
}

func (JobInfoNetType) MarshalJSON

func (c JobInfoNetType) MarshalJSON() ([]byte, error)

func (*JobInfoNetType) UnmarshalJSON

func (c *JobInfoNetType) UnmarshalJSON(b []byte) error

func (JobInfoNetType) Value added in v0.0.90

func (c JobInfoNetType) Value() string

type JobInfoNetTypeEnum

type JobInfoNetTypeEnum struct {
	VPN JobInfoNetType
	VPC JobInfoNetType
	EIP JobInfoNetType
}

func GetJobInfoNetTypeEnum

func GetJobInfoNetTypeEnum() JobInfoNetTypeEnum

type JobInfoStatus

type JobInfoStatus struct {
	// contains filtered or unexported fields
}

func (JobInfoStatus) MarshalJSON

func (c JobInfoStatus) MarshalJSON() ([]byte, error)

func (*JobInfoStatus) UnmarshalJSON

func (c *JobInfoStatus) UnmarshalJSON(b []byte) error

func (JobInfoStatus) Value added in v0.0.90

func (c JobInfoStatus) Value() string

type JobInfoStatusEnum

type JobInfoStatusEnum struct {
	CREATING                        JobInfoStatus
	CREATE_FAILED                   JobInfoStatus
	CONFIGURATION                   JobInfoStatus
	STARTJOBING                     JobInfoStatus
	WAITING_FOR_START               JobInfoStatus
	START_JOB_FAILED                JobInfoStatus
	PAUSING                         JobInfoStatus
	FULL_TRANSFER_STARTED           JobInfoStatus
	FULL_TRANSFER_FAILED            JobInfoStatus
	FULL_TRANSFER_COMPLETE          JobInfoStatus
	INCRE_TRANSFER_STARTED          JobInfoStatus
	INCRE_TRANSFER_FAILED           JobInfoStatus
	RELEASE_RESOURCE_STARTED        JobInfoStatus
	RELEASE_RESOURCE_FAILED         JobInfoStatus
	RELEASE_RESOURCE_COMPLETE       JobInfoStatus
	REBUILD_NODE_STARTED            JobInfoStatus
	REBUILD_NODE_FAILED             JobInfoStatus
	CHANGE_JOB_STARTED              JobInfoStatus
	CHANGE_JOB_FAILED               JobInfoStatus
	DELETED                         JobInfoStatus
	CHILD_TRANSFER_STARTING         JobInfoStatus
	CHILD_TRANSFER_STARTED          JobInfoStatus
	CHILD_TRANSFER_COMPLETE         JobInfoStatus
	CHILD_TRANSFER_FAILED           JobInfoStatus
	RELEASE_CHILD_TRANSFER_STARTED  JobInfoStatus
	RELEASE_CHILD_TRANSFER_COMPLETE JobInfoStatus
	NODE_UPGRADE_START              JobInfoStatus
	NODE_UPGRADE_COMPLETE           JobInfoStatus
	NODE_UPGRADE_FAILED             JobInfoStatus
}

func GetJobInfoStatusEnum

func GetJobInfoStatusEnum() JobInfoStatusEnum

type JobInfoTaskType

type JobInfoTaskType struct {
	// contains filtered or unexported fields
}

func (JobInfoTaskType) MarshalJSON

func (c JobInfoTaskType) MarshalJSON() ([]byte, error)

func (*JobInfoTaskType) UnmarshalJSON

func (c *JobInfoTaskType) UnmarshalJSON(b []byte) error

func (JobInfoTaskType) Value added in v0.0.90

func (c JobInfoTaskType) Value() string

type JobInfoTaskTypeEnum

type JobInfoTaskTypeEnum struct {
	FULL_TRANS      JobInfoTaskType
	FULL_INCR_TRANS JobInfoTaskType
	INCR_TRANS      JobInfoTaskType
}

func GetJobInfoTaskTypeEnum

func GetJobInfoTaskTypeEnum() JobInfoTaskTypeEnum

type KafkaSecurity added in v0.0.79

type KafkaSecurity struct {

	// 证书名称,使用安全认证时必填。
	TrustStoreKeyName *string `json:"trust_store_key_name,omitempty"`

	// 安全证书base64转码后的值,使用安全认证时必填。
	TrustStoreKey *string `json:"trust_store_key,omitempty"`

	// 证书密码,使用安全认证时必填。
	TrustStorePassword *string `json:"trust_store_password,omitempty"`

	// 认证类型,PLAINTEXT为无认证,,使用安全认证时必填。
	Type *KafkaSecurityType `json:"type,omitempty"`
}

Kafka安全认证相关参数

func (KafkaSecurity) String added in v0.0.79

func (o KafkaSecurity) String() string

type KafkaSecurityType added in v0.0.79

type KafkaSecurityType struct {
	// contains filtered or unexported fields
}

func (KafkaSecurityType) MarshalJSON added in v0.0.79

func (c KafkaSecurityType) MarshalJSON() ([]byte, error)

func (*KafkaSecurityType) UnmarshalJSON added in v0.0.79

func (c *KafkaSecurityType) UnmarshalJSON(b []byte) error

func (KafkaSecurityType) Value added in v0.0.90

func (c KafkaSecurityType) Value() string

type KafkaSecurityTypeEnum added in v0.0.79

type KafkaSecurityTypeEnum struct {
	PLAINTEXT KafkaSecurityType
	SASL_SSL  KafkaSecurityType
}

func GetKafkaSecurityTypeEnum added in v0.0.79

func GetKafkaSecurityTypeEnum() KafkaSecurityTypeEnum

type KerberosVo

type KerberosVo struct {

	// krb5配置文件
	Krb5ConfFile *string `json:"krb5_conf_file,omitempty"`

	// key文件
	KeyTabFile *string `json:"key_tab_file,omitempty"`

	// 域名
	DomainName *string `json:"domain_name,omitempty"`

	// Kerberos用户对象
	UserPrincipal *string `json:"user_principal,omitempty"`
}

kerberos认证需要的信息

func (KerberosVo) String

func (o KerberosVo) String() string

type LimitSpeedReq

type LimitSpeedReq struct {

	// 任务id
	JobId string `json:"job_id"`

	// 限速信息请求体
	SpeedLimit []SpeedLimitInfo `json:"speed_limit"`
}

func (LimitSpeedReq) String

func (o LimitSpeedReq) String() string

type LineCompareDetail

type LineCompareDetail struct {

	// 源库的表名称。
	SourceTableName string `json:"source_table_name"`

	// 目标库的表名称。
	TargetTableName string `json:"target_table_name"`

	// 源库的表行数。
	SourceRowNum int32 `json:"source_row_num"`

	// 目标库的表行数。
	TargetRowNum int32 `json:"target_row_num"`

	// 源库的表和目标库的表的差异值。
	DiffRowNum int32 `json:"diff_row_num"`

	// 对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	LineCompareResult LineCompareDetailLineCompareResult `json:"line_compare_result"`

	// 附加信息。
	Message *string `json:"message,omitempty"`
}

func (LineCompareDetail) String

func (o LineCompareDetail) String() string

type LineCompareDetailLineCompareResult

type LineCompareDetailLineCompareResult struct {
	// contains filtered or unexported fields
}

func (LineCompareDetailLineCompareResult) MarshalJSON

func (c LineCompareDetailLineCompareResult) MarshalJSON() ([]byte, error)

func (*LineCompareDetailLineCompareResult) UnmarshalJSON

func (c *LineCompareDetailLineCompareResult) UnmarshalJSON(b []byte) error

func (LineCompareDetailLineCompareResult) Value added in v0.0.90

type LineCompareResult

type LineCompareResult struct {

	// 行对比任务的id。
	CompareTaskId *string `json:"compare_task_id,omitempty"`

	// 行对比结果概览。
	LineCompareOverview *[]LineCompareResultOverview `json:"line_compare_overview,omitempty"`

	// 行对比结果概览总数。
	LineCompareOverviewCount *int32 `json:"line_compare_overview_count,omitempty"`

	// 行对比结果详情。
	LineCompareDetails *[]LineCompareResultDetails `json:"line_compare_details,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (LineCompareResult) String

func (o LineCompareResult) String() string

type LineCompareResultDetails

type LineCompareResultDetails struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 该库的表的行对比详情。
	LineCompareDetail []LineCompareDetail `json:"line_compare_detail"`

	// 该库的行对比结果详情总数。
	LineCompareDetailCount int32 `json:"line_compare_detail_count"`
}

func (LineCompareResultDetails) String

func (o LineCompareResultDetails) String() string

type LineCompareResultOverview

type LineCompareResultOverview struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 目标库名称。
	TargetDbName string `json:"target_db_name"`

	// 对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	LineCompareResult LineCompareResultOverviewLineCompareResult `json:"line_compare_result"`
}

func (LineCompareResultOverview) String

func (o LineCompareResultOverview) String() string

type LineCompareResultOverviewLineCompareResult

type LineCompareResultOverviewLineCompareResult struct {
	// contains filtered or unexported fields
}

func (LineCompareResultOverviewLineCompareResult) MarshalJSON

func (*LineCompareResultOverviewLineCompareResult) UnmarshalJSON

func (LineCompareResultOverviewLineCompareResult) Value added in v0.0.90

type ListAvailableZoneRequest added in v0.0.94

type ListAvailableZoneRequest struct {

	// 请求语言类型。
	XLanguage *ListAvailableZoneRequestXLanguage `json:"X-Language,omitempty"`

	Body *QueryAvailableNodeTypeReq `json:"body,omitempty"`
}

Request Object

func (ListAvailableZoneRequest) String added in v0.0.94

func (o ListAvailableZoneRequest) String() string

type ListAvailableZoneRequestXLanguage added in v0.0.94

type ListAvailableZoneRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ListAvailableZoneRequestXLanguage) MarshalJSON added in v0.0.94

func (c ListAvailableZoneRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListAvailableZoneRequestXLanguage) UnmarshalJSON added in v0.0.94

func (c *ListAvailableZoneRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListAvailableZoneRequestXLanguage) Value added in v0.0.94

type ListAvailableZoneRequestXLanguageEnum added in v0.0.94

type ListAvailableZoneRequestXLanguageEnum struct {
	EN_US ListAvailableZoneRequestXLanguage
	ZH_CN ListAvailableZoneRequestXLanguage
}

func GetListAvailableZoneRequestXLanguageEnum added in v0.0.94

func GetListAvailableZoneRequestXLanguageEnum() ListAvailableZoneRequestXLanguageEnum

type ListAvailableZoneResponse added in v0.0.94

type ListAvailableZoneResponse struct {

	// 可用区信息
	AzInfos        *[]AzInfoResp `json:"az_infos,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ListAvailableZoneResponse) String added in v0.0.94

func (o ListAvailableZoneResponse) String() string

type ListCompareResultRequest

type ListCompareResultRequest struct {

	// 请求语言类型
	XLanguage *ListCompareResultRequestXLanguage `json:"X-Language,omitempty"`

	Body *QueryCompareResultReq `json:"body,omitempty"`
}

Request Object

func (ListCompareResultRequest) String

func (o ListCompareResultRequest) String() string

type ListCompareResultRequestXLanguage

type ListCompareResultRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ListCompareResultRequestXLanguage) MarshalJSON

func (c ListCompareResultRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListCompareResultRequestXLanguage) UnmarshalJSON

func (c *ListCompareResultRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListCompareResultRequestXLanguage) Value added in v0.0.90

type ListCompareResultRequestXLanguageEnum

type ListCompareResultRequestXLanguageEnum struct {
	EN_US ListCompareResultRequestXLanguage
	ZH_CN ListCompareResultRequestXLanguage
}

func GetListCompareResultRequestXLanguageEnum

func GetListCompareResultRequestXLanguageEnum() ListCompareResultRequestXLanguageEnum

type ListCompareResultResponse

type ListCompareResultResponse struct {

	// 任务id。
	JobId *string `json:"job_id,omitempty"`

	ObjectLevelCompareResults *ObjectCompareResult `json:"object_level_compare_results,omitempty"`

	LineCompareResults *LineCompareResult `json:"line_compare_results,omitempty"`

	ContentCompareResults *ContentCompareResult `json:"content_compare_results,omitempty"`

	CompareTaskListResults *CompareTaskListResult `json:"compare_task_list_results,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ListCompareResultResponse) String

func (o ListCompareResultResponse) String() string

type ListUsersRequest

type ListUsersRequest struct {

	// 请求语言类型
	XLanguage *ListUsersRequestXLanguage `json:"X-Language,omitempty"`

	// 任务ID
	JobId string `json:"job_id"`
}

Request Object

func (ListUsersRequest) String

func (o ListUsersRequest) String() string

type ListUsersRequestXLanguage

type ListUsersRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ListUsersRequestXLanguage) MarshalJSON

func (c ListUsersRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ListUsersRequestXLanguage) UnmarshalJSON

func (c *ListUsersRequestXLanguage) UnmarshalJSON(b []byte) error

func (ListUsersRequestXLanguage) Value added in v0.0.90

type ListUsersRequestXLanguageEnum

type ListUsersRequestXLanguageEnum struct {
	EN_US ListUsersRequestXLanguage
	ZH_CN ListUsersRequestXLanguage
}

func GetListUsersRequestXLanguageEnum

func GetListUsersRequestXLanguageEnum() ListUsersRequestXLanguageEnum

type ListUsersResponse

type ListUsersResponse struct {

	// 任务id
	JobId *string `json:"job_id,omitempty"`

	// 是否使用全局密码
	IsGlobalPassword *string `json:"is_global_password,omitempty"`

	// 错误码
	Message *string `json:"message,omitempty"`

	// 用户列表数据
	UserList *[]QueryUserDetailResp `json:"user_list,omitempty"`

	// 角色列表数据
	RolesList *[]QueryRoleDetailResp `json:"roles_list,omitempty"`

	// 是否成功
	IsSuccess      *bool `json:"is_success,omitempty"`
	HttpStatusCode int   `json:"-"`
}

Response Object

func (ListUsersResponse) String

func (o ListUsersResponse) String() string

type ModifyDbPwdResp added in v0.0.84

type ModifyDbPwdResp struct {

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 状态
	Status *string `json:"status,omitempty"`

	// 源库:so,目标库:ta
	EndPointType *string `json:"end_point_type,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

修改数据库密码返回体

func (ModifyDbPwdResp) String added in v0.0.84

func (o ModifyDbPwdResp) String() string

type ModifyJobReq

type ModifyJobReq struct {

	// 任务id
	JobId string `json:"job_id"`

	// 任务描述,修改任务描述时必填。
	Description *string `json:"description,omitempty"`

	// 任务名称,修改任务名称时必填
	Name *string `json:"name,omitempty"`

	AlarmNotify *AlarmNotifyInfo `json:"alarm_notify,omitempty"`

	// 任务模式,FULL_TRANS:全量;FULL_INCR_TRANS:全量+增量;INCR_TRANS:增量。
	TaskType *ModifyJobReqTaskType `json:"task_type,omitempty"`

	SourceEndpoint *Endpoint `json:"source_endpoint,omitempty"`

	TargetEndpoint *Endpoint `json:"target_endpoint,omitempty"`

	// node规格类型,测试连接之后修改调用时必填。
	NodeType *ModifyJobReqNodeType `json:"node_type,omitempty"`

	// 引擎类型,测试连接之后修改调用时必填。mysql:迁移,同步使用。mongodb:迁移使用。cloudDataGuard-mysql:灾备使用
	EngineType *ModifyJobReqEngineType `json:"engine_type,omitempty"`

	// 网络类型,测试连接之后修改调用时必填。
	NetType *ModifyJobReqNetType `json:"net_type,omitempty"`

	// 保存数据库信息,测试连接之后修改调用时必填为true。
	StoreDbInfo *bool `json:"store_db_info,omitempty"`

	// 是否为重建任务。
	IsRecreate *bool `json:"is_recreate,omitempty"`

	// 迁移方向,up 入云 灾备场景时对应本云为备,down 出云 灾备场景时对应本云为主,non-dbs 自建
	JobDirection *ModifyJobReqJobDirection `json:"job_direction,omitempty"`

	// 目标实例是否限制为只读。
	IsTargetReadonly *bool `json:"is_target_readonly,omitempty"`

	// 所有Definer是否迁移到该用户下,MySQL数据库支持该设置,测试连接之后修改调用时必填。 - true:迁移后,所有源数据库对象的Definer都会迁移至该用户下,其他用户需要授权后才具有数据库对象权限 - false:迁移后,将保持源数据库对象Definer定义不变,选择此选项,需要配合下一步用户权限迁移功能,将源数据库的用户全部迁移,这样才能保持源数据库的权限体系完全不变。
	ReplaceDefiner *bool `json:"replace_definer,omitempty"`

	// 标签信息
	Tags *[]ResourceTag `json:"tags,omitempty"`

	// 迁移类型,migration-实时迁移,sync-实时同步,cloudDataGuard-实时灾备
	DbUseType *ModifyJobReqDbUseType `json:"db_use_type,omitempty"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`
}

修改任务描述信息、名称,设置异常通知信息、限速等。

func (ModifyJobReq) String

func (o ModifyJobReq) String() string

type ModifyJobReqDbUseType

type ModifyJobReqDbUseType struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqDbUseType) MarshalJSON

func (c ModifyJobReqDbUseType) MarshalJSON() ([]byte, error)

func (*ModifyJobReqDbUseType) UnmarshalJSON

func (c *ModifyJobReqDbUseType) UnmarshalJSON(b []byte) error

func (ModifyJobReqDbUseType) Value added in v0.0.90

func (c ModifyJobReqDbUseType) Value() string

type ModifyJobReqDbUseTypeEnum

type ModifyJobReqDbUseTypeEnum struct {
	MIGRATION        ModifyJobReqDbUseType
	SYNC             ModifyJobReqDbUseType
	CLOUD_DATA_GUARD ModifyJobReqDbUseType
}

func GetModifyJobReqDbUseTypeEnum

func GetModifyJobReqDbUseTypeEnum() ModifyJobReqDbUseTypeEnum

type ModifyJobReqEngineType

type ModifyJobReqEngineType struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqEngineType) MarshalJSON

func (c ModifyJobReqEngineType) MarshalJSON() ([]byte, error)

func (*ModifyJobReqEngineType) UnmarshalJSON

func (c *ModifyJobReqEngineType) UnmarshalJSON(b []byte) error

func (ModifyJobReqEngineType) Value added in v0.0.90

func (c ModifyJobReqEngineType) Value() string

type ModifyJobReqEngineTypeEnum

type ModifyJobReqEngineTypeEnum struct {
	MYSQL                  ModifyJobReqEngineType
	MONGODB                ModifyJobReqEngineType
	CLOUD_DATA_GUARD_MYSQL ModifyJobReqEngineType
}

func GetModifyJobReqEngineTypeEnum

func GetModifyJobReqEngineTypeEnum() ModifyJobReqEngineTypeEnum

type ModifyJobReqJobDirection

type ModifyJobReqJobDirection struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqJobDirection) MarshalJSON

func (c ModifyJobReqJobDirection) MarshalJSON() ([]byte, error)

func (*ModifyJobReqJobDirection) UnmarshalJSON

func (c *ModifyJobReqJobDirection) UnmarshalJSON(b []byte) error

func (ModifyJobReqJobDirection) Value added in v0.0.90

func (c ModifyJobReqJobDirection) Value() string

type ModifyJobReqJobDirectionEnum

type ModifyJobReqJobDirectionEnum struct {
	UP      ModifyJobReqJobDirection
	DOWN    ModifyJobReqJobDirection
	NON_DBS ModifyJobReqJobDirection
}

func GetModifyJobReqJobDirectionEnum

func GetModifyJobReqJobDirectionEnum() ModifyJobReqJobDirectionEnum

type ModifyJobReqNetType

type ModifyJobReqNetType struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqNetType) MarshalJSON

func (c ModifyJobReqNetType) MarshalJSON() ([]byte, error)

func (*ModifyJobReqNetType) UnmarshalJSON

func (c *ModifyJobReqNetType) UnmarshalJSON(b []byte) error

func (ModifyJobReqNetType) Value added in v0.0.90

func (c ModifyJobReqNetType) Value() string

type ModifyJobReqNetTypeEnum

type ModifyJobReqNetTypeEnum struct {
	VPC ModifyJobReqNetType
	VPN ModifyJobReqNetType
	EIP ModifyJobReqNetType
}

func GetModifyJobReqNetTypeEnum

func GetModifyJobReqNetTypeEnum() ModifyJobReqNetTypeEnum

type ModifyJobReqNodeType

type ModifyJobReqNodeType struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqNodeType) MarshalJSON

func (c ModifyJobReqNodeType) MarshalJSON() ([]byte, error)

func (*ModifyJobReqNodeType) UnmarshalJSON

func (c *ModifyJobReqNodeType) UnmarshalJSON(b []byte) error

func (ModifyJobReqNodeType) Value added in v0.0.90

func (c ModifyJobReqNodeType) Value() string

type ModifyJobReqNodeTypeEnum

type ModifyJobReqNodeTypeEnum struct {
	HIGH ModifyJobReqNodeType
}

func GetModifyJobReqNodeTypeEnum

func GetModifyJobReqNodeTypeEnum() ModifyJobReqNodeTypeEnum

type ModifyJobReqTaskType

type ModifyJobReqTaskType struct {
	// contains filtered or unexported fields
}

func (ModifyJobReqTaskType) MarshalJSON

func (c ModifyJobReqTaskType) MarshalJSON() ([]byte, error)

func (*ModifyJobReqTaskType) UnmarshalJSON

func (c *ModifyJobReqTaskType) UnmarshalJSON(b []byte) error

func (ModifyJobReqTaskType) Value added in v0.0.90

func (c ModifyJobReqTaskType) Value() string

type ModifyJobReqTaskTypeEnum

type ModifyJobReqTaskTypeEnum struct {
	FULL_TRANS      ModifyJobReqTaskType
	INCR_TRANS      ModifyJobReqTaskType
	FULL_INCR_TRANS ModifyJobReqTaskType
}

func GetModifyJobReqTaskTypeEnum

func GetModifyJobReqTaskTypeEnum() ModifyJobReqTaskTypeEnum

type ModifyJobResp

type ModifyJobResp struct {

	// 任务ID
	Id string `json:"id"`

	// 状态。 - success 成功 - failed 失败
	Status ModifyJobRespStatus `json:"status"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (ModifyJobResp) String

func (o ModifyJobResp) String() string

type ModifyJobRespStatus

type ModifyJobRespStatus struct {
	// contains filtered or unexported fields
}

func (ModifyJobRespStatus) MarshalJSON

func (c ModifyJobRespStatus) MarshalJSON() ([]byte, error)

func (*ModifyJobRespStatus) UnmarshalJSON

func (c *ModifyJobRespStatus) UnmarshalJSON(b []byte) error

func (ModifyJobRespStatus) Value added in v0.0.90

func (c ModifyJobRespStatus) Value() string

type ModifyJobRespStatusEnum

type ModifyJobRespStatusEnum struct {
	SUCCESS ModifyJobRespStatus
	FAILED  ModifyJobRespStatus
}

func GetModifyJobRespStatusEnum

func GetModifyJobRespStatusEnum() ModifyJobRespStatusEnum

type ModifyPwdEndPoint

type ModifyPwdEndPoint struct {

	// 数据库密码
	DbPassword string `json:"db_password"`

	// 类型,so:源库;ta:目标库。
	EndPointType ModifyPwdEndPointEndPointType `json:"end_point_type"`

	// 任务id
	JobId string `json:"job_id"`

	Kerberos *KerberosVo `json:"kerberos,omitempty"`
}

批量修改数据库密码请求列表

func (ModifyPwdEndPoint) String

func (o ModifyPwdEndPoint) String() string

type ModifyPwdEndPointEndPointType

type ModifyPwdEndPointEndPointType struct {
	// contains filtered or unexported fields
}

func (ModifyPwdEndPointEndPointType) MarshalJSON

func (c ModifyPwdEndPointEndPointType) MarshalJSON() ([]byte, error)

func (*ModifyPwdEndPointEndPointType) UnmarshalJSON

func (c *ModifyPwdEndPointEndPointType) UnmarshalJSON(b []byte) error

func (ModifyPwdEndPointEndPointType) Value added in v0.0.90

type ModifyPwdEndPointEndPointTypeEnum

type ModifyPwdEndPointEndPointTypeEnum struct {
	SO ModifyPwdEndPointEndPointType
	TA ModifyPwdEndPointEndPointType
}

func GetModifyPwdEndPointEndPointTypeEnum

func GetModifyPwdEndPointEndPointTypeEnum() ModifyPwdEndPointEndPointTypeEnum

type ModifyTargetParamsReq

type ModifyTargetParamsReq struct {

	// 参数分组
	Group ModifyTargetParamsReqGroup `json:"group"`

	// 修改的参数信息
	Params []ParamsReqBean `json:"params"`
}

修改数据库参数请求体

func (ModifyTargetParamsReq) String

func (o ModifyTargetParamsReq) String() string

type ModifyTargetParamsReqGroup

type ModifyTargetParamsReqGroup struct {
	// contains filtered or unexported fields
}

func (ModifyTargetParamsReqGroup) MarshalJSON

func (c ModifyTargetParamsReqGroup) MarshalJSON() ([]byte, error)

func (*ModifyTargetParamsReqGroup) UnmarshalJSON

func (c *ModifyTargetParamsReqGroup) UnmarshalJSON(b []byte) error

func (ModifyTargetParamsReqGroup) Value added in v0.0.90

type ModifyTargetParamsReqGroupEnum

type ModifyTargetParamsReqGroupEnum struct {
	COMMON      ModifyTargetParamsReqGroup
	PERFORMANCE ModifyTargetParamsReqGroup
}

func GetModifyTargetParamsReqGroupEnum

func GetModifyTargetParamsReqGroupEnum() ModifyTargetParamsReqGroupEnum

type ModifyTuningParamsReq added in v0.0.94

type ModifyTuningParamsReq struct {

	// 全量参数的参数名及对应的取值
	FullSync map[string]string `json:"full_sync,omitempty"`

	// 增量抓取参数的参数名及对应的取值
	IncreCapture map[string]string `json:"incre_capture,omitempty"`

	// 增量回放参数的参数名及对应的取值
	IncreApply map[string]string `json:"incre_apply,omitempty"`

	// 增量日志拉取参数的参数名及对应的取值 -slotAdvanceInterval: 源库逻辑复制槽推进间隔
	IncreRelay map[string]string `json:"incre_relay,omitempty"`

	// 初始化参数,首次调用时需要传true,其他时候不传。
	Recovery *bool `json:"recovery,omitempty"`
}

修改调优参数请求体

func (ModifyTuningParamsReq) String added in v0.0.94

func (o ModifyTuningParamsReq) String() string

type ObjectCompareResult

type ObjectCompareResult struct {

	// 对象级对比任务的id。
	CompareTaskId string `json:"compare_task_id"`

	// 对象对比结果概览。
	ObjectCompareOverview *[]ObjectCompareResultOverview `json:"object_compare_overview,omitempty"`

	// 对象对比结果详情。KEY值为对象对比结果概览中的对象类型。
	ObjectCompareDetails map[string][]ObjectCompareResultDetails `json:"object_compare_details,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (ObjectCompareResult) String

func (o ObjectCompareResult) String() string

type ObjectCompareResultDetails

type ObjectCompareResultDetails struct {

	// 源库名称。
	SourceDbName string `json:"source_db_name"`

	// 目标库名称。
	TargetDbName string `json:"target_db_name"`

	// 在源库的值。
	SourceDbValue *string `json:"source_db_value,omitempty"`

	// 在目标库的值。
	TargetDbValue *string `json:"target_db_value,omitempty"`

	// 错误信息。
	ErrorMessage *string `json:"error_message,omitempty"`
}

func (ObjectCompareResultDetails) String

type ObjectCompareResultOverview

type ObjectCompareResultOverview struct {

	// 对象类型。 - DB-数据库 - TABLE-表 - VIEW-视图 - EVENT-事件 - ROUTINE-存储过程和函数 - INDEX-索引,TRIGGER-触发器 - SYNONYM-同义词 - FUNCTION-函数 - PROCEDURE-存储过程 - TYPE-自定义类型 - RULE-规则 - DEFAULT_TYPE-缺省值 - PLAN_GUIDE-执行计划 - CONSTRAINT-约束 - FILE_GROUP-文件组 - PARTITION_FUNCTION-分区函数 - PARTITION_SCHEME-分区方案 - TABLE_COLLATION-表的排序规则
	ObjectType ObjectCompareResultOverviewObjectType `json:"object_type"`

	// 对比结果。 - CONSISTENT-一致 - INCONSISTENT-不一致 - COMPARING-正在对比 - WAITING_FOR_COMPARISON-等待对比 - FAILED_TO_COMPARE-对比失败 - TARGET_DB_NOT_EXIT-目标库不存在 - CAN_NOT_COMPARE-无法对比
	ObjectCompareResult ObjectCompareResultOverviewObjectCompareResult `json:"object_compare_result"`

	// 该类型的对象在目标库的个数。
	TargetCount int32 `json:"target_count"`

	// 该类型的对象在源库的个数。
	SourceCount int32 `json:"source_count"`

	// 源库和目标库的差异数量。
	DiffCount int32 `json:"diff_count"`
}

func (ObjectCompareResultOverview) String

type ObjectCompareResultOverviewObjectCompareResult

type ObjectCompareResultOverviewObjectCompareResult struct {
	// contains filtered or unexported fields
}

func (ObjectCompareResultOverviewObjectCompareResult) MarshalJSON

func (*ObjectCompareResultOverviewObjectCompareResult) UnmarshalJSON

func (ObjectCompareResultOverviewObjectCompareResult) Value added in v0.0.90

type ObjectCompareResultOverviewObjectType

type ObjectCompareResultOverviewObjectType struct {
	// contains filtered or unexported fields
}

func (ObjectCompareResultOverviewObjectType) MarshalJSON

func (c ObjectCompareResultOverviewObjectType) MarshalJSON() ([]byte, error)

func (*ObjectCompareResultOverviewObjectType) UnmarshalJSON

func (c *ObjectCompareResultOverviewObjectType) UnmarshalJSON(b []byte) error

func (ObjectCompareResultOverviewObjectType) Value added in v0.0.90

type PageReq

type PageReq struct {

	// 当前页, 不能超过item除每页任务数量的最大页
	CurPage *int32 `json:"cur_page,omitempty"`

	// 每页item数量,填0获取全部item
	PerPage *int32 `json:"per_page,omitempty"`
}

分页请求体

func (PageReq) String

func (o PageReq) String() string

type Params

type Params struct {

	// 参数对比结果
	CompareResult *ParamsCompareResult `json:"compare_result,omitempty"`

	// 参数类型
	DataType *string `json:"data_type,omitempty"`

	// 分组。 - common-常规参数 - performance-性能参数
	Group *ParamsGroup `json:"group,omitempty"`

	// 参数名
	Key *string `json:"key,omitempty"`

	// 是否需要重启
	NeedRestart *ParamsNeedRestart `json:"need_restart,omitempty"`

	// 源数据库参数值
	SourceValue *string `json:"source_value,omitempty"`

	// 目标数据库参数值
	TargetValue *string `json:"target_value,omitempty"`

	// 参数范围
	ValueRange *string `json:"value_range,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMessage *string `json:"error_message,omitempty"`
}

数据参数信息体

func (Params) String

func (o Params) String() string

type ParamsCompareResult

type ParamsCompareResult struct {
	// contains filtered or unexported fields
}

func (ParamsCompareResult) MarshalJSON

func (c ParamsCompareResult) MarshalJSON() ([]byte, error)

func (*ParamsCompareResult) UnmarshalJSON

func (c *ParamsCompareResult) UnmarshalJSON(b []byte) error

func (ParamsCompareResult) Value added in v0.0.90

func (c ParamsCompareResult) Value() string

type ParamsCompareResultEnum

type ParamsCompareResultEnum struct {
	TRUE  ParamsCompareResult
	FALSE ParamsCompareResult
}

func GetParamsCompareResultEnum

func GetParamsCompareResultEnum() ParamsCompareResultEnum

type ParamsGroup

type ParamsGroup struct {
	// contains filtered or unexported fields
}

func (ParamsGroup) MarshalJSON

func (c ParamsGroup) MarshalJSON() ([]byte, error)

func (*ParamsGroup) UnmarshalJSON

func (c *ParamsGroup) UnmarshalJSON(b []byte) error

func (ParamsGroup) Value added in v0.0.90

func (c ParamsGroup) Value() string

type ParamsGroupEnum

type ParamsGroupEnum struct {
	COMMON      ParamsGroup
	PERFORMANCE ParamsGroup
}

func GetParamsGroupEnum

func GetParamsGroupEnum() ParamsGroupEnum

type ParamsNeedRestart

type ParamsNeedRestart struct {
	// contains filtered or unexported fields
}

func (ParamsNeedRestart) MarshalJSON

func (c ParamsNeedRestart) MarshalJSON() ([]byte, error)

func (*ParamsNeedRestart) UnmarshalJSON

func (c *ParamsNeedRestart) UnmarshalJSON(b []byte) error

func (ParamsNeedRestart) Value added in v0.0.90

func (c ParamsNeedRestart) Value() string

type ParamsNeedRestartEnum

type ParamsNeedRestartEnum struct {
	TRUE  ParamsNeedRestart
	FALSE ParamsNeedRestart
}

func GetParamsNeedRestartEnum

func GetParamsNeedRestartEnum() ParamsNeedRestartEnum

type ParamsReqBean

type ParamsReqBean struct {

	// 数据库参数名
	Key string `json:"key"`

	// 目标数据库参数值
	TargetValue string `json:"target_value"`
}

参数信息

func (ParamsReqBean) String

func (o ParamsReqBean) String() string

type PauseInfo

type PauseInfo struct {

	// 任务id
	JobId string `json:"job_id"`

	// 暂停类型,target:停回放,all:停日志抓取和回放
	PauseMode PauseInfoPauseMode `json:"pause_mode"`
}

暂停任务请求参数

func (PauseInfo) String

func (o PauseInfo) String() string

type PauseInfoPauseMode

type PauseInfoPauseMode struct {
	// contains filtered or unexported fields
}

func (PauseInfoPauseMode) MarshalJSON

func (c PauseInfoPauseMode) MarshalJSON() ([]byte, error)

func (*PauseInfoPauseMode) UnmarshalJSON

func (c *PauseInfoPauseMode) UnmarshalJSON(b []byte) error

func (PauseInfoPauseMode) Value added in v0.0.90

func (c PauseInfoPauseMode) Value() string

type PauseInfoPauseModeEnum

type PauseInfoPauseModeEnum struct {
	TARGET PauseInfoPauseMode
	ALL    PauseInfoPauseMode
}

func GetPauseInfoPauseModeEnum

func GetPauseInfoPauseModeEnum() PauseInfoPauseModeEnum

type PauseJobResp

type PauseJobResp struct {

	// 任务id
	Id string `json:"id"`

	// 暂停结果
	Status string `json:"status"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

暂停任务返回体

func (PauseJobResp) String

func (o PauseJobResp) String() string

type PeriodOrderInfo added in v0.1.20

type PeriodOrderInfo struct {

	// 订购周期类型。 取值范围: - 2:表示周期类型为月。 - 3:表示周期类型为年。
	PeriodType *PeriodOrderInfoPeriodType `json:"period_type,omitempty"`

	// 订购周期数。 取值范围: - period_type=2(周期类型为月)时,取值为[1,9]。 - period_type=3(周期类型为年)时,取值为[1,3]。
	PeriodNum *int32 `json:"period_num,omitempty"`

	// 是否自动续订。 取值范围: - 0:表示不自动续订。 - 1:表示自动续订。
	IsAutoRenew *PeriodOrderInfoIsAutoRenew `json:"is_auto_renew,omitempty"`
}

包年/包月信息体

func (PeriodOrderInfo) String added in v0.1.20

func (o PeriodOrderInfo) String() string

type PeriodOrderInfoIsAutoRenew added in v0.1.20

type PeriodOrderInfoIsAutoRenew struct {
	// contains filtered or unexported fields
}

func (PeriodOrderInfoIsAutoRenew) MarshalJSON added in v0.1.20

func (c PeriodOrderInfoIsAutoRenew) MarshalJSON() ([]byte, error)

func (*PeriodOrderInfoIsAutoRenew) UnmarshalJSON added in v0.1.20

func (c *PeriodOrderInfoIsAutoRenew) UnmarshalJSON(b []byte) error

func (PeriodOrderInfoIsAutoRenew) Value added in v0.1.20

type PeriodOrderInfoIsAutoRenewEnum added in v0.1.20

type PeriodOrderInfoIsAutoRenewEnum struct {
	E_0 PeriodOrderInfoIsAutoRenew
	E_1 PeriodOrderInfoIsAutoRenew
}

func GetPeriodOrderInfoIsAutoRenewEnum added in v0.1.20

func GetPeriodOrderInfoIsAutoRenewEnum() PeriodOrderInfoIsAutoRenewEnum

type PeriodOrderInfoPeriodType added in v0.1.20

type PeriodOrderInfoPeriodType struct {
	// contains filtered or unexported fields
}

func (PeriodOrderInfoPeriodType) MarshalJSON added in v0.1.20

func (c PeriodOrderInfoPeriodType) MarshalJSON() ([]byte, error)

func (*PeriodOrderInfoPeriodType) UnmarshalJSON added in v0.1.20

func (c *PeriodOrderInfoPeriodType) UnmarshalJSON(b []byte) error

func (PeriodOrderInfoPeriodType) Value added in v0.1.20

func (c PeriodOrderInfoPeriodType) Value() int32

type PeriodOrderInfoPeriodTypeEnum added in v0.1.20

type PeriodOrderInfoPeriodTypeEnum struct {
	E_2 PeriodOrderInfoPeriodType
	E_3 PeriodOrderInfoPeriodType
}

func GetPeriodOrderInfoPeriodTypeEnum added in v0.1.20

func GetPeriodOrderInfoPeriodTypeEnum() PeriodOrderInfoPeriodTypeEnum

type PeriodOrderResp added in v0.1.20

type PeriodOrderResp struct {

	// 订单状态
	Status *string `json:"status,omitempty"`

	// 订单ID
	OrderId *string `json:"order_id,omitempty"`

	// 计费模式
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 订购包周期类型
	PeriodType *int32 `json:"period_type,omitempty"`

	// 订购周期数
	PeriodNum *int32 `json:"period_num,omitempty"`

	// 是否自动续费
	IsAutoRenew *int32 `json:"is_auto_renew,omitempty"`

	// 资源生效时间(即资源创建时间)
	EffTime *string `json:"eff_time,omitempty"`

	// 到期时间
	ExpTime *string `json:"exp_time,omitempty"`
}

详情返回包周期信息体。

func (PeriodOrderResp) String added in v0.1.20

func (o PeriodOrderResp) String() string

type PostPreCheckResp

type PostPreCheckResp struct {

	// 任务id。
	Id *string `json:"id,omitempty"`

	// 预检查id。
	PrecheckId *string `json:"precheck_id,omitempty"`

	// 成功或失败的状态
	Status *PostPreCheckRespStatus `json:"status,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (PostPreCheckResp) String

func (o PostPreCheckResp) String() string

type PostPreCheckRespStatus

type PostPreCheckRespStatus struct {
	// contains filtered or unexported fields
}

func (PostPreCheckRespStatus) MarshalJSON

func (c PostPreCheckRespStatus) MarshalJSON() ([]byte, error)

func (*PostPreCheckRespStatus) UnmarshalJSON

func (c *PostPreCheckRespStatus) UnmarshalJSON(b []byte) error

func (PostPreCheckRespStatus) Value added in v0.0.90

func (c PostPreCheckRespStatus) Value() string

type PostPreCheckRespStatusEnum

type PostPreCheckRespStatusEnum struct {
	SUCCESS PostPreCheckRespStatus
	FAILED  PostPreCheckRespStatus
}

func GetPostPreCheckRespStatusEnum

func GetPostPreCheckRespStatusEnum() PostPreCheckRespStatusEnum

type PreCheckInfo

type PreCheckInfo struct {

	// 任务id
	JobId string `json:"job_id"`

	// 预检查模式
	PrecheckMode PreCheckInfoPrecheckMode `json:"precheck_mode"`
}

预检查信息体

func (PreCheckInfo) String

func (o PreCheckInfo) String() string

type PreCheckInfoPrecheckMode

type PreCheckInfoPrecheckMode struct {
	// contains filtered or unexported fields
}

func (PreCheckInfoPrecheckMode) MarshalJSON

func (c PreCheckInfoPrecheckMode) MarshalJSON() ([]byte, error)

func (*PreCheckInfoPrecheckMode) UnmarshalJSON

func (c *PreCheckInfoPrecheckMode) UnmarshalJSON(b []byte) error

func (PreCheckInfoPrecheckMode) Value added in v0.0.90

func (c PreCheckInfoPrecheckMode) Value() string

type PreCheckInfoPrecheckModeEnum

type PreCheckInfoPrecheckModeEnum struct {
	FOR_START_JOB PreCheckInfoPrecheckMode
	FOR_RETRY_JOB PreCheckInfoPrecheckMode
}

func GetPreCheckInfoPrecheckModeEnum

func GetPreCheckInfoPrecheckModeEnum() PreCheckInfoPrecheckModeEnum

type PrecheckFailSubJobVo

type PrecheckFailSubJobVo struct {

	// 预检查失败子任务id。
	Id *string `json:"id,omitempty"`

	// 预检查失败子任务名称。
	Name *string `json:"name,omitempty"`

	// 检查结果。
	CheckResult *string `json:"check_result,omitempty"`
}

预检查失败子任务信息体

func (PrecheckFailSubJobVo) String

func (o PrecheckFailSubJobVo) String() string

type PrecheckResult

type PrecheckResult struct {

	// 检查项。
	Item *string `json:"item,omitempty"`

	// 检查结果
	Result *PrecheckResultResult `json:"result,omitempty"`

	// 失败原因。
	FailedReason *string `json:"failed_reason,omitempty"`

	// 加密的数据。
	Data *string `json:"data,omitempty"`

	// 行错误信息。
	RawErrorMsg *string `json:"raw_error_msg,omitempty"`

	// 检查项分组
	Group *string `json:"group,omitempty"`

	// 失败的子任务信息。
	FailedSubJobs *[]PrecheckFailSubJobVo `json:"failed_sub_jobs,omitempty"`
}

预检查结果信息体

func (PrecheckResult) String

func (o PrecheckResult) String() string

type PrecheckResultResult

type PrecheckResultResult struct {
	// contains filtered or unexported fields
}

func (PrecheckResultResult) MarshalJSON

func (c PrecheckResultResult) MarshalJSON() ([]byte, error)

func (*PrecheckResultResult) UnmarshalJSON

func (c *PrecheckResultResult) UnmarshalJSON(b []byte) error

func (PrecheckResultResult) Value added in v0.0.90

func (c PrecheckResultResult) Value() string

type PrecheckResultResultEnum

type PrecheckResultResultEnum struct {
	PASSED PrecheckResultResult
	ALARM  PrecheckResultResult
	FAILED PrecheckResultResult
}

func GetPrecheckResultResultEnum

func GetPrecheckResultResultEnum() PrecheckResultResultEnum

type ProgressInfo

type ProgressInfo struct {

	// 完成进度
	Completed *string `json:"completed,omitempty"`

	// 预计剩余时间
	RemainingTime *string `json:"remaining_time,omitempty"`
}

迁移进度信息体

func (ProgressInfo) String

func (o ProgressInfo) String() string

type QueryAvailableNodeTypeReq added in v0.0.94

type QueryAvailableNodeTypeReq struct {

	// 引擎类型
	EngineType string `json:"engine_type"`

	// 迁移场景,migration-实时迁移,sync-实时同步,cloudDataGuard-实时灾备
	DbUseType QueryAvailableNodeTypeReqDbUseType `json:"db_use_type"`

	// 迁移方向,up :入云 ,灾备场景时对应本云为备,down:出云,灾备场景时对应本云为主,non-dbs:自建
	JobDirection QueryAvailableNodeTypeReqJobDirection `json:"job_direction"`

	// 规格类型。
	NodeType string `json:"node_type"`

	// 是否是双主灾备,不填默认为false
	MultiWrite *string `json:"multi_write,omitempty"`
}

查询可用的AZ请求

func (QueryAvailableNodeTypeReq) String added in v0.0.94

func (o QueryAvailableNodeTypeReq) String() string

type QueryAvailableNodeTypeReqDbUseType added in v0.0.94

type QueryAvailableNodeTypeReqDbUseType struct {
	// contains filtered or unexported fields
}

func (QueryAvailableNodeTypeReqDbUseType) MarshalJSON added in v0.0.94

func (c QueryAvailableNodeTypeReqDbUseType) MarshalJSON() ([]byte, error)

func (*QueryAvailableNodeTypeReqDbUseType) UnmarshalJSON added in v0.0.94

func (c *QueryAvailableNodeTypeReqDbUseType) UnmarshalJSON(b []byte) error

func (QueryAvailableNodeTypeReqDbUseType) Value added in v0.0.94

type QueryAvailableNodeTypeReqDbUseTypeEnum added in v0.0.94

type QueryAvailableNodeTypeReqDbUseTypeEnum struct {
	MIGRATION        QueryAvailableNodeTypeReqDbUseType
	SYNC             QueryAvailableNodeTypeReqDbUseType
	CLOUD_DATA_GUARD QueryAvailableNodeTypeReqDbUseType
}

func GetQueryAvailableNodeTypeReqDbUseTypeEnum added in v0.0.94

func GetQueryAvailableNodeTypeReqDbUseTypeEnum() QueryAvailableNodeTypeReqDbUseTypeEnum

type QueryAvailableNodeTypeReqJobDirection added in v0.0.94

type QueryAvailableNodeTypeReqJobDirection struct {
	// contains filtered or unexported fields
}

func (QueryAvailableNodeTypeReqJobDirection) MarshalJSON added in v0.0.94

func (c QueryAvailableNodeTypeReqJobDirection) MarshalJSON() ([]byte, error)

func (*QueryAvailableNodeTypeReqJobDirection) UnmarshalJSON added in v0.0.94

func (c *QueryAvailableNodeTypeReqJobDirection) UnmarshalJSON(b []byte) error

func (QueryAvailableNodeTypeReqJobDirection) Value added in v0.0.94

type QueryAvailableNodeTypeReqJobDirectionEnum added in v0.0.94

type QueryAvailableNodeTypeReqJobDirectionEnum struct {
	UP      QueryAvailableNodeTypeReqJobDirection
	DOWN    QueryAvailableNodeTypeReqJobDirection
	NON_DBS QueryAvailableNodeTypeReqJobDirection
}

func GetQueryAvailableNodeTypeReqJobDirectionEnum added in v0.0.94

func GetQueryAvailableNodeTypeReqJobDirectionEnum() QueryAvailableNodeTypeReqJobDirectionEnum

type QueryCompareResultReq

type QueryCompareResultReq struct {

	// 任务id。
	JobId string `json:"job_id"`

	// 请求查询结果的对象级对比任务id。
	ObjectLevelCompareId *string `json:"object_level_compare_id,omitempty"`

	// 请求查询结果的行对比任务id。
	LineCompareId *string `json:"line_compare_id,omitempty"`

	// 请求查询结果的内容对比任务id。
	ContentCompareId *string `json:"content_compare_id,omitempty"`

	// 分页查询的当前页码,对查询对比任务的结果生效。
	CurrentPage int32 `json:"current_page"`

	// 分页查询的每页个数,对查询对比任务的结果生效。
	PerPage int32 `json:"per_page"`
}

func (QueryCompareResultReq) String

func (o QueryCompareResultReq) String() string

type QueryDataGuardMonitorAndChartResp

type QueryDataGuardMonitorAndChartResp struct {

	// 任务id
	Id string `json:"id"`

	DataGuardMinitor *QueryDataGuardMonitorResponse `json:"data_guard_minitor"`
}

容灾任务监控数据响应体

func (QueryDataGuardMonitorAndChartResp) String

type QueryDataGuardMonitorResponse

type QueryDataGuardMonitorResponse struct {

	// 带宽。
	Bandwidth *string `json:"bandwidth,omitempty"`

	// cpu百分比。
	CpuUsedPercent *string `json:"cpuUsed_percent,omitempty"`

	// 目标库时延。
	DstDelay *int64 `json:"dst_delay,omitempty"`

	// 目标io。
	DstIo *string `json:"dst_io,omitempty"`

	// 目标库连接状态。
	DstNormal *bool `json:"dst_normal,omitempty"`

	// 目标库offSet位点。
	DstOffset *string `json:"dst_offset,omitempty"`

	// 目标rps。
	DstRps *string `json:"dst_rps,omitempty"`

	// 内存使用。
	MemUsedInMB *string `json:"mem_used_inMB,omitempty"`

	// node内存总大小。
	NodeMemInMB *int64 `json:"node_mem_inMB,omitempty"`

	// 迁移实例offSet位点。
	NodeOffset *string `json:"node_offset,omitempty"`

	// node磁盘总大小。
	NodeVolumeInGB *int64 `json:"node_volume_inGB,omitempty"`

	// 源库时延。
	SrDelay *int64 `json:"sr_delay,omitempty"`

	// 源库offSet位点。
	SrOffset *string `json:"sr_offset,omitempty"`

	// 源io。
	SrcIo *string `json:"src_io,omitempty"`

	// 源库连接状态。
	SrcNormal *bool `json:"src_normal,omitempty"`

	// 源rps。
	SrcRps *string `json:"src_rps,omitempty"`

	// 迁移数据量。
	TransInMB *string `json:"trans_inMB,omitempty"`

	// 迁移数据行数。
	TransLines *string `json:"trans_lines,omitempty"`

	// 磁盘使用。
	VolumeUsedInGB *string `json:"volume_used_inGB,omitempty"`

	// 每秒迁移字节大小。
	MigrationBytesPerSecond *int64 `json:"migration_bytes_per_second,omitempty"`
}

容灾监控数据响应体

func (QueryDataGuardMonitorResponse) String

type QueryDbParamsResp

type QueryDbParamsResp struct {
	Params *[]Params `json:"params,omitempty"`
}

数据库参数信息响应体

func (QueryDbParamsResp) String

func (o QueryDbParamsResp) String() string

type QueryFlowCompareDataResp

type QueryFlowCompareDataResp struct {

	// 任务总数
	TotalRecord *int64 `json:"total_record,omitempty"`

	// 数据生成时间
	CreateTime *string `json:"create_time,omitempty"`

	// 对比结果
	List *[]StructDetailVo `json:"list,omitempty"`
}

灾备初始化对象详情信息

func (QueryFlowCompareDataResp) String

func (o QueryFlowCompareDataResp) String() string

type QueryJobResp

type QueryJobResp struct {

	// 任务id
	Id *string `json:"id,omitempty"`

	// 父任务id。
	ParentId *string `json:"parent_id,omitempty"`

	// 任务名称
	Name *string `json:"name,omitempty"`

	// 任务状态。 - CREATING:创建中 - CREATE_FAILED:创建失败 - CONFIGURATION:配置中 - STARTJOBING:启动中 - WAITING_FOR_START:等待启动中 - START_JOB_FAILED:启动失败 - PAUSING:已暂停 - FULL_TRANSFER_STARTED:全量开始,灾备场景下为初始化 - FULL_TRANSFER_FAILED:全量失败,灾备场景下为初始化失败 - FULL_TRANSFER_COMPLETE:全量完成,灾备场景下为初始化完成 - INCRE_TRANSFER_STARTED:增量开始,灾备场景下为灾备中 - INCRE_TRANSFER_FAILED:增量失败,灾备场景下为灾备异常 - RELEASE_RESOURCE_STARTED:结束任务中 - RELEASE_RESOURCE_FAILED:结束任务失败 - RELEASE_RESOURCE_COMPLETE:已结束 - REBUILD_NODE_STARTED:故障恢复中 - REBUILD_NODE_FAILED:故障恢复失败 - CHANGE_JOB_STARTED:任务变更中 - CHANGE_JOB_FAILED:任务变更失败 - DELETED:已删除 - CHILD_TRANSFER_STARTING:再编辑子任务启动中 - CHILD_TRANSFER_STARTED:再编辑子任务迁移中 - CHILD_TRANSFER_COMPLETE:再编辑子任务迁移完成 - CHILD_TRANSFER_FAILED:再编辑子任务迁移失败 - RELEASE_CHILD_TRANSFER_STARTED:再编辑子任务结束中 - RELEASE_CHILD_TRANSFER_COMPLETE:再编辑子任务已结束 - NODE_UPGRADE_START:升级开始 - NODE_UPGRADE_COMPLETE:升级完成 - NODE_UPGRADE_FAILED:升级失败
	Status *QueryJobRespStatus `json:"status,omitempty"`

	// 描述信息
	Description *string `json:"description,omitempty"`

	// 创建时间,时间戳格式。
	CreateTime *string `json:"create_time,omitempty"`

	// 迁移模式
	TaskType *QueryJobRespTaskType `json:"task_type,omitempty"`

	SourceEndpoint *Endpoint `json:"source_endpoint,omitempty"`

	DmqEndpoint *Endpoint `json:"dmq_endpoint,omitempty"`

	// 物理源库信息。
	SourceSharding *[]Endpoint `json:"source_sharding,omitempty"`

	TargetEndpoint *Endpoint `json:"target_endpoint,omitempty"`

	// 网络类型
	NetType *QueryJobRespNetType `json:"net_type,omitempty"`

	// 失败原因。
	FailedReason *string `json:"failed_reason,omitempty"`

	InstInfo *InstInfo `json:"inst_info,omitempty"`

	// 实际启动时间,时间戳格式。
	ActualStartTime *string `json:"actual_start_time,omitempty"`

	// 全量完成时间,时间戳格式。
	FullTransferCompleteTime *string `json:"full_transfer_complete_time,omitempty"`

	// 更新时间,时间戳格式
	UpdateTime *string `json:"update_time,omitempty"`

	// 任务方向
	JobDirection *QueryJobRespJobDirection `json:"job_direction,omitempty"`

	// 迁移场景 - migration:实时迁移 - sync:实时同步 - cloudDataGuard:实时灾备
	DbUseType *QueryJobRespDbUseType `json:"db_use_type,omitempty"`

	// 是否需要重启
	NeedRestart *bool `json:"need_restart,omitempty"`

	// 指定目标实例是否限制为只读
	IsTargetReadonly *bool `json:"is_target_readonly,omitempty"`

	// 冲突忽略策略 - stop:冲突失败 - overwrite:冲突覆盖 - ignore:冲突忽略
	ConflictPolicy *QueryJobRespConflictPolicy `json:"conflict_policy,omitempty"`

	// 过滤DDL策略 - drop_database:过滤drop_database - drop_databasefilter_all:过滤所有ddl - \"\":不过滤
	FilterDdlPolicy *string `json:"filter_ddl_policy,omitempty"`

	// 迁移速度限制。
	SpeedLimit *[]SpeedLimitInfo `json:"speed_limit,omitempty"`

	// 迁移方案 - Replication-主从复制 - Tungsten-日志解析 - PGBaseBackup-PG备份
	SchemaType *QueryJobRespSchemaType `json:"schema_type,omitempty"`

	// 节点个数。
	NodeNum *string `json:"node_num,omitempty"`

	// 对象选择开关
	ObjectSwitch *bool `json:"object_switch,omitempty"`

	// 主任务Id。
	MasterJobId *string `json:"master_job_id,omitempty"`

	// 全量快照模式。
	FullMode *string `json:"full_mode,omitempty"`

	// 是否迁移结构。
	StructTrans *bool `json:"struct_trans,omitempty"`

	// 否迁移索引。
	IndexTrans *bool `json:"index_trans,omitempty"`

	// 是否使用目标库的用户替换掉definer。
	ReplaceDefiner *bool `json:"replace_definer,omitempty"`

	// 是否迁移用户。
	MigrateUser *bool `json:"migrate_user,omitempty"`

	// 是否库级同步。
	SyncDatabase *bool `json:"sync_database,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMessage *string `json:"error_message,omitempty"`

	TargetRootDb *DefaultRootDb `json:"target_root_db,omitempty"`

	// node所在AZ
	AzCode *string `json:"az_code,omitempty"`

	// node所在VPC
	VpcId *string `json:"vpc_id,omitempty"`

	// node所在子网
	SubnetId *string `json:"subnet_id,omitempty"`

	// node所在安全组
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 是否多主灾备任务,双主灾备时有值为true
	MultiWrite *bool `json:"multi_write,omitempty"`

	// 是否支持IPV6
	SupportIpV6 *bool `json:"support_ip_v6,omitempty"`

	// 继承的任务ID,Oracle_Mrskafka链路时使用。
	InheritId *string `json:"inherit_id,omitempty"`

	// 断点的GTID集合
	Gtid *string `json:"gtid,omitempty"`

	AlarmNotify *QuerySmnInfoResp `json:"alarm_notify,omitempty"`

	// 增量任务启动位点
	IncreStartPosition *string `json:"incre_start_position,omitempty"`

	// 是否是主备任务。
	IsMultiAz *bool `json:"is_multi_az,omitempty"`

	// node所在节点AZ名称。
	AzName *string `json:"az_name,omitempty"`

	// 主备任务主AZ。
	MasterAz *string `json:"master_az,omitempty"`

	// 主备任务备AZ。
	SlaveAz *string `json:"slave_az,omitempty"`

	// 任务主备角色。
	NodeRole *string `json:"node_role,omitempty"`

	PeriodOrder *PeriodOrderResp `json:"period_order,omitempty"`

	// 已同步对象信息。
	ObjectInfos *[]DatabaseObjectInfo `json:"object_infos,omitempty"`

	// 初始任务方向。 取值: - up:入云,灾备场景时对应本云为备。 - down:出云,灾备场景时对应本云为主。 - non-dbs:自建。
	OriginalJobDirection *QueryJobRespOriginalJobDirection `json:"original_job_direction,omitempty"`

	DataTransformation *GetDataTransformationResp `json:"data_transformation,omitempty"`

	// DRS任务标签
	Tags *[]Tag `json:"tags,omitempty"`
}

func (QueryJobResp) String

func (o QueryJobResp) String() string

type QueryJobRespConflictPolicy

type QueryJobRespConflictPolicy struct {
	// contains filtered or unexported fields
}

func (QueryJobRespConflictPolicy) MarshalJSON

func (c QueryJobRespConflictPolicy) MarshalJSON() ([]byte, error)

func (*QueryJobRespConflictPolicy) UnmarshalJSON

func (c *QueryJobRespConflictPolicy) UnmarshalJSON(b []byte) error

func (QueryJobRespConflictPolicy) Value added in v0.0.90

type QueryJobRespConflictPolicyEnum

type QueryJobRespConflictPolicyEnum struct {
	STOP      QueryJobRespConflictPolicy
	OVERWRITE QueryJobRespConflictPolicy
	IGNORE    QueryJobRespConflictPolicy
}

func GetQueryJobRespConflictPolicyEnum

func GetQueryJobRespConflictPolicyEnum() QueryJobRespConflictPolicyEnum

type QueryJobRespDbUseType

type QueryJobRespDbUseType struct {
	// contains filtered or unexported fields
}

func (QueryJobRespDbUseType) MarshalJSON

func (c QueryJobRespDbUseType) MarshalJSON() ([]byte, error)

func (*QueryJobRespDbUseType) UnmarshalJSON

func (c *QueryJobRespDbUseType) UnmarshalJSON(b []byte) error

func (QueryJobRespDbUseType) Value added in v0.0.90

func (c QueryJobRespDbUseType) Value() string

type QueryJobRespDbUseTypeEnum

type QueryJobRespDbUseTypeEnum struct {
	MIGRATION        QueryJobRespDbUseType
	SYNC             QueryJobRespDbUseType
	CLOUD_DATA_GUARD QueryJobRespDbUseType
}

func GetQueryJobRespDbUseTypeEnum

func GetQueryJobRespDbUseTypeEnum() QueryJobRespDbUseTypeEnum

type QueryJobRespJobDirection

type QueryJobRespJobDirection struct {
	// contains filtered or unexported fields
}

func (QueryJobRespJobDirection) MarshalJSON

func (c QueryJobRespJobDirection) MarshalJSON() ([]byte, error)

func (*QueryJobRespJobDirection) UnmarshalJSON

func (c *QueryJobRespJobDirection) UnmarshalJSON(b []byte) error

func (QueryJobRespJobDirection) Value added in v0.0.90

func (c QueryJobRespJobDirection) Value() string

type QueryJobRespJobDirectionEnum

type QueryJobRespJobDirectionEnum struct {
	UP      QueryJobRespJobDirection
	DOWN    QueryJobRespJobDirection
	NON_DBS QueryJobRespJobDirection
}

func GetQueryJobRespJobDirectionEnum

func GetQueryJobRespJobDirectionEnum() QueryJobRespJobDirectionEnum

type QueryJobRespNetType

type QueryJobRespNetType struct {
	// contains filtered or unexported fields
}

func (QueryJobRespNetType) MarshalJSON

func (c QueryJobRespNetType) MarshalJSON() ([]byte, error)

func (*QueryJobRespNetType) UnmarshalJSON

func (c *QueryJobRespNetType) UnmarshalJSON(b []byte) error

func (QueryJobRespNetType) Value added in v0.0.90

func (c QueryJobRespNetType) Value() string

type QueryJobRespNetTypeEnum

type QueryJobRespNetTypeEnum struct {
	VPN QueryJobRespNetType
	VPC QueryJobRespNetType
	EIP QueryJobRespNetType
}

func GetQueryJobRespNetTypeEnum

func GetQueryJobRespNetTypeEnum() QueryJobRespNetTypeEnum

type QueryJobRespOriginalJobDirection added in v0.1.37

type QueryJobRespOriginalJobDirection struct {
	// contains filtered or unexported fields
}

func (QueryJobRespOriginalJobDirection) MarshalJSON added in v0.1.37

func (c QueryJobRespOriginalJobDirection) MarshalJSON() ([]byte, error)

func (*QueryJobRespOriginalJobDirection) UnmarshalJSON added in v0.1.37

func (c *QueryJobRespOriginalJobDirection) UnmarshalJSON(b []byte) error

func (QueryJobRespOriginalJobDirection) Value added in v0.1.37

type QueryJobRespOriginalJobDirectionEnum added in v0.1.37

type QueryJobRespOriginalJobDirectionEnum struct {
	UP      QueryJobRespOriginalJobDirection
	DOWN    QueryJobRespOriginalJobDirection
	NON_DBS QueryJobRespOriginalJobDirection
}

func GetQueryJobRespOriginalJobDirectionEnum added in v0.1.37

func GetQueryJobRespOriginalJobDirectionEnum() QueryJobRespOriginalJobDirectionEnum

type QueryJobRespSchemaType

type QueryJobRespSchemaType struct {
	// contains filtered or unexported fields
}

func (QueryJobRespSchemaType) MarshalJSON

func (c QueryJobRespSchemaType) MarshalJSON() ([]byte, error)

func (*QueryJobRespSchemaType) UnmarshalJSON

func (c *QueryJobRespSchemaType) UnmarshalJSON(b []byte) error

func (QueryJobRespSchemaType) Value added in v0.0.90

func (c QueryJobRespSchemaType) Value() string

type QueryJobRespSchemaTypeEnum

type QueryJobRespSchemaTypeEnum struct {
	REPLICATION    QueryJobRespSchemaType
	TUNGSTEN       QueryJobRespSchemaType
	PG_BASE_BACKUP QueryJobRespSchemaType
}

func GetQueryJobRespSchemaTypeEnum

func GetQueryJobRespSchemaTypeEnum() QueryJobRespSchemaTypeEnum

type QueryJobRespStatus

type QueryJobRespStatus struct {
	// contains filtered or unexported fields
}

func (QueryJobRespStatus) MarshalJSON

func (c QueryJobRespStatus) MarshalJSON() ([]byte, error)

func (*QueryJobRespStatus) UnmarshalJSON

func (c *QueryJobRespStatus) UnmarshalJSON(b []byte) error

func (QueryJobRespStatus) Value added in v0.0.90

func (c QueryJobRespStatus) Value() string

type QueryJobRespStatusEnum

type QueryJobRespStatusEnum struct {
	CREATING                        QueryJobRespStatus
	CREATE_FAILED                   QueryJobRespStatus
	CONFIGURATION                   QueryJobRespStatus
	STARTJOBING                     QueryJobRespStatus
	WAITING_FOR_START               QueryJobRespStatus
	START_JOB_FAILED                QueryJobRespStatus
	PAUSING                         QueryJobRespStatus
	FULL_TRANSFER_STARTED           QueryJobRespStatus
	FULL_TRANSFER_FAILED            QueryJobRespStatus
	FULL_TRANSFER_COMPLETE          QueryJobRespStatus
	INCRE_TRANSFER_STARTED          QueryJobRespStatus
	INCRE_TRANSFER_FAILED           QueryJobRespStatus
	RELEASE_RESOURCE_STARTED        QueryJobRespStatus
	RELEASE_RESOURCE_FAILED         QueryJobRespStatus
	RELEASE_RESOURCE_COMPLETE       QueryJobRespStatus
	REBUILD_NODE_STARTED            QueryJobRespStatus
	REBUILD_NODE_FAILED             QueryJobRespStatus
	CHANGE_JOB_STARTED              QueryJobRespStatus
	CHANGE_JOB_FAILED               QueryJobRespStatus
	DELETED                         QueryJobRespStatus
	CHILD_TRANSFER_STARTING         QueryJobRespStatus
	CHILD_TRANSFER_STARTED          QueryJobRespStatus
	CHILD_TRANSFER_COMPLETE         QueryJobRespStatus
	CHILD_TRANSFER_FAILED           QueryJobRespStatus
	RELEASE_CHILD_TRANSFER_STARTED  QueryJobRespStatus
	RELEASE_CHILD_TRANSFER_COMPLETE QueryJobRespStatus
	NODE_UPGRADE_START              QueryJobRespStatus
	NODE_UPGRADE_COMPLETE           QueryJobRespStatus
	NODE_UPGRADE_FAILED             QueryJobRespStatus
}

func GetQueryJobRespStatusEnum

func GetQueryJobRespStatusEnum() QueryJobRespStatusEnum

type QueryJobRespTaskType

type QueryJobRespTaskType struct {
	// contains filtered or unexported fields
}

func (QueryJobRespTaskType) MarshalJSON

func (c QueryJobRespTaskType) MarshalJSON() ([]byte, error)

func (*QueryJobRespTaskType) UnmarshalJSON

func (c *QueryJobRespTaskType) UnmarshalJSON(b []byte) error

func (QueryJobRespTaskType) Value added in v0.0.90

func (c QueryJobRespTaskType) Value() string

type QueryJobRespTaskTypeEnum

type QueryJobRespTaskTypeEnum struct {
	FULL_TRANS      QueryJobRespTaskType
	FULL_INCR_TRANS QueryJobRespTaskType
	INCR_TRANS      QueryJobRespTaskType
}

func GetQueryJobRespTaskTypeEnum

func GetQueryJobRespTaskTypeEnum() QueryJobRespTaskTypeEnum

type QueryJobStatusResp

type QueryJobStatusResp struct {

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 任务状态。 - CREATING:创建中 - CREATE_FAILED:创建失败 - CONFIGURATION:配置中 - STARTJOBING:启动中 - WAITING_FOR_START:等待启动中 - START_JOB_FAILED:启动失败 - PAUSING:已暂停 - FULL_TRANSFER_STARTED:全量开始,灾备场景下为初始化 - FULL_TRANSFER_FAILED:全量失败,灾备场景下为初始化失败 - FULL_TRANSFER_COMPLETE:全量完成,灾备场景下为初始化完成 - INCRE_TRANSFER_STARTED:增量开始,灾备场景下为灾备中 - INCRE_TRANSFER_FAILED:增量失败,灾备场景下为灾备异常 - RELEASE_RESOURCE_STARTED:结束任务中 - RELEASE_RESOURCE_FAILED:结束任务失败 - RELEASE_RESOURCE_COMPLETE:已结束 - REBUILD_NODE_STARTED:故障恢复中 - REBUILD_NODE_FAILED:故障恢复失败 - CHANGE_JOB_STARTED:任务变更中 - CHANGE_JOB_FAILED:任务变更失败 - DELETED:已删除 - CHILD_TRANSFER_STARTING:再编辑子任务启动中 - CHILD_TRANSFER_STARTED:再编辑子任务迁移中 - CHILD_TRANSFER_COMPLETE:再编辑子任务迁移完成 - CHILD_TRANSFER_FAILED:再编辑子任务迁移失败 - RELEASE_CHILD_TRANSFER_STARTED:再编辑子任务结束中 - RELEASE_CHILD_TRANSFER_COMPLETE:再编辑子任务已结束 - NODE_UPGRADE_START:升级开始 - NODE_UPGRADE_COMPLETE:升级完成 - NODE_UPGRADE_FAILED:升级失败
	Status *QueryJobStatusRespStatus `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMessage *string `json:"error_message,omitempty"`
}

批量查询任务状态返回体

func (QueryJobStatusResp) String

func (o QueryJobStatusResp) String() string

type QueryJobStatusRespStatus

type QueryJobStatusRespStatus struct {
	// contains filtered or unexported fields
}

func (QueryJobStatusRespStatus) MarshalJSON

func (c QueryJobStatusRespStatus) MarshalJSON() ([]byte, error)

func (*QueryJobStatusRespStatus) UnmarshalJSON

func (c *QueryJobStatusRespStatus) UnmarshalJSON(b []byte) error

func (QueryJobStatusRespStatus) Value added in v0.0.90

func (c QueryJobStatusRespStatus) Value() string

type QueryJobStatusRespStatusEnum

type QueryJobStatusRespStatusEnum struct {
	CREATING                        QueryJobStatusRespStatus
	CREATE_FAILED                   QueryJobStatusRespStatus
	CONFIGURATION                   QueryJobStatusRespStatus
	STARTJOBING                     QueryJobStatusRespStatus
	WAITING_FOR_START               QueryJobStatusRespStatus
	START_JOB_FAILED                QueryJobStatusRespStatus
	PAUSING                         QueryJobStatusRespStatus
	FULL_TRANSFER_STARTED           QueryJobStatusRespStatus
	FULL_TRANSFER_FAILED            QueryJobStatusRespStatus
	FULL_TRANSFER_COMPLETE          QueryJobStatusRespStatus
	INCRE_TRANSFER_STARTED          QueryJobStatusRespStatus
	INCRE_TRANSFER_FAILED           QueryJobStatusRespStatus
	RELEASE_RESOURCE_STARTED        QueryJobStatusRespStatus
	RELEASE_RESOURCE_FAILED         QueryJobStatusRespStatus
	RELEASE_RESOURCE_COMPLETE       QueryJobStatusRespStatus
	REBUILD_NODE_STARTED            QueryJobStatusRespStatus
	REBUILD_NODE_FAILED             QueryJobStatusRespStatus
	CHANGE_JOB_STARTED              QueryJobStatusRespStatus
	CHANGE_JOB_FAILED               QueryJobStatusRespStatus
	DELETED                         QueryJobStatusRespStatus
	CHILD_TRANSFER_STARTING         QueryJobStatusRespStatus
	CHILD_TRANSFER_STARTED          QueryJobStatusRespStatus
	CHILD_TRANSFER_COMPLETE         QueryJobStatusRespStatus
	CHILD_TRANSFER_FAILED           QueryJobStatusRespStatus
	RELEASE_CHILD_TRANSFER_STARTED  QueryJobStatusRespStatus
	RELEASE_CHILD_TRANSFER_COMPLETE QueryJobStatusRespStatus
	NODE_UPGRADE_START              QueryJobStatusRespStatus
	NODE_UPGRADE_COMPLETE           QueryJobStatusRespStatus
	NODE_UPGRADE_FAILED             QueryJobStatusRespStatus
}

func GetQueryJobStatusRespStatusEnum

func GetQueryJobStatusRespStatusEnum() QueryJobStatusRespStatusEnum

type QueryJobsReq

type QueryJobsReq struct {

	// 第几页
	CurPage int32 `json:"cur_page"`

	// 每页记录数
	PerPage int32 `json:"per_page"`

	// 迁移场景,migration:实时迁移,sync:实时同步,cloudDataGuard:实时灾备
	DbUseType QueryJobsReqDbUseType `json:"db_use_type"`

	// 引擎类型,mysql:迁移,同步使用。mongodb:迁移使用。cloudDataGuard-mysql:灾备使用。
	EngineType *QueryJobsReqEngineType `json:"engine_type,omitempty"`

	// 企业项目
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// name或id
	Name *string `json:"name,omitempty"`

	// 网络类型
	NetType *QueryJobsReqNetType `json:"net_type,omitempty"`

	// 开启EPS时使用,值为eps
	ServiceName *string `json:"service_name,omitempty"`

	// 任务状态。 - CREATING:创建中 - CREATE_FAILED:创建失败 - CONFIGURATION:配置中 - STARTJOBING:启动中 - WAITING_FOR_START:等待启动中 - START_JOB_FAILED:启动失败 - PAUSING:已暂停 - FULL_TRANSFER_STARTED:全量开始,灾备场景下为初始化 - FULL_TRANSFER_FAILED:全量失败,灾备场景下为初始化失败 - FULL_TRANSFER_COMPLETE:全量完成,灾备场景下为初始化完成 - INCRE_TRANSFER_STARTED:增量开始,灾备场景下为灾备中 - INCRE_TRANSFER_FAILED:增量失败,灾备场景下为灾备异常 - RELEASE_RESOURCE_STARTED:结束任务中 - RELEASE_RESOURCE_FAILED:结束任务失败 - RELEASE_RESOURCE_COMPLETE:已结束 - REBUILD_NODE_STARTED:故障恢复中 - REBUILD_NODE_FAILED:故障恢复失败 - CHANGE_JOB_STARTED:任务变更中 - CHANGE_JOB_FAILED:任务变更失败 - DELETED:已删除 - CHILD_TRANSFER_STARTING:再编辑子任务启动中 - CHILD_TRANSFER_STARTED:再编辑子任务迁移中 - CHILD_TRANSFER_COMPLETE:再编辑子任务迁移完成 - CHILD_TRANSFER_FAILED:再编辑子任务迁移失败 - RELEASE_CHILD_TRANSFER_STARTED:再编辑子任务结束中 - RELEASE_CHILD_TRANSFER_COMPLETE:再编辑子任务已结束 - NODE_UPGRADE_START:升级开始 - NODE_UPGRADE_COMPLETE:升级完成 - NODE_UPGRADE_FAILED:升级失败
	Status *QueryJobsReqStatus `json:"status,omitempty"`

	// 标签
	Tags map[string]string `json:"tags,omitempty"`
}

查询任务列表请求体

func (QueryJobsReq) String

func (o QueryJobsReq) String() string

type QueryJobsReqDbUseType

type QueryJobsReqDbUseType struct {
	// contains filtered or unexported fields
}

func (QueryJobsReqDbUseType) MarshalJSON

func (c QueryJobsReqDbUseType) MarshalJSON() ([]byte, error)

func (*QueryJobsReqDbUseType) UnmarshalJSON

func (c *QueryJobsReqDbUseType) UnmarshalJSON(b []byte) error

func (QueryJobsReqDbUseType) Value added in v0.0.90

func (c QueryJobsReqDbUseType) Value() string

type QueryJobsReqDbUseTypeEnum

type QueryJobsReqDbUseTypeEnum struct {
	MIGRATION        QueryJobsReqDbUseType
	SYNC             QueryJobsReqDbUseType
	CLOUD_DATA_GUARD QueryJobsReqDbUseType
}

func GetQueryJobsReqDbUseTypeEnum

func GetQueryJobsReqDbUseTypeEnum() QueryJobsReqDbUseTypeEnum

type QueryJobsReqEngineType

type QueryJobsReqEngineType struct {
	// contains filtered or unexported fields
}

func (QueryJobsReqEngineType) MarshalJSON

func (c QueryJobsReqEngineType) MarshalJSON() ([]byte, error)

func (*QueryJobsReqEngineType) UnmarshalJSON

func (c *QueryJobsReqEngineType) UnmarshalJSON(b []byte) error

func (QueryJobsReqEngineType) Value added in v0.0.90

func (c QueryJobsReqEngineType) Value() string

type QueryJobsReqEngineTypeEnum

type QueryJobsReqEngineTypeEnum struct {
	MYSQL                  QueryJobsReqEngineType
	MONGODB                QueryJobsReqEngineType
	CLOUD_DATA_GUARD_MYSQL QueryJobsReqEngineType
}

func GetQueryJobsReqEngineTypeEnum

func GetQueryJobsReqEngineTypeEnum() QueryJobsReqEngineTypeEnum

type QueryJobsReqNetType

type QueryJobsReqNetType struct {
	// contains filtered or unexported fields
}

func (QueryJobsReqNetType) MarshalJSON

func (c QueryJobsReqNetType) MarshalJSON() ([]byte, error)

func (*QueryJobsReqNetType) UnmarshalJSON

func (c *QueryJobsReqNetType) UnmarshalJSON(b []byte) error

func (QueryJobsReqNetType) Value added in v0.0.90

func (c QueryJobsReqNetType) Value() string

type QueryJobsReqNetTypeEnum

type QueryJobsReqNetTypeEnum struct {
	VPN QueryJobsReqNetType
	VPC QueryJobsReqNetType
	EIP QueryJobsReqNetType
}

func GetQueryJobsReqNetTypeEnum

func GetQueryJobsReqNetTypeEnum() QueryJobsReqNetTypeEnum

type QueryJobsReqStatus

type QueryJobsReqStatus struct {
	// contains filtered or unexported fields
}

func (QueryJobsReqStatus) MarshalJSON

func (c QueryJobsReqStatus) MarshalJSON() ([]byte, error)

func (*QueryJobsReqStatus) UnmarshalJSON

func (c *QueryJobsReqStatus) UnmarshalJSON(b []byte) error

func (QueryJobsReqStatus) Value added in v0.0.90

func (c QueryJobsReqStatus) Value() string

type QueryJobsReqStatusEnum

type QueryJobsReqStatusEnum struct {
	CREATING                        QueryJobsReqStatus
	CREATE_FAILED                   QueryJobsReqStatus
	CONFIGURATION                   QueryJobsReqStatus
	STARTJOBING                     QueryJobsReqStatus
	WAITING_FOR_START               QueryJobsReqStatus
	START_JOB_FAILED                QueryJobsReqStatus
	PAUSING                         QueryJobsReqStatus
	FULL_TRANSFER_STARTED           QueryJobsReqStatus
	FULL_TRANSFER_FAILED            QueryJobsReqStatus
	FULL_TRANSFER_COMPLETE          QueryJobsReqStatus
	INCRE_TRANSFER_STARTED          QueryJobsReqStatus
	INCRE_TRANSFER_FAILED           QueryJobsReqStatus
	RELEASE_RESOURCE_STARTED        QueryJobsReqStatus
	RELEASE_RESOURCE_FAILED         QueryJobsReqStatus
	RELEASE_RESOURCE_COMPLETE       QueryJobsReqStatus
	REBUILD_NODE_STARTED            QueryJobsReqStatus
	REBUILD_NODE_FAILED             QueryJobsReqStatus
	CHANGE_JOB_STARTED              QueryJobsReqStatus
	CHANGE_JOB_FAILED               QueryJobsReqStatus
	DELETED                         QueryJobsReqStatus
	CHILD_TRANSFER_STARTING         QueryJobsReqStatus
	CHILD_TRANSFER_STARTED          QueryJobsReqStatus
	CHILD_TRANSFER_COMPLETE         QueryJobsReqStatus
	CHILD_TRANSFER_FAILED           QueryJobsReqStatus
	RELEASE_CHILD_TRANSFER_STARTED  QueryJobsReqStatus
	RELEASE_CHILD_TRANSFER_COMPLETE QueryJobsReqStatus
	NODE_UPGRADE_START              QueryJobsReqStatus
	NODE_UPGRADE_COMPLETE           QueryJobsReqStatus
	NODE_UPGRADE_FAILED             QueryJobsReqStatus
}

func GetQueryJobsReqStatusEnum

func GetQueryJobsReqStatusEnum() QueryJobsReqStatusEnum

type QueryPreCheckResp

type QueryPreCheckResp struct {

	// 预检查id。
	PrecheckId *string `json:"precheck_id,omitempty"`

	// 返回的预检查结果是否通过。true表示预检查通过,通过后才可进行启动任务。
	Result *bool `json:"result,omitempty"`

	// 预检查进度百分比。
	Process *string `json:"process,omitempty"`

	// 预检查通过百分比。
	TotalPassedRate *string `json:"total_passed_rate,omitempty"`

	// RDS实例id。
	RdsInstanceId *string `json:"rds_instance_id,omitempty"`

	// 迁移方向。 - up-入云 灾备场景时对应本云为备 - down-出云 灾备场景时对应本云为主 - non-dbs-自建
	JobDirection *QueryPreCheckRespJobDirection `json:"job_direction,omitempty"`

	// 预检查各项结果。
	PrecheckResult *[]PrecheckResult `json:"precheck_result,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 任务错误码。
	ErrorCode *string `json:"error_code,omitempty"`
}

获取预检查结果返回体

func (QueryPreCheckResp) String

func (o QueryPreCheckResp) String() string

type QueryPreCheckRespJobDirection

type QueryPreCheckRespJobDirection struct {
	// contains filtered or unexported fields
}

func (QueryPreCheckRespJobDirection) MarshalJSON

func (c QueryPreCheckRespJobDirection) MarshalJSON() ([]byte, error)

func (*QueryPreCheckRespJobDirection) UnmarshalJSON

func (c *QueryPreCheckRespJobDirection) UnmarshalJSON(b []byte) error

func (QueryPreCheckRespJobDirection) Value added in v0.0.90

type QueryPreCheckRespJobDirectionEnum

type QueryPreCheckRespJobDirectionEnum struct {
	UP      QueryPreCheckRespJobDirection
	DOWN    QueryPreCheckRespJobDirection
	NON_DBS QueryPreCheckRespJobDirection
}

func GetQueryPreCheckRespJobDirectionEnum

func GetQueryPreCheckRespJobDirectionEnum() QueryPreCheckRespJobDirectionEnum

type QueryProgressResp

type QueryProgressResp struct {

	// 任务Id
	JobId *string `json:"job_id,omitempty"`

	// 迁移百分比
	Progress *string `json:"progress,omitempty"`

	// 增量迁移时延
	IncreTransDelay *string `json:"incre_trans_delay,omitempty"`

	// 迁移模式。 - FULL_TRANS: 全量 - INCR_TRANS: 增量 - FULL_INCR_TRANS: 全量+增量
	TaskMode *QueryProgressRespTaskMode `json:"task_mode,omitempty"`

	// 任务状态
	TransferStatus *string `json:"transfer_status,omitempty"`

	// 迁移时间,时间戳
	ProcessTime *string `json:"process_time,omitempty"`

	// 预计剩余时间
	RemainingTime *string `json:"remaining_time,omitempty"`

	// 数据,结构,索引迁移进度信息体
	ProgressMap map[string]ProgressInfo `json:"progress_map,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

获取指定任务迁移进度响应体

func (QueryProgressResp) String

func (o QueryProgressResp) String() string

type QueryProgressRespTaskMode

type QueryProgressRespTaskMode struct {
	// contains filtered or unexported fields
}

func (QueryProgressRespTaskMode) MarshalJSON

func (c QueryProgressRespTaskMode) MarshalJSON() ([]byte, error)

func (*QueryProgressRespTaskMode) UnmarshalJSON

func (c *QueryProgressRespTaskMode) UnmarshalJSON(b []byte) error

func (QueryProgressRespTaskMode) Value added in v0.0.90

type QueryProgressRespTaskModeEnum

type QueryProgressRespTaskModeEnum struct {
	FULL_TRANS      QueryProgressRespTaskMode
	FULL_INCR_TRANS QueryProgressRespTaskMode
	INCR_TRANS      QueryProgressRespTaskMode
}

func GetQueryProgressRespTaskModeEnum

func GetQueryProgressRespTaskModeEnum() QueryProgressRespTaskModeEnum

type QueryQuotaInfo

type QueryQuotaInfo struct {
	Resource *QuotaResource `json:"resource,omitempty"`
}

配额信息

func (QueryQuotaInfo) String

func (o QueryQuotaInfo) String() string

type QueryRoleDetailResp

type QueryRoleDetailResp struct {

	// 角色。
	Role *string `json:"role,omitempty"`

	// 说明。
	Comment *string `json:"comment,omitempty"`

	// 是否支持迁移。
	IsTransfer *bool `json:"is_transfer,omitempty"`

	// 角色权限。
	Privileges *string `json:"privileges,omitempty"`

	// 继承的角色。
	InheritsRoles *[]string `json:"inherits_roles,omitempty"`

	// 是否选择。
	Selected *bool `json:"selected,omitempty"`
}

迁移角色响应体

func (QueryRoleDetailResp) String

func (o QueryRoleDetailResp) String() string

type QueryRpoAndRtoResp

type QueryRpoAndRtoResp struct {

	// 任务ID
	JobId *string `json:"job_id,omitempty"`

	RpoInfo *RpoAndRtoInfo `json:"rpo_info,omitempty"`

	RtoInfo *RpoAndRtoInfo `json:"rto_info,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

RPO和RTO信息体

func (QueryRpoAndRtoResp) String

func (o QueryRpoAndRtoResp) String() string

type QuerySmnInfoResp added in v0.0.84

type QuerySmnInfoResp struct {

	// SMN信息
	Subscriptions *[]SubscriptionInfo `json:"subscriptions,omitempty"`

	// 主题名称
	TopicName *string `json:"topic_name,omitempty"`

	// 订阅延迟时间
	DelayTime *int64 `json:"delay_time,omitempty"`

	// rto延迟时间
	RtoDelay *int64 `json:"rto_delay,omitempty"`

	// rpo延迟时间
	RpoDelay *int64 `json:"rpo_delay,omitempty"`

	// 异常告警是否通知用户
	AlarmToUser *bool `json:"alarm_to_user,omitempty"`
}

已录入SMN信息体

func (QuerySmnInfoResp) String added in v0.0.84

func (o QuerySmnInfoResp) String() string

type QueryStructDetailResp

type QueryStructDetailResp struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMessage *string `json:"error_message,omitempty"`

	StructDetail *QueryFlowCompareDataResp `json:"struct_detail,omitempty"`
}

灾备初始化对象详情

func (QueryStructDetailResp) String

func (o QueryStructDetailResp) String() string

type QueryStructProcessResp

type QueryStructProcessResp struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMessage *string `json:"error_message,omitempty"`

	StructProcess *StructProcessResp `json:"struct_process,omitempty"`
}

查询灾备初始化进度

func (QueryStructProcessResp) String

func (o QueryStructProcessResp) String() string

type QueryUserDetailResp

type QueryUserDetailResp struct {

	// 用户账户id。
	Id *string `json:"id,omitempty"`

	// 账户。
	Account *string `json:"account,omitempty"`

	// 说明。
	Comment *string `json:"comment,omitempty"`

	// 是否支持迁移
	IsTransfer *bool `json:"is_transfer,omitempty"`

	// 权限
	Privileges *string `json:"privileges,omitempty"`

	// 密码。
	Password *string `json:"password,omitempty"`

	// 账号拥有的角色
	Roles *[]string `json:"roles,omitempty"`

	// 是否选择。
	Selected *bool `json:"selected,omitempty"`

	// 无法同步的用户权限
	NoPrivileges *string `json:"no_privileges,omitempty"`

	// 父用户
	ParentAccount *string `json:"parent_account,omitempty"`

	// 无法同步父子关系的父用户
	NoParentAccount *string `json:"no_parent_account,omitempty"`
}

迁移用户响应体

func (QueryUserDetailResp) String

func (o QueryUserDetailResp) String() string

type QueryUserResp

type QueryUserResp struct {

	// 任务id
	JobId *string `json:"job_id,omitempty"`

	// 是否使用全局密码
	IsGlobalPassword *string `json:"is_global_password,omitempty"`

	// 错误码
	Message *string `json:"message,omitempty"`

	// 用户列表数据
	UserList *[]QueryUserDetailResp `json:"user_list,omitempty"`

	// 角色列表数据
	RolesList *[]QueryRoleDetailResp `json:"roles_list,omitempty"`

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`
}

迁移用户响应体

func (QueryUserResp) String

func (o QueryUserResp) String() string

type QuotaResource

type QuotaResource struct {

	// 配额类型信息
	Type *string `json:"type,omitempty"`

	// 配额最小取值
	Min *int32 `json:"min,omitempty"`

	// 配额最大取值
	Max *int32 `json:"max,omitempty"`

	// 用户配额的实际值
	Quota *int32 `json:"quota,omitempty"`

	// 已使用的配额值
	Used *int32 `json:"used,omitempty"`
}

配额信息

func (QuotaResource) String

func (o QuotaResource) String() string

type ReplaceDefinerInfo

type ReplaceDefinerInfo struct {

	// 任务id
	JobId string `json:"job_id"`

	// 是否使用目标库的用户替换掉definer
	ReplaceDefiner bool `json:"replace_definer"`
}

设置replaceDefiner信息

func (ReplaceDefinerInfo) String

func (o ReplaceDefinerInfo) String() string

type ResourceTag

type ResourceTag struct {

	// 标签键,最大长度36,只能包含字母、数字、下划线、中划线和中文,需要修改标签时填写。
	Key *string `json:"key,omitempty"`

	// 标签值,最大长度43,只能包含字母、数字、下划线、中划线和中文,需要修改标签时填写。
	Value *string `json:"value,omitempty"`
}

标签信息体

func (ResourceTag) String

func (o ResourceTag) String() string

type RetryInfo

type RetryInfo struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 再编辑之后启动,必填为true。
	IsSyncReEdit *bool `json:"is_sync_re_edit,omitempty"`
}

func (RetryInfo) String

func (o RetryInfo) String() string

type RetryTaskResp

type RetryTaskResp struct {

	// 任务id
	Id string `json:"id"`

	// 状态
	Status string `json:"status"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

续传任务返回体

func (RetryTaskResp) String

func (o RetryTaskResp) String() string

type RpoAndRtoInfo

type RpoAndRtoInfo struct {

	// 检查点
	CheckPoint *string `json:"check_point,omitempty"`

	// 延迟
	Delay *string `json:"delay,omitempty"`

	// gtid集合
	GtidSet *string `json:"gtid_set,omitempty"`

	// 当前时间 ,格式为“yyyy-MM-dd HH:mm:ss”
	Time *string `json:"time,omitempty"`
}

RpoAndRTO信息体

func (RpoAndRtoInfo) String

func (o RpoAndRtoInfo) String() string

type SelectedSetAlarmTaskReq added in v0.0.84

type SelectedSetAlarmTaskReq struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 任务状态
	Status string `json:"status"`

	// 引擎类型
	EngineType string `json:"engine_type"`
}

需要设置SMN的任务信息。

func (SelectedSetAlarmTaskReq) String added in v0.0.84

func (o SelectedSetAlarmTaskReq) String() string

type ShowJobListRequest

type ShowJobListRequest struct {

	// 请求语言类型
	XLanguage *ShowJobListRequestXLanguage `json:"X-Language,omitempty"`

	Body *QueryJobsReq `json:"body,omitempty"`
}

Request Object

func (ShowJobListRequest) String

func (o ShowJobListRequest) String() string

type ShowJobListRequestXLanguage

type ShowJobListRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ShowJobListRequestXLanguage) MarshalJSON

func (c ShowJobListRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowJobListRequestXLanguage) UnmarshalJSON

func (c *ShowJobListRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowJobListRequestXLanguage) Value added in v0.0.90

type ShowJobListRequestXLanguageEnum

type ShowJobListRequestXLanguageEnum struct {
	EN_US ShowJobListRequestXLanguage
	ZH_CN ShowJobListRequestXLanguage
}

func GetShowJobListRequestXLanguageEnum

func GetShowJobListRequestXLanguageEnum() ShowJobListRequestXLanguageEnum

type ShowJobListResponse

type ShowJobListResponse struct {

	// 任务总数
	TotalRecord *int32 `json:"total_record,omitempty"`

	// 任务信息列表
	Jobs           *[]JobInfo `json:"jobs,omitempty"`
	HttpStatusCode int        `json:"-"`
}

Response Object

func (ShowJobListResponse) String

func (o ShowJobListResponse) String() string

type ShowMonitoringDataRequest

type ShowMonitoringDataRequest struct {

	// 请求语言类型
	XLanguage *ShowMonitoringDataRequestXLanguage `json:"X-Language,omitempty"`

	Body *BatchQueryJobReq `json:"body,omitempty"`
}

Request Object

func (ShowMonitoringDataRequest) String

func (o ShowMonitoringDataRequest) String() string

type ShowMonitoringDataRequestXLanguage

type ShowMonitoringDataRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ShowMonitoringDataRequestXLanguage) MarshalJSON

func (c ShowMonitoringDataRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowMonitoringDataRequestXLanguage) UnmarshalJSON

func (c *ShowMonitoringDataRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowMonitoringDataRequestXLanguage) Value added in v0.0.90

type ShowMonitoringDataRequestXLanguageEnum

type ShowMonitoringDataRequestXLanguageEnum struct {
	EN_US ShowMonitoringDataRequestXLanguage
	ZH_CN ShowMonitoringDataRequestXLanguage
}

func GetShowMonitoringDataRequestXLanguageEnum

func GetShowMonitoringDataRequestXLanguageEnum() ShowMonitoringDataRequestXLanguageEnum

type ShowMonitoringDataResponse

type ShowMonitoringDataResponse struct {

	// 容灾监控数据响应体集合
	Results *[]QueryDataGuardMonitorAndChartResp `json:"results,omitempty"`

	// 查询总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowMonitoringDataResponse) String

type ShowQuotasRequest

type ShowQuotasRequest struct {

	// 请求语言类型。
	XLanguage *ShowQuotasRequestXLanguage `json:"X-Language,omitempty"`
}

Request Object

func (ShowQuotasRequest) String

func (o ShowQuotasRequest) String() string

type ShowQuotasRequestXLanguage

type ShowQuotasRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (ShowQuotasRequestXLanguage) MarshalJSON

func (c ShowQuotasRequestXLanguage) MarshalJSON() ([]byte, error)

func (*ShowQuotasRequestXLanguage) UnmarshalJSON

func (c *ShowQuotasRequestXLanguage) UnmarshalJSON(b []byte) error

func (ShowQuotasRequestXLanguage) Value added in v0.0.90

type ShowQuotasRequestXLanguageEnum

type ShowQuotasRequestXLanguageEnum struct {
	EN_US ShowQuotasRequestXLanguage
	ZH_CN ShowQuotasRequestXLanguage
}

func GetShowQuotasRequestXLanguageEnum

func GetShowQuotasRequestXLanguageEnum() ShowQuotasRequestXLanguageEnum

type ShowQuotasResponse

type ShowQuotasResponse struct {
	Quotas         *QueryQuotaInfo `json:"quotas,omitempty"`
	HttpStatusCode int             `json:"-"`
}

Response Object

func (ShowQuotasResponse) String

func (o ShowQuotasResponse) String() string

type SpeedLimitInfo

type SpeedLimitInfo struct {

	// 开始限速时间, 此时间为UTC时间,开始时间为整时,若有分钟,则会忽略,格式为hh:mm,小时数为两位,例如:01:00。
	Begin string `json:"begin"`

	// 结束时间,此时间为UTC时间,输入必须为59分结尾,格式为hh:mm,小时数为两位,例如:05:59。
	End string `json:"end"`

	// 限速,取值范围为1~9999 ,单位为MB/s
	Speed string `json:"speed"`

	// 是否为UTC时间
	IsUtc *bool `json:"is_utc,omitempty"`
}

限制迁移速度请求体

func (SpeedLimitInfo) String

func (o SpeedLimitInfo) String() string

type StartInfo

type StartInfo struct {

	// 任务id。
	JobId string `json:"job_id"`

	// 任务启动时间,时间戳格式精确到毫秒,例如:1679966489593,取值为空代表立即启动。
	StartTime *string `json:"start_time,omitempty"`
}

启动任务请求体。

func (StartInfo) String

func (o StartInfo) String() string

type StartJobResp

type StartJobResp struct {

	// 任务id
	Id string `json:"id"`

	// 状态。
	Status *StartJobRespStatus `json:"status,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`
}

启动任务返回体。

func (StartJobResp) String

func (o StartJobResp) String() string

type StartJobRespStatus

type StartJobRespStatus struct {
	// contains filtered or unexported fields
}

func (StartJobRespStatus) MarshalJSON

func (c StartJobRespStatus) MarshalJSON() ([]byte, error)

func (*StartJobRespStatus) UnmarshalJSON

func (c *StartJobRespStatus) UnmarshalJSON(b []byte) error

func (StartJobRespStatus) Value added in v0.0.90

func (c StartJobRespStatus) Value() string

type StartJobRespStatusEnum

type StartJobRespStatusEnum struct {
	SUCCESS StartJobRespStatus
	FAILED  StartJobRespStatus
}

func GetStartJobRespStatusEnum

func GetStartJobRespStatusEnum() StartJobRespStatusEnum

type StructDetailVo

type StructDetailVo struct {

	// 进度
	Progress *int32 `json:"progress,omitempty"`

	// 源数据库名称
	SrcDB *string `json:"src_DB,omitempty"`

	// 源对象名称
	SrcTB *string `json:"src_TB,omitempty"`

	// 目标数据库名称
	DstDB *string `json:"dst_DB,omitempty"`

	// 目标对象名称
	DstTB *string `json:"dst_TB,omitempty"`
}

灾备初始化对象详情信息体

func (StructDetailVo) String

func (o StructDetailVo) String() string

type StructProcessResp

type StructProcessResp struct {

	// 数据生成时间
	CreateTime *string `json:"create_time,omitempty"`

	// 对比结果
	Result *[]StructProcessVo `json:"result,omitempty"`
}

灾备初始化进度

func (StructProcessResp) String

func (o StructProcessResp) String() string

type StructProcessVo

type StructProcessVo struct {

	// 对象类型
	Type string `json:"type"`

	// 状态
	Status int32 `json:"status"`

	// 源对象数量
	SrcCount int32 `json:"src_count"`

	// 目标对象数量
	DstCount int32 `json:"dst_count"`

	// 开始时间
	StartTime int64 `json:"start_time"`

	// 结束时间
	EndTime *int64 `json:"end_time,omitempty"`
}

灾备初始化进度信息体

func (StructProcessVo) String

func (o StructProcessVo) String() string

type SubscriptionInfo

type SubscriptionInfo struct {

	// 短信或者邮件列表
	Endpoints *[]string `json:"endpoints,omitempty"`

	// 收件方式,sms:短信,email:邮件
	Protocol *SubscriptionInfoProtocol `json:"protocol,omitempty"`
}

收件方式与信息体

func (SubscriptionInfo) String

func (o SubscriptionInfo) String() string

type SubscriptionInfoProtocol

type SubscriptionInfoProtocol struct {
	// contains filtered or unexported fields
}

func (SubscriptionInfoProtocol) MarshalJSON

func (c SubscriptionInfoProtocol) MarshalJSON() ([]byte, error)

func (*SubscriptionInfoProtocol) UnmarshalJSON

func (c *SubscriptionInfoProtocol) UnmarshalJSON(b []byte) error

func (SubscriptionInfoProtocol) Value added in v0.0.90

func (c SubscriptionInfoProtocol) Value() string

type SubscriptionInfoProtocolEnum

type SubscriptionInfoProtocolEnum struct {
	SMS   SubscriptionInfoProtocol
	EMAIL SubscriptionInfoProtocol
}

func GetSubscriptionInfoProtocolEnum

func GetSubscriptionInfoProtocolEnum() SubscriptionInfoProtocolEnum

type SwitchoverResp

type SwitchoverResp struct {

	// 任务ID
	JobId *string `json:"job_id,omitempty"`

	// 更新时间,格式yyyy-MM-dd'T'HH:mm:ss'Z'
	UpdatedAt *string `json:"updated_at,omitempty"`

	SourceDb *EndpointVo `json:"source_db,omitempty"`

	TargetDb *EndpointVo `json:"target_db,omitempty"`

	// 任务方向。 - up 入云 灾备场景时对应本云为备 - down 出云 灾备场景时对应本云为主 - non-dbs 自建
	JobDirection *SwitchoverRespJobDirection `json:"job_direction,omitempty"`

	// 目标库是否只读。
	IsTargetReadonly *bool `json:"is_target_readonly,omitempty"`

	// 错误信息。
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`
}

主备倒换响应体

func (SwitchoverResp) String

func (o SwitchoverResp) String() string

type SwitchoverRespJobDirection

type SwitchoverRespJobDirection struct {
	// contains filtered or unexported fields
}

func (SwitchoverRespJobDirection) MarshalJSON

func (c SwitchoverRespJobDirection) MarshalJSON() ([]byte, error)

func (*SwitchoverRespJobDirection) UnmarshalJSON

func (c *SwitchoverRespJobDirection) UnmarshalJSON(b []byte) error

func (SwitchoverRespJobDirection) Value added in v0.0.90

type SwitchoverRespJobDirectionEnum

type SwitchoverRespJobDirectionEnum struct {
	UP      SwitchoverRespJobDirection
	DOWN    SwitchoverRespJobDirection
	NON_DBS SwitchoverRespJobDirection
}

func GetSwitchoverRespJobDirectionEnum

func GetSwitchoverRespJobDirectionEnum() SwitchoverRespJobDirectionEnum

type SyncPolicyReq added in v0.0.63

type SyncPolicyReq struct {

	// 任务ID。
	JobId string `json:"job_id"`

	// 冲突策略。 - ignore:忽略 - overwrite:覆盖 - stop:报错
	ConflictPolicy *SyncPolicyReqConflictPolicy `json:"conflict_policy,omitempty"`

	// 过滤DDL策略。
	FilterDdlPolicy *SyncPolicyReqFilterDdlPolicy `json:"filter_ddl_policy,omitempty"`

	// 同步增量是否同步DDL。
	DdlTrans *bool `json:"ddl_trans,omitempty"`

	// 同步增量是否同步索引。
	IndexTrans *bool `json:"index_trans,omitempty"`

	// 同步Topic策略,目标库为kafka时必填,取值: - 0:集中投递到一个Topic - 1:按库名-schema-表名自动生成Topic名字 - 2:按库名自动生成Topic名字 - 3:按库名-schema自动生成Topic名字
	TopicPolicy *SyncPolicyReqTopicPolicy `json:"topic_policy,omitempty"`

	// Topic名称,topic_policy为0时必填,确保topic已存在。
	Topic *string `json:"topic,omitempty"`

	// 同步到kafka partition策略,取值: - 0:按库名.schema.表名的hash值投递到不同Partition - 1:全部投递到Partition 0 - 2:按主键的hash值投递到不同Partition - 3:按库名.schema的hash值投递到不同Partition **当topic_policy取0时,可以取0,1,2,3;当topic_policy取1时,可以取1,2;当topic_policy取2时,可以取0,1,3;当topic_policy取3时,可以取0,1;**
	PartitionPolicy *SyncPolicyReqPartitionPolicy `json:"partition_policy,omitempty"`

	// 投送到kafka的数据格式,不填默认为json:
	KafkaDataFormat *SyncPolicyReqKafkaDataFormat `json:"kafka_data_format,omitempty"`

	// Topic名字格式,topic_policy为1,2,3,时需要 - 当topic_policy取1时,Topic名字格式支持database、schema两个变量,其他字符当做常量。分别用$database$代替数据库名,$schema$代替模式名,不填默认为$database$-$schema$ - 当topic_policy取2时,Topic名字格式支持database一个变量,其他字符都当做常量,不填默认为$database$ - 当topic_policy取3时,Topic名字格式支持database、schema和tablename三个变量,其他字符当做常量。分别用$database$代替数据库名,$schema$代替模式名,$tablename$代替表名,不填默认为$database$-$schema$-$tablename$
	TopicNameFormat *string `json:"topic_name_format,omitempty"`

	// Partition个数,取值1-2147483647之间,topic_policy为1,2,3,时需要,不填默认为1
	PartitionsNum *string `json:"partitions_num,omitempty"`

	// 副本个数,取值1-32767之间,topic_policy为1,2,3,时需要,不填默认为1
	ReplicationFactor *string `json:"replication_factor,omitempty"`

	// PostgreSQL同步全量阶段是否填充物化视图,不填默认为false
	IsFillMaterializedView *bool `json:"is_fill_materialized_view,omitempty"`

	// PostgreSQL同步全量阶段是否使用快照模式导出,不填默认为false
	ExportSnapshot *bool `json:"export_snapshot,omitempty"`

	// 复制槽名称,gaussdbv5ha-to-kafka主备任务必填
	SlotName *string `json:"slot_name,omitempty"`
}

设置同步策略请求体

func (SyncPolicyReq) String added in v0.0.63

func (o SyncPolicyReq) String() string

type SyncPolicyReqConflictPolicy added in v0.0.63

type SyncPolicyReqConflictPolicy struct {
	// contains filtered or unexported fields
}

func (SyncPolicyReqConflictPolicy) MarshalJSON added in v0.0.63

func (c SyncPolicyReqConflictPolicy) MarshalJSON() ([]byte, error)

func (*SyncPolicyReqConflictPolicy) UnmarshalJSON added in v0.0.63

func (c *SyncPolicyReqConflictPolicy) UnmarshalJSON(b []byte) error

func (SyncPolicyReqConflictPolicy) Value added in v0.0.90

type SyncPolicyReqConflictPolicyEnum added in v0.0.63

type SyncPolicyReqConflictPolicyEnum struct {
	IGNORE    SyncPolicyReqConflictPolicy
	OVERWRITE SyncPolicyReqConflictPolicy
	STOP      SyncPolicyReqConflictPolicy
}

func GetSyncPolicyReqConflictPolicyEnum added in v0.0.63

func GetSyncPolicyReqConflictPolicyEnum() SyncPolicyReqConflictPolicyEnum

type SyncPolicyReqFilterDdlPolicy added in v0.0.63

type SyncPolicyReqFilterDdlPolicy struct {
	// contains filtered or unexported fields
}

func (SyncPolicyReqFilterDdlPolicy) MarshalJSON added in v0.0.63

func (c SyncPolicyReqFilterDdlPolicy) MarshalJSON() ([]byte, error)

func (*SyncPolicyReqFilterDdlPolicy) UnmarshalJSON added in v0.0.63

func (c *SyncPolicyReqFilterDdlPolicy) UnmarshalJSON(b []byte) error

func (SyncPolicyReqFilterDdlPolicy) Value added in v0.0.90

type SyncPolicyReqFilterDdlPolicyEnum added in v0.0.63

type SyncPolicyReqFilterDdlPolicyEnum struct {
	DROP_DATABASE SyncPolicyReqFilterDdlPolicy
}

func GetSyncPolicyReqFilterDdlPolicyEnum added in v0.0.63

func GetSyncPolicyReqFilterDdlPolicyEnum() SyncPolicyReqFilterDdlPolicyEnum

type SyncPolicyReqKafkaDataFormat added in v0.0.79

type SyncPolicyReqKafkaDataFormat struct {
	// contains filtered or unexported fields
}

func (SyncPolicyReqKafkaDataFormat) MarshalJSON added in v0.0.79

func (c SyncPolicyReqKafkaDataFormat) MarshalJSON() ([]byte, error)

func (*SyncPolicyReqKafkaDataFormat) UnmarshalJSON added in v0.0.79

func (c *SyncPolicyReqKafkaDataFormat) UnmarshalJSON(b []byte) error

func (SyncPolicyReqKafkaDataFormat) Value added in v0.0.90

type SyncPolicyReqKafkaDataFormatEnum added in v0.0.79

type SyncPolicyReqKafkaDataFormatEnum struct {
	JSON SyncPolicyReqKafkaDataFormat
	AVRO SyncPolicyReqKafkaDataFormat
}

func GetSyncPolicyReqKafkaDataFormatEnum added in v0.0.79

func GetSyncPolicyReqKafkaDataFormatEnum() SyncPolicyReqKafkaDataFormatEnum

type SyncPolicyReqPartitionPolicy added in v0.0.79

type SyncPolicyReqPartitionPolicy struct {
	// contains filtered or unexported fields
}

func (SyncPolicyReqPartitionPolicy) MarshalJSON added in v0.0.79

func (c SyncPolicyReqPartitionPolicy) MarshalJSON() ([]byte, error)

func (*SyncPolicyReqPartitionPolicy) UnmarshalJSON added in v0.0.79

func (c *SyncPolicyReqPartitionPolicy) UnmarshalJSON(b []byte) error

func (SyncPolicyReqPartitionPolicy) Value added in v0.0.90

type SyncPolicyReqPartitionPolicyEnum added in v0.0.79

func GetSyncPolicyReqPartitionPolicyEnum added in v0.0.79

func GetSyncPolicyReqPartitionPolicyEnum() SyncPolicyReqPartitionPolicyEnum

type SyncPolicyReqTopicPolicy added in v0.0.79

type SyncPolicyReqTopicPolicy struct {
	// contains filtered or unexported fields
}

func (SyncPolicyReqTopicPolicy) MarshalJSON added in v0.0.79

func (c SyncPolicyReqTopicPolicy) MarshalJSON() ([]byte, error)

func (*SyncPolicyReqTopicPolicy) UnmarshalJSON added in v0.0.79

func (c *SyncPolicyReqTopicPolicy) UnmarshalJSON(b []byte) error

func (SyncPolicyReqTopicPolicy) Value added in v0.0.90

func (c SyncPolicyReqTopicPolicy) Value() string

type SyncPolicyReqTopicPolicyEnum added in v0.0.79

type SyncPolicyReqTopicPolicyEnum struct {
	E_0 SyncPolicyReqTopicPolicy
	E_1 SyncPolicyReqTopicPolicy
	E_2 SyncPolicyReqTopicPolicy
	E_3 SyncPolicyReqTopicPolicy
}

func GetSyncPolicyReqTopicPolicyEnum added in v0.0.79

func GetSyncPolicyReqTopicPolicyEnum() SyncPolicyReqTopicPolicyEnum

type SyncPolicyResp added in v0.0.63

type SyncPolicyResp struct {

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 状态 - success:成功 - failed:失败
	Status *string `json:"status,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (SyncPolicyResp) String added in v0.0.63

func (o SyncPolicyResp) String() string

type Tag added in v0.1.39

type Tag struct {

	// 标签key
	Key *string `json:"key,omitempty"`

	// 标签value
	Value *string `json:"value,omitempty"`
}

DRS标签

func (Tag) String added in v0.1.39

func (o Tag) String() string

type TestEndPoint

type TestEndPoint struct {

	// 任务ID
	Id string `json:"id"`

	// 网络类型
	NetType TestEndPointNetType `json:"net_type"`

	// 数据库类型
	DbType TestEndPointDbType `json:"db_type"`

	// 数据库IP
	Ip string `json:"ip"`

	// 数据库端口,Mongo、DDS必填为0。
	DbPort *int32 `json:"db_port,omitempty"`

	// RDS实例id,RDS实例必填。
	InstId *string `json:"inst_id,omitempty"`

	// 数据库帐号。
	DbUser string `json:"db_user"`

	// 数据库密码。
	DbPassword string `json:"db_password"`

	// 是否SSL安全连接。
	SslLink *bool `json:"ssl_link,omitempty"`

	// SSL证书内容,base64加密后的值,源库安全连接必选。
	SslCertKey *string `json:"ssl_cert_key,omitempty"`

	// SSL证书名字,源库安全连接必选。
	SslCertName *string `json:"ssl_cert_name,omitempty"`

	// SSL证书内容checksum值,证书经过sha256加密后的值,后端校验,源库安全连接必选。
	SslCertCheckSum *string `json:"ssl_cert_check_sum,omitempty"`

	// SSL证书密码,证书文件后缀为.p12,需要密码。
	SslCertPassword *string `json:"ssl_cert_password,omitempty"`

	// vpcid,数据库为RDS时必选。
	VpcId *string `json:"vpc_id,omitempty"`

	// subnetid,数据库为RDS必选。
	SubnetId *string `json:"subnet_id,omitempty"`

	// 源库:so,目标库:ta
	EndPointType TestEndPointEndPointType `json:"end_point_type"`

	// rds实例region,数据库为RDS时必填。
	Region *string `json:"region,omitempty"`

	// 用户所处region的projectId。
	ProjectId *string `json:"project_id,omitempty"`

	// 数据库用户名,DDS的账号认证数据库,Oracle的serviceName。
	DbName *string `json:"db_name,omitempty"`

	KafkaSecurityConfig *KafkaSecurity `json:"kafka_security_config,omitempty"`
}

测试连接信息体

func (TestEndPoint) String

func (o TestEndPoint) String() string

type TestEndPointDbType

type TestEndPointDbType struct {
	// contains filtered or unexported fields
}

func (TestEndPointDbType) MarshalJSON

func (c TestEndPointDbType) MarshalJSON() ([]byte, error)

func (*TestEndPointDbType) UnmarshalJSON

func (c *TestEndPointDbType) UnmarshalJSON(b []byte) error

func (TestEndPointDbType) Value added in v0.0.90

func (c TestEndPointDbType) Value() string

type TestEndPointDbTypeEnum

type TestEndPointDbTypeEnum struct {
	MYSQL       TestEndPointDbType
	MONGODB     TestEndPointDbType
	GAUSSDBV5   TestEndPointDbType
	POSTGRESQL  TestEndPointDbType
	KAFKA       TestEndPointDbType
	GAUSSDBV5HA TestEndPointDbType
}

func GetTestEndPointDbTypeEnum

func GetTestEndPointDbTypeEnum() TestEndPointDbTypeEnum

type TestEndPointEndPointType

type TestEndPointEndPointType struct {
	// contains filtered or unexported fields
}

func (TestEndPointEndPointType) MarshalJSON

func (c TestEndPointEndPointType) MarshalJSON() ([]byte, error)

func (*TestEndPointEndPointType) UnmarshalJSON

func (c *TestEndPointEndPointType) UnmarshalJSON(b []byte) error

func (TestEndPointEndPointType) Value added in v0.0.90

func (c TestEndPointEndPointType) Value() string

type TestEndPointEndPointTypeEnum

type TestEndPointEndPointTypeEnum struct {
	SO TestEndPointEndPointType
	TA TestEndPointEndPointType
}

func GetTestEndPointEndPointTypeEnum

func GetTestEndPointEndPointTypeEnum() TestEndPointEndPointTypeEnum

type TestEndPointNetType

type TestEndPointNetType struct {
	// contains filtered or unexported fields
}

func (TestEndPointNetType) MarshalJSON

func (c TestEndPointNetType) MarshalJSON() ([]byte, error)

func (*TestEndPointNetType) UnmarshalJSON

func (c *TestEndPointNetType) UnmarshalJSON(b []byte) error

func (TestEndPointNetType) Value added in v0.0.90

func (c TestEndPointNetType) Value() string

type TestEndPointNetTypeEnum

type TestEndPointNetTypeEnum struct {
	VPN TestEndPointNetType
	VPC TestEndPointNetType
	EIP TestEndPointNetType
}

func GetTestEndPointNetTypeEnum

func GetTestEndPointNetTypeEnum() TestEndPointNetTypeEnum

type TransformationInfo

type TransformationInfo struct {

	// - 生成加工规则值为contentConditionalFilter - 生成配置规则值为configConditionalFilter
	TransformationType TransformationInfoTransformationType `json:"transformation_type"`

	// 过滤条件,生成加工规则值为sql条件语句,生成配置规则值为config。长度限制256。
	Value string `json:"value"`
}

数据加工信息

func (TransformationInfo) String

func (o TransformationInfo) String() string

type TransformationInfoTransformationType

type TransformationInfoTransformationType struct {
	// contains filtered or unexported fields
}

func (TransformationInfoTransformationType) MarshalJSON

func (c TransformationInfoTransformationType) MarshalJSON() ([]byte, error)

func (*TransformationInfoTransformationType) UnmarshalJSON

func (c *TransformationInfoTransformationType) UnmarshalJSON(b []byte) error

func (TransformationInfoTransformationType) Value added in v0.0.90

type TransformationInfoTransformationTypeEnum

type TransformationInfoTransformationTypeEnum struct {
	CONTENT_CONDITIONAL_FILTER TransformationInfoTransformationType
	CONFIG_CONDITIONAL_FILTER  TransformationInfoTransformationType
}

func GetTransformationInfoTransformationTypeEnum

func GetTransformationInfoTransformationTypeEnum() TransformationInfoTransformationTypeEnum

type TuningParameter added in v0.0.94

type TuningParameter struct {

	// 参数名称
	ParamName *string `json:"param_name,omitempty"`

	// 参数取值
	ParamValue *string `json:"param_value,omitempty"`

	// 是否可用
	Availability *string `json:"availability,omitempty"`
}

调优参数

func (TuningParameter) String added in v0.0.94

func (o TuningParameter) String() string

type UpdateDatabaseObjectReq

type UpdateDatabaseObjectReq struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 是否进行对象选择,是:自定义迁移对象,否:全部迁移,不填默认为否。
	Selected *bool `json:"selected,omitempty"`

	// 是否库级同步
	SyncDatabase *bool `json:"sync_database,omitempty"`

	// 数据对象选择信息,selected为true时必填。
	Job *[]DatabaseInfo `json:"job,omitempty"`
}

更新对象选择信息体

func (UpdateDatabaseObjectReq) String

func (o UpdateDatabaseObjectReq) String() string

type UpdateParamsRequest

type UpdateParamsRequest struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 请求语言类型
	XLanguage *UpdateParamsRequestXLanguage `json:"X-Language,omitempty"`

	Body *ModifyTargetParamsReq `json:"body,omitempty"`
}

Request Object

func (UpdateParamsRequest) String

func (o UpdateParamsRequest) String() string

type UpdateParamsRequestXLanguage

type UpdateParamsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (UpdateParamsRequestXLanguage) MarshalJSON

func (c UpdateParamsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateParamsRequestXLanguage) UnmarshalJSON

func (c *UpdateParamsRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateParamsRequestXLanguage) Value added in v0.0.90

type UpdateParamsRequestXLanguageEnum

type UpdateParamsRequestXLanguageEnum struct {
	EN_US UpdateParamsRequestXLanguage
	ZH_CN UpdateParamsRequestXLanguage
}

func GetUpdateParamsRequestXLanguageEnum

func GetUpdateParamsRequestXLanguageEnum() UpdateParamsRequestXLanguageEnum

type UpdateParamsResponse

type UpdateParamsResponse struct {

	// 修改参数是否成功
	Success *bool `json:"success,omitempty"`

	// 是否需要重启
	ShouldRestart *UpdateParamsResponseShouldRestart `json:"should_restart,omitempty"`

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误信息
	ErrorMsg       *string `json:"error_msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateParamsResponse) String

func (o UpdateParamsResponse) String() string

type UpdateParamsResponseShouldRestart

type UpdateParamsResponseShouldRestart struct {
	// contains filtered or unexported fields
}

func (UpdateParamsResponseShouldRestart) MarshalJSON

func (c UpdateParamsResponseShouldRestart) MarshalJSON() ([]byte, error)

func (*UpdateParamsResponseShouldRestart) UnmarshalJSON

func (c *UpdateParamsResponseShouldRestart) UnmarshalJSON(b []byte) error

func (UpdateParamsResponseShouldRestart) Value added in v0.0.90

type UpdateParamsResponseShouldRestartEnum

type UpdateParamsResponseShouldRestartEnum struct {
	TRUE  UpdateParamsResponseShouldRestart
	FALSE UpdateParamsResponseShouldRestart
}

func GetUpdateParamsResponseShouldRestartEnum

func GetUpdateParamsResponseShouldRestartEnum() UpdateParamsResponseShouldRestartEnum

type UpdateTuningParamsRequest added in v0.0.94

type UpdateTuningParamsRequest struct {

	// 租户在某一Region下的Job ID,如果是主备任务,使用父任务ID。
	JobId string `json:"job_id"`

	// 请求语言类型
	XLanguage *UpdateTuningParamsRequestXLanguage `json:"X-Language,omitempty"`

	Body *ModifyTuningParamsReq `json:"body,omitempty"`
}

Request Object

func (UpdateTuningParamsRequest) String added in v0.0.94

func (o UpdateTuningParamsRequest) String() string

type UpdateTuningParamsRequestXLanguage added in v0.0.94

type UpdateTuningParamsRequestXLanguage struct {
	// contains filtered or unexported fields
}

func (UpdateTuningParamsRequestXLanguage) MarshalJSON added in v0.0.94

func (c UpdateTuningParamsRequestXLanguage) MarshalJSON() ([]byte, error)

func (*UpdateTuningParamsRequestXLanguage) UnmarshalJSON added in v0.0.94

func (c *UpdateTuningParamsRequestXLanguage) UnmarshalJSON(b []byte) error

func (UpdateTuningParamsRequestXLanguage) Value added in v0.0.94

type UpdateTuningParamsRequestXLanguageEnum added in v0.0.94

type UpdateTuningParamsRequestXLanguageEnum struct {
	EN_US UpdateTuningParamsRequestXLanguage
	ZH_CN UpdateTuningParamsRequestXLanguage
}

func GetUpdateTuningParamsRequestXLanguageEnum added in v0.0.94

func GetUpdateTuningParamsRequestXLanguageEnum() UpdateTuningParamsRequestXLanguageEnum

type UpdateTuningParamsResponse added in v0.0.94

type UpdateTuningParamsResponse struct {

	// 全量调优参数
	FullSync *[]TuningParameter `json:"full_sync,omitempty"`

	// 增量抓取调优参数
	IncreCapture *[]TuningParameter `json:"incre_capture,omitempty"`

	// 增量回放调优参数
	IncreApply *[]TuningParameter `json:"incre_apply,omitempty"`

	// 增量日志拉取调优参数
	IncreRelay *[]TuningParameter `json:"incre_relay,omitempty"`

	// 参数修改是否成功
	ModifyResult   *string `json:"modify_result,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateTuningParamsResponse) String added in v0.0.94

type UpdateUserReq

type UpdateUserReq struct {

	// 任务ID
	JobId string `json:"job_id"`

	// 全局密码。
	Password *string `json:"password,omitempty"`

	// 用户迁移信息,迁移用户时必填
	List *[]UserAccountVo `json:"list,omitempty"`

	// 角色迁移信息,迁移用户时必填
	UserRoles *[]UserRoleVo `json:"user_roles,omitempty"`

	// 是否设置密码
	IsSetPassword bool `json:"is_set_password"`

	// 是否迁移用户
	IsMigrateUser bool `json:"is_migrate_user"`

	// 是否同步权限,不填默认为false,PG同步使用。
	IsSyncObjectPrivilege *bool `json:"is_sync_object_privilege,omitempty"`
}

更新迁移用户请求体

func (UpdateUserReq) String

func (o UpdateUserReq) String() string

type UserAccountVo

type UserAccountVo struct {

	// 用户账户ID。
	Id string `json:"id"`

	// 用户
	Account string `json:"account"`

	// 说明
	Comment *string `json:"comment,omitempty"`

	// 是否支持迁移
	IsTransfer bool `json:"is_transfer"`

	// 权限列表
	Privileges *[]string `json:"privileges,omitempty"`

	// 密码
	Password *string `json:"password,omitempty"`

	// 是否重置密码。
	IsSetPassword *bool `json:"is_set_password,omitempty"`

	// 角色
	Roles []string `json:"roles"`

	// 是否选择。
	Selected bool `json:"selected"`
}

用户信息

func (UserAccountVo) String

func (o UserAccountVo) String() string

type UserRoleVo

type UserRoleVo struct {

	// 角色
	Role string `json:"role"`

	// 说明
	Comment *string `json:"comment,omitempty"`

	// 是否支持迁移。
	IsTransfer bool `json:"is_transfer"`

	// 权限
	Privileges string `json:"privileges"`

	// 继承角色列表
	InheritsRoles *[]string `json:"inherits_roles,omitempty"`

	// 是否选择。
	Selected *bool `json:"selected,omitempty"`
}

用户的角色信息

func (UserRoleVo) String

func (o UserRoleVo) String() string

Source Files

Jump to

Keyboard shortcuts

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