model

package
v0.1.113 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 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 

func (c AutoScalingPolicyReqV11NodeGroup) Value() string

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 

func (c BatchCreateClusterTagsReqAction) Value() string

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 

func (o BatchCreateClusterTagsRequest) String() string

type BatchCreateClusterTagsResponse 

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

BatchCreateClusterTagsResponse Response Object

func (BatchCreateClusterTagsResponse) String 

func (o BatchCreateClusterTagsResponse) String() 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 

func (c BatchDeleteClusterTagsReqAction) Value() string

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 

func (o BatchDeleteClusterTagsRequest) String() string

type BatchDeleteClusterTagsResponse 

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

BatchDeleteClusterTagsResponse Response Object

func (BatchDeleteClusterTagsResponse) String 

func (o BatchDeleteClusterTagsResponse) String() 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 

func (c BootstrapScriptActionStages) Value() string

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 

func (c BootstrapScriptFailAction) Value() string

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 

func (c ClusterScalingParamsScaleType) Value() string

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 

func (o ComponentExternalDatasource) String() string

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 

func (o CreateAndExecuteJobRequest) String() string

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 

func (o CreateAndExecuteJobResponse) String() string

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 

func (c CreateClusterReqV11BillingType) Value() int32

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 

func (c CreateClusterReqV11ClusterType) Value() int32

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 

func (c CreateClusterReqV11CoreDataVolumeType) Value() string

type CreateClusterReqV11CoreDataVolumeTypeEnum added in v0.1.7 

type CreateClusterReqV11CoreDataVolumeTypeEnum struct {
	SATA  CreateClusterReqV11CoreDataVolumeType
	SAS   CreateClusterReqV11CoreDataVolumeType
	SSD   CreateClusterReqV11CoreDataVolumeType
	GPSSD CreateClusterReqV11CoreDataVolumeType
}

func GetCreateClusterReqV11CoreDataVolumeTypeEnum added in v0.1.7 

func GetCreateClusterReqV11CoreDataVolumeTypeEnum() CreateClusterReqV11CoreDataVolumeTypeEnum

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 

func (c CreateClusterReqV11LogCollection) Value() int32

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 

func (c CreateClusterReqV11LoginMode) Value() int32

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 (c CreateClusterReqV11MasterDataVolumeCount) MarshalJSON() ([]byte, error)

func (*CreateClusterReqV11MasterDataVolumeCount) UnmarshalJSON added in v0.1.7 

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

func (CreateClusterReqV11MasterDataVolumeCount) Value added in v0.1.7 

func (c CreateClusterReqV11MasterDataVolumeCount) Value() int32

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 

func (c CreateClusterReqV11MasterDataVolumeType) Value() string

type CreateClusterReqV11MasterDataVolumeTypeEnum added in v0.1.7 

type CreateClusterReqV11MasterDataVolumeTypeEnum struct {
	SATA  CreateClusterReqV11MasterDataVolumeType
	SAS   CreateClusterReqV11MasterDataVolumeType
	SSD   CreateClusterReqV11MasterDataVolumeType
	GPSSD CreateClusterReqV11MasterDataVolumeType
}

func GetCreateClusterReqV11MasterDataVolumeTypeEnum added in v0.1.7 

func GetCreateClusterReqV11MasterDataVolumeTypeEnum() CreateClusterReqV11MasterDataVolumeTypeEnum

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 

func (c CreateClusterReqV11SafeMode) Value() int32

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 

func (c CreateClusterReqV11VolumeType) Value() string

type CreateClusterReqV11VolumeTypeEnum added in v0.1.7 

type CreateClusterReqV11VolumeTypeEnum struct {
	SATA  CreateClusterReqV11VolumeType
	SAS   CreateClusterReqV11VolumeType
	SSD   CreateClusterReqV11VolumeType
	GPSSD CreateClusterReqV11VolumeType
}

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 

func (o CreateScalingPolicyRequest) String() string

type CreateScalingPolicyResponse added in v0.0.73 

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

CreateScalingPolicyResponse Response Object

func (CreateScalingPolicyResponse) String added in v0.0.73 

func (o CreateScalingPolicyResponse) String() string

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 

func (o DeleteJobExecutionResponse) String() string

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 

func (c ListAvailableZonesRequestScope) Value() string

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 

func (o ListAvailableZonesResponse) String() string

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 

func (o ListClustersByTagsResponse) String() 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 

func (c NodeGroupV10DataVolumeType) Value() string

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 

func (o ShowClusterDetailsResponse) String() string

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 

func (o ShowMrsVersionMetadataRequest) String() string

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 

func (o ShowMrsVersionMetadataResponse) String() string

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 

func (c TaskNodeGroupDataVolumeType) Value() string

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 

func (c TaskNodeInfoDataVolumeType) Value() string

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 

func (o UpdateClusterScalingRequest) String() string

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 

func (o UpdateClusterScalingResponse) String() string

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

View all Source files

Jump to

Keyboard shortcuts

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