model

package
v0.0.89 Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 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 ActionProgress 

type ActionProgress struct {

	// 创建集群进度，例如：29%
	Creating *string `json:"CREATING,omitempty"`

	// 扩容集群进度，例如：29%
	Growing *string `json:"GROWING,omitempty"`

	// 恢复集群进度，例如：29%
	Restoring *string `json:"RESTORING,omitempty"`

	// 集群快照进度，例如：29%
	Snapshotting *string `json:"SNAPSHOTTING,omitempty"`

	// 修复集群进度，例如：29%
	Repairing *string `json:"REPAIRING,omitempty"`
}

集群操作进度，任务信息，由key、value组成。key值为正在进行的任务，value值为正在进行任务的进度。示例如 \"action_progress\":{\"SNAPSHOTTING\":\"16%\"}

func (ActionProgress) String 

func (o ActionProgress) String() string

type CdmCreateAndUpdateLinkReq 

type CdmCreateAndUpdateLinkReq struct {

	// 连接列表，请参见links数据结构说明
	Links []Links `json:"links"`
}

func (CdmCreateAndUpdateLinkReq) String 

func (o CdmCreateAndUpdateLinkReq) String() string

type CdmCreateClusterReq 

type CdmCreateClusterReq struct {
	Cluster *CdmCreateClusterReqCluster `json:"cluster"`

	// 选择是否开启消息通知。开启后，支持配置5个手机号码或邮箱，作业（目前仅支持表/文件迁移的作业）失败时、EIP异常时会发送短信或邮件通知用户
	AutoRemind *bool `json:"auto_remind,omitempty"`

	// 接收消息通知的手机号码
	PhoneNum *string `json:"phone_num,omitempty"`

	// 接收消息通知的邮箱
	Email *string `json:"email,omitempty"`
}

func (CdmCreateClusterReq) String 

func (o CdmCreateClusterReq) String() string

type CdmCreateClusterReqCluster 

type CdmCreateClusterReqCluster struct {

	// 定时开机的时间，CDM集群会在每天这个时间开机
	ScheduleBootTime *string `json:"scheduleBootTime,omitempty"`

	// 选择是否启用定时开关机功能。定时开关机功能和自动关机功能不可同时开启
	IsScheduleBootOff *bool `json:"isScheduleBootOff,omitempty"`

	// 节点列表，请参见instances参数说明
	Instances *[]Instance `json:"instances,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	// 定时关机的时间，定时关机时系统不会等待未完成的作业执行完成
	ScheduleOffTime *string `json:"scheduleOffTime,omitempty"`

	// 指定虚拟私有云ID，用于集群网络配置
	VpcId *string `json:"vpcId,omitempty"`

	// 集群名称
	Name *string `json:"name,omitempty"`

	// 企业项目信息，请参见•sys_tags参数说明
	SysTags *[]SysTags `json:"sys_tags,omitempty"`

	// 选择是否启用自动关机功能，自动关机功能和定时开关机功能不可同时开启。如果选择自动关机，则当集群中无作业运行且无定时作业时，等待15分钟后集群将自动关机来帮您节约成本
	IsAutoOff *bool `json:"isAutoOff,omitempty"`
}

集群对象，请参见cluster参数说明

func (CdmCreateClusterReqCluster) String 

func (o CdmCreateClusterReqCluster) String() string

type CdmCreateJobJsonReq 

type CdmCreateJobJsonReq struct {

	// 作业列表，请参见jobs数据结构说明。
	Jobs []Job `json:"jobs"`
}

func (CdmCreateJobJsonReq) String 

func (o CdmCreateJobJsonReq) String() string

type CdmDeleteClusterReq 

type CdmDeleteClusterReq struct {

	// 日志备份数，填写为默认填0即可。
	KeepLastManualBackup int32 `json:"keep_last_manual_backup"`
}

func (CdmDeleteClusterReq) String 

func (o CdmDeleteClusterReq) String() string

type CdmQueryClusterDetailsRepsonseMaintainWindow 

type CdmQueryClusterDetailsRepsonseMaintainWindow struct {

	// 周几
	Day *string `json:"day,omitempty"`

	// 开始时间。
	StartTime *string `json:"startTime,omitempty"`

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

维护窗口

func (CdmQueryClusterDetailsRepsonseMaintainWindow) String 

func (o CdmQueryClusterDetailsRepsonseMaintainWindow) String() string

type CdmQueryClusterDetailsRepsonsePublicEndpointStatus 

type CdmQueryClusterDetailsRepsonsePublicEndpointStatus struct {

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

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

EIP状态信息

func (CdmQueryClusterDetailsRepsonsePublicEndpointStatus) String 

func (o CdmQueryClusterDetailsRepsonsePublicEndpointStatus) String() string

type CdmRandomCreateAndStartJobJsonReq 

type CdmRandomCreateAndStartJobJsonReq struct {

	// 作业列表，请参见jobs数据结构说明。
	Jobs []Job `json:"jobs"`

	// CDM集群ID列表，系统会从里面随机选择一个开机状态的集群，在该集群中创建作业并执行作业。
	Clusters []string `json:"clusters"`
}

func (CdmRandomCreateAndStartJobJsonReq) String 

func (o CdmRandomCreateAndStartJobJsonReq) String() string

type CdmRestartClusterReq 

type CdmRestartClusterReq struct {
	Restart *CdmRestartClusterReqRestart `json:"restart"`
}

func (CdmRestartClusterReq) String 

func (o CdmRestartClusterReq) String() string

type CdmRestartClusterReqRestart 

type CdmRestartClusterReqRestart struct {

	// 重启时延，单位：秒
	RestartDelayTime *int32 `json:"restartDelayTime,omitempty"`

	// 重启类型： - IMMEDIATELY：立即重启。 - GRACEFULL：优雅重启。 - FORCELY：强制重启。 - SOFTLY：一般重启。  默认值为“IMMEDIATELY”。优雅重启等作业执行完后，有序的释放资源再重启，并且只重启CDM服务的进程，不会重启集群虚拟机。强制重启业务进程会中断，并重启集群的虚拟机。
	RestartMode *string `json:"restartMode,omitempty"`

	// 重启级别： - SERVICE：重启服务。 - VM：重启虚拟机。  默认值为“SERVICE”。
	RestartLevel *string `json:"restartLevel,omitempty"`

	// 集群节点类型，只支持“cdm”
	Type string `json:"type"`

	// 预留字段，“restartLevel” 为“SERVICE”时，“instance”必填，填空字串。
	Instance *string `json:"instance,omitempty"`

	// 预留字段，“restartLevel” 为“SERVICE”时，“group”必填，填空字串。
	Group *string `json:"group,omitempty"`
}

集群重启操作，定义哪些集群节点需要重启，请参见restart参数说明

func (CdmRestartClusterReqRestart) String 

func (o CdmRestartClusterReqRestart) String() string

type CdmStartClusterReq 

type CdmStartClusterReq struct {

	// 集群启动操作，定义集群启动标识，为空对象
	Start *interface{} `json:"start"`
}

func (CdmStartClusterReq) String 

func (o CdmStartClusterReq) String() string

type CdmStopClusterReq 

type CdmStopClusterReq struct {
	Stop *CdmStopClusterReqStop `json:"stop"`
}

func (CdmStopClusterReq) String 

func (o CdmStopClusterReq) String() string

type CdmStopClusterReqStop 

type CdmStopClusterReqStop struct {

	// 关机类型： - IMMEDIATELY：立即关机。 - GRACEFULLY：优雅关机。
	StopMode CdmStopClusterReqStopStopMode `json:"stopMode"`

	// 关机时延，仅在stopMode为“GRACEFULLY”生效，单位：秒。该值为-1时，表示等待所有作业完成，并停止接受新作业。该值为大于0的任意值表示等待该时长后关机，并停止接受新作业。
	DelayTime *int32 `json:"delayTime,omitempty"`
}

集群启动操作，定义集群启动标识，为空对象

func (CdmStopClusterReqStop) String 

func (o CdmStopClusterReqStop) String() string

type CdmStopClusterReqStopStopMode 

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

func (CdmStopClusterReqStopStopMode) MarshalJSON 

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

func (*CdmStopClusterReqStopStopMode) UnmarshalJSON 

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

type CdmStopClusterReqStopStopModeEnum 

type CdmStopClusterReqStopStopModeEnum struct {
	IMMEDIATELY CdmStopClusterReqStopStopMode
	GRACEFULLY  CdmStopClusterReqStopStopMode
}

func GetCdmStopClusterReqStopStopModeEnum 

func GetCdmStopClusterReqStopStopModeEnum() CdmStopClusterReqStopStopModeEnum

type CdmUpdateJobJsonReq 

type CdmUpdateJobJsonReq struct {

	// 作业列表，请参见jobs数据结构说明。
	Jobs []Job `json:"jobs"`
}

func (CdmUpdateJobJsonReq) String 

func (o CdmUpdateJobJsonReq) String() string

type ClusterDetailInstance 

type ClusterDetailInstance struct {
	Flavor *ClusterDetailInstanceFlavor `json:"flavor"`

	Volume *ClusterDetailInstanceVolume `json:"volume"`

	// 节点状态： - 100：创建中。 - 200：正常。 - 300：失败。 - 303：创建失败。 - 400：已删除。 - 800：冻结。
	Status string `json:"status"`

	// 节点操作状态列表： - REBOOTING：重启中。 - RESTORING：恢复中。 - REBOOT_FAILURE：重启失败。
	Actions *[]string `json:"actions,omitempty"`

	// 节点类型，只支持一种类型“cdm”。
	Type string `json:"type"`

	// 节点的虚拟机ID。
	Id string `json:"id"`

	// 节点的虚拟机名称。
	Name string `json:"name"`

	// 节点是否冻结：0：否。1：是。
	IsFrozen string `json:"isFrozen"`

	// 组件
	Components *string `json:"components,omitempty"`

	// 节点配置状态（查询集群列表时为null）： - In-Sync：配置已同步。 - Applying：配置中。 - Sync-Failure：配置失败。
	ConfigStatus *string `json:"config_status,omitempty"`

	// 实例角色
	Role *string `json:"role,omitempty"`

	// 分组
	Group *string `json:"group,omitempty"`

	// 链接信息（查询集群列表时返回值为null）
	Links *[]ClusterLinks `json:"links,omitempty"`

	// 组件分组id
	ParamsGroupId *string `json:"paramsGroupId,omitempty"`

	// 公网ip
	PublicIp *string `json:"publicIp,omitempty"`

	// 管理ip
	ManageIp *string `json:"manageIp,omitempty"`

	// 流量ip
	TrafficIp *string `json:"trafficIp,omitempty"`

	// 分片id
	ShardId *string `json:"shard_id,omitempty"`

	// 管理修复ip
	ManageFixIp *string `json:"manage_fix_ip,omitempty"`

	// 私有ip
	PrivateIp *string `json:"private_ip,omitempty"`

	// 内部ip
	InternalIp *string `json:"internal_ip,omitempty"`

	// 资源信息（查询集群列表时返回值为null）
	Resource *[]Resource `json:"resource,omitempty"`
}

func (ClusterDetailInstance) String 

func (o ClusterDetailInstance) String() string

type ClusterDetailInstanceFlavor 

type ClusterDetailInstanceFlavor struct {

	// 节点虚拟机的规格ID。
	Id *string `json:"id,omitempty"`

	// 链接信息
	Links *[]ClusterLinks `json:"links,omitempty"`
}

节点的虚拟机规格，请参见flavor参数说明（查询集群列表时返回值为null）。

func (ClusterDetailInstanceFlavor) String 

func (o ClusterDetailInstanceFlavor) String() string

type ClusterDetailInstanceVolume 

type ClusterDetailInstanceVolume struct {

	// 节点的磁盘类型，只支持本地磁盘
	Type *string `json:"type,omitempty"`

	// 节点磁盘大小，单位G。
	Size *int64 `json:"size,omitempty"`
}

节点的磁盘信息，请参见volume参数说明（查询集群列表时返回值为null）。

func (ClusterDetailInstanceVolume) String 

func (o ClusterDetailInstanceVolume) String() string

type ClusterInstance added in v0.0.78 

type ClusterInstance struct {

	// 节点的虚拟机ID。
	Id *string `json:"id,omitempty"`

	// 节点的虚拟机名称。
	Name *string `json:"name,omitempty"`

	// 节点类型，只支持一种类型“cdm”。
	Type *string `json:"type,omitempty"`

	// 分片ID
	ShardId *string `json:"shard_id,omitempty"`
}

集群的节点信息

func (ClusterInstance) String added in v0.0.78 

func (o ClusterInstance) String() string
type ClusterLinks struct {

	// 关系
	Rel *string `json:"rel,omitempty"`

	// 链接地址
	Href *string `json:"href,omitempty"`
}

集群连接信息

func (ClusterLinks) String 

func (o ClusterLinks) String() string

type ClusterTask 

type ClusterTask struct {

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

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

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

任务信息

func (ClusterTask) String 

func (o ClusterTask) String() string

type Clusters 

type Clusters struct {
	CustomerConfig *CustomerConfig `json:"customerConfig,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	// 集群的节点信息，请参见instances参数说明
	Instances *[]ClusterDetailInstance `json:"instances,omitempty"`

	// az名称
	AzName *string `json:"azName,omitempty"`

	// 数据库用户
	Dbuser *string `json:"dbuser,omitempty"`

	// 规格名称
	FlavorName *string `json:"flavorName,omitempty"`

	// 事件数
	RecentEvent *int32 `json:"recentEvent,omitempty"`

	// 自动关机
	IsAutoOff *bool `json:"isAutoOff,omitempty"`

	// 选择是否启用定时开关机功能。定时开关机功能和自动关机功能不可同时开启
	IsScheduleBootOff *bool `json:"isScheduleBootOff,omitempty"`

	// 集群模式：sharding(分片集群)
	ClusterMode *string `json:"clusterMode,omitempty"`

	// 命名空间
	Namespace *string `json:"namespace,omitempty"`

	Task *ClusterTask `json:"task,omitempty"`

	// 集群绑定的EIP
	PublicEndpoint *string `json:"publicEndpoint,omitempty"`

	ActionProgress *ActionProgress `json:"actionProgress,omitempty"`

	// 集群创建时间，格式为ISO8601：YYYY-MM-DDThh:mm:ssZ
	Created string `json:"created"`

	// 开始时间
	BakExpectedStartTime *string `json:"bakExpectedStartTime,omitempty"`

	// 保留时间
	BakKeepDay *int32 `json:"bakKeepDay,omitempty"`

	// 集群名称
	Name string `json:"name"`

	// 集群状态描述：Normal（正常）
	StatusDetail *string `json:"statusDetail,omitempty"`

	// 集群ID
	Id string `json:"id"`

	// 集群是否冻结：0：否 1：是
	IsFrozen string `json:"isFrozen"`

	// 集群更新时间，格式为ISO8601：YYYY-MM-DDThh:mm:ssZ
	Updated string `json:"updated"`

	// 集群状态： - 100：创建中 - 200：正常 - 300：失败 - 303：创建失败 - 500：重启中 - 800：冻结 - 900：已关机 - 910：正在关机 - 920：正在开机
	Status string `json:"status"`

	FailedReasons *FailedReasons `json:"failedReasons,omitempty"`
}

func (Clusters) String 

func (o Clusters) String() string

type ConfigValues 

type ConfigValues struct {

	// 源连接参数、目的连接参数和作业任务参数，它们的配置数据结构相同，其中“inputs”里的参数不一样，详细请参见configs数据结构说明
	Configs *[]Configs `json:"configs,omitempty"`
}

func (ConfigValues) String 

func (o ConfigValues) String() string

type Configs 

type Configs struct {

	// 输入参数列表，列表中的每个参数为“name,value”结构，请参考inputs数据结构参数说明。在“from-config-values”数据结构中，不同的源连接类型有不同的“inputs”参数列表，请参见源端作业参数说明下的章节。在“to-cofig-values”数据结构中，不同的目的连接类型有不同的“inputs”参数列表，请参见目的端作业参数说明下面的子章节。在“driver-config-values”数据结构中，“inputs”具体参数请参见作业任务参数说明。
	Inputs []Input `json:"inputs"`

	// 配置名称：源端作业的配置名称为“fromJobConfig”。目的端作业的配置名称为“toJobConfig”,连接的配置名称固定为“linkConfig”。
	Name string `json:"name"`

	// 配置ID
	Id int32 `json:"id"`

	// 配置类型
	Type string `json:"type"`
}

func (Configs) String 

func (o Configs) String() string

type Counter 

type Counter struct {

	// 写入的字节数
	BytesWritten *int64 `json:"BYTES_WRITTEN,omitempty"`

	// 总文件数
	TotalFiles *int32 `json:"TOTAL_FILES,omitempty"`

	// 读取的行数
	RowsRead *int64 `json:"ROWS_READ,omitempty"`

	// 读取的字节数
	BytesRead *int64 `json:"BYTES_READ,omitempty"`

	// 写入的行数
	RowsWritten *int64 `json:"ROWS_WRITTEN,omitempty"`

	// 写入的文件数
	FilesWritten *int32 `json:"FILES_WRITTEN,omitempty"`

	// 读取的文件数
	FilesRead *int32 `json:"FILES_READ,omitempty"`

	// 总字节数
	TotalSize *int64 `json:"TOTAL_SIZE,omitempty"`

	// 跳过的文件数
	FilesSkipped *int32 `json:"FILES_SKIPPED,omitempty"`

	// 跳过的行数
	RowsWrittenSkipped *int64 `json:"ROWS_WRITTEN_SKIPPED,omitempty"`
}

func (Counter) String 

func (o Counter) String() string

type Counters 

type Counters struct {
	OrgApacheSqoopSubmissionCounterSqoopCounters *Counter `json:"org.apache.sqoop.submission.counter.SqoopCounters"`
}

func (Counters) String 

func (o Counters) String() string

type CreateAndStartRandomClusterJobRequest 

type CreateAndStartRandomClusterJobRequest struct {

	// 请求语言。
	XLanguage string `json:"X-Language"`

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

Request Object

func (CreateAndStartRandomClusterJobRequest) String 

func (o CreateAndStartRandomClusterJobRequest) String() string

type CreateAndStartRandomClusterJobResponse 

type CreateAndStartRandomClusterJobResponse struct {

	// 作业运行信息，请参见submission参数说明
	Submissions    *[]StartJobSubmission `json:"submissions,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (CreateAndStartRandomClusterJobResponse) String 

func (o CreateAndStartRandomClusterJobResponse) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {

	// 请求语言。
	XLanguage string `json:"X-Language"`

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

Request Object

func (CreateClusterRequest) String 

func (o CreateClusterRequest) String() string

type CreateClusterResponse 

type CreateClusterResponse struct {

	// 集群名称
	Name *string `json:"name,omitempty"`

	// 集群ID
	Id *string `json:"id,omitempty"`

	Task *Task `json:"task,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	// 集群的节点信息
	Instances      *[]ClusterInstance `json:"instances,omitempty"`
	HttpStatusCode int                `json:"-"`
}

Response Object

func (CreateClusterResponse) String 

func (o CreateClusterResponse) String() string

type CreateJobRequest 

type CreateJobRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

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

Request Object

func (CreateJobRequest) String 

func (o CreateJobRequest) String() string

type CreateJobResponse 

type CreateJobResponse struct {

	// 作业名称。
	Name *string `json:"name,omitempty"`

	// 校验结果： - 如果修改失败，返回失败原因。 - 如果修改成功，返回空列表。
	ValidationResult *[]JobValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                    `json:"-"`
}

Response Object

func (CreateJobResponse) String 

func (o CreateJobResponse) String() string

type CreateLinkRequest 

type CreateLinkRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 为“true”时，此API仅校验参数是否正确，不创建连接
	Validate *string `json:"validate,omitempty"`

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

Request Object

func (CreateLinkRequest) String 

func (o CreateLinkRequest) String() string

type CreateLinkResponse 

type CreateLinkResponse struct {

	// 连接名称
	Name *string `json:"name,omitempty"`

	// 校验结构：如果创建连接失败，返回失败原因，请参见validation-result参数说明。如果创建成功，返回空列表。
	ValidationResult *[]ValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                 `json:"-"`
}

Response Object

func (CreateLinkResponse) String 

func (o CreateLinkResponse) String() string

type CustomerConfig 

type CustomerConfig struct {

	// 失败提醒。
	FailureRemind *string `json:"failureRemind,omitempty"`

	// 集群类型。
	ClusterName *string `json:"clusterName,omitempty"`

	// 服务提供
	ServiceProvider *string `json:"serviceProvider,omitempty"`

	// 是否本地磁盘。
	LocalDisk *string `json:"localDisk,omitempty"`

	// 是否使用ssl。
	Ssl *string `json:"ssl,omitempty"`

	// 创建来源
	CreateFrom *string `json:"createFrom,omitempty"`

	// 资源ID
	ResourceId *string `json:"resourceId,omitempty"`

	// 规格类型
	FlavorType *string `json:"flavorType,omitempty"`

	// 工作空间ID
	WorkSpaceId *string `json:"workSpaceId,omitempty"`

	// 适用
	Trial *string `json:"trial,omitempty"`
}

用户配置信息

func (CustomerConfig) String 

func (o CustomerConfig) String() string

type Datastore 

type Datastore struct {

	// 类型，一般为cdm。
	Type *string `json:"type,omitempty"`

	// 集群版本。
	Version *string `json:"version,omitempty"`
}

cdm信息

func (Datastore) String 

func (o Datastore) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

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

Request Object

func (DeleteClusterRequest) String 

func (o DeleteClusterRequest) String() string

type DeleteClusterResponse 

type DeleteClusterResponse struct {

	// 作业ID
	JobId          *string `json:"jobId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteClusterResponse) String 

func (o DeleteClusterResponse) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称
	JobName string `json:"job_name"`
}

Request Object

func (DeleteJobRequest) String 

func (o DeleteJobRequest) String() string

type DeleteJobResponse 

type DeleteJobResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteJobResponse) String 

func (o DeleteJobResponse) String() string

type DeleteLinkRequest 

type DeleteLinkRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 需要删除的连接名
	LinkName string `json:"link_name"`
}

Request Object

func (DeleteLinkRequest) String 

func (o DeleteLinkRequest) String() string

type DeleteLinkResponse 

type DeleteLinkResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteLinkResponse) String 

func (o DeleteLinkResponse) String() string

type FailedReasons 

type FailedReasons struct {
	CreateFailed *FailedReasonsCreateFailed `json:"CREATE_FAILED,omitempty"`
}

失败原因。集群处于正常状态时不返回。

func (FailedReasons) String 

func (o FailedReasons) String() string

type FailedReasonsCreateFailed 

type FailedReasonsCreateFailed struct {

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

	// 失败原因
	ErrorMsg *string `json:"errorMsg,omitempty"`
}

集群创建失败原因。

func (FailedReasonsCreateFailed) String 

func (o FailedReasonsCreateFailed) String() string

type Input added in v0.0.61 

type Input struct {

	// 参数名
	Name string `json:"name"`

	// 参数值
	Values string `json:"values"`

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

func (Input) String added in v0.0.61 

func (o Input) String() string

type Instance 

type Instance struct {

	// 集群的可用分区
	AvailabilityZone string `json:"availability_zone"`

	// 网卡列表，最多两个网卡。请参见•nics参数说明
	Nics []Nics `json:"nics"`

	// 实例规格： - a79fd5ae-1833-448a-88e8-3ea2b913e1f6：表示cdm.small规格，2核CPU、4G内存的虚拟机。适合PoC验证和开发测试。 - fb8fe666-6734-4b11-bc6c-43d11db3c745：表示cdm.medium规格，4核CPU、8G内存的虚拟机适合单张表规模<1000万条的场景。 - 5ddb1071-c5d7-40e0-a874-8a032e81a697：表示cdm.large规格，8核CPU、16G内存的虚拟机。适合单张表规模≥1000万条的场景。 - 6ddb1072-c5d7-40e0-a874-8a032e81a698：表示cdm.xlarge规格，16核CPU、32G内存的虚拟机。需要10GE高速带宽进行TB以上的数据量迁移时使用
	FlavorRef string `json:"flavorRef"`

	// 节点类型，当前只有“cdm”一种类型
	Type string `json:"type"`
}

func (Instance) String 

func (o Instance) String() string

type Job 

type Job struct {

	// 作业类型： - NORMAL_JOB：表/文件迁移。 - BATCH_JOB：整库迁移。 - SCENARIO_JOB：场景迁移。
	JobType *JobJobType `json:"job_type,omitempty"`

	// 源端连接类型
	FromConnectorName string `json:"from-connector-name"`

	ToConfigValues *ConfigValues `json:"to-config-values"`

	// 目的端连接名称
	ToLinkName string `json:"to-link-name"`

	DriverConfigValues *ConfigValues `json:"driver-config-values"`

	FromConfigValues *ConfigValues `json:"from-config-values"`

	// 目的端连接类型
	ToConnectorName *string `json:"to-connector-name,omitempty"`

	// 作业名称，长度在1到240个字符之间
	Name *string `json:"name,omitempty"`

	// 源连接名称
	FromLinkName *string `json:"from-link-name,omitempty"`

	// 创建的用户。
	CreationUser *string `json:"creation-user,omitempty"`

	// 作业创建的时间，单位：毫秒。
	CreationDate *int64 `json:"creation-date,omitempty"`

	// 作业最后更新的时间，单位：毫秒。
	UpdateDate *int64 `json:"update-date,omitempty"`

	// 是否增量
	IsIncreJob *bool `json:"is_incre_job,omitempty"`

	// 标记
	Flag *int32 `json:"flag,omitempty"`

	// 已读文件数
	FilesRead *int32 `json:"files_read,omitempty"`

	// 作业最后更新的用户。
	UpdateUser *string `json:"update-user,omitempty"`

	// 外部ID。
	ExternalId *string `json:"external_id,omitempty"`

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

	// 执行_开始_日期。
	ExecuteStartDate *int64 `json:"execute_start_date,omitempty"`

	// 删除行数
	DeleteRows *int32 `json:"delete_rows,omitempty"`

	// 是否激活连接
	Enabled *bool `json:"enabled,omitempty"`

	// 写入字节
	BytesWritten *int64 `json:"bytes_written,omitempty"`

	// 作业ID
	Id *int32 `json:"id,omitempty"`

	// 用户是否使用sql
	IsUseSql *bool `json:"is_use_sql,omitempty"`

	// 更新行数
	UpdateRows *int32 `json:"update_rows,omitempty"`

	// 组_名称
	GroupName *string `json:"group_name,omitempty"`

	// 读取字节
	BytesRead *int64 `json:"bytes_read,omitempty"`

	// 执行_更新_日期。
	ExecuteUpdateDate *int64 `json:"execute_update_date,omitempty"`

	// 写入行数
	WriteRows *int32 `json:"write_rows,omitempty"`

	// 写入文件数
	FilesWritte *int32 `json:"files_writte,omitempty"`

	// 是否增量
	IsIncrementing *bool `json:"is_incrementing,omitempty"`

	// 执行_创建_日期
	ExecuteCreateDate *int64 `json:"execute_create_date,omitempty"`

	// 作业最后的执行状态： - BOOTING：启动中。 - RUNNING：运行中。 - SUCCEEDED：成功。 - FAILED：失败。 - NEW：未被执行。
	Status *string `json:"status,omitempty"`
}

func (Job) String 

func (o Job) String() string

type JobJobType 

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

func (JobJobType) MarshalJSON 

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

func (*JobJobType) UnmarshalJSON 

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

type JobJobTypeEnum 

type JobJobTypeEnum struct {
	NORMAL_JOB   JobJobType
	BATCH_JOB    JobJobType
	SCENARIO_JOB JobJobType
}

func GetJobJobTypeEnum 

func GetJobJobTypeEnum() JobJobTypeEnum

type JobValidationResult 

type JobValidationResult struct {

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

	// ERROR,WARNING
	Status *JobValidationResultStatus `json:"status,omitempty"`
}

失败原因

func (JobValidationResult) String 

func (o JobValidationResult) String() string

type JobValidationResultStatus 

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

func (JobValidationResultStatus) MarshalJSON 

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

func (*JobValidationResultStatus) UnmarshalJSON 

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

type JobValidationResultStatusEnum 

type JobValidationResultStatusEnum struct {
	ERROR   JobValidationResultStatus
	WARNING JobValidationResultStatus
}

func GetJobValidationResultStatusEnum 

func GetJobValidationResultStatusEnum() JobValidationResultStatusEnum
type Links struct {
	LinkConfigValues *LinksLinkconfigvalues `json:"link-config-values"`

	// 创建连接的用户
	CreationUser *string `json:"creation-user,omitempty"`

	// 连接名称
	Name string `json:"name"`

	// 连接ID
	Id *int32 `json:"id,omitempty"`

	// 创建连接的时间
	CreationDate *int64 `json:"creation-date,omitempty"`

	// 连接器名称，对应的连接参数如下：generic-jdbc-connector：关系数据库连接。obs-connector：OBS连接、阿里云OSS连接。hdfs-connector：HDFS连接。hbase-connector：HBase连接、CloudTable连接。hive-connector：Hive连接。ftp-connector/sftp-connector：FTP/SFTP连接。mongodb-connector：MongoDB连接。redis-connector：Redis/DCS连接。nas-connector：NAS/SFS连接。kafka-connector：Kafka连接。dis-connector：DIS连接。elasticsearch-connector：Elasticsearch/云搜索服务连接。dli-connector：DLI连接。opentsdb-connector：CloudTable OpenTSDB连接。http-connector：HTTP/HTTPS连接，该连接暂无连接参数。thirdparty-obs-connector：七牛云KODO/腾讯云COS连接、亚马逊对象存储连接。dms-kafka-connector：DMS Kafka连接
	ConnectorName string `json:"connector-name"`

	// 更新连接的时间
	UpdateDate *int64 `json:"update-date,omitempty"`

	// 是否激活连接，默认为“true”
	Enabled *bool `json:"enabled,omitempty"`

	// 更新连接的用户
	UpdateUser *string `json:"update-user,omitempty"`
}

func (Links) String 

func (o Links) String() string

type LinksLinkconfigvalues 

type LinksLinkconfigvalues struct {

	// 连接配置参数数据结构，请参见configs参数说明。
	Configs []Configs `json:"configs"`

	ExtendedConfigs *LinksLinkconfigvaluesExtendedconfigs `json:"extended-configs,omitempty"`

	// 校验器
	Validators *[]string `json:"validators,omitempty"`
}

连接参数配置，请参见link-config-values参数说明

func (LinksLinkconfigvalues) String 

func (o LinksLinkconfigvalues) String() string

type LinksLinkconfigvaluesExtendedconfigs added in v0.0.73 

type LinksLinkconfigvaluesExtendedconfigs struct {

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

	// 值
	Value *string `json:"value,omitempty"`
}

扩展配置，请参见extended-configs参数说明。

func (LinksLinkconfigvaluesExtendedconfigs) String added in v0.0.73 

func (o LinksLinkconfigvaluesExtendedconfigs) String() string

type ListClustersRequest 

type ListClustersRequest struct {
}

Request Object

func (ListClustersRequest) String 

func (o ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// 集群列表，请参见clusters参数说明
	Clusters       *[]Clusters `json:"clusters,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ListClustersResponse) String 

func (o ListClustersResponse) String() string

type Nics 

type Nics struct {

	// 安全组ID
	SecurityGroupId string `json:"securityGroupId"`

	// 子网ID
	NetId string `json:"net-id"`
}

func (Nics) String 

func (o Nics) String() string

type Resource 

type Resource struct {

	// 资源id
	ResourceId *string `json:"resource_id,omitempty"`

	// 资源类型：server(服务器)
	ResourceType *string `json:"resource_type,omitempty"`
}

func (Resource) String 

func (o Resource) String() string

type RestartClusterRequest 

type RestartClusterRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

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

Request Object

func (RestartClusterRequest) String 

func (o RestartClusterRequest) String() string

type RestartClusterResponse 

type RestartClusterResponse struct {

	// 作业ID
	JobId          *string `json:"jobId,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (RestartClusterResponse) String 

func (o RestartClusterResponse) String() string

type ShowClusterDetailRequest 

type ShowClusterDetailRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`
}

Request Object

func (ShowClusterDetailRequest) String 

func (o ShowClusterDetailRequest) String() string

type ShowClusterDetailResponse 

type ShowClusterDetailResponse struct {

	// 集群绑定的EIP
	PublicEndpoint *string `json:"publicEndpoint,omitempty"`

	// 集群的节点信息，请参见instances参数说明
	Instances *[]ClusterDetailInstance `json:"instances,omitempty"`

	// 安全组id
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 子网id
	SubnetId *string `json:"subnet_id,omitempty"`

	// 虚拟私有云ID
	VpcId *string `json:"vpc_id,omitempty"`

	CustomerConfig *CustomerConfig `json:"customerConfig,omitempty"`

	Datastore *Datastore `json:"datastore,omitempty"`

	// 自动关机
	IsAutoOff *bool `json:"isAutoOff,omitempty"`

	// 集群绑定的EIP域名
	PublicEndpointDomainName *string `json:"publicEndpointDomainName,omitempty"`

	// 开始时间
	BakExpectedStartTime *string `json:"bakExpectedStartTime,omitempty"`

	// 保留时间
	BakKeepDay *int32 `json:"bakKeepDay,omitempty"`

	MaintainWindow *CdmQueryClusterDetailsRepsonseMaintainWindow `json:"maintainWindow,omitempty"`

	// 事件数
	RecentEvent *int32 `json:"recentEvent,omitempty"`

	// 规格名称
	FlavorName *string `json:"flavorName,omitempty"`

	// az名称
	AzName *string `json:"azName,omitempty"`

	// 对端域名
	EndpointDomainName *string `json:"endpointDomainName,omitempty"`

	PublicEndpointStatus *CdmQueryClusterDetailsRepsonsePublicEndpointStatus `json:"publicEndpointStatus,omitempty"`

	// 选择是否启用定时开关机功能。定时开关机功能和自动关机功能不可同时开启
	IsScheduleBootOff *bool `json:"isScheduleBootOff,omitempty"`

	// 命名空间
	Namespace *string `json:"namespace,omitempty"`

	// 弹性ip id
	EipId *string `json:"eipId,omitempty"`

	FailedReasons *FailedReasons `json:"failedReasons,omitempty"`

	// 数据库用户
	Dbuser *string `json:"dbuser,omitempty"`

	Links *[]ClusterLinks `json:"links,omitempty"`

	// 集群模式：sharding(分片集群)
	ClusterMode *string `json:"clusterMode,omitempty"`

	Task *ClusterTask `json:"task,omitempty"`

	// 集群创建时间，格式为ISO8601：YYYY-MM-DDThh:mm:ssZ
	Created *string `json:"created,omitempty"`

	// 集群状态描述：Normal（正常）
	StatusDetail *string `json:"statusDetail,omitempty"`

	// 集群配置状态： - In-Sync：配置已同步。 - Applying：配置中。 - Sync-Failure：配置失败
	ConfigStatus *string `json:"config_status,omitempty"`

	ActionProgress *ActionProgress `json:"actionProgress,omitempty"`

	// 集群名称
	Name *string `json:"name,omitempty"`

	// 集群ID
	Id *string `json:"id,omitempty"`

	// 集群是否冻结：0：否1：是
	IsFrozen *string `json:"isFrozen,omitempty"`

	// 集群配置状态：In-Sync：配置已同步。Applying：配置中。Sync-Failure：配置失败
	Actions *[]string `json:"actions,omitempty"`

	// 集群更新时间，格式为 ISO8601：YYYY-MM-DDThh:mm:ssZ
	Updated *string `json:"updated,omitempty"`

	// 集群状态： - 100：创建中 - 200：正常 - 300：失败 - 303：创建失败 - 800：冻结 - 900：已关机 - 910：正在关机 - 920：正在开机
	Status         *string `json:"status,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowClusterDetailResponse) String 

func (o ShowClusterDetailResponse) String() string

type ShowJobStatusRequest 

type ShowJobStatusRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称
	JobName string `json:"job_name"`
}

Request Object

func (ShowJobStatusRequest) String 

func (o ShowJobStatusRequest) String() string

type ShowJobStatusResponse 

type ShowJobStatusResponse struct {

	// 作业运行信息，详见submissions参数说明。
	Submissions    *[]Submission `json:"submissions,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ShowJobStatusResponse) String 

func (o ShowJobStatusResponse) String() string

type ShowJobsRequest 

type ShowJobsRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 查询多个作业用all,查询单个作业输入作业名
	JobName string `json:"job_name"`

	// 当“job_name”为“all”时，此参数用于模糊过滤作业
	Filter *string `json:"filter,omitempty"`

	// 指定作业页号
	PageNo *int32 `json:"page_no,omitempty"`

	// 每页作业数，值在10-100之间
	PageSize *int32 `json:"page_size,omitempty"`

	// 作业类型: - jobType=NORMAL_JOB：表示查询表/文件迁移的作业。 - jobType=BATCH_JOB：表示查询整库迁移的作业。 - jobType=SCENARIO_JOB：表示查询场景迁移的作业。 - 不指定该参数时，默认只查询表/文件迁移的作业。
	JobType *ShowJobsRequestJobType `json:"jobType,omitempty"`
}

Request Object

func (ShowJobsRequest) String 

func (o ShowJobsRequest) String() string

type ShowJobsRequestJobType 

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

func (ShowJobsRequestJobType) MarshalJSON 

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

func (*ShowJobsRequestJobType) UnmarshalJSON 

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

type ShowJobsRequestJobTypeEnum 

type ShowJobsRequestJobTypeEnum struct {
	NORMAL_JOB   ShowJobsRequestJobType
	BATCH_JOB    ShowJobsRequestJobType
	SCENARIO_JOB ShowJobsRequestJobType
}

func GetShowJobsRequestJobTypeEnum 

func GetShowJobsRequestJobTypeEnum() ShowJobsRequestJobTypeEnum

type ShowJobsResponse 

type ShowJobsResponse struct {

	// 作业数,查询单个作业时为0
	Total *int32 `json:"total,omitempty"`

	// 作业列表，请参见jobs参数说明
	Jobs *[]Job `json:"jobs,omitempty"`

	// 返回指定页号的作业
	PageNo *int32 `json:"page_no,omitempty"`

	// 每页作业数
	PageSize       *int32 `json:"page_size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowJobsResponse) String 

func (o ShowJobsResponse) String() string

type ShowLinkRequest 

type ShowLinkRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 连接名称
	LinkName string `json:"link_name"`
}

Request Object

func (ShowLinkRequest) String 

func (o ShowLinkRequest) String() string

type ShowLinkResponse 

type ShowLinkResponse struct {

	// 连接列表，请参见links数据结构说明
	Links *[]Links `json:"links,omitempty"`

	// 表/文件迁移不支持哪些数据源迁移到哪些数据源
	FromToUnMapping *string `json:"fromTo-unMapping,omitempty"`

	// 整库迁移支持哪些数据源迁移到哪些数据源
	BatchFromToMapping *string `json:"batchFromTo-mapping,omitempty"`
	HttpStatusCode     int     `json:"-"`
}

Response Object

func (ShowLinkResponse) String 

func (o ShowLinkResponse) String() string

type ShowSubmissionsRequest 

type ShowSubmissionsRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称
	Jname string `json:"jname"`
}

Request Object

func (ShowSubmissionsRequest) String 

func (o ShowSubmissionsRequest) String() string

type ShowSubmissionsResponse 

type ShowSubmissionsResponse struct {

	// 作业运行信息，详见submissions参数说明。
	Submissions *[]Submission `json:"submissions,omitempty"`

	// 查询该作业总的历史记录数。
	Total *int32 `json:"total,omitempty"`

	// 查询作业记录时，分页数。
	PageNo *int32 `json:"page_no,omitempty"`

	// 分页查询，每页返回的记录数。默认值：10。
	PageSize       *int32 `json:"page_size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowSubmissionsResponse) String 

func (o ShowSubmissionsResponse) String() string

type StartClusterRequest 

type StartClusterRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

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

Request Object

func (StartClusterRequest) String 

func (o StartClusterRequest) String() string

type StartClusterResponse 

type StartClusterResponse struct {

	// 作业ID
	JobId          *[]string `json:"jobId,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (StartClusterResponse) String 

func (o StartClusterResponse) String() string

type StartJobRequest 

type StartJobRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称
	JobName string `json:"job_name"`
}

Request Object

func (StartJobRequest) String 

func (o StartJobRequest) String() string

type StartJobResponse 

type StartJobResponse struct {

	// 作业运行信息，请参见submission参数说明
	Submissions    *[]StartJobSubmission `json:"submissions,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (StartJobResponse) String 

func (o StartJobResponse) String() string

type StartJobSubmission 

type StartJobSubmission struct {

	// 作业是否为增量迁移
	IsIncrementing *bool `json:"isIncrementing,omitempty"`

	// 删除数据行数
	DeleteRows *int32 `json:"delete_rows,omitempty"`

	// 更新数据行数
	UpdateRows *int32 `json:"update_rows,omitempty"`

	// 写入数据行数
	WriteRows *int32 `json:"write_rows,omitempty"`

	// 作业提交id
	SubmissionId *int32 `json:"submission-id,omitempty"`

	// 作业名称
	JobName string `json:"job-name"`

	// 创建用户
	CreationUser string `json:"creation-user"`

	// 创建时间，单位：毫秒。
	CreationDate int64 `json:"creation-date"`

	// 执行时间
	ExecuteDate *int64 `json:"execute-date,omitempty"`

	// 作业进度，失败时为“-1”，其它情况为0～100
	Progress float32 `json:"progress"`

	// 作业状态： - BOOTING：启动中。 - FAILURE_ON_SUBMIT：提交失败。 - RUNNING：运行中。 - SUCCEEDED：成功。 - FAILED：失败。 - UNKNOWN：未知。 - NEVER_EXECUTED：未被执行
	Status string `json:"status"`

	// 是否停止增量迁移
	IsStopingIncrement *string `json:"isStopingIncrement,omitempty"`

	// 是否定时执行作业
	IsExecuteAuto *bool `json:"is-execute-auto,omitempty"`

	// 作业最后更新时间
	LastUpdateDate *int64 `json:"last-update-date,omitempty"`

	// 最后更新作业状态的用户
	LastUdpateUser *string `json:"last-udpate-user,omitempty"`

	// 作业执行完成后是否删除
	IsDeleteJob *bool `json:"isDeleteJob,omitempty"`
}

func (StartJobSubmission) String 

func (o StartJobSubmission) String() string

type StopClusterRequest 

type StopClusterRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

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

Request Object

func (StopClusterRequest) String 

func (o StopClusterRequest) String() string

type StopClusterResponse 

type StopClusterResponse struct {

	// 作业ID
	JobId          *[]string `json:"jobId,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (StopClusterResponse) String 

func (o StopClusterResponse) String() string

type StopJobRequest 

type StopJobRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称
	JobName string `json:"job_name"`
}

Request Object

func (StopJobRequest) String 

func (o StopJobRequest) String() string

type StopJobResponse 

type StopJobResponse struct {

	// 作业运行信息，请参见submission参数说明
	Submissions    *[]StartJobSubmission `json:"submissions,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (StopJobResponse) String 

func (o StopJobResponse) String() string

type Submission 

type Submission struct {

	// 作业是否为增量迁移
	IsIncrementing bool `json:"isIncrementing"`

	// 作业名称
	JobName string `json:"job-name"`

	Counters *Counters `json:"counters,omitempty"`

	// 是否停止增量迁移
	IsStopingIncrement string `json:"isStopingIncrement"`

	// 是否定时执行作业
	IsExecuteAuto bool `json:"is-execute-auto"`

	// 作业最后更新时间
	LastUpdateDate int64 `json:"last-update-date"`

	// 最后更新作业状态的用户
	LastUdpateUser string `json:"last-udpate-user"`

	// 作业执行完成后是否删除
	IsDeleteJob bool `json:"isDeleteJob"`

	// 创建用户
	CreationUser string `json:"creation-user"`

	// 创建时间
	CreationDate int64 `json:"creation-date"`

	// 作业ID
	ExternalId string `json:"external-id"`

	// 作业进度，失败时为“-1”，其它情况为0～100
	Progress float32 `json:"progress"`

	// 作业提交id
	SubmissionId *int32 `json:"submission-id,omitempty"`

	// 删除数据行数
	DeleteRows *int32 `json:"delete_rows,omitempty"`

	// 更新数据行数
	UpdateRows *int32 `json:"update_rows,omitempty"`

	// 写入数据行数
	WriteRows *int32 `json:"write_rows,omitempty"`

	// 执行时间
	ExecuteDate *int64 `json:"execute-date,omitempty"`

	// 作业状态： - BOOTING：启动中。 - FAILURE_ON_SUBMIT：提交失败。 - RUNNING：运行中。 - SUCCEEDED：成功。 - FAILED：失败。 - UNKNOWN：未知。 - NEVER_EXECUTED：未被执行
	Status string `json:"status"`

	// 错误详情，当“status”为“FAILED”时才有此字段。
	ErrorDetails *string `json:"error-details,omitempty"`

	// 错误总结，当“status”为“FAILED”时才有此字段。
	ErrorSummary *string `json:"error-summary,omitempty"`
}

func (Submission) String 

func (o Submission) String() string

type SysTags 

type SysTags struct {

	// 企业项目ID
	Value string `json:"value"`

	// 该值目前固定为“_sys_enterprise_project_id”
	Key string `json:"key"`
}

func (SysTags) String 

func (o SysTags) String() string

type Task added in v0.0.78 

type Task struct {

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

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

任务信息

func (Task) String added in v0.0.78 

func (o Task) String() string

type UpdateJobRequest 

type UpdateJobRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 作业名称。
	JobName string `json:"job_name"`

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

Request Object

func (UpdateJobRequest) String 

func (o UpdateJobRequest) String() string

type UpdateJobResponse 

type UpdateJobResponse struct {

	// 校验结果：如果修改失败，返回失败原因。如果修改成功，返回空列表
	ValidationResult *[]JobValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                    `json:"-"`
}

Response Object

func (UpdateJobResponse) String 

func (o UpdateJobResponse) String() string

type UpdateLinkRequest 

type UpdateLinkRequest struct {

	// 集群ID
	ClusterId string `json:"cluster_id"`

	// 连接名称
	LinkName string `json:"link_name"`

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

Request Object

func (UpdateLinkRequest) String 

func (o UpdateLinkRequest) String() string

type UpdateLinkResponse 

type UpdateLinkResponse struct {

	// 校验结构：如果创建连接失败，返回失败原因，请参见validation-result参数说明。如果创建成功，返回空列表。
	ValidationResult *[]ValidationResult `json:"validation-result,omitempty"`
	HttpStatusCode   int                 `json:"-"`
}

Response Object

func (UpdateLinkResponse) String 

func (o UpdateLinkResponse) String() string

type ValidationLinkConfig 

type ValidationLinkConfig struct {

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

	// ERROR,WARNING
	Status *ValidationLinkConfigStatus `json:"status,omitempty"`
}

func (ValidationLinkConfig) String 

func (o ValidationLinkConfig) String() string

type ValidationLinkConfigStatus 

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

func (ValidationLinkConfigStatus) MarshalJSON 

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

func (*ValidationLinkConfigStatus) UnmarshalJSON 

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

type ValidationLinkConfigStatusEnum 

type ValidationLinkConfigStatusEnum struct {
	ERROR   ValidationLinkConfigStatus
	WARNING ValidationLinkConfigStatus
}

func GetValidationLinkConfigStatusEnum 

func GetValidationLinkConfigStatusEnum() ValidationLinkConfigStatusEnum

type ValidationResult 

type ValidationResult struct {

	// 创建或更新连接校验结果，请参见linkConfig参数说明
	LinkConfig *[]ValidationLinkConfig `json:"linkConfig,omitempty"`
}

func (ValidationResult) String 

func (o ValidationResult) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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