model

package
v0.1.32 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type 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：以“obs://”开头。不支持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：以“obs://”开头。不支持KMS加密的文件或程序。 - HDFS：以“/”开头。 最多为1023字符，不能包含;|&>'<$特殊字符，可为空。
	Input *string `json:"input,omitempty"`

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

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

	// sql程序路径，仅Spark Script和Hive Script作业需要使用此参数。需要满足如下要求： - 最多为1023字符，不能包含;|&><'$特殊字符，且不可为空或全空格。 - 文件可存储于HDFS或者OBS中，不同的文件系统对应的路径存在差异。     - OBS：以“obs://”开头。不支持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 AgencyMapping 

type AgencyMapping struct {

	// 该映射绑定的IAM委托名称。
	Agency string `json:"agency"`

	// 委托类型，分为“User”和“Group”两种。 - User表示该映射关系为针对用户的映射，identifiers中填写用户名称列表。 - Group表示该映射关系为针对用户组的映射，identifiers中填写用户组名称列表。
	IdentifierType string `json:"identifier_type"`

	// IAM委托映射的用户（组）名称列表。请前往IAM，单击“用户（组）”按钮，获取用户（组）名称列表。
	Identifiers []string `json:"identifiers"`

	// 该映射关系绑定的委托的的唯一标识码。请前往IAM，单击“委托”按钮，进入委托页面，将鼠标放置委托名称上，在弹窗中获取委托唯一标识码。
	AgencyId string `json:"agency_id"`
}

用户（组）与IAM委托的映射关系结构体

func (AgencyMapping) String 

func (o AgencyMapping) String() string

type AgencyMappingArray 

type AgencyMappingArray struct {

	// 用户（组）与委托之间的映射关系详细信息。
	AgencyMappings []AgencyMapping `json:"agency_mappings"`
}

用户（组）与IAM委托的映射关系数组结构体

func (AgencyMappingArray) String 

func (o AgencyMappingArray) 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 AutoScalingPolicyV2 added in v0.1.13 

type AutoScalingPolicyV2 struct {

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

	// 资源计划名称
	ResourcePoolName string `json:"resource_pool_name"`

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

func (AutoScalingPolicyV2) String added in v0.1.13 

func (o AutoScalingPolicyV2) String() string

type BatchDeleteJobsRequest 

type BatchDeleteJobsRequest struct {

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

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

Request Object

func (BatchDeleteJobsRequest) String 

func (o BatchDeleteJobsRequest) String() string

type BatchDeleteJobsResponse 

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

Response Object

func (BatchDeleteJobsResponse) String 

func (o BatchDeleteJobsResponse) String() string

type BootstrapScript 

type BootstrapScript struct {

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

	// 引导操作脚本的路径。设置为OBS桶的路径或虚拟机本地的路径。 - OBS桶的路径：直接手动输入脚本路径。例如输入MRS提供的公共样例脚本路径。示例：obs://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 

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

func (BootstrapScriptActionStages) MarshalJSON 

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

func (*BootstrapScriptActionStages) UnmarshalJSON 

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

func (BootstrapScriptActionStages) Value added in v0.0.90 

func (c BootstrapScriptActionStages) Value() string

type BootstrapScriptActionStagesEnum 

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 

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 CancelSqlRequest 

type CancelSqlRequest struct {

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

	// SQL的执行ID，即提交SQL语句返回结果中的sql_id。
	SqlId string `json:"sql_id"`
}

Request Object

func (CancelSqlRequest) String 

func (o CancelSqlRequest) String() string

type CancelSqlResponse 

type CancelSqlResponse struct {

	// 错误信息。
	Message *string `json:"message,omitempty"`

	// 取消SQL的执行结果。 说明： 默认返回SUCCEED，对于已经结束的任务也会返回SUCCEED，只有取消正在运行的SQL时没成功才会FAILED。 枚举值： - SUCCEED：成功 - FAILED：失败
	Status         *CancelSqlResponseStatus `json:"status,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

Response Object

func (CancelSqlResponse) String 

func (o CancelSqlResponse) String() string

type CancelSqlResponseStatus 

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

func (CancelSqlResponseStatus) MarshalJSON 

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

func (*CancelSqlResponseStatus) UnmarshalJSON 

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

func (CancelSqlResponseStatus) Value added in v0.0.90 

func (c CancelSqlResponseStatus) Value() string

type CancelSqlResponseStatusEnum 

type CancelSqlResponseStatusEnum struct {
	SUCCEED CancelSqlResponseStatus
	FAILED  CancelSqlResponseStatus
}

func GetCancelSqlResponseStatusEnum 

func GetCancelSqlResponseStatusEnum() CancelSqlResponseStatusEnum

type ChargeInfo 

type ChargeInfo struct {

	// 计费模式。 取值范围： - prePaid：预付费，即包年/包月。暂不支持。 - postPaid：后付费，即按需计费。
	ChargeMode string `json:"charge_mode"`
}

func (ChargeInfo) String 

func (o ChargeInfo) String() string

type ClusterDataConnectorMap added in v0.1.28 

type ClusterDataConnectorMap struct {

	// 数据连接关联ID值
	MapId *int32 `json:"map_id,omitempty"`

	// 数据连接ID值
	ConnectorId *string `json:"connector_id,omitempty"`

	// 组件名
	ComponentName *string `json:"component_name,omitempty"`

	// 组件角色类型。 - hive_metastore：Hive Metastore角色 - hive_data：Hive角色 - hbase_data：Hbase角色 - ranger_data：Ranger角色
	RoleType *ClusterDataConnectorMapRoleType `json:"role_type,omitempty"`

	// 数据连接类型。 - LOCAL_DB：本地元数据 - RDS_POSTGRES：RDS服务PostgreSQL数据库 - RDS_MYSQL：RDS服务MySQL数据库 - gaussdb-mysql：云数据库GaussDB(for MySQL)
	SourceType *ClusterDataConnectorMapSourceType `json:"source_type,omitempty"`

	// 关联集群id
	ClusterId *string `json:"cluster_id,omitempty"`

	// 数据连接状态。 - 0：代表正常状态 - 1：代表使用中
	Status *int32 `json:"status,omitempty"`
}

func (ClusterDataConnectorMap) String added in v0.1.28 

func (o ClusterDataConnectorMap) String() string

type ClusterDataConnectorMapRoleType added in v0.1.28 

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

func (ClusterDataConnectorMapRoleType) MarshalJSON added in v0.1.28 

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

func (*ClusterDataConnectorMapRoleType) UnmarshalJSON added in v0.1.28 

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

func (ClusterDataConnectorMapRoleType) Value added in v0.1.28 

func (c ClusterDataConnectorMapRoleType) Value() string

type ClusterDataConnectorMapRoleTypeEnum added in v0.1.28 

type ClusterDataConnectorMapRoleTypeEnum struct {
	LOCAL_DB      ClusterDataConnectorMapRoleType
	RDS_POSTGRES  ClusterDataConnectorMapRoleType
	RDS_MYSQL     ClusterDataConnectorMapRoleType
	GAUSSDB_MYSQL ClusterDataConnectorMapRoleType
}

func GetClusterDataConnectorMapRoleTypeEnum added in v0.1.28 

func GetClusterDataConnectorMapRoleTypeEnum() ClusterDataConnectorMapRoleTypeEnum

type ClusterDataConnectorMapSourceType added in v0.1.28 

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

func (ClusterDataConnectorMapSourceType) MarshalJSON added in v0.1.28 

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

func (*ClusterDataConnectorMapSourceType) UnmarshalJSON added in v0.1.28 

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

func (ClusterDataConnectorMapSourceType) Value added in v0.1.28 

func (c ClusterDataConnectorMapSourceType) Value() string

type ClusterDataConnectorMapSourceTypeEnum added in v0.1.28 

type ClusterDataConnectorMapSourceTypeEnum struct {
	LOCAL_DB      ClusterDataConnectorMapSourceType
	RDS_POSTGRES  ClusterDataConnectorMapSourceType
	RDS_MYSQL     ClusterDataConnectorMapSourceType
	GAUSSDB_MYSQL ClusterDataConnectorMapSourceType
}

func GetClusterDataConnectorMapSourceTypeEnum added in v0.1.28 

func GetClusterDataConnectorMapSourceTypeEnum() ClusterDataConnectorMapSourceTypeEnum

type CreateClusterReqV2 

type CreateClusterReqV2 struct {

	// 说明是否为专属云的资源，默认为false。
	IsDecProject *bool `json:"is_dec_project,omitempty"`

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

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

	// 集群类型，取值范围： - ANALYSIS：分析集群 - STREAMING：流式集群 - MIXED：混合集群 - CUSTOM：自定义集群，仅MRS 3.x版本支持。
	ClusterType string `json:"cluster_type"`

	ChargeInfo *ChargeInfo `json:"charge_info,omitempty"`

	// 集群所在区域信息，请参见[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)。
	Region string `json:"region"`

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

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

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

	// 组件名称列表，用逗号分隔。支持的组件请参见[获取MRS集群信息](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)页面的“MRS服务支持的组件”内容。
	Components string `json:"components"`

	// 部署Hive和Ranger等组件时，可以关联数据连接，将元数据存储于关联的数据库
	ExternalDatasources *[]ClusterDataConnectorMap `json:"external_datasources,omitempty"`

	// 可用分区名称，不支持多AZ集群。 可用分区信息请参见[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)。
	AvailabilityZone string `json:"availability_zone"`

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

	// 是否要创建MRS集群默认安全组，默认为false。 当指定该参数为true，则无论“security_groups_id”参数是否指定，都会为集群创建默认安全组。
	AutoCreateDefaultSecurityGroup *bool `json:"auto_create_default_security_group,omitempty"`

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

	// 配置Manager管理员用户的密码。 - 密码长度应在8～26个字符之间。 - 至少包含四种字符组合，如大写字母，小写字母，数字，特殊字符（!@$%^-_=+[{}]:,./?），但不能包含空格。 - 不能与用户名或者倒序用户名相同。
	ManagerAdminPassword string `json:"manager_admin_password"`

	// 节点登录方式。 - PASSWORD：密码登录，选择此项时，node_root_password不能为空。 - KEYPAIR：密钥对登录，选择此项时，node_keypair_name不能为空。
	LoginMode string `json:"login_mode"`

	// 配置访问集群节点的root密码。 密码设置约束如下： - 字符串类型，可输入的字符串长度为8-26。 - 至少包含四种字符组合，如大写字母，小写字母，数字，特殊字符（!@$%^-_=+[{}]:,./?），但不能包含空格。 - 不能与用户名或者倒序用户名相同。
	NodeRootPassword *string `json:"node_root_password,omitempty"`

	// 密钥对名称。用户可以使用密钥对方式登录集群节点。
	NodeKeypairName *string `json:"node_keypair_name,omitempty"`

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

	// 与MRS集群绑定的弹性公网IP，可实现使用弹性公网IP访问Manager的目的。该弹性公网IP必须已经创建且与集群在同一区域。
	EipAddress *string `json:"eip_address,omitempty"`

	// 当“eip_address”配置时，该参数必须配置，用于表示绑定的弹性公网IP的ID。可通过在VPC服务的“网络控制台 > 弹性公网IP和带宽 > 弹性公网IP”页面单击待绑定的弹性公网IP，在基本信息中获取“ID”。
	EipId *string `json:"eip_id,omitempty"`

	// 集群节点默认绑定的委托名称，固定为MRS_ECS_DEFAULT_AGENCY。 通过绑定委托，您可以将部分资源共享给ECS或BMS云服务来管理，例如通过配置ECS委托可自动获取AK/SK访问OBS。 MRS_ECS_DEFAULT_AGENCY委托拥有对象存储服务的OBS OperateAccess权限和在集群所在区域拥有CES FullAccess（对开启细粒度策略的用户）、CES Administrator和KMS Administrator权限。
	MrsEcsDefaultAgency *string `json:"mrs_ecs_default_agency,omitempty"`

	// 当集群类型为CUSTOM时，用于指定节点部署所使用的模板。 - mgmt_control_combined_v2：管控合设模板，管理角色和控制角色共同部署在Master节点中，数据实例合设在同一节点组。该部署方式适用于100个以下的节点，可以减少成本。 - mgmt_control_separated_v2：管控分设模板，管理角色和控制角色分别部署在不同的Master节点中，数据实例合设在同一节点组。该部署方式适用于100-500个节点，在高并发负载情况下表现更好。 - mgmt_control_data_separated_v2：数据分设模板，管理角色和控制角色分别部署在不同的Master节点中，数据实例分设在不同节点组。该部署方式适用于500个以上的节点，可以将各组件进一步分开部署，适用于更大的集群规模。
	TemplateId *string `json:"template_id,omitempty"`

	// 集群的标签信息。 同一个集群最多能使用10个tag，tag的名称（key）不能重复。
	Tags *[]Tag `json:"tags,omitempty"`

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

	// 组成集群的节点组信息。
	NodeGroups []NodeGroupV2 `json:"node_groups"`

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

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

func (CreateClusterReqV2) String 

func (o CreateClusterReqV2) String() string

type CreateClusterReqV2LogCollection 

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

func (CreateClusterReqV2LogCollection) MarshalJSON 

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

func (*CreateClusterReqV2LogCollection) UnmarshalJSON 

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

func (CreateClusterReqV2LogCollection) Value added in v0.0.90 

func (c CreateClusterReqV2LogCollection) Value() int32

type CreateClusterReqV2LogCollectionEnum 

type CreateClusterReqV2LogCollectionEnum struct {
	E_0 CreateClusterReqV2LogCollection
	E_1 CreateClusterReqV2LogCollection
}

func GetCreateClusterReqV2LogCollectionEnum 

func GetCreateClusterReqV2LogCollectionEnum() CreateClusterReqV2LogCollectionEnum

type CreateClusterRequest 

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

Request Object

func (CreateClusterRequest) String 

func (o CreateClusterRequest) String() string

type CreateClusterResponse 

type CreateClusterResponse struct {

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

Response Object

func (CreateClusterResponse) String 

func (o CreateClusterResponse) String() string

type CreateExecuteJobRequest 

type CreateExecuteJobRequest struct {

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

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

Request Object

func (CreateExecuteJobRequest) String 

func (o CreateExecuteJobRequest) String() string

type CreateExecuteJobResponse 

type CreateExecuteJobResponse struct {
	JobSubmitResult *JobSubmitResult `json:"job_submit_result,omitempty"`
	HttpStatusCode  int              `json:"-"`
}

Response Object

func (CreateExecuteJobResponse) String 

func (o CreateExecuteJobResponse) String() string

type ExecuteSqlRequest 

type ExecuteSqlRequest struct {

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

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

Request Object

func (ExecuteSqlRequest) String 

func (o ExecuteSqlRequest) String() string

type ExecuteSqlResponse 

type ExecuteSqlResponse struct {

	// SQL的执行id。执行select、show和desc语句时才会生成id，其他操作id为空
	Id *string `json:"id,omitempty"`

	// 错误信息。
	Message *string `json:"message,omitempty"`

	// 执行的SQL语句。
	Statement *string `json:"statement,omitempty"`

	// SQL的执行状态。 - QUEUED - WAITING_FOR_RESOURCES - PLANNING - STARTING - RUNNING - FINISHING - FINISHED - FAILED
	Status *string `json:"status,omitempty"`

	// SQL查询语句的最终结果归档路径。 说明： 只有select的语句才会在将SQL的执行结果转储到result_location中。
	ResultLocation *string `json:"result_location,omitempty"`

	// SQL的执行结果。 说明： 只有非select的语句才会在content中返回结果，如果SQL中没有结果，content为空。
	Content        *[][]string `json:"content,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ExecuteSqlResponse) String 

func (o ExecuteSqlResponse) String() string

type FileStatusV2 

type FileStatusV2 struct {

	// 文件在当前目录下的后缀，如获取“/tmp”目录，下面的“/tmp/test”文件，此处path_suffix内容为“test”。
	PathSuffix *string `json:"path_suffix,omitempty"`

	// 文件拥有者。
	Owner *string `json:"owner,omitempty"`

	// 文件属组。
	Group *string `json:"group,omitempty"`

	// 权限信息。
	Permission *string `json:"permission,omitempty"`

	// 副本数。
	Replication *int32 `json:"replication,omitempty"`

	// 块大小。
	BlockSize *int32 `json:"block_size,omitempty"`

	// 文件长度。
	Length *int32 `json:"length,omitempty"`

	// 文件类型： - FILE：文件 - DIRECTORY：目录
	Type *string `json:"type,omitempty"`

	// 该目录下的文件条目数。
	ChildrenNum *int32 `json:"children_num,omitempty"`

	// 文件访问时间。
	AccessTime *int64 `json:"access_time,omitempty"`

	// 文件修改时间。
	ModificationTime *int64 `json:"modification_time,omitempty"`
}

func (FileStatusV2) String 

func (o FileStatusV2) String() string

type JobBatchDelete 

type JobBatchDelete struct {

	// 作业ID列表。获取方法，请参见[获取作业ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	JobIdList *[]string `json:"job_id_list,omitempty"`
}

func (JobBatchDelete) String 

func (o JobBatchDelete) String() string

type JobExecution 

type JobExecution struct {

	// 作业类型: - MapReduce - SparkSubmit - SparkPython：该类型作业将转换为SparkSubmit类型提交，MRS控制台界面的作业类型展示为SparkSubmit，通过接口查询作业列表信息时作业类型请选择SparkSubmit。 - HiveScript - HiveSql - DistCp，导入、导出数据。 - SparkScript - SparkSql - Flink
	JobType string `json:"job_type"`

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

	// 程序执行的关键参数，该参数由用户程序内的函数指定，MRS只负责参数的传入。 最多为150000字符，不能包含;|&>'<$!\\\"\\特殊字符，可为空。 说明： - 若输入带有敏感信息（如登录密码）的参数可能在作业详情展示和日志打印中存在暴露的风险，请谨慎操作。 - 提交HiveScript或HiveSql类型的作业时如需以“obs://”开头格式访问存储在OBS上的文件，请在Hive服务配置页面搜索参数“core.site.customized.configs”，新增OBS的endpoint配置项，参数为“fs.obs.endpoint”，值请输入OBS对应的endpoint，具体请参考[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)。
	Arguments *[]string `json:"arguments,omitempty"`

	// 程序系统参数。 最多为2048字符，不能包含><|'`&!\\特殊字符，可为空。
	Properties map[string]string `json:"properties,omitempty"`
}

func (JobExecution) String 

func (o JobExecution) String() string

type JobQueryBean 

type JobQueryBean struct {

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

	// 提交作业的用户名称。
	User *string `json:"user,omitempty"`

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

	// 作业最终结果。 - FAILED：执行失败的作业 - KILLED：执行中被手动终止的作业。 - UNDEFINED：正在执行的作业。 - SUCCEEDED：执行成功的作业。
	JobResult *string `json:"job_result,omitempty"`

	// 作业执行状态。  - FAILED：失败 - KILLED：已终止 - NEW：已创建 - NEW_SAVING：已创建保存中 - SUBMITTED：已提交 - ACCEPTED：已接受 - RUNNING：运行中 - FINISHED：已完成
	JobState *string `json:"job_state,omitempty"`

	// 作业执行进度。
	JobProgress *float32 `json:"job_progress,omitempty"`

	// 作业类型。 - MapReduce - SparkSubmit：SparkPython类型的作业在查询时作业类型请选择SparkSubmit。 - HiveScript - HiveSql - DistCp，导入、导出数据。 - SparkScript - SparkSql - Flink
	JobType *string `json:"job_type,omitempty"`

	// 作业开始执行时间。单位：毫秒。
	StartedTime *int64 `json:"started_time,omitempty"`

	// 作业提交时间。单位：毫秒。
	SubmittedTime *int64 `json:"submitted_time,omitempty"`

	// 作业完成时间。单位：毫秒。
	FinishedTime *int64 `json:"finished_time,omitempty"`

	// 作业执行时长。单位：毫秒。
	ElapsedTime *int64 `json:"elapsed_time,omitempty"`

	// 运行参数。
	Arguments *string `json:"arguments,omitempty"`

	// 实际作业编号。
	LauncherId *string `json:"launcher_id,omitempty"`

	// 配置参数，用于传-d参数。最多为2048字符，不能包含><|'`&!\\特殊字符，可为空。
	Properties *string `json:"properties,omitempty"`

	// 实际作业编号。
	AppId *string `json:"app_id,omitempty"`

	//  日志链接地址。当前仅SparkSubmit作业支持该参数。 该参数基于集群的EIP访问集群中的YARN WebUI页面，用户如果在VPC界面解绑EIP，MRS服务侧数据会因为未更新导致该参数引用旧EIP导致访问失败，可通过对集群重新进行EIP的绑定来修复该问题。
	TrackingUrl *string `json:"tracking_url,omitempty"`

	// 作业的资源对列类型。
	Queue *string `json:"queue,omitempty"`
}

func (JobQueryBean) String 

func (o JobQueryBean) String() string

type JobSubmitResult 

type JobSubmitResult struct {

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

	// 作业提交状态。 枚举值： - COMPLETE：作业提交完成。 - FAILED：作业提交失败。
	State *JobSubmitResultState `json:"state,omitempty"`
}

func (JobSubmitResult) String 

func (o JobSubmitResult) String() string

type JobSubmitResultState 

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

func (JobSubmitResultState) MarshalJSON 

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

func (*JobSubmitResultState) UnmarshalJSON 

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

func (JobSubmitResultState) Value added in v0.0.90 

func (c JobSubmitResultState) Value() string

type JobSubmitResultStateEnum 

type JobSubmitResultStateEnum struct {
	COMPLETE JobSubmitResultState
	FAILED   JobSubmitResultState
}

func GetJobSubmitResultStateEnum 

func GetJobSubmitResultStateEnum() JobSubmitResultStateEnum

type NodeGroupV2 

type NodeGroupV2 struct {

	// 节点组名称，最大长度64，支持大小写英文、数字以及“_”。节点组配置原则如下： - master_node_default_group：Master节点组，所有集群类型均需包含该节点组。 - core_node_analysis_group：分析Core节点组，分析集群、混合集群均需包含该节点组。 - core_node_streaming_group：流式Core节点组，流式集群和混合集群均需包含该节点组。 - task_node_analysis_group：分析Task节点组，分析集群和混合集群可根据需要选择该节点组。 - task_node_streaming_group：流式Task节点组，流式集群、混合集群可根据需要选择该节点组。 - node_group{x}：自定义集群节点组，可根据需要添加多个，最多支持添加9个该节点组。
	GroupName string `json:"group_name"`

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

	// 节点的实例规格。 例如：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"`

	RootVolume *Volume `json:"root_volume,omitempty"`

	DataVolume *Volume `json:"data_volume,omitempty"`

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

	ChargeInfo *ChargeInfo `json:"charge_info,omitempty"`

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

	// 当集群类型为CUSTOM时，该参数必选。可以指定节点组中部署的角色，该参数是一个字符串数组，每个字符串表示一个角色表达式。 角色表达式定义： - 当该角色在节点组所有节点部署时： {role name}，如“DataNode”。 - 当该角色在节点组指定下标节点部署时：{role name}:{index1},{index2}…,{indexN}，如“NameNode:1,2”，下标从1开始计数。 - 部分角色支持多实例部署（即在一个节点部署多个同角色的实例）：{role name}[{instance count}]，如“EsNode[9]” 可选的角色请参考[MRS支持的角色与组件对应表](https://support.huaweicloud.com/api-mrs/mrs_02_0106.html)。
	AssignedRoles *[]string `json:"assigned_roles,omitempty"`
}

func (NodeGroupV2) String 

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

	// 资源计划的生效日期，为空时代表每日，另外也可为以下返回值：  MONDAY（周一）、TUESDAY（周二）、WEDNESDAY（周三）、THURSDAY（周四）、FRIDAY（周五）、SATURDAY（周六）、SUNDAY（周日）
	EffectiveDays *[]ResourcesPlanEffectiveDays `json:"effective_days,omitempty"`
}

func (ResourcesPlan) String 

func (o ResourcesPlan) String() string

type ResourcesPlanEffectiveDays added in v0.1.28 

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

func (ResourcesPlanEffectiveDays) MarshalJSON added in v0.1.28 

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

func (*ResourcesPlanEffectiveDays) UnmarshalJSON added in v0.1.28 

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

func (ResourcesPlanEffectiveDays) Value added in v0.1.28 

func (c ResourcesPlanEffectiveDays) Value() string

type ResourcesPlanEffectiveDaysEnum added in v0.1.28 

type ResourcesPlanEffectiveDaysEnum struct {
	MONDAY    ResourcesPlanEffectiveDays
	TUESDAY   ResourcesPlanEffectiveDays
	WEDNESDAY ResourcesPlanEffectiveDays
	THURSDAY  ResourcesPlanEffectiveDays
	FRIDAY    ResourcesPlanEffectiveDays
	SATURDAY  ResourcesPlanEffectiveDays
	SUNDAY    ResourcesPlanEffectiveDays
}

func GetResourcesPlanEffectiveDaysEnum added in v0.1.28 

func GetResourcesPlanEffectiveDaysEnum() ResourcesPlanEffectiveDaysEnum

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桶的路径：直接手动输入脚本路径。示例：obs://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"`

	// 自定义自动化脚本所执行的节点组名称。
	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 ShowAgencyMappingRequest 

type ShowAgencyMappingRequest struct {

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

Request Object

func (ShowAgencyMappingRequest) String 

func (o ShowAgencyMappingRequest) String() string

type ShowAgencyMappingResponse 

type ShowAgencyMappingResponse struct {

	// 用户（组）与委托之间的映射关系详细信息。
	AgencyMappings *[]AgencyMapping `json:"agency_mappings,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ShowAgencyMappingResponse) String 

func (o ShowAgencyMappingResponse) String() string

type ShowAutoScalingPolicyRequest added in v0.1.13 

type ShowAutoScalingPolicyRequest struct {

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

Request Object

func (ShowAutoScalingPolicyRequest) String added in v0.1.13 

func (o ShowAutoScalingPolicyRequest) String() string

type ShowAutoScalingPolicyResponse added in v0.1.13 

type ShowAutoScalingPolicyResponse struct {

	// 弹性伸缩策略列表
	Body           *[]AutoScalingPolicyV2 `json:"body,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (ShowAutoScalingPolicyResponse) String added in v0.1.13 

func (o ShowAutoScalingPolicyResponse) String() string

type ShowHdfsFileListRequest 

type ShowHdfsFileListRequest struct {

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

	// 文件目录。 比如访问“/tmp/test”目录列表，此处必须是目录，整体URI为/v2/{project_id}/clusters/{cluster_id}/files?path=%2Ftmp%2Ftest 单层目录要遵循以下规则： - 不能为空 - 不能以\".\"开头或结尾 - 不能包括下列符号 : :*?\"<>|\\;&,'`!{}[]$%+ - 不能超过255个字节
	Path string `json:"path"`

	// 分页参数，表示从该偏移量开始查询文件列表，默认值为0。
	Offset *string `json:"offset,omitempty"`

	// 分页参数，列表当前分页的数量限制，默认为100，最大1000。
	Limit *string `json:"limit,omitempty"`

	// 列表排序按该属性排序。缺省值：path_suffix - path_suffix：文件或目录名称 - length：文件大小 - modification_time：修改时间
	SortKey *ShowHdfsFileListRequestSortKey `json:"sort_key,omitempty"`

	// 列表排序方式，desc为降序，asc为升序，默认值为desc。
	Order *ShowHdfsFileListRequestOrder `json:"order,omitempty"`
}

Request Object

func (ShowHdfsFileListRequest) String 

func (o ShowHdfsFileListRequest) String() string

type ShowHdfsFileListRequestOrder 

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

func (ShowHdfsFileListRequestOrder) MarshalJSON 

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

func (*ShowHdfsFileListRequestOrder) UnmarshalJSON 

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

func (ShowHdfsFileListRequestOrder) Value added in v0.0.90 

func (c ShowHdfsFileListRequestOrder) Value() string

type ShowHdfsFileListRequestOrderEnum 

type ShowHdfsFileListRequestOrderEnum struct {
	DESC ShowHdfsFileListRequestOrder
	ASC  ShowHdfsFileListRequestOrder
}

func GetShowHdfsFileListRequestOrderEnum 

func GetShowHdfsFileListRequestOrderEnum() ShowHdfsFileListRequestOrderEnum

type ShowHdfsFileListRequestSortKey 

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

func (ShowHdfsFileListRequestSortKey) MarshalJSON 

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

func (*ShowHdfsFileListRequestSortKey) UnmarshalJSON 

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

func (ShowHdfsFileListRequestSortKey) Value added in v0.0.90 

func (c ShowHdfsFileListRequestSortKey) Value() string

type ShowHdfsFileListRequestSortKeyEnum 

type ShowHdfsFileListRequestSortKeyEnum struct {
	PATH_SUFFIX       ShowHdfsFileListRequestSortKey
	LENGTH            ShowHdfsFileListRequestSortKey
	MODIFICATION_TIME ShowHdfsFileListRequestSortKey
}

func GetShowHdfsFileListRequestSortKeyEnum 

func GetShowHdfsFileListRequestSortKeyEnum() ShowHdfsFileListRequestSortKeyEnum

type ShowHdfsFileListResponse 

type ShowHdfsFileListResponse struct {

	// 文件总数，与分页无关。
	TotalCount *int64 `json:"total_count,omitempty"`

	// 文件列表。
	Files          *[]FileStatusV2 `json:"files,omitempty"`
	HttpStatusCode int             `json:"-"`
}

Response Object

func (ShowHdfsFileListResponse) String 

func (o ShowHdfsFileListResponse) String() string

type ShowJobExeListNewRequest 

type ShowJobExeListNewRequest struct {

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

	// 作业名称，只能由字母、数字、中划线和下划线组成，并且长度为1～128个字符。
	JobName *string `json:"job_name,omitempty"`

	// 作业ID，只能由字母、数字、中划线(-)组成，并且长度为1~64字符。
	JobId *string `json:"job_id,omitempty"`

	// 用户名称、只能由字母、数字、特殊字符(-_.)组成，且不能以数字开头，并且长度为1～32字符。
	User *string `json:"user,omitempty"`

	// 作业类型。 - MapReduce - SparkPython - SparkSubmit：SparkPython类型的作业在查询时作业类型请选择SparkSubmit。 - HiveScript - HiveSql - DistCp，导入、导出数据。 - SparkScript - SparkSql - Flink
	JobType *string `json:"job_type,omitempty"`

	// 作业运行状态。 - FAILED：失败 - KILLED：已终止 - NEW：已创建 - NEW_SAVING：已创建保存中 - SUBMITTED：已提交 - ACCEPTED：已接受 - RUNNING：运行中 - FINISHED：已完成
	JobState *ShowJobExeListNewRequestJobState `json:"job_state,omitempty"`

	// 作业运行结果。 - FAILED：执行失败的作业。 - KILLED：执行中被手动终止的作业。 - UNDEFINED：正在执行的作业。 - SUCCEEDED：执行成功的作业。
	JobResult *ShowJobExeListNewRequestJobResult `json:"job_result,omitempty"`

	// 作业的资源对列类型名称，作业的资源对列类型名称，只能由数字、字母和特殊字符(-_)组成, 并且长度为1～64字符。
	Queue *string `json:"queue,omitempty"`

	// 返回结果中每页显示条数。缺省值：10
	Limit *string `json:"limit,omitempty"`

	// 表示作业列表从该偏移量开始查询。缺省值：0
	Offset *string `json:"offset,omitempty"`

	// 返回结果的排序方式，默认值为desc。 - asc：按升序排列 - desc：按降序排列
	SortBy *string `json:"sort_by,omitempty"`

	// 查询该时间之后提交的作业，UTC的毫秒时间戳。例如：1562032041362。
	SubmittedTimeBegin *int64 `json:"submitted_time_begin,omitempty"`

	// 查询该时间之前提交的作业UTC的毫秒时间戳。例如：1562032041362。
	SubmittedTimeEnd *int64 `json:"submitted_time_end,omitempty"`
}

Request Object

func (ShowJobExeListNewRequest) String 

func (o ShowJobExeListNewRequest) String() string

type ShowJobExeListNewRequestJobResult 

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

func (ShowJobExeListNewRequestJobResult) MarshalJSON 

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

func (*ShowJobExeListNewRequestJobResult) UnmarshalJSON 

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

func (ShowJobExeListNewRequestJobResult) Value added in v0.0.90 

func (c ShowJobExeListNewRequestJobResult) Value() string

type ShowJobExeListNewRequestJobResultEnum 

type ShowJobExeListNewRequestJobResultEnum struct {
	FAILED    ShowJobExeListNewRequestJobResult
	KILLED    ShowJobExeListNewRequestJobResult
	UNDEFINED ShowJobExeListNewRequestJobResult
	SUCCEEDED ShowJobExeListNewRequestJobResult
}

func GetShowJobExeListNewRequestJobResultEnum 

func GetShowJobExeListNewRequestJobResultEnum() ShowJobExeListNewRequestJobResultEnum

type ShowJobExeListNewRequestJobState 

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

func (ShowJobExeListNewRequestJobState) MarshalJSON 

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

func (*ShowJobExeListNewRequestJobState) UnmarshalJSON 

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

func (ShowJobExeListNewRequestJobState) Value added in v0.0.90 

func (c ShowJobExeListNewRequestJobState) Value() string

type ShowJobExeListNewRequestJobStateEnum 

type ShowJobExeListNewRequestJobStateEnum struct {
	FAILED     ShowJobExeListNewRequestJobState
	KILLED     ShowJobExeListNewRequestJobState
	NEW        ShowJobExeListNewRequestJobState
	NEW_SAVING ShowJobExeListNewRequestJobState
	SUBMITTED  ShowJobExeListNewRequestJobState
	ACCEPTED   ShowJobExeListNewRequestJobState
	RUNNING    ShowJobExeListNewRequestJobState
	FINISHED   ShowJobExeListNewRequestJobState
}

func GetShowJobExeListNewRequestJobStateEnum 

func GetShowJobExeListNewRequestJobStateEnum() ShowJobExeListNewRequestJobStateEnum

type ShowJobExeListNewResponse 

type ShowJobExeListNewResponse struct {

	// 总记录数
	TotalRecord *int32 `json:"total_record,omitempty"`

	// 作业列表。
	JobList        *[]JobQueryBean `json:"job_list,omitempty"`
	HttpStatusCode int             `json:"-"`
}

Response Object

func (ShowJobExeListNewResponse) String 

func (o ShowJobExeListNewResponse) String() string

type ShowSingleJobExeRequest 

type ShowSingleJobExeRequest struct {

	// 作业ID。获取方法，请参见[获取作业ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	JobExecutionId string `json:"job_execution_id"`

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

Request Object

func (ShowSingleJobExeRequest) String 

func (o ShowSingleJobExeRequest) String() string

type ShowSingleJobExeResponse 

type ShowSingleJobExeResponse struct {
	JobDetail      *JobQueryBean `json:"job_detail,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ShowSingleJobExeResponse) String 

func (o ShowSingleJobExeResponse) String() string

type ShowSqlResultRequest 

type ShowSqlResultRequest struct {

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

	// SQL的执行ID，即提交SQL语句返回结果中的sql_id。
	SqlId string `json:"sql_id"`
}

Request Object

func (ShowSqlResultRequest) String 

func (o ShowSqlResultRequest) String() string

type ShowSqlResultResponse 

type ShowSqlResultResponse struct {

	// SQL的执行id。执行select、show和desc语句时才会生成id，其他操作id为空
	Id *string `json:"id,omitempty"`

	// 错误信息。
	Message *string `json:"message,omitempty"`

	// 执行的SQL语句。
	Statement *string `json:"statement,omitempty"`

	// SQL的执行状态。 - QUEUED - WAITING_FOR_RESOURCES - PLANNING - STARTING - RUNNING - FINISHING - FINISHED - FAILED
	Status *string `json:"status,omitempty"`

	// SQL查询语句的最终结果归档路径。 说明： 只有select的语句才会在将SQL的执行结果转储到result_location中。
	ResultLocation *string `json:"result_location,omitempty"`

	// SQL的执行结果。 说明： 只有非select的语句才会在content中返回结果，如果SQL中没有结果，content为空。
	Content        *[][]string `json:"content,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ShowSqlResultResponse) String 

func (o ShowSqlResultResponse) String() string

type ShowSqlResultWithJobRequest 

type ShowSqlResultWithJobRequest struct {

	// 作业ID。获取方法，请参见[获取作业ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	JobExecutionId string `json:"job_execution_id"`

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

Request Object

func (ShowSqlResultWithJobRequest) String 

func (o ShowSqlResultWithJobRequest) String() string

type ShowSqlResultWithJobResponse 

type ShowSqlResultWithJobResponse struct {

	// SQL语句查询结果。
	SqlResults     *interface{} `json:"sql_results,omitempty"`
	HttpStatusCode int          `json:"-"`
}

Response Object

func (ShowSqlResultWithJobResponse) String 

func (o ShowSqlResultWithJobResponse) String() string

type SqlExecutionReq 

type SqlExecutionReq struct {

	// SQL类型。目前仅支持“presto”类型的SQL。 说明： - 只有包含Presto组件的集群才能提交执行presto类型的SQL。 - 当前仅MRS 2.0.6版本的MRS 2.0.6.1补丁、MRS 2.1.0版本的MRS 2.1.0.7补丁、MRS 3.1.2及之后版本集群支持。
	SqlType string `json:"sql_type"`

	// 待执行的SQL语句。 说明： 目前仅支持执行单条语句，语句中不包含“;”。
	SqlContent string `json:"sql_content"`

	// 执行SQL所在的数据库，默认为default。
	Database *string `json:"database,omitempty"`

	// SQL执行结果的转储文件夹。 说明： 只有select语句才会转储查询的结果。当前仅支持转储到OBS中。
	ArchivePath *string `json:"archive_path,omitempty"`
}

func (SqlExecutionReq) String 

func (o SqlExecutionReq) String() string

type StopJobRequest 

type StopJobRequest struct {

	// 作业ID。获取方法，请参见[获取作业ID](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)。
	JobExecutionId string `json:"job_execution_id"`

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

Request Object

func (StopJobRequest) String 

func (o StopJobRequest) String() string

type StopJobResponse 

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

Response Object

func (StopJobResponse) String 

func (o StopJobResponse) 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 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 UpdateAgencyMappingRequest 

type UpdateAgencyMappingRequest struct {

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

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

Request Object

func (UpdateAgencyMappingRequest) String 

func (o UpdateAgencyMappingRequest) String() string

type UpdateAgencyMappingResponse 

type UpdateAgencyMappingResponse struct {

	// 更新映射请求操作结果，succeeded为操作成功，failed为操作失败
	Result         *string `json:"result,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateAgencyMappingResponse) String 

func (o UpdateAgencyMappingResponse) String() string

type UpdateClusterNameRequest added in v0.1.13 

type UpdateClusterNameRequest struct {

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

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

Request Object

func (UpdateClusterNameRequest) String added in v0.1.13 

func (o UpdateClusterNameRequest) String() string

type UpdateClusterNameResponse added in v0.1.13 

type UpdateClusterNameResponse struct {

	// 更新映射请求操作结果，succeeded为操作成功，failed为操作失败
	Result         *string `json:"result,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateClusterNameResponse) String added in v0.1.13 

func (o UpdateClusterNameResponse) String() string

type UpdateClusterReq added in v0.1.13 

type UpdateClusterReq struct {

	// 新的集群名称。
	ClusterName string `json:"cluster_name"`
}

func (UpdateClusterReq) String added in v0.1.13 

func (o UpdateClusterReq) String() string

type Volume 

type Volume struct {

	// 磁盘类型。 磁盘类型枚举值： - SATA：普通IO磁盘类型。 - SAS：高IO磁盘类型。 - SSD：超高IO磁盘类型。 - GPSSD：通用型SSD磁盘类型
	Type string `json:"type"`

	// 数据盘大小，容量单位为GB，输入大小范围为[10,32768]。
	Size int32 `json:"size"`
}

func (Volume) String 

func (o Volume) 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.