model

package
v0.1.11 Latest Latest
Warning

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

Go to latest
Published: Nov 17, 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"`

	ExtendedProperties *ExtendedProperties `json:"extended_properties,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

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

type CdmQueryClusterDetailsRepsonsePublicEndpointStatus

type CdmQueryClusterDetailsRepsonsePublicEndpointStatus struct {

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

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

EIP状态信息

func (CdmQueryClusterDetailsRepsonsePublicEndpointStatus) String

type CdmRandomCreateAndStartJobJsonReq

type CdmRandomCreateAndStartJobJsonReq struct {

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

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

func (CdmRandomCreateAndStartJobJsonReq) 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:立即重启。 - FORCELY:强制重启。 - SOFTLY:一般重启。  默认值为“IMMEDIATELY”。强制重启业务进程会中断,并重启集群的虚拟机。
	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

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

func (CdmStopClusterReqStopStopMode) Value added in v0.0.90

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

type ClusterDetailInstanceVolume

type ClusterDetailInstanceVolume struct {

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

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

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

func (ClusterDetailInstanceVolume) 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"`

	ExtendedConfigs *ExtendedConfigs `json:"extended-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,omitempty"`

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

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

type CreateAndStartRandomClusterJobResponse

type CreateAndStartRandomClusterJobResponse struct {

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

Response Object

func (CreateAndStartRandomClusterJobResponse) 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 ExtendedConfigs added in v0.0.106

type ExtendedConfigs struct {

	// 扩展参数属性名称
	Name *string `json:"name,omitempty"`

	// cdm-base64编码后的值
	Value *string `json:"value,omitempty"`
}

func (ExtendedConfigs) String added in v0.0.106

func (o ExtendedConfigs) String() string

type ExtendedProperties added in v0.0.106

type ExtendedProperties struct {

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

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

	// 是否是试用集群。
	Trial *string `json:"trial,omitempty"`
}

集群扩展信息

func (ExtendedProperties) String added in v0.0.106

func (o ExtendedProperties) 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"`

	// 参数值
	Value string `json:"value"`

	// 值类型
	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"`

	// 写入行数
	RowsWritten *int32 `json:"rows_written,omitempty"`

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

	// 写入文件数
	FilesWritten *int32 `json:"files_written,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

func (JobJobType) Value added in v0.0.90

func (c JobJobType) Value() string

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

func (JobValidationResultStatus) Value added in v0.0.90

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

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

func (ShowJobsRequestJobType) Value added in v0.0.90

func (c ShowJobsRequestJobType) Value() string

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 {

	// 校验结构:如果停止作业接失败,返回失败原因,请参见validation-result参数说明。如果停止成功,返回空列表。
	ValidationResult *[]JobValidationResult `json:"validation-result,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

func (ValidationLinkConfigStatus) Value added in v0.0.90

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

Jump to

Keyboard shortcuts

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