model

package
v0.1.126 Latest Latest
Warning

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

Go to latest
Published: Dec 10, 2024 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 AddJobsReqV11 added in v0.1.7

type AddJobsReqV11 struct {

	// 作业类型码。 - 1:MapReduce - 2:Spark - 3:Hive Script - 4:HiveSQL(当前不支持) - 5:DistCp,导入、导出数据,(当前不支持)。 - 6:Spark Script - 7:Spark SQL,提交SQL语句,(当前不支持)。
	JobType int32 `json:"job_type"`

	// 作业名称。 只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。  说明: 不同作业的名称允许相同,但不建议设置相同。
	JobName string `json:"job_name"`

	// 执行程序Jar包或sql文件地址,需要满足如下要求: - 最多为1023字符,不能包含;|&>,<'$特殊字符,且不可为空或全空格。 - 文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。    - OBS:以“s3a://”开头。不支持KMS加密的文件或程序。    - HDFS:以“/”开头。 - Spark Script需要以“.sql”结尾,MapReduce和Spark Jar需要以“.jar”结尾,sql和jar不区分大小写。
	JarPath *string `json:"jar_path,omitempty"`

	// 程序执行的关键参数,该参数由用户程序内的函数指定,MRS只负责参数的传入。 最多为150000字符,不能包含;|&>'<$特殊字符,可为空。
	Arguments *string `json:"arguments,omitempty"`

	// 数据输入地址。 文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 - OBS:以“s3a://”开头。不支持KMS加密的文件或程序。 - HDFS:以“/”开头。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Input *string `json:"input,omitempty"`

	// 数据输出地址。 文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 - OBS:以“s3a://”开头。 - HDFS:以“/”开头。  如果该路径不存在,系统会自动创建。 最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Output *string `json:"output,omitempty"`

	// 作业日志存储地址,该日志信息记录作业运行状态。 文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。 - OBS:以“s3a://”开头。 - HDFS:以“/”开头。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	JobLog *string `json:"job_log,omitempty"`

	// sql程序路径,仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求: - 最多为1023字符,不能包含;|&><'$特殊字符,且不可为空或全空格。 - 文件可存储于HDFS或者OBS中,不同的文件系统对应的路径存在差异。     - OBS:以“s3a://”开头。不支持KMS加密的文件或程序。     - HDFS:以“/”开头。 - 需要以“.sql”结尾,sql不区分大小写。
	HiveScriptPath *string `json:"hive_script_path,omitempty"`

	// HQL脚本语句。
	Hql *string `json:"hql,omitempty"`

	// 作业执行完成后,是否删除集群。  - true:是  - false:否
	ShutdownCluster *bool `json:"shutdown_cluster,omitempty"`

	// - true:创建集群同时提交作业  - false:单独提交作业  此处应设置为true。
	SubmitJobOnceClusterRun bool `json:"submit_job_once_cluster_run"`

	// 数据导入导出。 - import - export
	FileAction *string `json:"file_action,omitempty"`
}

func (AddJobsReqV11) String added in v0.1.7

func (o AddJobsReqV11) String() string

type AutoScalingPolicy

type AutoScalingPolicy struct {

	// 当前自动伸缩规则是否开启。
	AutoScalingEnable bool `json:"auto_scaling_enable"`

	// 指定该节点组的最小保留节点数。  取值范围:[0~500]
	MinCapacity int32 `json:"min_capacity"`

	// 指定该节点组的最大节点数。  取值范围:[0~500]
	MaxCapacity int32 `json:"max_capacity"`

	// 资源计划列表。若该参数为空表示不启用资源计划。  当启用弹性伸缩时,资源计划与自动伸缩规则需至少配置其中一种。
	ResourcesPlans *[]ResourcesPlan `json:"resources_plans,omitempty"`

	// 自动伸缩的规则列表。  当启用弹性伸缩时,资源计划与自动伸缩规则需至少配置其中一种。
	Rules *[]Rule `json:"rules,omitempty"`

	// 弹性伸缩自定义自动化脚本列表。若该参数为空表示不启用自动化脚本。
	ExecScripts *[]ScaleScript `json:"exec_scripts,omitempty"`
}

func (AutoScalingPolicy) String

func (o AutoScalingPolicy) String() string

type AutoScalingPolicyReqV11 added in v0.0.73

type AutoScalingPolicyReqV11 struct {

	// 弹性伸缩规则适用的节点类型,当前只支持task节点。
	NodeGroup AutoScalingPolicyReqV11NodeGroup `json:"node_group"`

	AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy"`
}

func (AutoScalingPolicyReqV11) String added in v0.0.73

func (o AutoScalingPolicyReqV11) String() string

type AutoScalingPolicyReqV11NodeGroup added in v0.0.73

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

func (AutoScalingPolicyReqV11NodeGroup) MarshalJSON added in v0.0.73

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

func (*AutoScalingPolicyReqV11NodeGroup) UnmarshalJSON added in v0.0.73

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

func (AutoScalingPolicyReqV11NodeGroup) Value added in v0.0.90

type AutoScalingPolicyReqV11NodeGroupEnum added in v0.0.73

type AutoScalingPolicyReqV11NodeGroupEnum struct {
	TASK_NODE_DEFAULT_GROUP AutoScalingPolicyReqV11NodeGroup
}

func GetAutoScalingPolicyReqV11NodeGroupEnum added in v0.0.73

func GetAutoScalingPolicyReqV11NodeGroupEnum() AutoScalingPolicyReqV11NodeGroupEnum

type AvailableTag added in v0.1.43

type AvailableTag struct {

	// 可用区计费模式,分为专属dedicated和共享shard
	Mode *string `json:"mode,omitempty"`

	// az的别名
	Alias *string `json:"alias,omitempty"`

	// 所属group。默认为”center”
	PublicBorderGroup *string `json:"public_border_group,omitempty"`
}

AvailableTag 可用区标签

func (AvailableTag) String added in v0.1.43

func (o AvailableTag) String() string

type AvailableZoneV2 added in v0.1.43

type AvailableZoneV2 struct {

	// 可用区编码
	Id *string `json:"id,omitempty"`

	// 可用区编码
	AzCode *string `json:"az_code,omitempty"`

	// 可用区名称
	AzName *string `json:"az_name,omitempty"`

	// 可用区id
	AzId *string `json:"az_id,omitempty"`

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

	// 区域id
	RegionId *string `json:"region_id,omitempty"`

	// 可用区分组id
	AzGroupId *string `json:"az_group_id,omitempty"`

	// 当前AZ的类型 Core 核心 Satellite 卫星 Dedicated 专属 Virtual 虚拟 Edge 边缘 EdgeCental 中心边缘 Hybrid 混合云
	AzType *string `json:"az_type,omitempty"`

	AzTags *AvailableTag `json:"az_tags,omitempty"`
}

AvailableZoneV2 可用区信息

func (AvailableZoneV2) String added in v0.1.43

func (o AvailableZoneV2) String() string

type BatchCreateClusterTagsReq

type BatchCreateClusterTagsReq struct {

	// 操作标识:仅限于create(创建)。
	Action BatchCreateClusterTagsReqAction `json:"action"`

	// 标签列表。
	Tags []Tag `json:"tags"`
}

func (BatchCreateClusterTagsReq) String

func (o BatchCreateClusterTagsReq) String() string

type BatchCreateClusterTagsReqAction

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

func (BatchCreateClusterTagsReqAction) MarshalJSON

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

func (*BatchCreateClusterTagsReqAction) UnmarshalJSON

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

func (BatchCreateClusterTagsReqAction) Value added in v0.0.90

type BatchCreateClusterTagsReqActionEnum

type BatchCreateClusterTagsReqActionEnum struct {
	CREATE BatchCreateClusterTagsReqAction
}

func GetBatchCreateClusterTagsReqActionEnum

func GetBatchCreateClusterTagsReqActionEnum() BatchCreateClusterTagsReqActionEnum

type BatchCreateClusterTagsRequest

type BatchCreateClusterTagsRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`

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

BatchCreateClusterTagsRequest Request Object

func (BatchCreateClusterTagsRequest) String

type BatchCreateClusterTagsResponse

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

BatchCreateClusterTagsResponse Response Object

func (BatchCreateClusterTagsResponse) String

type BatchDeleteClusterTagsReq

type BatchDeleteClusterTagsReq struct {

	// 操作标识:仅限于delete(删除)。
	Action BatchDeleteClusterTagsReqAction `json:"action"`

	// 标签列表。
	Tags []Tag `json:"tags"`
}

func (BatchDeleteClusterTagsReq) String

func (o BatchDeleteClusterTagsReq) String() string

type BatchDeleteClusterTagsReqAction

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

func (BatchDeleteClusterTagsReqAction) MarshalJSON

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

func (*BatchDeleteClusterTagsReqAction) UnmarshalJSON

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

func (BatchDeleteClusterTagsReqAction) Value added in v0.0.90

type BatchDeleteClusterTagsReqActionEnum

type BatchDeleteClusterTagsReqActionEnum struct {
	DELETE BatchDeleteClusterTagsReqAction
}

func GetBatchDeleteClusterTagsReqActionEnum

func GetBatchDeleteClusterTagsReqActionEnum() BatchDeleteClusterTagsReqActionEnum

type BatchDeleteClusterTagsRequest

type BatchDeleteClusterTagsRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`

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

BatchDeleteClusterTagsRequest Request Object

func (BatchDeleteClusterTagsRequest) String

type BatchDeleteClusterTagsResponse

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

BatchDeleteClusterTagsResponse Response Object

func (BatchDeleteClusterTagsResponse) String

type BootstrapScript

type BootstrapScript struct {

	// 引导操作脚本的名称,同一个集群的引导操作脚本名称不允许相同。  只能由数字、英文字符、空格、中划线和下划线组成,且不能以空格开头。  可输入的字符串长度为1~64个字符。
	Name string `json:"name"`

	// 引导操作脚本的路径。设置为OBS桶的路径或虚拟机本地的路径。 - OBS桶的路径:直接手动输入脚本路径。例如输入MRS提供的公共样例脚本路径。示例:s3a://bootstrap/presto/presto-install.sh,其中安装dualroles时,presto-install.sh脚本参数为dualroles, 安装worker时,presto-install.sh脚本参数为worker。根据Presto使用习惯,建议您在Active Master节点上安装dualroles,在Core节点上安装worker。 - 虚拟机本地的路径:用户需要输入正确的脚本路径。脚本所在的路径必须以‘/’开头,以.sh结尾。
	Uri string `json:"uri"`

	// 引导操作脚本参数。
	Parameters *string `json:"parameters,omitempty"`

	// 引导操作脚本所执行的节点类型,包含master、core和task三种类型。 说明:节点类型必须为小写字母。
	Nodes []string `json:"nodes"`

	// 引导操作脚本是否只运行在主Master节点上。 缺省值为false,表示引导操作脚本可运行在所有Master节点上。
	ActiveMaster *bool `json:"active_master,omitempty"`

	// 引导操作脚本执行失败后,是否继续执行后续脚本和创建集群。  缺省值为errorout,表示终止操作。  说明: 建议您在调试阶段设置为“继续”,无论此引导操作是否执行成功,则集群都能继续安装和启动。  枚举值: - continue:继续执行后续脚本。 - errorout:终止操作。
	FailAction BootstrapScriptFailAction `json:"fail_action"`

	// 引导操作脚本执行的时间。目前支持“组件启动前”和“组件启动后”两种类型。 缺省值为false,表示引导操作脚本在组件启动后执行。
	BeforeComponentStart *bool `json:"before_component_start,omitempty"`

	// 单个引导操作脚本的执行时间。
	StartTime *int64 `json:"start_time,omitempty"`

	// 单个引导操作脚本的运行状态。  - PENDING - IN_PROGRESS - SUCCESS - FAILURE
	State *BootstrapScriptState `json:"state,omitempty"`

	// 选择引导操作脚本执行的时间。 - BEFORE_COMPONENT_FIRST_START: 组件首次启动后 - AFTER_COMPONENT_FIRST_START: 组件首次启动前 - BEFORE_SCALE_IN: 缩容前 - AFTER_SCALE_IN: 缩容后 - BEFORE_SCALE_OUT: 扩容前 - AFTER_SCALE_OUT: 扩容后
	ActionStages *[]BootstrapScriptActionStages `json:"action_stages,omitempty"`
}

func (BootstrapScript) String

func (o BootstrapScript) String() string

type BootstrapScriptActionStages added in v0.0.50

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

func (BootstrapScriptActionStages) MarshalJSON added in v0.0.50

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

func (*BootstrapScriptActionStages) UnmarshalJSON added in v0.0.50

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

func (BootstrapScriptActionStages) Value added in v0.0.90

type BootstrapScriptActionStagesEnum added in v0.0.50

type BootstrapScriptActionStagesEnum struct {
	BEFORE_COMPONENT_FIRST_START BootstrapScriptActionStages
	AFTER_COMPONENT_FIRST_START  BootstrapScriptActionStages
	BEFORE_SCALE_IN              BootstrapScriptActionStages
	AFTER_SCALE_IN               BootstrapScriptActionStages
	BEFORE_SCALE_OUT             BootstrapScriptActionStages
	AFTER_SCALE_OUT              BootstrapScriptActionStages
}

func GetBootstrapScriptActionStagesEnum added in v0.0.50

func GetBootstrapScriptActionStagesEnum() BootstrapScriptActionStagesEnum

type BootstrapScriptFailAction

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

func (BootstrapScriptFailAction) MarshalJSON

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

func (*BootstrapScriptFailAction) UnmarshalJSON

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

func (BootstrapScriptFailAction) Value added in v0.0.90

type BootstrapScriptFailActionEnum

type BootstrapScriptFailActionEnum struct {
	CONTINUE BootstrapScriptFailAction
	ERROROUT BootstrapScriptFailAction
}

func GetBootstrapScriptFailActionEnum

func GetBootstrapScriptFailActionEnum() BootstrapScriptFailActionEnum

type BootstrapScriptState added in v0.1.7

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

func (BootstrapScriptState) MarshalJSON added in v0.1.7

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

func (*BootstrapScriptState) UnmarshalJSON added in v0.1.7

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

func (BootstrapScriptState) Value added in v0.1.7

func (c BootstrapScriptState) Value() string

type BootstrapScriptStateEnum added in v0.1.7

type BootstrapScriptStateEnum struct {
	PENDING     BootstrapScriptState
	IN_PROGRESS BootstrapScriptState
	SUCCESS     BootstrapScriptState
	FAILURE     BootstrapScriptState
}

func GetBootstrapScriptStateEnum added in v0.1.7

func GetBootstrapScriptStateEnum() BootstrapScriptStateEnum

type Cluster added in v0.0.51

type Cluster struct {

	// 集群ID。
	ClusterId *string `json:"clusterId,omitempty"`

	// 集群名称。
	ClusterName *string `json:"clusterName,omitempty"`

	// 集群部署的节点总数。
	TotalNodeNum *string `json:"totalNodeNum,omitempty"`

	// 集群状态,包括: - starting:启动中的集群。 - running:运行中的集群。 - terminated:已删除的集群。 - failed:失败的集群。 - abnormal:异常的集群。 - terminating:删除中的集群。 - frozen:已冻结的集群。 - scaling-out:扩容中的集群。 - scaling-in:缩容中的集群。
	ClusterState *string `json:"clusterState,omitempty"`

	// 集群进度描述。  安装集群进度包括: - Verifying cluster parameters:校验集群参数中 - Applying for cluster resources:申请集群资源中 - Creating VM:创建虚拟机中 - Initializing VM:初始化虚拟机中 - Installing MRS Manager:安装MRS Manager中 - Deploying cluster:部署集群中 - Cluster installation failed:集群安装失败  扩容集群进度包括: - Preparing for cluster expansion:准备扩容中 - Creating VM:创建虚拟机中 - Initializing VM:初始化虚拟机中 - Adding node to the cluster:节点加入集群中 - Cluster expansion failed:集群扩容失败  缩容集群进度包括: - Preparing for cluster shrink:正在准备缩容 - Decommissioning instance:实例退服中 - Deleting VM:删除虚拟机中 - Deleting node from the cluster:从集群删除节点中 - Cluster shrink failed:集群缩容失败 集群安装、扩容、缩容失败,stageDesc会显示失败的原因。
	StageDesc *string `json:"stageDesc,omitempty"`

	// 集群创建时间,十位时间戳。
	CreateAt *string `json:"createAt,omitempty"`

	// 集群更新时间,十位时间戳。
	UpdateAt *string `json:"updateAt,omitempty"`

	// 开始计费时间。
	ChargingStartTime *string `json:"chargingStartTime,omitempty"`

	// 集群计费模式。
	BillingType *string `json:"billingType,omitempty"`

	// 集群工作区域。
	DataCenter *string `json:"dataCenter,omitempty"`

	// VPC名称。
	Vpc *string `json:"vpc,omitempty"`

	// VPC ID。
	VpcId *string `json:"vpcId,omitempty"`

	// 集群购买时长。
	Duration *string `json:"duration,omitempty"`

	// 创建集群所需费用,系统自动计算。
	Fee *string `json:"fee,omitempty"`

	// Hadoop组件版本信息。
	HadoopVersion *string `json:"hadoopVersion,omitempty"`

	// 组件列表信息。
	ComponentList *[]ComponentAmb `json:"componentList,omitempty"`

	// 公网IP地址。
	ExternalIp *string `json:"externalIp,omitempty"`

	// 公网备用IP地址。
	ExternalAlternateIp *string `json:"externalAlternateIp,omitempty"`

	// 内网IP地址。
	InternalIp *string `json:"internalIp,omitempty"`

	// 集群部署ID。
	DeploymentId *string `json:"deploymentId,omitempty"`

	// 集群备注信息。
	Remark *string `json:"remark,omitempty"`

	// 创建集群的订单号。
	OrderId *string `json:"orderId,omitempty"`

	// 可用区域ID。
	AzId *string `json:"azId,omitempty"`

	// 可用区域名称。
	AzName *string `json:"azName,omitempty"`

	// 可用区域英文名称
	AzCode *string `json:"azCode,omitempty"`

	// 可用区域
	AvailabilityZoneId *string `json:"availabilityZoneId,omitempty"`

	// 实例ID。
	InstanceId *string `json:"instanceId,omitempty"`

	// 远程登录弹性云服务器的URI地址。
	Vnc *string `json:"vnc,omitempty"`

	// 项目编号。
	TenantId *string `json:"tenantId,omitempty"`

	// 磁盘存储空间。
	VolumeSize *int32 `json:"volumeSize,omitempty"`

	// 磁盘类型。
	VolumeType *string `json:"volumeType,omitempty"`

	// 子网ID。
	SubnetId *string `json:"subnetId,omitempty"`

	// 子网名称。
	SubnetName *string `json:"subnetName,omitempty"`

	// 安全组ID。
	SecurityGroupsId *string `json:"securityGroupsId,omitempty"`

	// 非Master节点的安全组id,当前一个MRS集群只会使用一个安全组,所以该字段已经废弃,从兼容性考虑,该字段会返回和securityGroupsId同样的值。
	SlaveSecurityGroupsId *string `json:"slaveSecurityGroupsId,omitempty"`

	// 配置引导操作脚本信息。
	BootstrapScripts *[]BootstrapScript `json:"bootstrapScripts,omitempty"`

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

	// 集群版本。
	ClusterVersion *string `json:"clusterVersion,omitempty"`

	// 密钥文件名称。
	NodePublicCertName *string `json:"nodePublicCertName,omitempty"`

	// Master节点IP。
	MasterNodeIp *string `json:"masterNodeIp,omitempty"`

	// 首选私有IP。
	PrivateIpFirst *string `json:"privateIpFirst,omitempty"`

	// 错误信息。
	ErrorInfo *string `json:"errorInfo,omitempty"`

	// 标签信息
	Tags *string `json:"tags,omitempty"`

	// 集群部署的Master节点数量。
	MasterNodeNum *string `json:"masterNodeNum,omitempty"`

	// 集群部署的Core节点数量。
	CoreNodeNum *string `json:"coreNodeNum,omitempty"`

	// Master节点的实例规格。
	MasterNodeSize *string `json:"masterNodeSize,omitempty"`

	// Core节点的实例规格。
	CoreNodeSize *string `json:"coreNodeSize,omitempty"`

	// Master节点产品ID。
	MasterNodeProductId *string `json:"masterNodeProductId,omitempty"`

	// Master节点规格ID。
	MasterNodeSpecId *string `json:"masterNodeSpecId,omitempty"`

	// Core节点产品ID。
	CoreNodeProductId *string `json:"coreNodeProductId,omitempty"`

	// Core节点规格ID。
	CoreNodeSpecId *string `json:"coreNodeSpecId,omitempty"`

	// Master节点数据磁盘存储类别,目前支持SATA、SAS和SSD。
	MasterDataVolumeType *string `json:"masterDataVolumeType,omitempty"`

	// Master节点数据磁盘存储空间。为增大数据存储容量,创建集群时可同时添加磁盘。 取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	MasterDataVolumeSize *int32 `json:"masterDataVolumeSize,omitempty"`

	// Master节点数据磁盘个数。 取值只能是1
	MasterDataVolumeCount *int32 `json:"masterDataVolumeCount,omitempty"`

	// Core节点数据磁盘存储类别,目前支持SATA、SAS和SSD。
	CoreDataVolumeType *string `json:"coreDataVolumeType,omitempty"`

	// Core节点数据磁盘存储空间。为增大数据存储容量,创建集群时可同时添加磁盘。 取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	CoreDataVolumeSize *int32 `json:"coreDataVolumeSize,omitempty"`

	// Core节点数据磁盘个数。 取值范围:1~10
	CoreDataVolumeCount *int32 `json:"coreDataVolumeCount,omitempty"`

	// 企业项目ID。
	EnterpriseProjectId *string `json:"enterpriseProjectId,omitempty"`

	// 表示集群创建过程中,MRS Manager是否安装完成。 - true:安装完成 - false:安装未完成
	IsMrsManagerFinish *bool `json:"isMrsManagerFinish,omitempty"`

	// 集群类型。
	ClusterType *int32 `json:"clusterType,omitempty"`

	// 集群安装失败时,是否搜集日志。 - 0:不收集 - 1:收集
	LogCollection *int32 `json:"logCollection,omitempty"`

	// 区分包周期,集群是包年还是包月。 - 0:包月 - 1:包年
	PeriodType *int32 `json:"periodType,omitempty"`

	// 集群节点的变更状态(扩容/缩容/变更规格)。当该参数取值为空时,表示集群节点没有进行变更操作。 取值范围: - scaling-out:扩容中 - scaling-in:缩容中 - scaling-error:处于running状态,且上一次扩容/缩容/升级规格失败的集群 - scaling-up:Master节点规格升级中 - scaling_up_first:备Master节点规格升级中 - scaled_up_first:备Master节点规格升级成功 - scaled-up-success:Master节点规格升级成功
	Scale *string `json:"scale,omitempty"`

	// Master节点、Core节点和Task节点列表信息。
	NodeGroups *[]NodeGroupV10 `json:"nodeGroups,omitempty"`

	// Task节点列表信息。
	TaskNodeGroups *[]NodeGroupV10 `json:"taskNodeGroups,omitempty"`

	// 集群弹性公网ip的唯一标识
	EipId *string `json:"eipId,omitempty"`

	// 集群弹性公网ip的IPV4地址
	EipAddress *string `json:"eipAddress,omitempty"`

	// 集群弹性公网ip的IPV6地址,IPv4时无此字段。
	Eipv6Address *string `json:"eipv6Address,omitempty"`
}

func (Cluster) String added in v0.0.51

func (o Cluster) String() string

type ClusterScalingParams added in v0.0.73

type ClusterScalingParams struct {

	// 扩容/缩容时系统获取的订单号,用户不需要配置。
	OrderId *string `json:"order_id,omitempty"`

	// - scale_in:缩容 - scale_out:扩容
	ScaleType ClusterScalingParamsScaleType `json:"scale_type"`

	// 扩容/缩容时新增或者减少节点的ID标识,参数值固定为node_orderadd。
	NodeId string `json:"node_id"`

	// 扩容或缩容的节点组。 - 如果node_group为core_node_default_group,表示Core节点组。 - 如果node_group为task_node_default_group,表示Task节点组。  该字段可以为空,为空时,系统默认值为core_node_default_group。
	NodeGroup *string `json:"node_group,omitempty"`

	// 是否跳过引导操作,默认为false,即执行引导操作。 仅在创建集群时配置了引导操作且扩容时有意义,表示扩容时是否在新增节点上执行创建集群时指定的引导操作。
	SkipBootstrapScripts *string `json:"skip_bootstrap_scripts,omitempty"`

	// 扩容后是否启动扩容节点上的组件。  - true:扩容后不启动组件。 - false:扩容后启动组件。
	ScaleWithoutStart *bool `json:"scale_without_start,omitempty"`

	// 缩容Task节点时指定待删除Task节点的ID列表。  - 当scale_type为扩容时,该参数不生效。 - 当scale_type为缩容且该参数不为空时,删除指定的Task节点。 - 当scale_type为缩容且server_ids为空时,按照系统规则自动选择删除Task节点。
	ServerIds *[]string `json:"server_ids,omitempty"`

	// 扩容或缩容的节点数。  - 扩容时的最大节点数为(500 - 集群Core/Task节点数)。例如,当前集群Core节点数为3,此处扩容的节点数必须小于等于497。     Core和Task节点总数最大值为500,如果用户需要的Core/Task节点数大于500,可以联系技术支持人员或者调用后台接口修改数据库。   - 缩容时Core节点数大于3或者Task节点数大于0可以进行节点删除。例如,当前集群Core节点和Task节点数均为5,Core节点可缩容的节点数为2(5减去3),Task节点可缩容节点数为小于等于5。
	Instances int32 `json:"instances"`

	TaskNodeInfo *TaskNodeInfo `json:"task_node_info,omitempty"`
}

func (ClusterScalingParams) String added in v0.0.73

func (o ClusterScalingParams) String() string

type ClusterScalingParamsScaleType added in v0.0.73

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

func (ClusterScalingParamsScaleType) MarshalJSON added in v0.0.73

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

func (*ClusterScalingParamsScaleType) UnmarshalJSON added in v0.0.73

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

func (ClusterScalingParamsScaleType) Value added in v0.0.90

type ClusterScalingParamsScaleTypeEnum added in v0.0.73

type ClusterScalingParamsScaleTypeEnum struct {
	SCALE_IN  ClusterScalingParamsScaleType
	SCALE_OUT ClusterScalingParamsScaleType
}

func GetClusterScalingParamsScaleTypeEnum added in v0.0.73

func GetClusterScalingParamsScaleTypeEnum() ClusterScalingParamsScaleTypeEnum

type ClusterScalingReq added in v0.0.73

type ClusterScalingReq struct {

	// 服务ID,为扩展接口,预留此参数。用户不需要配置。
	ServiceId *string `json:"service_id,omitempty"`

	// 套餐ID,为扩展接口,预留此参数。用户不需要配置。
	PlanId *string `json:"plan_id,omitempty"`

	Parameters *ClusterScalingParams `json:"parameters"`

	// 扩展接口,预留此参数。用户不需要配置。
	PreviousValues map[string]string `json:"previous_values,omitempty"`
}

func (ClusterScalingReq) String added in v0.0.73

func (o ClusterScalingReq) String() string

type ComponentAmb added in v0.0.51

type ComponentAmb struct {

	// 组件ID。
	ComponentId *string `json:"componentId,omitempty"`

	// 组件名称。
	ComponentName *string `json:"componentName,omitempty"`

	// 组件版本。
	ComponentVersion *string `json:"componentVersion,omitempty"`

	// 组件描述信息。
	ComponentDesc *string `json:"componentDesc,omitempty"`
}

func (ComponentAmb) String added in v0.0.51

func (o ComponentAmb) String() string

type ComponentAmbV11 added in v0.1.7

type ComponentAmbV11 struct {

	// 组件名称
	ComponentName string `json:"component_name"`
}

func (ComponentAmbV11) String added in v0.1.7

func (o ComponentAmbV11) String() string

type ComponentExternalDatasource added in v0.1.72

type ComponentExternalDatasource struct {

	// 外部数据源名称
	Name *string `json:"name,omitempty"`

	// 外部数据源类型
	Types *[]string `json:"types,omitempty"`
}

ComponentExternalDatasource 组件外部数据源

func (ComponentExternalDatasource) String added in v0.1.72

type CreateAndExecuteJobRequest added in v0.0.73

type CreateAndExecuteJobRequest struct {
	Body *SubmitJobReqV11 `json:"body,omitempty"`
}

CreateAndExecuteJobRequest Request Object

func (CreateAndExecuteJobRequest) String added in v0.0.73

type CreateAndExecuteJobResponse added in v0.0.73

type CreateAndExecuteJobResponse struct {

	// 作业执行对象是否由作业模板生成。
	Templated *bool `json:"templated,omitempty"`

	// 作业创建时间,十位时间戳。
	CreatedAt *int64 `json:"created_at,omitempty"`

	// 作业更新时间,十位时间戳。
	UpdatedAt *int64 `json:"updated_at,omitempty"`

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

	// 项目编号。获取方法,请参见[获取项目ID](https://support.huaweicloud.com/api-mrs/mrs_02_0011.html)。
	TenantId *string `json:"tenant_id,omitempty"`

	// 作业应用ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称,只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。  说明: 不同作业的名称允许相同,但不建议设置相同。
	JobName *string `json:"job_name,omitempty"`

	// 数据输入ID。
	InputId *string `json:"input_id,omitempty"`

	// 数据输出ID。
	OutputId *string `json:"output_id,omitempty"`

	// 作业执行开始时间,十位时间戳。
	StartTime *int64 `json:"start_time,omitempty"`

	// 作业执行结束时间,十位时间戳。
	EndTime *int64 `json:"end_time,omitempty"`

	// 集群ID。
	ClusterId *string `json:"cluster_id,omitempty"`

	// Oozie工作流ID。
	EngineJobId *string `json:"engine_job_id,omitempty"`

	// 运行结果返回码。
	ReturnCode *string `json:"return_code,omitempty"`

	// 是否公开。 当前版本不支持该功能。
	IsPublic *bool `json:"is_public,omitempty"`

	// 是否受保护。 当前版本不支持该功能。
	IsProtected *bool `json:"is_protected,omitempty"`

	// 作业执行组ID。
	GroupId *string `json:"group_id,omitempty"`

	// 执行程序Jar包或sql文件地址,需要满足如下要求:  - 最多为1023字符,不能包含;|&><'$特殊字符,且不可为空或全空格。  - 需要以“/”或“s3a://”开头。OBS路径不支持KMS加密的文件或程序。  - Spark Script需要以“.sql”结尾,MapReduce和Spark Jar需要以“.jar”结尾,sql和jar不区分大小写。
	JarPath *string `json:"jar_path,omitempty"`

	// 数据输入地址,必须以“/”或“s3a://”开头。请配置为正确的OBS路径,OBS路径不支持KMS加密的文件或程序。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Input *string `json:"input,omitempty"`

	// 数据输出地址,必须以“/”或“s3a://”开头。请配置为正确的OBS路径,如果该路径不存在,系统会自动创建。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Output *string `json:"output,omitempty"`

	// 作业日志存储地址,该日志信息记录作业运行状态。必须以“/”或“s3a://”开头,请配置为正确的OBS路径。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	JobLog *string `json:"job_log,omitempty"`

	// 作业类型码。 - 1:MapReduce - 2:Spark - 3:Hive Script - 4:HiveSQL(当前不支持) - 5:DistCp,导入、导出数据。 - 6:Spark Script - 7:Spark SQL,提交SQL语句,(该接口当前不支持)  说明: 只有包含Spark和Hive组件的集群才能新增Spark和Hive类型的作业。
	JobType *int32 `json:"job_type,omitempty"`

	// 文件操作类型,包括:  - export:从HDFS导出数据至OBS  - import:从OBS导入数据至HDFS
	FileAction *string `json:"file_action,omitempty"`

	// 程序执行的关键参数,该参数由用户程序内的函数指定,MRS只负责参数的传入。 最多为150000字符,不能包含;|&>'<$!\\\"\\特殊字符,可为空。 说明: 用户输入带有敏感信息(如登录密码)的参数时,可通过在参数名前添加“@”的方式,为该参数值加密,以防止敏感信息被明文形式持久化。在查看作业信息时,敏感信息显示为“*”。 例如:username=admin @password=admin_123
	Arguments *string `json:"arguments,omitempty"`

	// Hive&Spark Sql语句
	Hql *string `json:"hql,omitempty"`

	// 作业状态码。  - 1:Terminated - 2:Starting - 3:Running - 4:Completed - 5:Abnormal - 6:Error
	JobState *int32 `json:"job_state,omitempty"`

	// 作业最终状态码。  - 0:未完成 - 1:执行错误,终止执行 - 2:执行完成并且成功 - 3:已取消
	JobFinalStatus *int32 `json:"job_final_status,omitempty"`

	// sql程序路径,仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求:  - 最多为1023字符,不能包含;|&><'$特殊字符,且不可为空或全空格。 - 需要以“/”或“s3a://”开头,OBS路径不支持KMS加密的文件或程序。 - 需要以“.sql”结尾,sql不区分大小写。
	HiveScriptPath *string `json:"hive_script_path,omitempty"`

	// 创建作业的用户ID。  为兼容历史版本,保留此参数。
	CreateBy *string `json:"create_by,omitempty"`

	// 当前已完成的步骤数。  为兼容历史版本,保留此参数。
	FinishedStep *int32 `json:"finished_step,omitempty"`

	// 作业主ID。  为兼容历史版本,保留此参数。
	JobMainId *string `json:"job_main_id,omitempty"`

	// 作业步骤ID。  为兼容历史版本,保留此参数。
	JobStepId *string `json:"job_step_id,omitempty"`

	// 延迟时间,十位时间戳。  为兼容历史版本,保留此参数。
	PostponeAt *int64 `json:"postpone_at,omitempty"`

	// 作业步骤名。  为兼容历史版本,保留此参数。
	StepName *string `json:"step_name,omitempty"`

	// 步骤数量  为兼容历史版本,保留此参数。
	StepNum *int32 `json:"step_num,omitempty"`

	// 任务数量。为兼容历史版本,保留此参数。
	TaskNum *int32 `json:"task_num,omitempty"`

	// 更新作业的用户ID。
	UpdateBy *string `json:"update_by,omitempty"`

	// 令牌,当前版本不支持。
	Credentials *string `json:"credentials,omitempty"`

	// 创建作业的用户ID。  历史版本兼容,不再使用。
	UserId *string `json:"user_id,omitempty"`

	// 键值对集合,用于保存作业运行配置。
	JobConfigs map[string]interface{} `json:"job_configs,omitempty"`

	// 认证信息,当前版本不支持。
	Extra map[string]interface{} `json:"extra,omitempty"`

	// 数据源URL。
	DataSourceUrls map[string]interface{} `json:"data_source_urls,omitempty"`

	// 键值对集合,包含oozie返回的作业运行信息。
	Info           map[string]interface{} `json:"info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

CreateAndExecuteJobResponse Response Object

func (CreateAndExecuteJobResponse) String added in v0.0.73

type CreateClusterReqV11 added in v0.1.7

type CreateClusterReqV11 struct {

	// 集群版本。 例如:MRS 3.1.0。
	ClusterVersion string `json:"cluster_version"`

	// 集群名称,不允许相同。 只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。
	ClusterName string `json:"cluster_name"`

	// Master节点数量。启用集群高可用功能时配置为2,不启用集群高可用功能时配置为1。MRS 3.x版本暂时不支持该参数配置为1。
	MasterNodeNum *int32 `json:"master_node_num,omitempty"`

	// Core节点数量。  取值范围:[1~500]  Core节点默认的最大值为500,如果用户需要的Core节点数大于500,请申请扩大配额。
	CoreNodeNum *int32 `json:"core_node_num,omitempty"`

	// 集群的计费模式。  12:表示按需计费。接口调用仅支持创建按需计费集群。
	BillingType CreateClusterReqV11BillingType `json:"billing_type"`

	// 集群区域信息,请参见[终端节点及区域](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)。
	DataCenter string `json:"data_center"`

	// 子网所在VPC名称。 通过VPC管理控制台获取名称: 1) 登录管理控制台。 2) 单击“虚拟私有云”,从左侧列表选择虚拟私有云。  在“虚拟私有云”页面的列表中即可获取VPC名称。
	Vpc string `json:"vpc"`

	// Master节点的实例规格,例如:c3.4xlarge.2.linux.bigdata。MRS当前支持主机规格的配型由CPU+内存+Disk共同决定。实例规格详细说明请参见[MRS所使用的弹性云服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9006.html)和[MRS所使用的裸金属服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9001.html)。 该参数建议从MRS控制台的集群创建页面获取对应区域对应版本所支持的规格。
	MasterNodeSize *string `json:"master_node_size,omitempty"`

	// Core节点的实例规格,例如:c3.4xlarge.2.linux.bigdata。实例规格详细说明请参见[MRS所使用的弹性云服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9006.html)和[MRS所使用的裸金属服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9001.html)。 该参数建议从MRS控制台的集群创建页面获取对应区域对应版本所支持的规格。
	CoreNodeSize *string `json:"core_node_size,omitempty"`

	// 服务组件安装列表信息。
	ComponentList []ComponentAmbV11 `json:"component_list"`

	// 可用分区ID。  - 华北-北京一可用区1(cn-north-1a):ae04cf9d61544df3806a3feeb401b204 - 华北-北京一可用区2(cn-north-1b):d573142f24894ef3bd3664de068b44b0 - 华东-上海二可用区1(cn-east-2a):72d50cedc49846b9b42c21495f38d81c - 华东-上海二可用区2(cn-east-2b):38b0f7a602344246bcb0da47b5d548e7 - 华东-上海二可用区3(cn-east-2c):5547fd6bf8f84bb5a7f9db062ad3d015 - 华南-广州可用区1(cn-south-1a):34f5ff4865cf4ed6b270f15382ebdec5 - 华南-广州可用区2(cn-south-2b):043c7e39ecb347a08dc8fcb6c35a274e - 华南-广州可用区3(cn-south-1c):af1687643e8c4ec1b34b688e4e3b8901 - 华北-北京四可用区1(cn-north-4a):effdcbc7d4d64a02aa1fa26b42f56533 - 华北-北京四可用区2(cn-north-4b):a0865121f83b41cbafce65930a22a6e8 - 华北-北京四可用区3(cn-north-4c):2dcb154ac2724a6d92e9bcc859657c1e
	AvailableZoneId string `json:"available_zone_id"`

	// 子网所在VPC ID。 通过VPC管理控制台获取ID: 1) 登录管理控制台。 2) 单击“虚拟私有云”,从左侧列表选择虚拟私有云。   在“虚拟私有云”页面的列表中即可获取VPC ID。
	VpcId string `json:"vpc_id"`

	// 子网ID。通过VPC管理控制台获取子网ID: 1) 登录管理控制台。 2) 单击“虚拟私有云”,从左侧列表选择虚拟私有云。 3) 单击对应虚拟私有云所在行的“子网个数”查看子网。 4) 单击对应子网名称,获取“网络ID”。  “subnet_id”和“subnet_name”必须至少填写一个,当这两个参数同时配置但是不匹配同一个子网时,集群会创建失败,请仔细填写参数。推荐使用“subnet_id”。
	SubnetId string `json:"subnet_id"`

	// 子网名称。 通过VPC管理控制台获取子网名称: 1) 登录管理控制台。 2) 单击“虚拟私有云”,从左侧列表选择虚拟私有云。 3) 单击对应虚拟私有云所在行的“子网个数”查看子网,获取子网名称。  “subnet_id”和“subnet_name”必须至少填写一个,当这两个参数同时配置但是不匹配同一个子网时,集群会创建失败,请仔细填写参数。当仅填写“subnet_name”一个参数且VPC下存在同名子网时,创建集群时以VPC平台第一个名称的子网为准。推荐使用“subnet_id”。
	SubnetName string `json:"subnet_name"`

	// 集群安全组的ID。 - 当该ID为空时MRS后台会自己创建安全组,自动创建的安全组名称以mrs_{cluster_name}开头。 - 当该ID不为空时,表示使用固定安全组来创建集群,传入的ID必须是当前租户中包含的安全组ID,且该安全组中包含一条全部协议,全部端口,源地址为指定的管理面节点IP的入方向规则。
	SecurityGroupsId *string `json:"security_groups_id,omitempty"`

	// 创建集群时可同时提交作业,当前版本暂时只支持新增一个作业。
	AddJobs *[]AddJobsReqV11 `json:"add_jobs,omitempty"`

	// Master和Core节点数据磁盘存储空间。为增大数据存储容量,创建集群时可同时添加磁盘。可以根据如下应用场景合理选择磁盘存储空间大小: - 数据存储和计算分离,数据存储在OBS系统中,集群费用相对较低,计算性能不高,并且集群随时可以删除,建议数据计算不频繁场景下使用。 - 数据存储和计算不分离,数据存储在HDFS中,集群费用相对较高,计算性能高,集群需要长期存在,建议数据计算频繁场景下使用。  取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。 不建议使用该参数,详情请参考volume_type参数的说明。
	VolumeSize *int32 `json:"volume_size,omitempty"`

	// Master和Core节点的磁盘存储类别,目前支持SATA、SAS、SSD和GPSSD。磁盘参数可以使用volume_type和volume_size表示,也可以使用多磁盘相关的参数表示。volume_type和volume_size这两个参数如果与多磁盘参数同时出现,系统优先读取volume_type和volume_size参数。建议使用多磁盘参数。 - SATA:普通IO - SAS:高IO - SSD:超高IO - GPSSD:通用型SSD
	VolumeType *CreateClusterReqV11VolumeType `json:"volume_type,omitempty"`

	// 该参数为多磁盘参数,表示Master节点数据磁盘存储类别,目前支持SATA、SAS、SSD和GPSSD。
	MasterDataVolumeType *CreateClusterReqV11MasterDataVolumeType `json:"master_data_volume_type,omitempty"`

	// 该参数为多磁盘参数,表示Master节点数据磁盘存储空间。为增大数据存储容量,创建集群时可同时添加磁盘。  取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	MasterDataVolumeSize *int32 `json:"master_data_volume_size,omitempty"`

	// 该参数为多磁盘参数,表示Master节点数据磁盘个数。取值只能是1。
	MasterDataVolumeCount *CreateClusterReqV11MasterDataVolumeCount `json:"master_data_volume_count,omitempty"`

	// 该参数为多磁盘参数,表示Core节点数据磁盘存储类别,目前支持SATA、SAS、SSD和GPSSD。
	CoreDataVolumeType *CreateClusterReqV11CoreDataVolumeType `json:"core_data_volume_type,omitempty"`

	// 该参数为多磁盘参数,表示Core节点数据磁盘存储空间。为增大数据存储容量,创建集群时可同时添加磁盘。  取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	CoreDataVolumeSize *int32 `json:"core_data_volume_size,omitempty"`

	// 该参数为多磁盘参数,表示Core节点数据磁盘个数。 取值范围:1~20
	CoreDataVolumeCount *int32 `json:"core_data_volume_count,omitempty"`

	// Task节点列表信息。
	TaskNodeGroups *[]TaskNodeGroup `json:"task_node_groups,omitempty"`

	// 配置引导操作脚本信息。
	BootstrapScripts *[]BootstrapScript `json:"bootstrap_scripts,omitempty"`

	// 密钥对名称。用户可以使用密钥对方式登录集群节点。当“login_mode”配置为“1”时,请求消息体中包含node_public_cert_name字段。
	NodePublicCertName *string `json:"node_public_cert_name,omitempty"`

	// 配置MRS Manager管理员用户的密码。 - 密码长度应在8~26个字符之间 - 不能与用户名或者倒序用户名相同 - 必须包含如下4种字符的组合     - 至少一个小写字母     - 至少一个大写字母     - 至少一个数字     - 至少一个特殊字符:!@$%^-_=+[{}]:,./?
	ClusterAdminSecret *string `json:"cluster_admin_secret,omitempty"`

	// 配置访问集群节点的root密码。当“login_mode”配置为“0”时,请求消息体中包含cluster_master_secret字段。  密码设置约束如下: - 字符串类型,可输入的字符串长度为8-26。 - 至少包含4种字符组合,如大写字母,小写字母,数字,特殊字符(!@$%^-_=+[{}]:,./?),但不能包含空格。 - 不能与用户名或者倒序用户名相同。
	ClusterMasterSecret *string `json:"cluster_master_secret,omitempty"`

	// MRS集群运行模式。 - 0:普通集群,表示Kerberos认证关闭,用户可使用集群提供的所有功能。 - 1:安全集群,表示Kerberos认证开启,普通用户无权限使用MRS集群的“文件管理”和“作业管理”功能,并且无法查看Hadoop、Spark的作业记录以及集群资源使用情况。如果需要使用集群更多功能,需要找MRS Manager的管理员分配权限。
	SafeMode CreateClusterReqV11SafeMode `json:"safe_mode"`

	// 集群类型。  默认值为0:分析集群。  说明:暂不支持通过接口方式创建混合集群。  枚举值: - 0:分析集群 - 1:流式集群
	ClusterType *CreateClusterReqV11ClusterType `json:"cluster_type,omitempty"`

	// 集群创建失败时,是否收集失败日志。  默认设置为1,将创建OBS桶仅用于MRS集群创建失败时的日志收集。  枚举值: - 0:不收集 - 1:收集
	LogCollection *CreateClusterReqV11LogCollection `json:"log_collection,omitempty"`

	// 企业项目ID。  创建集群时,给集群绑定企业项目ID。  默认设置为0,表示为default企业项目。  获取方式请参见《企业管理API参考》的“查询企业项目列表”响应消息表“enterprise_project字段数据结构说明”的“id”。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 集群的标签信息。  同一个集群最多能使用10个tag,tag的名称(key)不能重复 标签的键/值不能包含“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”。
	Tags *[]Tag `json:"tags,omitempty"`

	// 集群登录方式。默认设置为1。  - 当“login_mode”配置为“0”时,请求消息体中包含cluster_master_secret字段。 - 当“login_mode”配置为“1”时,请求消息体中包含node_public_cert_name字段。  枚举值: - 0:密码方式 - 1:密钥对方式
	LoginMode *CreateClusterReqV11LoginMode `json:"login_mode,omitempty"`

	// 节点列表信息。  说明:如下参数和该参数任选一组进行配置即可。  master_node_num、master_node_size、core_node_num、core_node_size、master_data_volume_type、master_data_volume_size、master_data_volume_count、core_data_volume_type、core_data_volume_size、core_data_volume_count、volume_type、volume_size、task_node_groups。
	NodeGroups *[]NodeGroupV11 `json:"node_groups,omitempty"`
}

func (CreateClusterReqV11) String added in v0.1.7

func (o CreateClusterReqV11) String() string

type CreateClusterReqV11BillingType added in v0.1.7

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

func (CreateClusterReqV11BillingType) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11BillingType) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11BillingType) Value added in v0.1.7

type CreateClusterReqV11BillingTypeEnum added in v0.1.7

type CreateClusterReqV11BillingTypeEnum struct {
	E_12 CreateClusterReqV11BillingType
}

func GetCreateClusterReqV11BillingTypeEnum added in v0.1.7

func GetCreateClusterReqV11BillingTypeEnum() CreateClusterReqV11BillingTypeEnum

type CreateClusterReqV11ClusterType added in v0.1.7

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

func (CreateClusterReqV11ClusterType) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11ClusterType) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11ClusterType) Value added in v0.1.7

type CreateClusterReqV11ClusterTypeEnum added in v0.1.7

type CreateClusterReqV11ClusterTypeEnum struct {
	E_0 CreateClusterReqV11ClusterType
	E_1 CreateClusterReqV11ClusterType
}

func GetCreateClusterReqV11ClusterTypeEnum added in v0.1.7

func GetCreateClusterReqV11ClusterTypeEnum() CreateClusterReqV11ClusterTypeEnum

type CreateClusterReqV11CoreDataVolumeType added in v0.1.7

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

func (CreateClusterReqV11CoreDataVolumeType) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11CoreDataVolumeType) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11CoreDataVolumeType) Value added in v0.1.7

type CreateClusterReqV11LogCollection added in v0.1.7

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

func (CreateClusterReqV11LogCollection) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11LogCollection) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11LogCollection) Value added in v0.1.7

type CreateClusterReqV11LogCollectionEnum added in v0.1.7

type CreateClusterReqV11LogCollectionEnum struct {
	E_0 CreateClusterReqV11LogCollection
	E_1 CreateClusterReqV11LogCollection
}

func GetCreateClusterReqV11LogCollectionEnum added in v0.1.7

func GetCreateClusterReqV11LogCollectionEnum() CreateClusterReqV11LogCollectionEnum

type CreateClusterReqV11LoginMode added in v0.1.7

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

func (CreateClusterReqV11LoginMode) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11LoginMode) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11LoginMode) Value added in v0.1.7

type CreateClusterReqV11LoginModeEnum added in v0.1.7

type CreateClusterReqV11LoginModeEnum struct {
	E_0 CreateClusterReqV11LoginMode
	E_1 CreateClusterReqV11LoginMode
}

func GetCreateClusterReqV11LoginModeEnum added in v0.1.7

func GetCreateClusterReqV11LoginModeEnum() CreateClusterReqV11LoginModeEnum

type CreateClusterReqV11MasterDataVolumeCount added in v0.1.7

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

func (CreateClusterReqV11MasterDataVolumeCount) MarshalJSON added in v0.1.7

func (*CreateClusterReqV11MasterDataVolumeCount) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11MasterDataVolumeCount) Value added in v0.1.7

type CreateClusterReqV11MasterDataVolumeCountEnum added in v0.1.7

type CreateClusterReqV11MasterDataVolumeCountEnum struct {
	E_1 CreateClusterReqV11MasterDataVolumeCount
}

func GetCreateClusterReqV11MasterDataVolumeCountEnum added in v0.1.7

func GetCreateClusterReqV11MasterDataVolumeCountEnum() CreateClusterReqV11MasterDataVolumeCountEnum

type CreateClusterReqV11MasterDataVolumeType added in v0.1.7

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

func (CreateClusterReqV11MasterDataVolumeType) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11MasterDataVolumeType) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11MasterDataVolumeType) Value added in v0.1.7

type CreateClusterReqV11SafeMode added in v0.1.7

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

func (CreateClusterReqV11SafeMode) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11SafeMode) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11SafeMode) Value added in v0.1.7

type CreateClusterReqV11SafeModeEnum added in v0.1.7

type CreateClusterReqV11SafeModeEnum struct {
	E_0 CreateClusterReqV11SafeMode
	E_1 CreateClusterReqV11SafeMode
}

func GetCreateClusterReqV11SafeModeEnum added in v0.1.7

func GetCreateClusterReqV11SafeModeEnum() CreateClusterReqV11SafeModeEnum

type CreateClusterReqV11VolumeType added in v0.1.7

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

func (CreateClusterReqV11VolumeType) MarshalJSON added in v0.1.7

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

func (*CreateClusterReqV11VolumeType) UnmarshalJSON added in v0.1.7

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

func (CreateClusterReqV11VolumeType) Value added in v0.1.7

type CreateClusterReqV11VolumeTypeEnum added in v0.1.7

func GetCreateClusterReqV11VolumeTypeEnum added in v0.1.7

func GetCreateClusterReqV11VolumeTypeEnum() CreateClusterReqV11VolumeTypeEnum

type CreateClusterRequest

type CreateClusterRequest struct {
	Body *CreateClusterReqV11 `json:"body,omitempty"`
}

CreateClusterRequest Request Object

func (CreateClusterRequest) String

func (o CreateClusterRequest) String() string

type CreateClusterResponse

type CreateClusterResponse struct {

	// 操作结果。 - true:操作成功 - false:操作失败
	Result *bool `json:"result,omitempty"`

	// 系统提示信息,可为空。
	Msg *string `json:"msg,omitempty"`

	// 集群创建成功后系统返回的集群ID值。
	ClusterId      *string `json:"cluster_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateClusterResponse Response Object

func (CreateClusterResponse) String

func (o CreateClusterResponse) String() string

type CreateClusterTagRequest

type CreateClusterTagRequest struct {

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

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

CreateClusterTagRequest Request Object

func (CreateClusterTagRequest) String

func (o CreateClusterTagRequest) String() string

type CreateClusterTagResponse

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

CreateClusterTagResponse Response Object

func (CreateClusterTagResponse) String

func (o CreateClusterTagResponse) String() string

type CreateScalingPolicyRequest added in v0.0.73

type CreateScalingPolicyRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`

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

CreateScalingPolicyRequest Request Object

func (CreateScalingPolicyRequest) String added in v0.0.73

type CreateScalingPolicyResponse added in v0.0.73

type CreateScalingPolicyResponse struct {

	// 操作结果。 - succeeded:操作成功 - 操作失败时返回的错误码信息如[错误码](https://support.huaweicloud.com/api-mrs/ErrorCode.html)所示。
	Result         *string `json:"result,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateScalingPolicyResponse Response Object

func (CreateScalingPolicyResponse) String added in v0.0.73

type CreateTagReq

type CreateTagReq struct {
	Tag *Tag `json:"tag"`
}

func (CreateTagReq) String

func (o CreateTagReq) String() string

type DeleteClusterRequest

type DeleteClusterRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`
}

DeleteClusterRequest Request Object

func (DeleteClusterRequest) String

func (o DeleteClusterRequest) String() string

type DeleteClusterResponse

type DeleteClusterResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteClusterResponse Response Object

func (DeleteClusterResponse) String

func (o DeleteClusterResponse) String() string

type DeleteClusterTagRequest

type DeleteClusterTagRequest struct {

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

	// 键。标签的key值
	Key string `json:"key"`
}

DeleteClusterTagRequest Request Object

func (DeleteClusterTagRequest) String

func (o DeleteClusterTagRequest) String() string

type DeleteClusterTagResponse

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

DeleteClusterTagResponse Response Object

func (DeleteClusterTagResponse) String

func (o DeleteClusterTagResponse) String() string

type DeleteJobExecutionRequest added in v0.0.73

type DeleteJobExecutionRequest struct {

	// 作业ID。
	JobExecutionId string `json:"job_execution_id"`
}

DeleteJobExecutionRequest Request Object

func (DeleteJobExecutionRequest) String added in v0.0.73

func (o DeleteJobExecutionRequest) String() string

type DeleteJobExecutionResponse added in v0.0.73

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

DeleteJobExecutionResponse Response Object

func (DeleteJobExecutionResponse) String added in v0.0.73

type FlavorLists added in v0.1.72

type FlavorLists struct {

	// master节点支持的规格列表
	Master *[]string `json:"master,omitempty"`

	// core节点支持的规格列表
	Core *[]string `json:"core,omitempty"`

	// task节点支持的规格列表
	Task *[]string `json:"task,omitempty"`
}

FlavorLists 支持规格列表

func (FlavorLists) String added in v0.1.72

func (o FlavorLists) String() string

type HostModel added in v0.0.73

type HostModel struct {

	// 虚拟机ID
	Id *string `json:"id,omitempty"`

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

	// 虚拟机IP地址
	Ip *string `json:"ip,omitempty"`

	// 可用区域
	AvailabilityZoneId *string `json:"availability_zone_id,omitempty"`

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

	// 虚拟机当前状态
	Status *string `json:"status,omitempty"`

	// 节点资源ID
	ResourceId *string `json:"resource_id,omitempty"`

	// 虚拟机规格ID
	Flavor *string `json:"flavor,omitempty"`

	// 虚拟机类型,当前支持MasterNode,CoreNode,TaskNode
	Type *string `json:"type,omitempty"`

	// 内存
	Mem *string `json:"mem,omitempty"`

	// CPU核数
	Cpu *string `json:"cpu,omitempty"`

	// 操作系统盘容量
	RootVolumeSize *string `json:"root_volume_size,omitempty"`

	// 数据盘类型
	DataVolumeType *string `json:"data_volume_type,omitempty"`

	// 数据盘容量
	DataVolumeSize *int32 `json:"data_volume_size,omitempty"`

	// 数据盘个数
	DataVolumeCount *int32 `json:"data_volume_count,omitempty"`

	// 节点组名称
	NodeGroupName *string `json:"node_group_name,omitempty"`
}

func (HostModel) String added in v0.0.73

func (o HostModel) String() string

type JobExeResult added in v0.0.73

type JobExeResult struct {

	// 作业ID。
	Id string `json:"id"`

	// 作业创建时间,十三位时间戳。
	CreateAt int64 `json:"create_at"`

	// 作业更新时间,十三位时间戳。
	UpdateAt int64 `json:"update_at"`

	// 项目编号。获取方法,请参见[获取项目ID](https://support.huaweicloud.com/api-mrs/mrs_02_0011.html)。
	TenantId string `json:"tenant_id"`

	// 作业ID。
	JobId string `json:"job_id"`

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

	// 作业执行开始时间,十三位时间戳。
	StartTime int64 `json:"start_time"`

	// 作业执行结束时间,十三位时间戳。
	EndTime int64 `json:"end_time"`

	// 作业所属集群ID。
	ClusterId string `json:"cluster_id"`

	// 作业执行组ID
	GroupId string `json:"group_id"`

	// 执行程序jar包或sql文件地址。
	JarPath string `json:"jar_path"`

	// 数据输入地址。
	Input string `json:"input"`

	// 数据输出地址。
	Output *string `json:"output,omitempty"`

	// 作业日志存储地址
	JobLog string `json:"job_log"`

	// 作业类型码。  - 1:MapReduce - 2:Spark - 3:Hive Script - 4:HiveSQL(当前不支持) - 5:DistCp - 6:Spark Script - 7:Spark SQL(该接口当前不支持)
	JobType int32 `json:"job_type"`

	// 导入导出数据。
	FileAction string `json:"file_action"`

	// 程序执行的关键参数,该参数由用户程序内的函数指定,MRS只负责参数的传入。该参数可为空。
	Arguments string `json:"arguments"`

	// HQL脚本语句。
	Hql string `json:"hql"`

	// 作业状态编码:  - 1:Terminated表示已终止的作业状态 - 2:Running表示运行中的作业状态 - 3:Completed表示已完成的作业状态 - 4:Abnormal表示异常的作业状态
	JobState int32 `json:"job_state"`

	// 作业最终状态码。  - 0:未完成 - 1:执行错误,终止执行 - 2:执行完成并且成功 - 3:已取消
	JobFinalStatus int32 `json:"job_final_status"`

	// Hive脚本地址。
	HiveScriptPath string `json:"hive_script_path"`

	// 创建作业的用户ID。
	CreateBy string `json:"create_by"`

	// 当前已完成的步骤数。
	FinishedStep int32 `json:"finished_step"`

	// 作业主ID。
	JobMainId string `json:"job_main_id"`

	// 作业步骤ID。
	JobStepId string `json:"job_step_id"`

	// 延迟时间,十三位时间戳。
	PostponeAt int64 `json:"postpone_at"`

	// 作业步骤名。
	StepName string `json:"step_name"`

	// 步骤数量。
	StepNum int32 `json:"step_num"`

	// 任务数量。
	TaskNum int32 `json:"task_num"`

	// 更新作业的用户ID。
	UpdateBy string `json:"update_by"`

	// 作业执行持续时间,单位:秒。
	SpendTime float32 `json:"spend_time"`

	// 步骤序列号。
	StepSeq int32 `json:"step_seq"`

	// 作业执行进度。
	Progress string `json:"progress"`
}

func (JobExeResult) String added in v0.0.73

func (o JobExeResult) String() string

type ListAllTagsRequest

type ListAllTagsRequest struct {
}

ListAllTagsRequest Request Object

func (ListAllTagsRequest) String

func (o ListAllTagsRequest) String() string

type ListAllTagsResponse

type ListAllTagsResponse struct {

	// 标签列表信息
	Tags           *[]TagWithMultiValue `json:"tags,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

ListAllTagsResponse Response Object

func (ListAllTagsResponse) String

func (o ListAllTagsResponse) String() string

type ListAvailableZonesRequest added in v0.1.43

type ListAvailableZonesRequest struct {

	// 区域id,例如cn-north-4
	RegionId string `json:"region_id"`

	// 可用区范围
	Scope *ListAvailableZonesRequestScope `json:"scope,omitempty"`
}

ListAvailableZonesRequest Request Object

func (ListAvailableZonesRequest) String added in v0.1.43

func (o ListAvailableZonesRequest) String() string

type ListAvailableZonesRequestScope added in v0.1.43

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

func (ListAvailableZonesRequestScope) MarshalJSON added in v0.1.43

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

func (*ListAvailableZonesRequestScope) UnmarshalJSON added in v0.1.43

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

func (ListAvailableZonesRequestScope) Value added in v0.1.43

type ListAvailableZonesRequestScopeEnum added in v0.1.43

type ListAvailableZonesRequestScopeEnum struct {
	CENTER ListAvailableZonesRequestScope
	EDGE   ListAvailableZonesRequestScope
}

func GetListAvailableZonesRequestScopeEnum added in v0.1.43

func GetListAvailableZonesRequestScopeEnum() ListAvailableZonesRequestScopeEnum

type ListAvailableZonesResponse added in v0.1.43

type ListAvailableZonesResponse struct {

	// 可用区列表
	AvailableZones *[]AvailableZoneV2 `json:"available_zones,omitempty"`

	// 默认可用区编码
	DefaultAzCode *string `json:"default_az_code,omitempty"`

	// 支持的物理可用区分组
	SupportPhysicalAzGroup *bool `json:"support_physical_az_group,omitempty"`
	HttpStatusCode         int   `json:"-"`
}

ListAvailableZonesResponse Response Object

func (ListAvailableZonesResponse) String added in v0.1.43

type ListClusterTagsRequest

type ListClusterTagsRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`
}

ListClusterTagsRequest Request Object

func (ListClusterTagsRequest) String

func (o ListClusterTagsRequest) String() string

type ListClusterTagsResponse

type ListClusterTagsResponse struct {

	// 标签列表
	Tags           *[]TagPlain `json:"tags,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ListClusterTagsResponse Response Object

func (ListClusterTagsResponse) String

func (o ListClusterTagsResponse) String() string

type ListClustersByTagsRequest

type ListClustersByTagsRequest struct {
	Body *ListResourceReq `json:"body,omitempty"`
}

ListClustersByTagsRequest Request Object

func (ListClustersByTagsRequest) String

func (o ListClustersByTagsRequest) String() string

type ListClustersByTagsResponse

type ListClustersByTagsResponse struct {

	// 资源列表
	Resources *[]MrsResource `json:"resources,omitempty"`

	// 资源总数
	TotalCount     *int32 `json:"total_count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListClustersByTagsResponse Response Object

func (ListClustersByTagsResponse) String

type ListClustersRequest added in v0.0.51

type ListClustersRequest struct {

	// 可以通过集群的标签来搜索指定标签的集群,当指定多个tag进行查询时,标签之间是与的关系。  - tags参数的格式为tags=k1*v1,k2*v2,k3*v3 - 当标签的value为空时,格式为tags=k1,k2,k3*v3
	Tags *string `json:"tags,omitempty"`

	// 分页查询每页返回的最大集群数量。  取值范围:[1~2147483646]
	PageSize *string `json:"pageSize,omitempty"`

	// 当前查询页码。
	CurrentPage *string `json:"currentPage,omitempty"`

	// 集群名称。
	ClusterName *string `json:"clusterName,omitempty"`

	// 根据集群状态查询集群列表。 - existing:查询现有集群列表,包括除“已删除”、包周期集群的“订单处理中”和“准备中”状态外的所有集群。 - history:查询历史集群列表,包括所有“已删除”、删除集群失败、集群删除虚拟机失败、删除集群更新数据库失败等状态的集群。 - starting:查询启动中的集群列表。 - running:查询运行中的集群列表。 - terminated:查询已删除的集群列表。 - failed:查询失败的集群列表。 - abnormal:查询异常的集群列表。 - terminating:查询删除中的集群列表。 - frozen:查询已冻结的集群列表。 - scaling-out:查询扩容中的集群列表。 - scaling-in:查询缩容中的集群列表。
	ClusterState *string `json:"clusterState,omitempty"`

	// 通过企业项目ID来搜索指定项目的集群。  该参数默认设置为0,表示为default企业项目。  获取方式请参见《企业管理API参考》的“查询企业项目列表”响应消息表“enterprise_project字段数据结构说明”的“id”。
	EnterpriseProjectId *string `json:"enterpriseProjectId,omitempty"`
}

ListClustersRequest Request Object

func (ListClustersRequest) String added in v0.0.51

func (o ListClustersRequest) String() string

type ListClustersResponse added in v0.0.51

type ListClustersResponse struct {

	// 集群列表总数。
	ClusterTotal *int32 `json:"clusterTotal,omitempty"`

	// 集群参数。
	Clusters       *[]Cluster `json:"clusters,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ListClustersResponse Response Object

func (ListClustersResponse) String added in v0.0.51

func (o ListClustersResponse) String() string

type ListExecuteJobRequest added in v0.0.73

type ListExecuteJobRequest struct {

	// 分页查询每页返回的最大作业数量。  取值范围:[1~100]
	PageSize *string `json:"page_size,omitempty"`

	// 当前查询页码。
	CurrentPage *string `json:"current_page,omitempty"`

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

	// 集群编号。
	ClusterId string `json:"cluster_id"`

	// 作业状态编码:  - 1:Terminated表示已终止的作业状态 - 2:Running表示运行中的作业状态 - 3:Completed表示已完成的作业状态 - 4:Abnormal表示异常的作业状态
	State *string `json:"state,omitempty"`

	// 作业执行对象的编号。
	Id *string `json:"id,omitempty"`
}

ListExecuteJobRequest Request Object

func (ListExecuteJobRequest) String added in v0.0.73

func (o ListExecuteJobRequest) String() string

type ListExecuteJobResponse added in v0.0.73

type ListExecuteJobResponse struct {

	// 作业列表总数。
	TotalRecord *int32 `json:"totalRecord,omitempty"`

	// 作业列表。
	JobExecutions  *[]JobExeResult `json:"job_executions,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListExecuteJobResponse Response Object

func (ListExecuteJobResponse) String added in v0.0.73

func (o ListExecuteJobResponse) String() string

type ListHostsRequest added in v0.0.73

type ListHostsRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`

	// 分页查询每页返回的最大集群数量。 取值范围:[1~2147483646] 默认值为10。
	PageSize *string `json:"pageSize,omitempty"`

	// 当前查询页码。默认值为1。
	CurrentPage *string `json:"currentPage,omitempty"`
}

ListHostsRequest Request Object

func (ListHostsRequest) String added in v0.0.73

func (o ListHostsRequest) String() string

type ListHostsResponse added in v0.0.73

type ListHostsResponse struct {

	// 主机参数。
	Hosts *[]HostModel `json:"hosts,omitempty"`

	// 主机列表总数。
	Total          *int32 `json:"total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListHostsResponse Response Object

func (ListHostsResponse) String added in v0.0.73

func (o ListHostsResponse) String() string

type ListResourceReq

type ListResourceReq struct {

	// 返回结果包含该参数中所有标签对应的资源,该参数最多包含10个key,每个key下面的value最多10个,结构体不能缺失,key不能为空或者空字符串。
	Tags *[]TagWithMultiValue `json:"tags,omitempty"`

	// 返回结果包含该参数中任意一个标签对应的资源,该参数最多包含10个key,每个key下面的value最多10个,结构体不能缺失,key不能为空或者空字符串。Key不能重复,同一个key中values不能重复。
	TagsAny *[]TagWithMultiValue `json:"tags_any,omitempty"`

	// 返回结果不包含该参数中所有标签对应的资源,该参数最多包含10个key,每个key下面的value最多10个, 结构体不能缺失,key不能为空或者空字符串。Key不能重复,同一个key中values不能重复。
	NotTags *[]TagWithMultiValue `json:"not_tags,omitempty"`

	// 返回结果不包含该参数中任意一个标签对应的资源,该参数最多包含10个key,每个key下面的value最多10个,结构体不能缺失,key不能为空或者空字符串。Key不能重复,同一个key中values不能重复。
	NotTagsAny *[]TagWithMultiValue `json:"not_tags_any,omitempty"`

	// 操作标识(仅限于filter,count):filter(过滤),count(查询总条数)。  如果是filter则为分页查询,如果是count会按照条件将总条数返回。
	Action ListResourceReqAction `json:"action"`

	// 查询记录数(action为count时无此参数)如果action为filter默认为1000,limit最多为1000,不能为负数,最小值为1。
	Limit *int32 `json:"limit,omitempty"`

	// (索引位置),从offset指定的下一条数据开始查询。查询第一页数据时,不需要传入此参数,查询后续页码数据时,将查询前一页数据时响应体中的值带入此参数(action为count时无此参数)如果action为filter默认为0,必须为数字,不能为负数。
	Offset *int32 `json:"offset,omitempty"`

	// 搜索字段,key为要匹配的字段,如resource_name等。value为匹配的值。此字段为固定字典值。 根据不同的字段确认是否需要模糊匹配,如resource_name默认为模糊搜索,如果value为空字符串精确匹配。
	Matches *[]Match `json:"matches,omitempty"`
}

func (ListResourceReq) String

func (o ListResourceReq) String() string

type ListResourceReqAction

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

func (ListResourceReqAction) MarshalJSON

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

func (*ListResourceReqAction) UnmarshalJSON

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

func (ListResourceReqAction) Value added in v0.0.90

func (c ListResourceReqAction) Value() string

type ListResourceReqActionEnum

type ListResourceReqActionEnum struct {
	FILTER ListResourceReqAction
	COUNT  ListResourceReqAction
}

func GetListResourceReqActionEnum

func GetListResourceReqActionEnum() ListResourceReqActionEnum

type Match

type Match struct {

	// 键。当前只有resource_name可用,表示集群的名称,后续扩展。
	Key *string `json:"key,omitempty"`

	// 值。每个值最大长度64个unicode字符。
	Value *string `json:"value,omitempty"`
}

func (Match) String

func (o Match) String() string

type MrsResource

type MrsResource struct {

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

	// 资源详情
	ResourceDetail *string `json:"resource_detail,omitempty"`

	// 标签
	Tags *[]TagPlain `json:"tags,omitempty"`

	// 资源名称
	ResourceName *string `json:"resource_name,omitempty"`
}

func (MrsResource) String

func (o MrsResource) String() string

type NodeConstraint added in v0.1.72

type NodeConstraint struct {

	// 其他限制
	Other map[string]interface{} `json:"other,omitempty"`

	// 最少节点数
	MinNodeNum *int32 `json:"min_node_num,omitempty"`

	// 最多节点数
	MaxNodeNum *int32 `json:"max_node_num,omitempty"`

	// 最少核心数
	MinCoreNum map[string]int32 `json:"min_core_num,omitempty"`

	// 最小内存容量
	MinMemSize map[string]int32 `json:"min_mem_size,omitempty"`

	// 最小磁盘容量
	MinDiskSize *int32 `json:"min_disk_size,omitempty"`

	// 最大节点组数
	MaxNodeGroupNum *int32 `json:"max_node_group_num,omitempty"`

	// 最小数据卷容量
	MinDataVolumeTotalSize map[string]int32 `json:"min_data_volume_total_size,omitempty"`

	// 磁盘类型限制,包含当前节点组所支持的磁盘类型
	DiskTypeConstraint map[string]string `json:"disk_type_constraint,omitempty"`

	// 最小系统磁盘大小
	MinRootDiskSize *int32 `json:"min_root_disk_size,omitempty"`
}

NodeConstraint 节点限制

func (NodeConstraint) String added in v0.1.72

func (o NodeConstraint) String() string

type NodeConstraints added in v0.1.72

type NodeConstraints struct {

	// 其他节点限制
	Other map[string]interface{} `json:"other,omitempty"`

	Master *NodeConstraint `json:"master,omitempty"`

	Core *NodeConstraint `json:"core,omitempty"`

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

	CoreSeparate *NodeConstraint `json:"core_separate,omitempty"`

	CoreCombine *NodeConstraint `json:"core_combine,omitempty"`

	TaskSeparate *NodeConstraint `json:"task_separate,omitempty"`

	TaskCombine *NodeConstraint `json:"task_combine,omitempty"`

	NodeGroupTask *NodeConstraint `json:"node_group_task,omitempty"`
}

NodeConstraints 节点限制

func (NodeConstraints) String added in v0.1.72

func (o NodeConstraints) String() string

type NodeGroupV10 added in v0.0.51

type NodeGroupV10 struct {

	// 节点组名。
	GroupName *string `json:"GroupName,omitempty"`

	// 节点数量,取值范围0~500,Master节点和Core节点数量至少为1,Core与Task节点总数最大为500个。
	NodeNum *int32 `json:"NodeNum,omitempty"`

	// 节点的实例规格。
	NodeSize *string `json:"NodeSize,omitempty"`

	// 节点实例规格ID。
	NodeSpecId *string `json:"NodeSpecId,omitempty"`

	// 节点虚拟机产品ID。
	VmProductId *string `json:"VmProductId,omitempty"`

	// 节点虚拟机产品规格。
	VmSpecCode *string `json:"VmSpecCode,omitempty"`

	// 节点实例产品ID。
	NodeProductId *string `json:"NodeProductId,omitempty"`

	// 节点系统盘大小,不可配置,默认为40GB。
	RootVolumeSize *int32 `json:"RootVolumeSize,omitempty"`

	// 节点系统盘的产品ID。
	RootVolumeProductId *string `json:"RootVolumeProductId,omitempty"`

	// 节点系统盘的类型。
	RootVolumeType *string `json:"RootVolumeType,omitempty"`

	// 节点系统盘产品规格。
	RootVolumeResourceSpecCode *string `json:"RootVolumeResourceSpecCode,omitempty"`

	// 节点系统盘产品类型。
	RootVolumeResourceType *string `json:"RootVolumeResourceType,omitempty"`

	// 节点数据磁盘存储类别,目前支持SATA、SAS和SSD。  - SATA:普通IO - SAS:高IO - SSD:超高IO
	DataVolumeType *NodeGroupV10DataVolumeType `json:"DataVolumeType,omitempty"`

	// 节点数据磁盘存储数目。
	DataVolumeCount *int32 `json:"DataVolumeCount,omitempty"`

	// 节点数据磁盘存储大小。
	DataVolumeSize *int32 `json:"DataVolumeSize,omitempty"`

	// 节点数据磁盘的产品ID。
	DataVolumeProductId *string `json:"DataVolumeProductId,omitempty"`

	// 节点数据磁盘的产品规格。
	DataVolumeResourceSpecCode *string `json:"DataVolumeResourceSpecCode,omitempty"`

	// 节点数据磁盘的产品类型。
	DataVolumeResourceType *string `json:"DataVolumeResourceType,omitempty"`
}

func (NodeGroupV10) String added in v0.0.51

func (o NodeGroupV10) String() string

type NodeGroupV10DataVolumeType added in v0.0.51

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

func (NodeGroupV10DataVolumeType) MarshalJSON added in v0.0.51

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

func (*NodeGroupV10DataVolumeType) UnmarshalJSON added in v0.0.51

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

func (NodeGroupV10DataVolumeType) Value added in v0.0.90

type NodeGroupV10DataVolumeTypeEnum added in v0.0.51

type NodeGroupV10DataVolumeTypeEnum struct {
	SATA  NodeGroupV10DataVolumeType
	SAS   NodeGroupV10DataVolumeType
	SSD   NodeGroupV10DataVolumeType
	GPSSD NodeGroupV10DataVolumeType
}

func GetNodeGroupV10DataVolumeTypeEnum added in v0.0.51

func GetNodeGroupV10DataVolumeTypeEnum() NodeGroupV10DataVolumeTypeEnum

type NodeGroupV11 added in v0.0.47

type NodeGroupV11 struct {

	// 节点组名。 - master_node_default_group - core_node_analysis_group - core_node_streaming_group - task_node_analysis_group - task_node_streaming_group
	GroupName string `json:"group_name"`

	// 节点数量,取值范围0~500,Core与Task节点总数最大为500个。
	NodeNum int32 `json:"node_num"`

	// 节点的实例规格,例如:c3.4xlarge.2.linux.bigdata。MRS当前支持主机规格的配型由CPU+内存+Disk共同决定。实例规格详细说明请参见[MRS所使用的弹性云服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9006.html)和[MRS所使用的裸金属服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9001.html)。 该参数建议从MRS控制台的集群创建页面获取对应区域对应版本所支持的规格。
	NodeSize string `json:"node_size"`

	// 节点系统磁盘存储大小。
	RootVolumeSize *string `json:"root_volume_size,omitempty"`

	// 节点系统磁盘存储类别,目前支持SATA、SAS和SSD。 - SATA:普通IO - SAS:高IO - SSD:超高IO - GPSSD:通用型SSD
	RootVolumeType *string `json:"root_volume_type,omitempty"`

	// 节点数据磁盘存储类别,目前支持SATA、SAS和SSD。 - SATA:普通IO - SAS:高IO - SSD:超高IO - GPSSD:通用型SSD
	DataVolumeType *string `json:"data_volume_type,omitempty"`

	// 节点数据磁盘存储数目 取值范围:0~20。
	DataVolumeCount *int32 `json:"data_volume_count,omitempty"`

	// 节点数据磁盘存储大小 取值范围:100GB~32000GB。
	DataVolumeSize *int32 `json:"data_volume_size,omitempty"`

	AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy,omitempty"`
}

func (NodeGroupV11) String added in v0.0.47

func (o NodeGroupV11) String() string

type ResourcesPlan

type ResourcesPlan struct {

	// 资源计划的周期类型,当前只允许以下类型:  daily
	PeriodType string `json:"period_type"`

	// 资源计划的起始时间,格式为“hour:minute”,表示时间在0:00-23:59之间。
	StartTime string `json:"start_time"`

	// 资源计划的结束时间,格式与“start_time”相同,不早于start_time表示的时间,且与start_time间隔不小于30min。
	EndTime string `json:"end_time"`

	// 资源计划内该节点组的最小保留节点数。  取值范围:[0~500]
	MinCapacity int32 `json:"min_capacity"`

	// 资源计划内该节点组的最大保留节点数。  取值范围:[0~500]
	MaxCapacity int32 `json:"max_capacity"`
}

func (ResourcesPlan) String

func (o ResourcesPlan) String() string

type RoleDeployMeta added in v0.1.72

type RoleDeployMeta struct {

	// 其他扩展属性
	Other map[string]interface{} `json:"other,omitempty"`

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

	// 角色简称
	CodeName *string `json:"code_name,omitempty"`

	// 角色所属组件
	Component *string `json:"component,omitempty"`

	// 部署倾向
	NodePreference *string `json:"node_preference,omitempty"`

	// 角色数量限制
	Count *string `json:"count,omitempty"`

	// 亲和
	Affinity *string `json:"affinity,omitempty"`

	// 亲和目标
	AffinityTarget *string `json:"affinity_target,omitempty"`

	// 多实例
	MultiInstance *int32 `json:"multi_instance,omitempty"`

	// 角色类型
	RoleKind *string `json:"role_kind,omitempty"`

	// 角色限制,包含当前组件角色的一些功能限制,例如:\"no_scale_in\"
	Constraints *[]string `json:"constraints,omitempty"`

	// 多az部署
	MultiAzPlacement *string `json:"multi_az_placement,omitempty"`

	// 仲裁部署
	ArbitrationDeployment *bool `json:"arbitration_deployment,omitempty"`

	// 支持ELB
	SupportElb *bool `json:"support_elb,omitempty"`

	// 启用多亲和组
	MultiAffinityGroupEnable *bool `json:"multi_affinity_group_enable,omitempty"`

	// 本地盘反亲和
	LocalDisksAntiAffinity *bool `json:"local_disks_anti_affinity,omitempty"`

	// 多实例名称模式
	MultiInstanceNamePattern *string `json:"multi_instance_name_pattern,omitempty"`

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

	// 权重
	Weight *string `json:"weight,omitempty"`
}

RoleDeployMeta 角色部署元数据

func (RoleDeployMeta) String added in v0.1.72

func (o RoleDeployMeta) String() string

type Rule added in v0.1.7

type Rule struct {

	// 弹性伸缩规则的名称。  只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。  在一个节点组范围内,不允许重名。
	Name string `json:"name"`

	// 弹性伸缩规则的说明。  最大长度为1024字符。
	Description *string `json:"description,omitempty"`

	// 弹性伸缩规则的调整类型,只允许以下类型:  枚举值: - scale_out:扩容 - scale_in:缩容
	AdjustmentType RuleAdjustmentType `json:"adjustment_type"`

	// 触发弹性伸缩规则后,该集群处于冷却状态(不再执行弹性伸缩操作)的时长,单位为分钟。  取值范围[0~10080],10080为一周的分钟数。
	CoolDownMinutes int32 `json:"cool_down_minutes"`

	// 单次调整集群节点的个数。  取值范围[1~100]
	ScalingAdjustment int32 `json:"scaling_adjustment"`

	Trigger *Trigger `json:"trigger"`
}

func (Rule) String added in v0.1.7

func (o Rule) String() string

type RuleAdjustmentType added in v0.1.7

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

func (RuleAdjustmentType) MarshalJSON added in v0.1.7

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

func (*RuleAdjustmentType) UnmarshalJSON added in v0.1.7

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

func (RuleAdjustmentType) Value added in v0.1.7

func (c RuleAdjustmentType) Value() string

type RuleAdjustmentTypeEnum added in v0.1.7

type RuleAdjustmentTypeEnum struct {
	SCALE_OUT RuleAdjustmentType
	SCALE_IN  RuleAdjustmentType
}

func GetRuleAdjustmentTypeEnum added in v0.1.7

func GetRuleAdjustmentTypeEnum() RuleAdjustmentTypeEnum

type ScaleScript

type ScaleScript struct {

	// 弹性伸缩自定义自动化脚本的名称,同一个集群的自定义自动化脚本名称不允许相同。  只能由数字、英文字符、空格、中划线和下划线组成,且不能以空格开头。  可输入的字符串长度为1~64个字符。
	Name string `json:"name"`

	// 自定义自动化脚本的路径。设置为OBS桶的路径或虚拟机本地的路径。  - OBS桶的路径:直接手动输入脚本路径。示例:s3a://XXX/scale.sh  - 虚拟机本地的路径:用户需要输入正确的脚本路径。脚本所在的路径必须以‘/’开头,以.sh结尾。
	Uri string `json:"uri"`

	// 自定义自动化脚本参数。  多个参数间用空格隔开。 可以传入以下系统预定义参数: - ${mrs_scale_node_num}:扩缩容节点数 - ${mrs_scale_type}:扩缩容类型,扩容为scale_out,缩容为scale_in - ${mrs_scale_node_hostnames}:扩缩容的节点主机名称 - ${mrs_scale_node_ips}:扩缩容的节点IP - ${mrs_scale_rule_name}:触发扩缩容的规则名   其他用户自定义参数使用方式与普通shell脚本相同,多个参数中间用空格隔开。
	Parameters *string `json:"parameters,omitempty"`

	// 自定义自动化脚本所执行的节点组名称(非自定义集群也可使用节点类型,包含Master、Core和Task三种类型)。
	Nodes []string `json:"nodes"`

	// 自定义自动化脚本是否只运行在主Master节点上。  缺省值为false,表示自定义自动化脚本可运行在所有Master节点上。
	ActiveMaster *bool `json:"active_master,omitempty"`

	// 自自定义自动化脚本执行失败后,是否继续执行后续脚本和创建集群。  说明:  - 建议您在调试阶段设置为“continue”,无论此自定义自动化脚本是否执行成功,则集群都能继续安装和启动。  - 由于缩容成功无法回滚,因此缩容后执行的脚本“fail_action”必须设置为“continue”。  枚举值: - continue:继续执行后续脚本。 - errorout:终止操作。
	FailAction ScaleScriptFailAction `json:"fail_action"`

	// 脚本执行时机。  枚举值: - before_scale_out:扩容前 - before_scale_in:缩容前 - after_scale_out:扩容后 - after_scale_in:缩容后
	ActionStage ScaleScriptActionStage `json:"action_stage"`
}

func (ScaleScript) String

func (o ScaleScript) String() string

type ScaleScriptActionStage

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

func (ScaleScriptActionStage) MarshalJSON

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

func (*ScaleScriptActionStage) UnmarshalJSON

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

func (ScaleScriptActionStage) Value added in v0.0.90

func (c ScaleScriptActionStage) Value() string

type ScaleScriptActionStageEnum

type ScaleScriptActionStageEnum struct {
	BEFORE_SCALE_OUT ScaleScriptActionStage
	BEFORE_SCALE_IN  ScaleScriptActionStage
	AFTER_SCALE_OUT  ScaleScriptActionStage
	AFTER_SCALE_IN   ScaleScriptActionStage
}

func GetScaleScriptActionStageEnum

func GetScaleScriptActionStageEnum() ScaleScriptActionStageEnum

type ScaleScriptFailAction

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

func (ScaleScriptFailAction) MarshalJSON

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

func (*ScaleScriptFailAction) UnmarshalJSON

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

func (ScaleScriptFailAction) Value added in v0.0.90

func (c ScaleScriptFailAction) Value() string

type ScaleScriptFailActionEnum

type ScaleScriptFailActionEnum struct {
	CONTINUE ScaleScriptFailAction
	ERROROUT ScaleScriptFailAction
}

func GetScaleScriptFailActionEnum

func GetScaleScriptFailActionEnum() ScaleScriptFailActionEnum

type ShowClusterDetailsRequest added in v0.0.73

type ShowClusterDetailsRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`
}

ShowClusterDetailsRequest Request Object

func (ShowClusterDetailsRequest) String added in v0.0.73

func (o ShowClusterDetailsRequest) String() string

type ShowClusterDetailsResponse added in v0.0.73

type ShowClusterDetailsResponse struct {
	Cluster        *Cluster `json:"cluster,omitempty"`
	HttpStatusCode int      `json:"-"`
}

ShowClusterDetailsResponse Response Object

func (ShowClusterDetailsResponse) String added in v0.0.73

type ShowJobExesRequest added in v0.0.73

type ShowJobExesRequest struct {

	// 作业ID。
	JobExeId string `json:"job_exe_id"`
}

ShowJobExesRequest Request Object

func (ShowJobExesRequest) String added in v0.0.73

func (o ShowJobExesRequest) String() string

type ShowJobExesResponse added in v0.0.73

type ShowJobExesResponse struct {
	JobExecution   *JobExeResult `json:"job_execution,omitempty"`
	HttpStatusCode int           `json:"-"`
}

ShowJobExesResponse Response Object

func (ShowJobExesResponse) String added in v0.0.73

func (o ShowJobExesResponse) String() string

type ShowMrsVersionMetadataRequest added in v0.1.72

type ShowMrsVersionMetadataRequest struct {

	// 集群版本。例如“MRS 3.1.0”。如果请求客户端不支持自动转义,则需要将空格转义为%20,例如“MRS%203.1.0”。
	VersionName string `json:"version_name"`

	// 集群ID。如果指定集群ID,则获取该集群做过补丁更新的最新版本元数据。
	ClusterId *string `json:"cluster_id,omitempty"`
}

ShowMrsVersionMetadataRequest Request Object

func (ShowMrsVersionMetadataRequest) String added in v0.1.72

type ShowMrsVersionMetadataResponse added in v0.1.72

type ShowMrsVersionMetadataResponse struct {

	// 其他
	Other map[string]interface{} `json:"other,omitempty"`

	// 镜像版本名称
	Name *string `json:"name,omitempty"`

	// 模板类型
	TemplateType *string `json:"template_type,omitempty"`

	// 镜像ID
	ImageId *string `json:"image_id,omitempty"`

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

	// 特性列表
	Features *[]string `json:"features,omitempty"`

	// 集群类型列表
	ClusterTypes *[]string `json:"cluster_types,omitempty"`

	// 版本类型
	VersionType *string `json:"version_type,omitempty"`

	// 组件列表
	Components *[]VersionComponent `json:"components,omitempty"`

	// 版本所需的ip等资源说明
	ResourceRequirement *[]string `json:"resource_requirement,omitempty"`

	Constraints *VersionConstraint `json:"constraints,omitempty"`

	Flavors *FlavorLists `json:"flavors,omitempty"`

	// 版本组件实例角色部署策略
	RoleDeployMeta *[]RoleDeployMeta `json:"role_deploy_meta,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ShowMrsVersionMetadataResponse Response Object

func (ShowMrsVersionMetadataResponse) String added in v0.1.72

type SubmitJobReqV11 added in v0.0.73

type SubmitJobReqV11 struct {

	// 作业名称,只能由字母、数字、中划线和下划线组成,并且长度为1~64个字符。  说明: 不同作业的名称允许相同,但不建议设置相同。
	JobName string `json:"job_name"`

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

	// 执行程序Jar包或sql文件地址,需要满足如下要求: - 最多为1023字符,不能包含;|&><'$特殊字符,且不可为空或全空格。 - 需要以“/”或“s3a://”开头。OBS路径不支持KMS加密的文件或程序。 - Spark Script需要以“.sql”结尾,MapReduce和Spark Jar需要以“.jar”结尾,sql和jar不区分大小写。 说明: 作业类型为MapReduce或Spark时,jar_path参数为必选。
	JarPath *string `json:"jar_path,omitempty"`

	// 数据输入地址,必须以“/”或“s3a://”开头。请配置为正确的OBS路径,OBS路径不支持KMS加密的文件或程序。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Input *string `json:"input,omitempty"`

	// 数据输出地址,必须以“/”或“s3a://”开头。请配置为正确的OBS路径,如果该路径不存在,系统会自动创建。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	Output *string `json:"output,omitempty"`

	// 作业日志存储地址,该日志信息记录作业运行状态。必须以“/”或“s3a://”开头,请配置为正确的OBS路径。  最多为1023字符,不能包含;|&>'<$特殊字符,可为空。
	JobLog *string `json:"job_log,omitempty"`

	// 作业类型码。  - 1:MapReduce - 2:Spark - 3:Hive Script - 4:HiveSQL(当前不支持) - 5:DistCp,导入、导出数据。 - 6:Spark Script - 7:Spark SQL,提交SQL语句(该接口当前不支持)
	JobType int32 `json:"job_type"`

	// 文件操作类型,包括: - export:从HDFS导出数据至OBS - import:从OBS导入数据至HDFS
	FileAction *string `json:"file_action,omitempty"`

	// 程序执行的关键参数,该参数由用户程序内的函数指定,MRS只负责参数的传入。 最多为150000字符,不能包含;|&>'<$!\\\"\\特殊字符,可为空。 说明: 用户输入带有敏感信息(如登录密码)的参数时,可通过在参数名前添加“@”的方式,为该参数值加密,以防止敏感信息被明文形式持久化。在查看作业信息时,敏感信息显示为“*”。 例如:username=admin @password=admin_123
	Arguments *string `json:"arguments,omitempty"`

	// Spark SQL语句,该语句需要进行Base64编码和解码,“ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”为标准的编码表,MRS使用“ABCDEFGHILKJMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”进行Base64编码。在编码后所得字符串首位任意加上一个字母,即得到Hql参数的值。后台自动进行解码得到Spark SQL语句。 使用样例: 1) 在Web界面输入Spark SQL语句“show tables;”。 2) 使用“ABCDEFGHILKJMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/”编码后得到字符串“c2hvdyB0YWLsZXM7”。 3) 在“c2hvdyB0YWLsZXM7”首位任意加上一字母,例如“gc2hvdyB0YWLsZXM7”,即Hql参数的值。 4) 后台自动进行解码得到Spark SQL语句“show tables;”。
	Hql *string `json:"hql,omitempty"`

	// sql程序路径,仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求:  - 最多为1023字符,不能包含;|&><'$特殊字符,且不可为空或全空格。 - 需要以“/”或“s3a://”开头,OBS路径不支持KMS加密的文件或程序。 - 需要以“.sql”结尾,sql不区分大小写。
	HiveScriptPath *string `json:"hive_script_path,omitempty"`
}

func (SubmitJobReqV11) String added in v0.0.73

func (o SubmitJobReqV11) String() string

type Tag

type Tag struct {

	// 键。 - 最大长度36个unicode字符,不能为空字符串。  - 标签的key值不能包含非打印字符ASCII(0-31),“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。  - 同一资源的key值不能重复。
	Key string `json:"key"`

	// 值。 - 最大长度43个unicode字符,可以为空字符串。  - 标签的value值不能包含非打印字符ASCII(0-31),“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。
	Value string `json:"value"`
}

func (Tag) String

func (o Tag) String() string

type TagPlain

type TagPlain struct {

	// 键。标签的key值不能包含“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。
	Key *string `json:"key,omitempty"`

	// 值。标签的value值不能包含“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。
	Value *string `json:"value,omitempty"`
}

func (TagPlain) String

func (o TagPlain) String() string

type TagWithMultiValue

type TagWithMultiValue struct {

	// 键。标签的key值不能包含“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。
	Key string `json:"key"`

	// 值。标签的value值不能包含“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”,且首尾字符不能为空格。
	Values *[]string `json:"values,omitempty"`
}

func (TagWithMultiValue) String

func (o TagWithMultiValue) String() string

type TaskNodeGroup added in v0.1.7

type TaskNodeGroup struct {

	// Task节点节点数量,取值范围0~500,Core与Task节点总数最大为500个。
	NodeNum int32 `json:"node_num"`

	// Task节点的实例规格,例如:c3.4xlarge.2.linux.bigdata。实例规格详细说明请参见[MRS所使用的弹性云服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9006.html)和[MRS所使用的裸金属服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9001.html)。 该参数建议从MRS控制台的集群创建页面获取对应区域对应版本所支持的规格。
	NodeSize string `json:"node_size"`

	// Task节点数据磁盘存储类别,目前支持SATA、SAS和SSD。 - SATA:普通IO - SAS:高IO - SSD:超高IO - GPSSD:通用型SSD
	DataVolumeType TaskNodeGroupDataVolumeType `json:"data_volume_type"`

	// Task节点数据磁盘存储数目,取值范围:0~20。
	DataVolumeCount int32 `json:"data_volume_count"`

	// Task节点数据磁盘存储大小。  取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	DataVolumeSize int32 `json:"data_volume_size"`

	AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy,omitempty"`
}

func (TaskNodeGroup) String added in v0.1.7

func (o TaskNodeGroup) String() string

type TaskNodeGroupDataVolumeType added in v0.1.7

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

func (TaskNodeGroupDataVolumeType) MarshalJSON added in v0.1.7

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

func (*TaskNodeGroupDataVolumeType) UnmarshalJSON added in v0.1.7

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

func (TaskNodeGroupDataVolumeType) Value added in v0.1.7

type TaskNodeGroupDataVolumeTypeEnum added in v0.1.7

type TaskNodeGroupDataVolumeTypeEnum struct {
	SATA  TaskNodeGroupDataVolumeType
	SAS   TaskNodeGroupDataVolumeType
	SSD   TaskNodeGroupDataVolumeType
	GPSSD TaskNodeGroupDataVolumeType
}

func GetTaskNodeGroupDataVolumeTypeEnum added in v0.1.7

func GetTaskNodeGroupDataVolumeTypeEnum() TaskNodeGroupDataVolumeTypeEnum

type TaskNodeInfo added in v0.0.73

type TaskNodeInfo struct {

	// Task节点的实例规格,例如:c3.4xlarge.2.linux.bigdata。实例规格详细说明请参见[MRS所使用的弹性云服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9006.html)和[MRS所使用的裸金属服务器规格](https://support.huaweicloud.com/api-mrs/mrs_01_9001.html)。 该参数建议从MRS控制台的集群创建页面获取对应区域对应版本所支持的规格。
	NodeSize string `json:"node_size"`

	// Task节点数据磁盘存储类别,目前支持SATA、SAS和SSD。 - SATA:普通IO - SAS:高IO - SSD:超高IO - GPSSD:通用型SSD
	DataVolumeType TaskNodeInfoDataVolumeType `json:"data_volume_type"`

	// Task节点数据磁盘存储数目,取值范围:0~20。
	DataVolumeCount int32 `json:"data_volume_count"`

	// Task节点数据磁盘存储大小。  取值范围:100GB~32000GB,传值只需填数字,不需要带单位GB。
	DataVolumeSize int32 `json:"data_volume_size"`
}

func (TaskNodeInfo) String added in v0.0.73

func (o TaskNodeInfo) String() string

type TaskNodeInfoDataVolumeType added in v0.0.73

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

func (TaskNodeInfoDataVolumeType) MarshalJSON added in v0.0.73

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

func (*TaskNodeInfoDataVolumeType) UnmarshalJSON added in v0.0.73

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

func (TaskNodeInfoDataVolumeType) Value added in v0.0.90

type TaskNodeInfoDataVolumeTypeEnum added in v0.0.73

type TaskNodeInfoDataVolumeTypeEnum struct {
	SATA  TaskNodeInfoDataVolumeType
	SAS   TaskNodeInfoDataVolumeType
	SSD   TaskNodeInfoDataVolumeType
	GPSSD TaskNodeInfoDataVolumeType
}

func GetTaskNodeInfoDataVolumeTypeEnum added in v0.0.73

func GetTaskNodeInfoDataVolumeTypeEnum() TaskNodeInfoDataVolumeTypeEnum

type Trigger

type Trigger struct {

	// 指标名称。  该触发条件会依据该名称对应指标的值来进行判断。  最大长度为64个字符。
	MetricName string `json:"metric_name"`

	// 指标阈值。  触发该条件的指标阈值,只允许输入整数或者带两位小数的数。
	MetricValue string `json:"metric_value"`

	// 指标判断逻辑运算符,包括:  - LT:小于 - GT:大于 - LTOE:小于等于 - GTOE:大于等于
	ComparisonOperator *string `json:"comparison_operator,omitempty"`

	// 判断连续满足指标阈值的周期数(一个周期为5分钟)。  取值范围[1~288]
	EvaluationPeriods int32 `json:"evaluation_periods"`
}

func (Trigger) String

func (o Trigger) String() string

type UpdateClusterScalingRequest added in v0.0.73

type UpdateClusterScalingRequest struct {

	// 集群ID。获取方法,请参见[获取集群ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	ClusterId string `json:"cluster_id"`

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

UpdateClusterScalingRequest Request Object

func (UpdateClusterScalingRequest) String added in v0.0.73

type UpdateClusterScalingResponse added in v0.0.73

type UpdateClusterScalingResponse struct {

	// 操作结果。 - succeeded:操作成功 - 操作失败时返回的错误码信息如[错误码](https://support.huaweicloud.com/api-mrs/ErrorCode.html)所示。
	Result         *string `json:"result,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateClusterScalingResponse Response Object

func (UpdateClusterScalingResponse) String added in v0.0.73

type VersionComponent added in v0.1.72

type VersionComponent struct {

	// 其他
	Other map[string]interface{} `json:"other,omitempty"`

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

	// 支持版本
	Version *string `json:"version,omitempty"`

	// 组件依赖项
	DependOn *[]string `json:"depend_on,omitempty"`

	// 组件描述
	Description *string `json:"description,omitempty"`

	// 支持该组件的集群类型
	AvailableClusterTypes *[]string `json:"available_cluster_types,omitempty"`

	// 外部数据源
	ExternalDatasources *[]ComponentExternalDatasource `json:"external_datasources,omitempty"`

	// 所需的ip等资源说明
	ResourceRequirement *[]string `json:"resource_requirement,omitempty"`

	// 有效角色
	ValidRoles *[]string `json:"valid_roles,omitempty"`

	// 是否可见
	Visible *bool `json:"visible,omitempty"`

	// 子组件
	ChildrenComponents *[]string `json:"children_components,omitempty"`

	// 多az支持状态
	MultiAzSupportStatus *string `json:"multi_az_support_status,omitempty"`
}

VersionComponent 组件详情

func (VersionComponent) String added in v0.1.72

func (o VersionComponent) String() string

type VersionConstraint added in v0.1.72

type VersionConstraint struct {

	// 其他限制
	Other map[string]interface{} `json:"other,omitempty"`

	NodeConstraint *NodeConstraints `json:"node_constraint,omitempty"`

	// 安全模式kerberos排除组件列表
	SafeModeKerberosExcludeComponents *[]string `json:"safe_mode_kerberos_exclude_components,omitempty"`
}

VersionConstraint 版本限制说明

func (VersionConstraint) String added in v0.1.72

func (o VersionConstraint) String() string

Source Files

Jump to

Keyboard shortcuts

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