model

package
v0.1.108 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 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 AddComponentRequest added in v0.1.67

type AddComponentRequest struct {

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

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

AddComponentRequest Request Object

func (AddComponentRequest) String added in v0.1.67

func (o AddComponentRequest) String() string

type AddComponentResponse added in v0.1.67

type AddComponentResponse struct {

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

AddComponentResponse Response Object

func (AddComponentResponse) String added in v0.1.67

func (o AddComponentResponse) String() string

type AddComponentsReq added in v0.1.67

type AddComponentsReq struct {

	// 组件模型详情
	ComponentsInstallMode []ComponentInstallMode `json:"components_install_mode"`
}

AddComponentsReq 添加组件请求

func (AddComponentsReq) String added in v0.1.67

func (o AddComponentsReq) String() string

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"`
}

AgencyMapping 用户(组)与IAM委托的映射关系结构体

func (AgencyMapping) String

func (o AgencyMapping) String() string

type AgencyMappingArray

type AgencyMappingArray struct {

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

AgencyMappingArray 用户(组)与IAM委托的映射关系数组结构体

func (AgencyMappingArray) String

func (o AgencyMappingArray) String() string

type AssignedNodeGroup added in v0.1.67

type AssignedNodeGroup struct {

	// 节点组名称
	Name string `json:"name"`

	// 角色部署信息。 可以指定节点组中部署的角色,该参数是一个字符串数组,每个字符串表示一个角色表达式。 角色表达式定义: - 当该角色在节点组所有节点部署时: {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"`
}

AssignedNodeGroup 节点组详情

func (AssignedNodeGroup) String added in v0.1.67

func (o AssignedNodeGroup) 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 AutoScalingPolicyDeleteReq added in v0.1.71

type AutoScalingPolicyDeleteReq struct {

	// 节点组名称。如果resource_pool_name为default,则删除节点组维度的弹性伸缩策略。如果resource_pool_name不为default,则在该节点组下删除对应资源池维度的策略。
	NodeGroupName string `json:"node_group_name"`

	// 资源池名称。当集群版本不支持按指定资源池进行弹性伸缩时,需要填写为default资源池。不为default时删除指定资源池维度的弹性伸缩策略。
	ResourcePoolName string `json:"resource_pool_name"`
}

AutoScalingPolicyDeleteReq 删除弹性伸缩策略请求。

func (AutoScalingPolicyDeleteReq) String added in v0.1.71

type AutoScalingPolicyInfo added in v0.1.71

type AutoScalingPolicyInfo 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"`

	// 弹性伸缩标签列表
	Tags *[]Tag `json:"tags,omitempty"`
}

func (AutoScalingPolicyInfo) String added in v0.1.71

func (o AutoScalingPolicyInfo) String() string

type AutoScalingPolicyV2 added in v0.1.13

type AutoScalingPolicyV2 struct {

	// 节点组名称。必填参数。如果resource_pool_name为default,则创建节点组维度的弹性伸缩策略。如果resource_pool_name不为default,则在该节点组下创建对应资源池维度的策略。
	NodeGroupName string `json:"node_group_name"`

	// 资源池名称。必填参数。当集群版本不支持按指定资源池进行弹性伸缩时,需要填写为default资源池。不为default时删除指定资源池维度的弹性伸缩策略。
	ResourcePoolName string `json:"resource_pool_name"`

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

func (AutoScalingPolicyV2) String added in v0.1.13

func (o AutoScalingPolicyV2) String() string

type AzFlavors added in v0.1.76

type AzFlavors struct {

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

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

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

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

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

AzFlavors 支持规格列表

func (AzFlavors) String added in v0.1.76

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

BatchDeleteJobsRequest Request Object

func (BatchDeleteJobsRequest) String

func (o BatchDeleteJobsRequest) String() string

type BatchDeleteJobsResponse

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

BatchDeleteJobsResponse 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"`

	// 引导操作脚本所执行的节点组名称。
	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

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

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"`
}

CancelSqlRequest 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:"-"`
}

CancelSqlResponse 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 CancelSyncIamUserRequest added in v0.1.76

type CancelSyncIamUserRequest struct {

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

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

CancelSyncIamUserRequest Request Object

func (CancelSyncIamUserRequest) String added in v0.1.76

func (o CancelSyncIamUserRequest) String() string

type CancelSyncIamUserResponse added in v0.1.76

type CancelSyncIamUserResponse struct {

	// 请求下发的结果
	State          *string `json:"state,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CancelSyncIamUserResponse Response Object

func (CancelSyncIamUserResponse) String added in v0.1.76

func (o CancelSyncIamUserResponse) String() string

type CancelSyncRequest added in v0.1.76

type CancelSyncRequest struct {

	// 指定取消同步的IAM用户组。
	GroupNames *[]string `json:"group_names,omitempty"`

	// 指定同步的IAM用户。
	UserNames *[]string `json:"user_names,omitempty"`
}

CancelSyncRequest 取消IAM同步请求的指定参数

func (CancelSyncRequest) String added in v0.1.76

func (o CancelSyncRequest) String() string

type CceInfo added in v0.1.99

type CceInfo struct {

	// pod名称。
	PodName *string `json:"pod_name,omitempty"`

	// pod的IP。
	PodIp *string `json:"pod_ip,omitempty"`

	// pod的ID。
	PodId *string `json:"pod_id,omitempty"`

	// 容器集群ID。对应CCE集群ID。
	CceClusterId *string `json:"cce_cluster_id,omitempty"`

	// 容器集群命名空间。
	CceNamespace *string `json:"cce_namespace,omitempty"`

	// cce节点IP。
	CceNodeIp *string `json:"cce_node_ip,omitempty"`
}

CceInfo 容器信息。

func (CceInfo) String added in v0.1.99

func (o CceInfo) String() string

type ChargeInfo

type ChargeInfo struct {

	// 计费模式。 取值范围: - prePaid:预付费,即包年/包月。(创建集群接口现已支持预付费,创建集群并提交作业接口暂不支持预付费。) - postPaid:后付费,即按需计费。
	ChargeMode string `json:"charge_mode"`

	// 周期类型。取值范围: - month:包月。 - year: 包年。 - day:按需计费。
	PeriodType *string `json:"period_type,omitempty"`

	// 周期数,“charge_mode”为“prePaid”时生效,且为必选值,指定订购的时间。取值范围: - 当“period_type”为“month”时,取值为1~9。 - 当“period_type”为“year”时,取值为1~3。
	PeriodNum *int32 `json:"period_num,omitempty"`

	// 是否自动支付,包周期模式下使用,下单订购后,是否自动从客户的账户中支付,而不需要客户手动去进行支付,默认为手动支付。取值范围: - true:自动支付,会自动选择折扣和优惠券进行优惠,然后自动从客户账户中支付,自动支付失败后会生成订单成功、但订单状态为“待支付”,等待客户手动支付。 - false:手动支付,需要客户手动去支付,客户可以选择折扣和优惠券。
	IsAutoPay *bool `json:"is_auto_pay,omitempty"`
}

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

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

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 ClusterNode added in v0.1.99

type ClusterNode struct {

	// 节点名称,对应manager里的节点名称。
	NodeName *string `json:"node_name,omitempty"`

	// 资源id。确定节点的唯一性,包周期节点可用于计费的查询。
	ResourceId *string `json:"resource_id,omitempty"`

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

	// 节点类型。Task、Core、Master等。
	NodeType *string `json:"node_type,omitempty"`

	// on-period包周期或者on-quantity按需。
	BillingType *string `json:"billing_type,omitempty"`

	// 部署类型。支持Server主机类型。
	DeploymentType string `json:"deployment_type"`

	ServerInfo *ServerInfo `json:"server_info,omitempty"`

	CceInfo *CceInfo `json:"cce_info,omitempty"`

	// 节点标签
	Tags *[]Tag `json:"tags,omitempty"`

	NodeDetail *NodeDetail `json:"node_detail,omitempty"`

	// 节点状态。对应页面上的操作状态。
	NodeStatus *string `json:"node_status,omitempty"`

	// 组件实例信息数组。
	ComponentInfos *[]ComponentInfo `json:"component_infos,omitempty"`
}

func (ClusterNode) String added in v0.1.99

func (o ClusterNode) String() string

type ComponentConfig added in v0.1.35

type ComponentConfig struct {

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

	// 组件配置项列表
	Configs *[]Config `json:"configs,omitempty"`
}

func (ComponentConfig) String added in v0.1.35

func (o ComponentConfig) String() string

type ComponentInfo added in v0.1.99

type ComponentInfo struct {

	// 组件ID。
	Id *string `json:"id,omitempty"`

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

	// 组件所在组名称。
	InstanceGroupName *string `json:"instance_group_name,omitempty"`

	// 运行状态。
	RunningStatus *string `json:"running_status,omitempty"`

	// HA状态。
	HaStatus *string `json:"ha_status,omitempty"`

	// 配置状态。
	ConfigStatus *string `json:"config_status,omitempty"`

	// 角色。
	RoleName *string `json:"role_name,omitempty"`

	// 角色缩写。
	RoleShortName *string `json:"role_short_name,omitempty"`

	// 角色类型。
	RoleType *string `json:"role_type,omitempty"`

	// 服务名。
	ServiceName *string `json:"service_name,omitempty"`

	// 对名。
	PairName *string `json:"pair_name,omitempty"`

	// 关联对。
	RelationPairs *string `json:"relation_pairs,omitempty"`

	// 是否支持Decom。
	SupportDecom *string `json:"support_decom,omitempty"`

	// 是否支持重装。
	SupportReinstall *string `json:"support_reinstall,omitempty"`

	// 是否支持收集堆栈信息。
	SupportCollectStackInfo *string `json:"support_collect_stack_info,omitempty"`
}

ComponentInfo 组件实例信息。

func (ComponentInfo) String added in v0.1.99

func (o ComponentInfo) String() string

type ComponentInstallMode added in v0.1.67

type ComponentInstallMode struct {

	// 组件名称
	Component string `json:"component"`

	// 该组件的角色部署信息
	NodeGroups []AssignedNodeGroup `json:"node_groups"`

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

	// 配置组件default用户密码,该密码用于ClickHouse组件人机用户连接使用。 - 密码长度应在8~26个字符之间 - 不能与用户名或者倒序用户名相同 - 必须包含如下4种字符的组合 - 至少一个小写字母 - 至少一个大写字母 - 至少一个数字 - 至少一个特殊字符:!@$%^-_=+[{}]:,./?
	ComponentDefaultPassword *string `json:"component_default_password,omitempty"`
}

ComponentInstallMode 组件详情

func (ComponentInstallMode) String added in v0.1.67

func (o ComponentInstallMode) String() string

type Config added in v0.1.35

type Config struct {

	// 配置名,仅支持MRS组件配置页面上所展示的配置名。
	Key string `json:"key"`

	// 配置值
	Value string `json:"value"`

	// 配置文件名,仅支持MRS组件配置页面上所展示的文件名。
	ConfigFileName string `json:"config_file_name"`
}

func (Config) String added in v0.1.35

func (o Config) String() string

type CreateAutoScalingPolicyRequest added in v0.1.71

type CreateAutoScalingPolicyRequest struct {

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

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

CreateAutoScalingPolicyRequest Request Object

func (CreateAutoScalingPolicyRequest) String added in v0.1.71

type CreateAutoScalingPolicyResponse added in v0.1.71

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

CreateAutoScalingPolicyResponse Response Object

func (CreateAutoScalingPolicyResponse) String added in v0.1.71

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的入方向规则。 - 支持多个安全组ID,以逗号分隔。
	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"`

	// 创建集群时可同时提交作业,当前仅MRS1.8.7之前版本支持,暂时只支持新增一个作业。建议使用创建集群并提交作业接口RunJobFlow的steps参数
	AddJobs *[]AddJobsReqV11 `json:"add_jobs,omitempty"`

	// 集群日志转储至OBS的具体路径。 开启日志转储功能后,日志上传需要对应OBS路径的读写权限, 请配置MRS_ECS_DEFULT_AGENCY默认委托或具有对应OBS路径读写权限的自定义委托。 具体请参见[配置存算分离集群(委托方式)](https://support.huaweicloud.com/usermanual-mrs/mrs_01_0768.html)。 该参数只适用于支持“集群日志转储OBS”特性的集群版本。
	LogUri *string `json:"log_uri,omitempty"`

	// 集群组件自定义配置。 该参数只适用于支持“自定义组件配置创建集群”特性的集群版本。
	ComponentConfigs *[]ComponentConfig `json:"component_configs,omitempty"`

	SmnNotify *SmnNotify `json:"smn_notify,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

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"`
}

CreateClusterRequest 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:"-"`
}

CreateClusterResponse Response Object

func (CreateClusterResponse) String

func (o CreateClusterResponse) String() string

type CreateDataConnectorRequest added in v0.1.52

type CreateDataConnectorRequest struct {
	Body *DataConnectorReq `json:"body,omitempty"`
}

CreateDataConnectorRequest Request Object

func (CreateDataConnectorRequest) String added in v0.1.52

type CreateDataConnectorResponse added in v0.1.52

type CreateDataConnectorResponse struct {

	// 数据连接创建成功后系统返回的数据连接ID值。
	ConnectorId    *string `json:"connector_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateDataConnectorResponse Response Object

func (CreateDataConnectorResponse) String added in v0.1.52

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"`
}

CreateExecuteJobRequest 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:"-"`
}

CreateExecuteJobResponse Response Object

func (CreateExecuteJobResponse) String

func (o CreateExecuteJobResponse) String() string

type DataConnector added in v0.1.52

type DataConnector struct {

	// 数据连接名称。
	ConnectorName string `json:"connector_name"`

	// 数据连接类型。 - RDS_POSTGRES:RDS服务PostgreSQL数据库 - RDS_MYSQL:RDS服务MySQL数据库 - gaussdb-mysql:云数据库GaussDB(for MySQL)
	SourceType DataConnectorSourceType `json:"source_type"`

	// 数据源信息,为json格式,不同数据连接有不同的信息,各数据源的source_info请求内容可参见示例。
	SourceInfo string `json:"source_info"`
}

func (DataConnector) String added in v0.1.52

func (o DataConnector) String() string

type DataConnectorDetail added in v0.1.52

type DataConnectorDetail struct {

	// 数据连接名称。
	ConnectorName string `json:"connector_name"`

	// 数据连接类型。 - RDS_POSTGRES:RDS服务PostgreSQL数据库 - RDS_MYSQL:RDS服务MySQL数据库 - gaussdb-mysql:云数据库GaussDB(for MySQL)
	SourceType DataConnectorDetailSourceType `json:"source_type"`

	// 数据源信息,为json格式,不同数据连接有不同的信息,各数据源的source_info请求内容可参见示例。
	SourceInfo string `json:"source_info"`

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

	// 创建时间
	CreateTime *int64 `json:"create_time,omitempty"`

	// 最后更新时间
	LastUpdateTime *int64 `json:"last_update_time,omitempty"`

	// 创建时间
	CreateBy *string `json:"create_by,omitempty"`

	// 创建用户
	CreateUser *string `json:"create_user,omitempty"`

	// 租户ID
	TenantId *string `json:"tenant_id,omitempty"`

	// 最后更新时间
	LastUpdateBy *string `json:"last_update_by,omitempty"`

	// 数据连接状态
	Status *int32 `json:"status,omitempty"`

	// 使用集群
	UsedClusters *string `json:"used_clusters,omitempty"`

	// 加密类型
	EncryptType *int32 `json:"encrypt_type,omitempty"`
}

func (DataConnectorDetail) String added in v0.1.52

func (o DataConnectorDetail) String() string

type DataConnectorDetailSourceType added in v0.1.52

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

func (DataConnectorDetailSourceType) MarshalJSON added in v0.1.52

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

func (*DataConnectorDetailSourceType) UnmarshalJSON added in v0.1.52

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

func (DataConnectorDetailSourceType) Value added in v0.1.52

type DataConnectorDetailSourceTypeEnum added in v0.1.52

type DataConnectorDetailSourceTypeEnum struct {
	RDS_MYSQL     DataConnectorDetailSourceType
	RDS_POSTGRES  DataConnectorDetailSourceType
	GAUSSDB_MYSQL DataConnectorDetailSourceType
}

func GetDataConnectorDetailSourceTypeEnum added in v0.1.52

func GetDataConnectorDetailSourceTypeEnum() DataConnectorDetailSourceTypeEnum

type DataConnectorReq added in v0.1.52

type DataConnectorReq struct {
	DataConnector *DataConnector `json:"data_connector"`
}

DataConnectorReq 创建数据连接请求

func (DataConnectorReq) String added in v0.1.52

func (o DataConnectorReq) String() string

type DataConnectorSourceType added in v0.1.52

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

func (DataConnectorSourceType) MarshalJSON added in v0.1.52

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

func (*DataConnectorSourceType) UnmarshalJSON added in v0.1.52

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

func (DataConnectorSourceType) Value added in v0.1.52

func (c DataConnectorSourceType) Value() string

type DataConnectorSourceTypeEnum added in v0.1.52

type DataConnectorSourceTypeEnum struct {
	RDS_MYSQL     DataConnectorSourceType
	RDS_POSTGRES  DataConnectorSourceType
	GAUSSDB_MYSQL DataConnectorSourceType
}

func GetDataConnectorSourceTypeEnum added in v0.1.52

func GetDataConnectorSourceTypeEnum() DataConnectorSourceTypeEnum

type DeleteAutoScalingPolicyRequest added in v0.1.71

type DeleteAutoScalingPolicyRequest struct {

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

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

DeleteAutoScalingPolicyRequest Request Object

func (DeleteAutoScalingPolicyRequest) String added in v0.1.71

type DeleteAutoScalingPolicyResponse added in v0.1.71

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

DeleteAutoScalingPolicyResponse Response Object

func (DeleteAutoScalingPolicyResponse) String added in v0.1.71

type DeleteDataConnectorRequest added in v0.1.52

type DeleteDataConnectorRequest struct {

	// 数据连接id
	ConnectorId string `json:"connector_id"`
}

DeleteDataConnectorRequest Request Object

func (DeleteDataConnectorRequest) String added in v0.1.52

type DeleteDataConnectorResponse added in v0.1.52

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

DeleteDataConnectorResponse Response Object

func (DeleteDataConnectorResponse) String added in v0.1.52

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"`
}

ExecuteSqlRequest 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:"-"`
}

ExecuteSqlResponse Response Object

func (ExecuteSqlResponse) String

func (o ExecuteSqlResponse) String() string

type ExpandClusterRequest added in v0.1.60

type ExpandClusterRequest struct {

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

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

ExpandClusterRequest Request Object

func (ExpandClusterRequest) String added in v0.1.60

func (o ExpandClusterRequest) String() string

type ExpandClusterResponse added in v0.1.60

type ExpandClusterResponse struct {

	// 请求操作结果,succeeded为操作成功,failed为操作失败。非包周期节点组扩容请求下发成功时,会包含该字段且内容为success。
	Result *string `json:"result,omitempty"`

	// 订单ID。对包周期节点组进行扩容时,会返回本次扩容产生的订单ID,需要客户到订单支付页面进行自主支付才能真正触发扩容。
	OrderId        *string `json:"order_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExpandClusterResponse Response Object

func (ExpandClusterResponse) String added in v0.1.60

func (o ExpandClusterResponse) String() string

type ExpandParam added in v0.1.60

type ExpandParam struct {

	// 节点组名称
	NodeGroupName string `json:"node_group_name"`

	// 扩容节点数量
	Count int32 `json:"count"`

	// 扩容时是否在新增节点上跳过执行创建集群时指定的引导操作。未填写时,默认不执行引导操作。
	SkipBootstrapScripts *bool `json:"skip_bootstrap_scripts,omitempty"`

	// 扩容后是否选择不启动扩容节点上的组件。未填写时,默认启动组件。  - true:扩容后不启动组件。 - false:扩容后启动组件。
	ScaleWithoutStart *bool `json:"scale_without_start,omitempty"`

	// 支持跨AZ场景下的扩缩容,可以传入多个AZ,逗号分隔,如果为空或“”表示非跨az场景,不进行跨AZ扩缩容校验。
	AzCode *string `json:"az_code,omitempty"`
}

ExpandParam 扩容相关参数

func (ExpandParam) String added in v0.1.60

func (o ExpandParam) 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 Flavor added in v0.1.76

type Flavor struct {

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

Flavor 规格详情

func (Flavor) String added in v0.1.76

func (o Flavor) 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 ListDataConnectorRequest added in v0.1.52

type ListDataConnectorRequest struct {

	// 连接id
	ConnectorId *string `json:"connector_id,omitempty"`

	// 数据源类别
	SourceType *string `json:"source_type,omitempty"`

	// 数据连接名称
	ConnectorName *string `json:"connector_name,omitempty"`

	// 每页返回的资源个数
	Limit *int32 `json:"limit,omitempty"`

	// 分页查询起始偏移量
	Offset *int32 `json:"offset,omitempty"`

	// 数据连接是否有效
	Available *bool `json:"available,omitempty"`
}

ListDataConnectorRequest Request Object

func (ListDataConnectorRequest) String added in v0.1.52

func (o ListDataConnectorRequest) String() string

type ListDataConnectorResponse added in v0.1.52

type ListDataConnectorResponse struct {

	// 数据连接总数
	TotalCount *int32 `json:"total_count,omitempty"`

	// 数据连接详情列表
	DataConnectors *[]DataConnectorDetail `json:"data_connectors,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ListDataConnectorResponse Response Object

func (ListDataConnectorResponse) String added in v0.1.52

func (o ListDataConnectorResponse) String() string

type ListNodesRequest added in v0.1.99

type ListNodesRequest struct {

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

	// 要查询的节点组名称。
	NodeGroup *string `json:"node_group,omitempty"`

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

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

	// 指定节点名称,支持模糊搜索。
	NodeName *string `json:"node_name,omitempty"`

	// 排序键,支持对节点名称排序。
	SortKey *ListNodesRequestSortKey `json:"sort_key,omitempty"`

	// 列表排序方式,desc为降序,asc为升序。
	SortDir *ListNodesRequestSortDir `json:"sort_dir,omitempty"`

	// 是否查询节点详情。该字段设为true时可能会影响接口性能。
	QueryNodeDetail *bool `json:"query_node_detail,omitempty"`

	// 是否查询ECS详情信息,会涉及对ECS接口调用。
	QueryEcsDetail *bool `json:"query_ecs_detail,omitempty"`

	// 指定内网IP。
	InternalIp *string `json:"internal_ip,omitempty"`
}

ListNodesRequest Request Object

func (ListNodesRequest) String added in v0.1.99

func (o ListNodesRequest) String() string

type ListNodesRequestSortDir added in v0.1.99

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

func (ListNodesRequestSortDir) MarshalJSON added in v0.1.99

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

func (*ListNodesRequestSortDir) UnmarshalJSON added in v0.1.99

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

func (ListNodesRequestSortDir) Value added in v0.1.99

func (c ListNodesRequestSortDir) Value() string

type ListNodesRequestSortDirEnum added in v0.1.99

type ListNodesRequestSortDirEnum struct {
	DESC ListNodesRequestSortDir
	ASC  ListNodesRequestSortDir
}

func GetListNodesRequestSortDirEnum added in v0.1.99

func GetListNodesRequestSortDirEnum() ListNodesRequestSortDirEnum

type ListNodesRequestSortKey added in v0.1.99

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

func (ListNodesRequestSortKey) MarshalJSON added in v0.1.99

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

func (*ListNodesRequestSortKey) UnmarshalJSON added in v0.1.99

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

func (ListNodesRequestSortKey) Value added in v0.1.99

func (c ListNodesRequestSortKey) Value() string

type ListNodesRequestSortKeyEnum added in v0.1.99

type ListNodesRequestSortKeyEnum struct {
	NODE_NAME ListNodesRequestSortKey
}

func GetListNodesRequestSortKeyEnum added in v0.1.99

func GetListNodesRequestSortKeyEnum() ListNodesRequestSortKeyEnum

type ListNodesResponse added in v0.1.99

type ListNodesResponse struct {

	// 节点列表。
	Nodes *[]ClusterNode `json:"nodes,omitempty"`

	// 节点数。
	NodeTotal      *int32 `json:"node_total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListNodesResponse Response Object

func (ListNodesResponse) String added in v0.1.99

func (o ListNodesResponse) String() string

type ModifyDefaultTagsRequestBody added in v0.1.72

type ModifyDefaultTagsRequestBody struct {

	// 操作类型,支持创建和删除
	Action ModifyDefaultTagsRequestBodyAction `json:"action"`
}

ModifyDefaultTagsRequestBody 操作默认标签请求体

func (ModifyDefaultTagsRequestBody) String added in v0.1.72

type ModifyDefaultTagsRequestBodyAction added in v0.1.72

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

func (ModifyDefaultTagsRequestBodyAction) MarshalJSON added in v0.1.72

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

func (*ModifyDefaultTagsRequestBodyAction) UnmarshalJSON added in v0.1.72

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

func (ModifyDefaultTagsRequestBodyAction) Value added in v0.1.72

type ModifyDefaultTagsRequestBodyActionEnum added in v0.1.72

type ModifyDefaultTagsRequestBodyActionEnum struct {
	CREATE ModifyDefaultTagsRequestBodyAction
	DELETE ModifyDefaultTagsRequestBodyAction
}

func GetModifyDefaultTagsRequestBodyActionEnum added in v0.1.72

func GetModifyDefaultTagsRequestBodyActionEnum() ModifyDefaultTagsRequestBodyActionEnum

type NodeDetail added in v0.1.99

type NodeDetail struct {

	// 运行状态。
	RunningStatus *string `json:"running_status,omitempty"`

	// CPU使用率。
	CpuUsage *string `json:"cpu_usage,omitempty"`

	// 内存使用率。
	MemoryUsage *string `json:"memory_usage,omitempty"`

	// 硬盘使用率。
	DiskUsage *string `json:"disk_usage,omitempty"`

	// 总内存。单位MB。
	TotalMemory *string `json:"total_memory,omitempty"`

	// 可用内存。单位MB。
	AvailableMemory *string `json:"available_memory,omitempty"`

	// 总硬盘空间。单位GB。
	TotalHardDiskSpace *string `json:"total_hard_disk_space,omitempty"`

	// 可用硬盘空间。单位GB。
	AvailableHardDiskSpace *string `json:"available_hard_disk_space,omitempty"`

	// 网络读取速度。单位Byte/s。
	NetworkRead *string `json:"network_read,omitempty"`

	// 网络写入速度。单位Byte/s。
	NetworkWrite *string `json:"network_write,omitempty"`
}

NodeDetail 节点监控详情。

func (NodeDetail) String added in v0.1.99

func (o NodeDetail) String() string

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~20。
	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

type ResourcesPlanEffectiveDaysEnum added in v0.1.28

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 RunJobFlowCommand added in v0.1.35

type RunJobFlowCommand 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的入方向规则。 - 支持多个安全组ID,以逗号分隔。
	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 *RunJobFlowCommandLogCollection `json:"log_collection,omitempty"`

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

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

	// 集群日志转储至OBS的具体路径。 开启日志转储功能后,日志上传需要对应OBS路径的读写权限, 请配置MRS_ECS_DEFULT_AGENCY默认委托或具有对应OBS路径读写权限的自定义委托。 具体请参见[配置存算分离集群(委托方式)](https://support.huaweicloud.com/usermanual-mrs/mrs_01_0768.html)。 该参数只适用于支持“集群日志转储OBS”特性的集群版本。
	LogUri *string `json:"log_uri,omitempty"`

	// 集群组件自定义配置。 该参数只适用于支持“自定义组件配置创建集群”特性的集群版本。
	ComponentConfigs *[]ComponentConfig `json:"component_configs,omitempty"`

	// 作业完成后是否自动删除集群,默认为false。
	DeleteWhenNoSteps *bool `json:"delete_when_no_steps,omitempty"`

	// 作业列表。
	Steps []StepConfig `json:"steps"`
}

func (RunJobFlowCommand) String added in v0.1.35

func (o RunJobFlowCommand) String() string

type RunJobFlowCommandLogCollection added in v0.1.35

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

func (RunJobFlowCommandLogCollection) MarshalJSON added in v0.1.35

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

func (*RunJobFlowCommandLogCollection) UnmarshalJSON added in v0.1.35

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

func (RunJobFlowCommandLogCollection) Value added in v0.1.35

type RunJobFlowCommandLogCollectionEnum added in v0.1.35

type RunJobFlowCommandLogCollectionEnum struct {
	E_0 RunJobFlowCommandLogCollection
	E_1 RunJobFlowCommandLogCollection
}

func GetRunJobFlowCommandLogCollectionEnum added in v0.1.35

func GetRunJobFlowCommandLogCollectionEnum() RunJobFlowCommandLogCollectionEnum

type RunJobFlowRequest added in v0.1.35

type RunJobFlowRequest struct {
	Body *RunJobFlowCommand `json:"body,omitempty"`
}

RunJobFlowRequest Request Object

func (RunJobFlowRequest) String added in v0.1.35

func (o RunJobFlowRequest) String() string

type RunJobFlowResponse added in v0.1.35

type RunJobFlowResponse struct {

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

RunJobFlowResponse Response Object

func (RunJobFlowResponse) String added in v0.1.35

func (o RunJobFlowResponse) String() string

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 ServerInfo added in v0.1.99

type ServerInfo struct {

	// 服务器ID。
	ServerId string `json:"server_id"`

	// 服务器名称。
	ServerName string `json:"server_name"`

	// ECS或者BMS。
	ServerType string `json:"server_type"`

	// 数据盘。
	DataVolumes *[]VolumeInfo `json:"data_volumes,omitempty"`

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

	// CPU类型。x86或者ARM。
	CpuType *string `json:"cpu_type,omitempty"`

	// CPU大小。
	Cpu *string `json:"cpu,omitempty"`

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

	// 内部IP。
	InternalIp *string `json:"internal_ip,omitempty"`
}

func (ServerInfo) String added in v0.1.99

func (o ServerInfo) String() string

type ShowAgencyMappingRequest

type ShowAgencyMappingRequest struct {

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

ShowAgencyMappingRequest Request Object

func (ShowAgencyMappingRequest) String

func (o ShowAgencyMappingRequest) String() string

type ShowAgencyMappingResponse

type ShowAgencyMappingResponse struct {

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

ShowAgencyMappingResponse 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"`
}

ShowAutoScalingPolicyRequest Request Object

func (ShowAutoScalingPolicyRequest) String added in v0.1.13

type ShowAutoScalingPolicyResponse added in v0.1.13

type ShowAutoScalingPolicyResponse struct {

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

ShowAutoScalingPolicyResponse Response Object

func (ShowAutoScalingPolicyResponse) String added in v0.1.13

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"`
}

ShowHdfsFileListRequest 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

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

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:"-"`
}

ShowHdfsFileListResponse 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"`
}

ShowJobExeListNewRequest 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

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

type ShowJobExeListNewResponse

type ShowJobExeListNewResponse struct {

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

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

ShowJobExeListNewResponse Response Object

func (ShowJobExeListNewResponse) String

func (o ShowJobExeListNewResponse) String() string

type ShowMrsFlavorsRequest added in v0.1.76

type ShowMrsFlavorsRequest struct {

	// MRS集群版本,不支持多版本查询 ,例如 MRS%203.1.5.1
	VersionName string `json:"version_name"`

	// 可用区id,用于查询指定可用区的可用规格
	AvailabilityZone *string `json:"availability_zone,omitempty"`
}

ShowMrsFlavorsRequest Request Object

func (ShowMrsFlavorsRequest) String added in v0.1.76

func (o ShowMrsFlavorsRequest) String() string

type ShowMrsFlavorsResponse added in v0.1.76

type ShowMrsFlavorsResponse struct {

	// 版本名称
	VersionName *string `json:"version_name,omitempty"`

	// 不同可用区支持的规格列表
	AvailableFlavors *[]AzFlavors `json:"available_flavors,omitempty"`
	HttpStatusCode   int          `json:"-"`
}

ShowMrsFlavorsResponse Response Object

func (ShowMrsFlavorsResponse) String added in v0.1.76

func (o ShowMrsFlavorsResponse) String() string

type ShowMrsVersionListRequest added in v0.1.57

type ShowMrsVersionListRequest struct {
}

ShowMrsVersionListRequest Request Object

func (ShowMrsVersionListRequest) String added in v0.1.57

func (o ShowMrsVersionListRequest) String() string

type ShowMrsVersionListResponse added in v0.1.57

type ShowMrsVersionListResponse struct {

	// 可用集群版本列表
	ClusterVersions *[]string `json:"cluster_versions,omitempty"`
	HttpStatusCode  int       `json:"-"`
}

ShowMrsVersionListResponse Response Object

func (ShowMrsVersionListResponse) String added in v0.1.57

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"`
}

ShowSingleJobExeRequest Request Object

func (ShowSingleJobExeRequest) String

func (o ShowSingleJobExeRequest) String() string

type ShowSingleJobExeResponse

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

ShowSingleJobExeResponse 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"`
}

ShowSqlResultRequest 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:"-"`
}

ShowSqlResultResponse 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"`
}

ShowSqlResultWithJobRequest Request Object

func (ShowSqlResultWithJobRequest) String

type ShowSqlResultWithJobResponse

type ShowSqlResultWithJobResponse struct {

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

ShowSqlResultWithJobResponse Response Object

func (ShowSqlResultWithJobResponse) String

type ShowSyncIamUserRequest added in v0.1.76

type ShowSyncIamUserRequest struct {

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

ShowSyncIamUserRequest Request Object

func (ShowSyncIamUserRequest) String added in v0.1.76

func (o ShowSyncIamUserRequest) String() string

type ShowSyncIamUserResponse added in v0.1.76

type ShowSyncIamUserResponse struct {

	// 已经同步了的用户
	UserNames *[]string `json:"user_names,omitempty"`

	// 已经同步了的用户组
	GroupNames     *[]string `json:"group_names,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowSyncIamUserResponse Response Object

func (ShowSyncIamUserResponse) String added in v0.1.76

func (o ShowSyncIamUserResponse) String() string

type ShowTagQuotaRequest added in v0.1.72

type ShowTagQuotaRequest struct {

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

	// 是否查询弹性伸缩策略标签
	AutoScalingPolicyTags *bool `json:"auto_scaling_policy_tags,omitempty"`
}

ShowTagQuotaRequest Request Object

func (ShowTagQuotaRequest) String added in v0.1.72

func (o ShowTagQuotaRequest) String() string

type ShowTagQuotaResponse added in v0.1.72

type ShowTagQuotaResponse struct {

	// 总配额大小
	TotalQuota *int32 `json:"total_quota,omitempty"`

	// 可使用配额大小
	AvailableQuota *int32 `json:"available_quota,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowTagQuotaResponse Response Object

func (ShowTagQuotaResponse) String added in v0.1.72

func (o ShowTagQuotaResponse) String() string

type ShowTagStatusRequest added in v0.1.72

type ShowTagStatusRequest struct {

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

ShowTagStatusRequest Request Object

func (ShowTagStatusRequest) String added in v0.1.72

func (o ShowTagStatusRequest) String() string

type ShowTagStatusResponse added in v0.1.72

type ShowTagStatusResponse struct {

	// 标签处理状态
	Status *ShowTagStatusResponseStatus `json:"status,omitempty"`

	// 默认标签是否已开启
	DefaultTagsEnable *bool `json:"default_tags_enable,omitempty"`
	HttpStatusCode    int   `json:"-"`
}

ShowTagStatusResponse Response Object

func (ShowTagStatusResponse) String added in v0.1.72

func (o ShowTagStatusResponse) String() string

type ShowTagStatusResponseStatus added in v0.1.72

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

func (ShowTagStatusResponseStatus) MarshalJSON added in v0.1.72

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

func (*ShowTagStatusResponseStatus) UnmarshalJSON added in v0.1.72

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

func (ShowTagStatusResponseStatus) Value added in v0.1.72

type ShowTagStatusResponseStatusEnum added in v0.1.72

type ShowTagStatusResponseStatusEnum struct {
	PROCESSING ShowTagStatusResponseStatus
	SUCCEED    ShowTagStatusResponseStatus
	FAILED     ShowTagStatusResponseStatus
}

func GetShowTagStatusResponseStatusEnum added in v0.1.72

func GetShowTagStatusResponseStatusEnum() ShowTagStatusResponseStatusEnum

type ShrinkClusterRequest added in v0.1.60

type ShrinkClusterRequest struct {

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

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

ShrinkClusterRequest Request Object

func (ShrinkClusterRequest) String added in v0.1.60

func (o ShrinkClusterRequest) String() string

type ShrinkClusterResponse added in v0.1.60

type ShrinkClusterResponse struct {

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

ShrinkClusterResponse Response Object

func (ShrinkClusterResponse) String added in v0.1.60

func (o ShrinkClusterResponse) String() string

type ShrinkParam added in v0.1.60

type ShrinkParam struct {

	// 节点组名称
	NodeGroupName string `json:"node_group_name"`

	// 缩容节点数量,如果是指定节点缩容,则该参数可以不填。
	Count *int32 `json:"count,omitempty"`

	// 缩容节点时指定待删除节点的资源ID列表。 resource_ids为空时,按照系统规则自动选择删除节点。 仅支持删除状态异常的ecs节点。 会针对指定节点进行强制删除。 可通过查询主机接口获取resource_id。
	ResourceIds *[]string `json:"resource_ids,omitempty"`

	// 启用该参数时,如果缩容失败或者节点为异常状态,会进行强制删除主机操作。如果resource_id不为空,该值默认为true。 如果resource_ids为空,则默认为false。
	ForceDelete *bool `json:"force_delete,omitempty"`

	// 支持跨AZ场景下的扩缩容,可以传入多个AZ,逗号分隔,如果为空或“”表示非跨AZ场景,不进行跨AZ扩缩容校验。
	AzCode *string `json:"az_code,omitempty"`
}

ShrinkParam 缩容参数

func (ShrinkParam) String added in v0.1.60

func (o ShrinkParam) String() string

type SmnNotify added in v0.1.76

type SmnNotify struct {

	// SMN消息通知服务的主题urn,如果需要开启告警订阅,则必填。
	TopicUrn *string `json:"topic_urn,omitempty"`

	// 该订阅规则名称。如果不填写,则默认为default_alert_rule。
	SubscriptionName *string `json:"subscription_name,omitempty"`
}

SmnNotify smn消息订阅信息。用于订阅集群全量告警信息。如果需要配置更精细化的告警或者事件,请于创建集群完成后,在”告警管理“中进行设置。

func (SmnNotify) String added in v0.1.76

func (o SmnNotify) 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 StepConfig added in v0.1.35

type StepConfig struct {
	JobExecution *JobExecution `json:"job_execution"`
}

StepConfig 作业配置。

func (StepConfig) String added in v0.1.35

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

StopJobRequest Request Object

func (StopJobRequest) String

func (o StopJobRequest) String() string

type StopJobResponse

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

StopJobResponse Response Object

func (StopJobResponse) String

func (o StopJobResponse) String() string

type SwitchClusterTagsRequest added in v0.1.72

type SwitchClusterTagsRequest struct {

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

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

SwitchClusterTagsRequest Request Object

func (SwitchClusterTagsRequest) String added in v0.1.72

func (o SwitchClusterTagsRequest) String() string

type SwitchClusterTagsResponse added in v0.1.72

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

SwitchClusterTagsResponse Response Object

func (SwitchClusterTagsResponse) String added in v0.1.72

func (o SwitchClusterTagsResponse) String() string

type Tag

type Tag struct {

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

	// 标签值。
	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"`
}

UpdateAgencyMappingRequest Request Object

func (UpdateAgencyMappingRequest) String

type UpdateAgencyMappingResponse

type UpdateAgencyMappingResponse struct {

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

UpdateAgencyMappingResponse Response Object

func (UpdateAgencyMappingResponse) String

type UpdateAutoScalingPolicyRequest added in v0.1.71

type UpdateAutoScalingPolicyRequest struct {

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

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

UpdateAutoScalingPolicyRequest Request Object

func (UpdateAutoScalingPolicyRequest) String added in v0.1.71

type UpdateAutoScalingPolicyResponse added in v0.1.71

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

UpdateAutoScalingPolicyResponse Response Object

func (UpdateAutoScalingPolicyResponse) String added in v0.1.71

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"`
}

UpdateClusterNameRequest 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:"-"`
}

UpdateClusterNameResponse 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 UpdateDataConnectorRequest added in v0.1.52

type UpdateDataConnectorRequest struct {

	// 数据连接id
	ConnectorId string `json:"connector_id"`

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

UpdateDataConnectorRequest Request Object

func (UpdateDataConnectorRequest) String added in v0.1.52

type UpdateDataConnectorResponse added in v0.1.52

type UpdateDataConnectorResponse struct {

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

UpdateDataConnectorResponse Response Object

func (UpdateDataConnectorResponse) String added in v0.1.52

type UpdateSyncIamUserRequest added in v0.1.76

type UpdateSyncIamUserRequest struct {

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

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

UpdateSyncIamUserRequest Request Object

func (UpdateSyncIamUserRequest) String added in v0.1.76

func (o UpdateSyncIamUserRequest) String() string

type UpdateSyncIamUserResponse added in v0.1.76

type UpdateSyncIamUserResponse struct {

	// 请求下发的结果
	State          *string `json:"state,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSyncIamUserResponse Response Object

func (UpdateSyncIamUserResponse) String added in v0.1.76

func (o UpdateSyncIamUserResponse) String() string

type UpdateSyncRequest added in v0.1.76

type UpdateSyncRequest struct {

	// 是否是全量同步。true为全量同步,false为指定用户、用户组同步。默认值为false。
	IsAllSync *bool `json:"is_all_sync,omitempty"`

	// 指定同步的IAM用户组。
	GroupNames *[]string `json:"group_names,omitempty"`

	// 指定同步的IAM用户。
	UserNames *[]string `json:"user_names,omitempty"`
}

UpdateSyncRequest IAM同步请求的指定参数

func (UpdateSyncRequest) String added in v0.1.76

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

type VolumeInfo added in v0.1.99

type VolumeInfo struct {

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

	// 磁盘大小。单位为GB。
	Size int32 `json:"size"`

	// 磁盘数量。
	Count int32 `json:"count"`
}

VolumeInfo 磁盘信息。

func (VolumeInfo) String added in v0.1.99

func (o VolumeInfo) String() string

Source Files

Jump to

Keyboard shortcuts

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