Documentation ¶
Index ¶
- type AddJobs
- type AutoScalingPolicy
- type AutoScalingPolicyReqV11
- type AutoScalingPolicyReqV11NodeGroup
- type AutoScalingPolicyReqV11NodeGroupEnum
- type BatchCreateClusterTagsReq
- type BatchCreateClusterTagsReqAction
- type BatchCreateClusterTagsReqActionEnum
- type BatchCreateClusterTagsRequest
- type BatchCreateClusterTagsResponse
- type BatchDeleteClusterTagsReq
- type BatchDeleteClusterTagsReqAction
- type BatchDeleteClusterTagsReqActionEnum
- type BatchDeleteClusterTagsRequest
- type BatchDeleteClusterTagsResponse
- type BootstrapScript
- type BootstrapScriptActionStages
- type BootstrapScriptActionStagesEnum
- type BootstrapScriptFailAction
- type BootstrapScriptFailActionEnum
- type BootstrapScriptResp
- type BootstrapScriptRespFailAction
- type BootstrapScriptRespFailActionEnum
- type Cluster
- type ClusterScalingParams
- type ClusterScalingParamsScaleType
- type ClusterScalingParamsScaleTypeEnum
- type ClusterScalingReq
- type ComponentAmb
- type ComponentList
- type CreateAndExecuteJobRequest
- type CreateAndExecuteJobResponse
- type CreateClusterReq
- type CreateClusterReqBillingType
- type CreateClusterReqBillingTypeEnum
- type CreateClusterReqClusterType
- type CreateClusterReqClusterTypeEnum
- type CreateClusterReqCoreDataVolumeType
- type CreateClusterReqCoreDataVolumeTypeEnum
- type CreateClusterReqLogCollection
- type CreateClusterReqLogCollectionEnum
- type CreateClusterReqLoginMode
- type CreateClusterReqLoginModeEnum
- type CreateClusterReqMasterDataVolumeCount
- type CreateClusterReqMasterDataVolumeCountEnum
- type CreateClusterReqMasterDataVolumeType
- type CreateClusterReqMasterDataVolumeTypeEnum
- type CreateClusterReqSafeMode
- type CreateClusterReqSafeModeEnum
- type CreateClusterReqVolumeType
- type CreateClusterReqVolumeTypeEnum
- type CreateClusterRequest
- type CreateClusterResponse
- type CreateClusterTagRequest
- type CreateClusterTagResponse
- type CreateScalingPolicyRequest
- type CreateScalingPolicyResponse
- type CreateTagReq
- type DeleteClusterRequest
- type DeleteClusterResponse
- type DeleteClusterTagRequest
- type DeleteClusterTagResponse
- type DeleteJobExecutionRequest
- type DeleteJobExecutionResponse
- type HostModel
- type JobExeResult
- type ListAllTagsRequest
- type ListAllTagsResponse
- type ListClusterTagsRequest
- type ListClusterTagsResponse
- type ListClustersByTagsRequest
- type ListClustersByTagsResponse
- type ListClustersRequest
- type ListClustersResponse
- type ListExecuteJobRequest
- type ListExecuteJobResponse
- type ListHostsRequest
- type ListHostsResponse
- type ListResourceReq
- type ListResourceReqAction
- type ListResourceReqActionEnum
- type Match
- type MrsResource
- type NodeGroupV10
- type NodeGroupV10DataVolumeType
- type NodeGroupV10DataVolumeTypeEnum
- type NodeGroupV11
- type ResourcesPlan
- type Rules
- type RulesAdjustmentType
- type RulesAdjustmentTypeEnum
- type ScaleScript
- type ScaleScriptActionStage
- type ScaleScriptActionStageEnum
- type ScaleScriptFailAction
- type ScaleScriptFailActionEnum
- type ShowClusterDetailsRequest
- type ShowClusterDetailsResponse
- type ShowJobExesRequest
- type ShowJobExesResponse
- type SubmitJobReqV11
- type Tag
- type TagPlain
- type TagWithMultiValue
- type TaskNodeGroups
- type TaskNodeGroupsDataVolumeType
- type TaskNodeGroupsDataVolumeTypeEnum
- type TaskNodeInfo
- type TaskNodeInfoDataVolumeType
- type TaskNodeInfoDataVolumeTypeEnum
- type Trigger
- type UpdateClusterScalingRequest
- type UpdateClusterScalingResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddJobs ¶
type AddJobs struct { JobType int32 `json:"job_type"` JobName string `json:"job_name"` JarPath *string `json:"jar_path,omitempty"` Arguments *string `json:"arguments,omitempty"` Input *string `json:"input,omitempty"` Output *string `json:"output,omitempty"` JobLog *string `json:"job_log,omitempty"` HiveScriptPath *string `json:"hive_script_path,omitempty"` Hql *string `json:"hql,omitempty"` ShutdownCluster *bool `json:"shutdown_cluster,omitempty"` SubmitJobOnceClusterRun bool `json:"submit_job_once_cluster_run"` FileAction *string `json:"file_action,omitempty"` }
type AutoScalingPolicy ¶
type AutoScalingPolicy struct { AutoScalingEnable bool `json:"auto_scaling_enable"` MinCapacity int32 `json:"min_capacity"` MaxCapacity int32 `json:"max_capacity"` ResourcesPlans *[]ResourcesPlan `json:"resources_plans,omitempty"` Rules *[]Rules `json:"rules,omitempty"` ExecScripts *[]ScaleScript `json:"exec_scripts,omitempty"` }
func (AutoScalingPolicy) String ¶
func (o AutoScalingPolicy) String() string
type AutoScalingPolicyReqV11 ¶ added in v0.0.73
type AutoScalingPolicyReqV11 struct { NodeGroup AutoScalingPolicyReqV11NodeGroup `json:"node_group"` AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy"` }
func (AutoScalingPolicyReqV11) String ¶ added in v0.0.73
func (o AutoScalingPolicyReqV11) String() string
type AutoScalingPolicyReqV11NodeGroup ¶ added in v0.0.73
type AutoScalingPolicyReqV11NodeGroup struct {
// contains filtered or unexported fields
}
func (AutoScalingPolicyReqV11NodeGroup) MarshalJSON ¶ added in v0.0.73
func (c AutoScalingPolicyReqV11NodeGroup) MarshalJSON() ([]byte, error)
func (*AutoScalingPolicyReqV11NodeGroup) UnmarshalJSON ¶ added in v0.0.73
func (c *AutoScalingPolicyReqV11NodeGroup) UnmarshalJSON(b []byte) error
type AutoScalingPolicyReqV11NodeGroupEnum ¶ added in v0.0.73
type AutoScalingPolicyReqV11NodeGroupEnum struct {
TASK_NODE_DEFAULT_GROUP AutoScalingPolicyReqV11NodeGroup
}
func GetAutoScalingPolicyReqV11NodeGroupEnum ¶ added in v0.0.73
func GetAutoScalingPolicyReqV11NodeGroupEnum() AutoScalingPolicyReqV11NodeGroupEnum
type BatchCreateClusterTagsReq ¶
type BatchCreateClusterTagsReq struct { Action BatchCreateClusterTagsReqAction `json:"action"` Tags []Tag `json:"tags"` }
func (BatchCreateClusterTagsReq) String ¶
func (o BatchCreateClusterTagsReq) String() string
type BatchCreateClusterTagsReqAction ¶
type BatchCreateClusterTagsReqAction struct {
// contains filtered or unexported fields
}
func (BatchCreateClusterTagsReqAction) MarshalJSON ¶
func (c BatchCreateClusterTagsReqAction) MarshalJSON() ([]byte, error)
func (*BatchCreateClusterTagsReqAction) UnmarshalJSON ¶
func (c *BatchCreateClusterTagsReqAction) UnmarshalJSON(b []byte) error
type BatchCreateClusterTagsReqActionEnum ¶
type BatchCreateClusterTagsReqActionEnum struct {
CREATE BatchCreateClusterTagsReqAction
}
func GetBatchCreateClusterTagsReqActionEnum ¶
func GetBatchCreateClusterTagsReqActionEnum() BatchCreateClusterTagsReqActionEnum
type BatchCreateClusterTagsRequest ¶
type BatchCreateClusterTagsRequest struct { ClusterId string `json:"cluster_id"` Body *BatchCreateClusterTagsReq `json:"body,omitempty"` }
Request Object
func (BatchCreateClusterTagsRequest) String ¶
func (o BatchCreateClusterTagsRequest) String() string
type BatchCreateClusterTagsResponse ¶
type BatchCreateClusterTagsResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (BatchCreateClusterTagsResponse) String ¶
func (o BatchCreateClusterTagsResponse) String() string
type BatchDeleteClusterTagsReq ¶
type BatchDeleteClusterTagsReq struct { Action BatchDeleteClusterTagsReqAction `json:"action"` Tags []Tag `json:"tags"` }
func (BatchDeleteClusterTagsReq) String ¶
func (o BatchDeleteClusterTagsReq) String() string
type BatchDeleteClusterTagsReqAction ¶
type BatchDeleteClusterTagsReqAction struct {
// contains filtered or unexported fields
}
func (BatchDeleteClusterTagsReqAction) MarshalJSON ¶
func (c BatchDeleteClusterTagsReqAction) MarshalJSON() ([]byte, error)
func (*BatchDeleteClusterTagsReqAction) UnmarshalJSON ¶
func (c *BatchDeleteClusterTagsReqAction) UnmarshalJSON(b []byte) error
type BatchDeleteClusterTagsReqActionEnum ¶
type BatchDeleteClusterTagsReqActionEnum struct {
DELETE BatchDeleteClusterTagsReqAction
}
func GetBatchDeleteClusterTagsReqActionEnum ¶
func GetBatchDeleteClusterTagsReqActionEnum() BatchDeleteClusterTagsReqActionEnum
type BatchDeleteClusterTagsRequest ¶
type BatchDeleteClusterTagsRequest struct { ClusterId string `json:"cluster_id"` Body *BatchDeleteClusterTagsReq `json:"body,omitempty"` }
Request Object
func (BatchDeleteClusterTagsRequest) String ¶
func (o BatchDeleteClusterTagsRequest) String() string
type BatchDeleteClusterTagsResponse ¶
type BatchDeleteClusterTagsResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (BatchDeleteClusterTagsResponse) String ¶
func (o BatchDeleteClusterTagsResponse) String() string
type BootstrapScript ¶
type BootstrapScript struct { Name string `json:"name"` Uri string `json:"uri"` Parameters *string `json:"parameters,omitempty"` Nodes []string `json:"nodes"` ActiveMaster *bool `json:"active_master,omitempty"` FailAction BootstrapScriptFailAction `json:"fail_action"` BeforeComponentStart *bool `json:"before_component_start,omitempty"` ActionStages *[]BootstrapScriptActionStages `json:"action_stages,omitempty"` }
func (BootstrapScript) String ¶
func (o BootstrapScript) String() string
type BootstrapScriptActionStages ¶ added in v0.0.50
type BootstrapScriptActionStages struct {
// contains filtered or unexported fields
}
func (BootstrapScriptActionStages) MarshalJSON ¶ added in v0.0.50
func (c BootstrapScriptActionStages) MarshalJSON() ([]byte, error)
func (*BootstrapScriptActionStages) UnmarshalJSON ¶ added in v0.0.50
func (c *BootstrapScriptActionStages) UnmarshalJSON(b []byte) error
type BootstrapScriptActionStagesEnum ¶ added in v0.0.50
type BootstrapScriptActionStagesEnum struct { BEFORE_COMPONENT_FIRST_START BootstrapScriptActionStages AFTER_COMPONENT_FIRST_START BootstrapScriptActionStages BEFORE_SCALE_IN BootstrapScriptActionStages AFTER_SCALE_IN BootstrapScriptActionStages BEFORE_SCALE_OUT BootstrapScriptActionStages AFTER_SCALE_OUT BootstrapScriptActionStages }
func GetBootstrapScriptActionStagesEnum ¶ added in v0.0.50
func GetBootstrapScriptActionStagesEnum() BootstrapScriptActionStagesEnum
type BootstrapScriptFailAction ¶
type BootstrapScriptFailAction struct {
// contains filtered or unexported fields
}
func (BootstrapScriptFailAction) MarshalJSON ¶
func (c BootstrapScriptFailAction) MarshalJSON() ([]byte, error)
func (*BootstrapScriptFailAction) UnmarshalJSON ¶
func (c *BootstrapScriptFailAction) UnmarshalJSON(b []byte) error
type BootstrapScriptFailActionEnum ¶
type BootstrapScriptFailActionEnum struct { CONTINUE BootstrapScriptFailAction ERROROUT BootstrapScriptFailAction }
func GetBootstrapScriptFailActionEnum ¶
func GetBootstrapScriptFailActionEnum() BootstrapScriptFailActionEnum
type BootstrapScriptResp ¶ added in v0.0.55
type BootstrapScriptResp struct { Name string `json:"name"` Uri string `json:"uri"` Parameters *string `json:"parameters,omitempty"` Nodes []string `json:"nodes"` ActiveMaster *bool `json:"active_master,omitempty"` FailAction BootstrapScriptRespFailAction `json:"fail_action"` BeforeComponentStart *bool `json:"before_component_start,omitempty"` StartTime *int64 `json:"start_time,omitempty"` State *string `json:"state,omitempty"` }
func (BootstrapScriptResp) String ¶ added in v0.0.55
func (o BootstrapScriptResp) String() string
type BootstrapScriptRespFailAction ¶ added in v0.0.55
type BootstrapScriptRespFailAction struct {
// contains filtered or unexported fields
}
func (BootstrapScriptRespFailAction) MarshalJSON ¶ added in v0.0.55
func (c BootstrapScriptRespFailAction) MarshalJSON() ([]byte, error)
func (*BootstrapScriptRespFailAction) UnmarshalJSON ¶ added in v0.0.55
func (c *BootstrapScriptRespFailAction) UnmarshalJSON(b []byte) error
type BootstrapScriptRespFailActionEnum ¶ added in v0.0.55
type BootstrapScriptRespFailActionEnum struct { CONTINUE BootstrapScriptRespFailAction ERROROUT BootstrapScriptRespFailAction }
func GetBootstrapScriptRespFailActionEnum ¶ added in v0.0.55
func GetBootstrapScriptRespFailActionEnum() BootstrapScriptRespFailActionEnum
type Cluster ¶ added in v0.0.51
type Cluster struct { ClusterId *string `json:"clusterId,omitempty"` ClusterName *string `json:"clusterName,omitempty"` TotalNodeNum *string `json:"totalNodeNum,omitempty"` ClusterState *string `json:"clusterState,omitempty"` StageDesc *string `json:"stageDesc,omitempty"` CreateAt *string `json:"createAt,omitempty"` UpdateAt *string `json:"updateAt,omitempty"` ChargingStartTime *string `json:"chargingStartTime,omitempty"` BillingType *string `json:"billingType,omitempty"` DataCenter *string `json:"dataCenter,omitempty"` Vpc *string `json:"vpc,omitempty"` VpcId *string `json:"vpcId,omitempty"` Duration *string `json:"duration,omitempty"` Fee *string `json:"fee,omitempty"` HadoopVersion *string `json:"hadoopVersion,omitempty"` ComponentList *[]ComponentAmb `json:"componentList,omitempty"` ExternalIp *string `json:"externalIp,omitempty"` ExternalAlternateIp *string `json:"externalAlternateIp,omitempty"` InternalIp *string `json:"internalIp,omitempty"` DeploymentId *string `json:"deploymentId,omitempty"` Remark *string `json:"remark,omitempty"` OrderId *string `json:"orderId,omitempty"` AzId *string `json:"azId,omitempty"` AzName *string `json:"azName,omitempty"` AzCode *string `json:"azCode,omitempty"` InstanceId *string `json:"instanceId,omitempty"` Vnc *string `json:"vnc,omitempty"` TenantId *string `json:"tenantId,omitempty"` VolumeSize *int32 `json:"volumeSize,omitempty"` VolumeType *string `json:"volumeType,omitempty"` SubnetId *string `json:"subnetId,omitempty"` SubnetName *string `json:"subnetName,omitempty"` SecurityGroupsId *string `json:"securityGroupsId,omitempty"` SlaveSecurityGroupsId *string `json:"slaveSecurityGroupsId,omitempty"` BootstrapScripts *[]BootstrapScriptResp `json:"bootstrapScripts,omitempty"` SafeMode *int32 `json:"safeMode,omitempty"` ClusterVersion *string `json:"clusterVersion,omitempty"` NodePublicCertName *string `json:"nodePublicCertName,omitempty"` MasterNodeIp *string `json:"masterNodeIp,omitempty"` PrivateIpFirst *string `json:"privateIpFirst,omitempty"` ErrorInfo *string `json:"errorInfo,omitempty"` Tags *string `json:"tags,omitempty"` MasterNodeNum *string `json:"masterNodeNum,omitempty"` CoreNodeNum *string `json:"coreNodeNum,omitempty"` MasterNodeSize *string `json:"masterNodeSize,omitempty"` CoreNodeSize *string `json:"coreNodeSize,omitempty"` MasterNodeProductId *string `json:"masterNodeProductId,omitempty"` MasterNodeSpecId *string `json:"masterNodeSpecId,omitempty"` CoreNodeProductId *string `json:"coreNodeProductId,omitempty"` CoreNodeSpecId *string `json:"coreNodeSpecId,omitempty"` MasterDataVolumeType *string `json:"masterDataVolumeType,omitempty"` MasterDataVolumeSize *int32 `json:"masterDataVolumeSize,omitempty"` MasterDataVolumeCount *int32 `json:"masterDataVolumeCount,omitempty"` CoreDataVolumeType *string `json:"coreDataVolumeType,omitempty"` CoreDataVolumeSize *int32 `json:"coreDataVolumeSize,omitempty"` CoreDataVolumeCount *int32 `json:"coreDataVolumeCount,omitempty"` EnterpriseProjectId *string `json:"enterpriseProjectId,omitempty"` IsMrsManagerFinish *bool `json:"isMrsManagerFinish,omitempty"` ClusterType *int32 `json:"clusterType,omitempty"` LogCollection *int32 `json:"logCollection,omitempty"` PeriodType *int32 `json:"periodType,omitempty"` Scale *string `json:"scale,omitempty"` NodeGroups *[]NodeGroupV10 `json:"nodeGroups,omitempty"` TaskNodeGroups *[]NodeGroupV10 `json:"taskNodeGroups,omitempty"` }
type ClusterScalingParams ¶ added in v0.0.73
type ClusterScalingParams struct { OrderId *string `json:"order_id,omitempty"` ScaleType ClusterScalingParamsScaleType `json:"scale_type"` NodeId string `json:"node_id"` NodeGroup *string `json:"node_group,omitempty"` SkipBootstrapScripts *string `json:"skip_bootstrap_scripts,omitempty"` ScaleWithoutStart *bool `json:"scale_without_start,omitempty"` ServerIds *[]string `json:"server_ids,omitempty"` Instances int32 `json:"instances"` TaskNodeInfo *TaskNodeInfo `json:"task_node_info,omitempty"` }
func (ClusterScalingParams) String ¶ added in v0.0.73
func (o ClusterScalingParams) String() string
type ClusterScalingParamsScaleType ¶ added in v0.0.73
type ClusterScalingParamsScaleType struct {
// contains filtered or unexported fields
}
func (ClusterScalingParamsScaleType) MarshalJSON ¶ added in v0.0.73
func (c ClusterScalingParamsScaleType) MarshalJSON() ([]byte, error)
func (*ClusterScalingParamsScaleType) UnmarshalJSON ¶ added in v0.0.73
func (c *ClusterScalingParamsScaleType) UnmarshalJSON(b []byte) error
type ClusterScalingParamsScaleTypeEnum ¶ added in v0.0.73
type ClusterScalingParamsScaleTypeEnum struct { SCALE_IN ClusterScalingParamsScaleType SCALE_OUT ClusterScalingParamsScaleType }
func GetClusterScalingParamsScaleTypeEnum ¶ added in v0.0.73
func GetClusterScalingParamsScaleTypeEnum() ClusterScalingParamsScaleTypeEnum
type ClusterScalingReq ¶ added in v0.0.73
type ClusterScalingReq struct { ServiceId *string `json:"service_id,omitempty"` PlanId *string `json:"plan_id,omitempty"` Parameters *ClusterScalingParams `json:"parameters"` PreviousValues map[string]string `json:"previous_values,omitempty"` }
func (ClusterScalingReq) String ¶ added in v0.0.73
func (o ClusterScalingReq) String() string
type ComponentAmb ¶ added in v0.0.51
type ComponentAmb struct { ComponentId *string `json:"componentId,omitempty"` ComponentName *string `json:"componentName,omitempty"` ComponentVersion *string `json:"componentVersion,omitempty"` ComponentDesc *string `json:"componentDesc,omitempty"` }
func (ComponentAmb) String ¶ added in v0.0.51
func (o ComponentAmb) String() string
type ComponentList ¶
type ComponentList struct {
ComponentName string `json:"component_name"`
}
func (ComponentList) String ¶
func (o ComponentList) String() string
type CreateAndExecuteJobRequest ¶ added in v0.0.73
type CreateAndExecuteJobRequest struct {
Body *SubmitJobReqV11 `json:"body,omitempty"`
}
Request Object
func (CreateAndExecuteJobRequest) String ¶ added in v0.0.73
func (o CreateAndExecuteJobRequest) String() string
type CreateAndExecuteJobResponse ¶ added in v0.0.73
type CreateAndExecuteJobResponse struct { Templated *bool `json:"templated,omitempty"` CreatedAt *int64 `json:"created_at,omitempty"` UpdatedAt *int64 `json:"updated_at,omitempty"` Id *string `json:"id,omitempty"` TenantId *string `json:"tenant_id,omitempty"` JobId *string `json:"job_id,omitempty"` JobName *string `json:"job_name,omitempty"` InputId *string `json:"input_id,omitempty"` OutputId *string `json:"output_id,omitempty"` StartTime *int64 `json:"start_time,omitempty"` EndTime *int64 `json:"end_time,omitempty"` ClusterId *string `json:"cluster_id,omitempty"` EngineJobId *string `json:"engine_job_id,omitempty"` ReturnCode *string `json:"return_code,omitempty"` IsPublic *bool `json:"is_public,omitempty"` IsProtected *bool `json:"is_protected,omitempty"` GroupId *string `json:"group_id,omitempty"` JarPath *string `json:"jar_path,omitempty"` Input *string `json:"input,omitempty"` Output *string `json:"output,omitempty"` JobLog *string `json:"job_log,omitempty"` JobType *int32 `json:"job_type,omitempty"` FileAction *string `json:"file_action,omitempty"` Arguments *string `json:"arguments,omitempty"` Hql *string `json:"hql,omitempty"` JobState *int32 `json:"job_state,omitempty"` JobFinalStatus *int32 `json:"job_final_status,omitempty"` HiveScriptPath *string `json:"hive_script_path,omitempty"` CreateBy *string `json:"create_by,omitempty"` FinishedStep *int32 `json:"finished_step,omitempty"` JobMainId *string `json:"job_main_id,omitempty"` JobStepId *string `json:"job_step_id,omitempty"` PostponeAt *int64 `json:"postpone_at,omitempty"` StepName *string `json:"step_name,omitempty"` StepNum *int32 `json:"step_num,omitempty"` TaskNum *int32 `json:"task_num,omitempty"` UpdateBy *string `json:"update_by,omitempty"` Credentials *string `json:"credentials,omitempty"` UserId *string `json:"user_id,omitempty"` JobConfigs map[string]interface{} `json:"job_configs,omitempty"` Extra map[string]interface{} `json:"extra,omitempty"` DataSourceUrls map[string]interface{} `json:"data_source_urls,omitempty"` Info map[string]interface{} `json:"info,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateAndExecuteJobResponse) String ¶ added in v0.0.73
func (o CreateAndExecuteJobResponse) String() string
type CreateClusterReq ¶
type CreateClusterReq struct { ClusterVersion string `json:"cluster_version"` ClusterName string `json:"cluster_name"` MasterNodeNum int32 `json:"master_node_num"` CoreNodeNum int32 `json:"core_node_num"` BillingType CreateClusterReqBillingType `json:"billing_type"` DataCenter string `json:"data_center"` Vpc string `json:"vpc"` MasterNodeSize string `json:"master_node_size"` CoreNodeSize string `json:"core_node_size"` ComponentList []ComponentList `json:"component_list"` AvailableZoneId string `json:"available_zone_id"` VpcId string `json:"vpc_id"` SubnetId string `json:"subnet_id"` SubnetName string `json:"subnet_name"` SecurityGroupsId *string `json:"security_groups_id,omitempty"` AddJobs *[]AddJobs `json:"add_jobs,omitempty"` VolumeSize *int32 `json:"volume_size,omitempty"` VolumeType *CreateClusterReqVolumeType `json:"volume_type,omitempty"` MasterDataVolumeType *CreateClusterReqMasterDataVolumeType `json:"master_data_volume_type,omitempty"` MasterDataVolumeSize *int32 `json:"master_data_volume_size,omitempty"` MasterDataVolumeCount *CreateClusterReqMasterDataVolumeCount `json:"master_data_volume_count,omitempty"` CoreDataVolumeType *CreateClusterReqCoreDataVolumeType `json:"core_data_volume_type,omitempty"` CoreDataVolumeSize *int32 `json:"core_data_volume_size,omitempty"` CoreDataVolumeCount *int32 `json:"core_data_volume_count,omitempty"` TaskNodeGroups *[]TaskNodeGroups `json:"task_node_groups,omitempty"` BootstrapScripts *[]BootstrapScript `json:"bootstrap_scripts,omitempty"` NodePublicCertName *string `json:"node_public_cert_name,omitempty"` ClusterAdminSecret *string `json:"cluster_admin_secret,omitempty"` ClusterMasterSecret string `json:"cluster_master_secret"` SafeMode CreateClusterReqSafeMode `json:"safe_mode"` ClusterType *CreateClusterReqClusterType `json:"cluster_type,omitempty"` LogCollection *CreateClusterReqLogCollection `json:"log_collection,omitempty"` EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` Tags *[]Tag `json:"tags,omitempty"` LoginMode *CreateClusterReqLoginMode `json:"login_mode,omitempty"` NodeGroups *[]NodeGroupV11 `json:"node_groups,omitempty"` }
func (CreateClusterReq) String ¶
func (o CreateClusterReq) String() string
type CreateClusterReqBillingType ¶
type CreateClusterReqBillingType struct {
// contains filtered or unexported fields
}
func (CreateClusterReqBillingType) MarshalJSON ¶
func (c CreateClusterReqBillingType) MarshalJSON() ([]byte, error)
func (*CreateClusterReqBillingType) UnmarshalJSON ¶
func (c *CreateClusterReqBillingType) UnmarshalJSON(b []byte) error
type CreateClusterReqBillingTypeEnum ¶
type CreateClusterReqBillingTypeEnum struct {
E_12 CreateClusterReqBillingType
}
func GetCreateClusterReqBillingTypeEnum ¶
func GetCreateClusterReqBillingTypeEnum() CreateClusterReqBillingTypeEnum
type CreateClusterReqClusterType ¶
type CreateClusterReqClusterType struct {
// contains filtered or unexported fields
}
func (CreateClusterReqClusterType) MarshalJSON ¶
func (c CreateClusterReqClusterType) MarshalJSON() ([]byte, error)
func (*CreateClusterReqClusterType) UnmarshalJSON ¶
func (c *CreateClusterReqClusterType) UnmarshalJSON(b []byte) error
type CreateClusterReqClusterTypeEnum ¶
type CreateClusterReqClusterTypeEnum struct { E_0 CreateClusterReqClusterType E_1 CreateClusterReqClusterType }
func GetCreateClusterReqClusterTypeEnum ¶
func GetCreateClusterReqClusterTypeEnum() CreateClusterReqClusterTypeEnum
type CreateClusterReqCoreDataVolumeType ¶
type CreateClusterReqCoreDataVolumeType struct {
// contains filtered or unexported fields
}
func (CreateClusterReqCoreDataVolumeType) MarshalJSON ¶
func (c CreateClusterReqCoreDataVolumeType) MarshalJSON() ([]byte, error)
func (*CreateClusterReqCoreDataVolumeType) UnmarshalJSON ¶
func (c *CreateClusterReqCoreDataVolumeType) UnmarshalJSON(b []byte) error
type CreateClusterReqCoreDataVolumeTypeEnum ¶
type CreateClusterReqCoreDataVolumeTypeEnum struct { SATA CreateClusterReqCoreDataVolumeType SAS CreateClusterReqCoreDataVolumeType SSD CreateClusterReqCoreDataVolumeType GPSSD CreateClusterReqCoreDataVolumeType }
func GetCreateClusterReqCoreDataVolumeTypeEnum ¶
func GetCreateClusterReqCoreDataVolumeTypeEnum() CreateClusterReqCoreDataVolumeTypeEnum
type CreateClusterReqLogCollection ¶
type CreateClusterReqLogCollection struct {
// contains filtered or unexported fields
}
func (CreateClusterReqLogCollection) MarshalJSON ¶
func (c CreateClusterReqLogCollection) MarshalJSON() ([]byte, error)
func (*CreateClusterReqLogCollection) UnmarshalJSON ¶
func (c *CreateClusterReqLogCollection) UnmarshalJSON(b []byte) error
type CreateClusterReqLogCollectionEnum ¶
type CreateClusterReqLogCollectionEnum struct { E_0 CreateClusterReqLogCollection E_1 CreateClusterReqLogCollection }
func GetCreateClusterReqLogCollectionEnum ¶
func GetCreateClusterReqLogCollectionEnum() CreateClusterReqLogCollectionEnum
type CreateClusterReqLoginMode ¶
type CreateClusterReqLoginMode struct {
// contains filtered or unexported fields
}
func (CreateClusterReqLoginMode) MarshalJSON ¶
func (c CreateClusterReqLoginMode) MarshalJSON() ([]byte, error)
func (*CreateClusterReqLoginMode) UnmarshalJSON ¶
func (c *CreateClusterReqLoginMode) UnmarshalJSON(b []byte) error
type CreateClusterReqLoginModeEnum ¶
type CreateClusterReqLoginModeEnum struct { E_0 CreateClusterReqLoginMode E_1 CreateClusterReqLoginMode }
func GetCreateClusterReqLoginModeEnum ¶
func GetCreateClusterReqLoginModeEnum() CreateClusterReqLoginModeEnum
type CreateClusterReqMasterDataVolumeCount ¶
type CreateClusterReqMasterDataVolumeCount struct {
// contains filtered or unexported fields
}
func (CreateClusterReqMasterDataVolumeCount) MarshalJSON ¶
func (c CreateClusterReqMasterDataVolumeCount) MarshalJSON() ([]byte, error)
func (*CreateClusterReqMasterDataVolumeCount) UnmarshalJSON ¶
func (c *CreateClusterReqMasterDataVolumeCount) UnmarshalJSON(b []byte) error
type CreateClusterReqMasterDataVolumeCountEnum ¶
type CreateClusterReqMasterDataVolumeCountEnum struct {
E_1 CreateClusterReqMasterDataVolumeCount
}
func GetCreateClusterReqMasterDataVolumeCountEnum ¶
func GetCreateClusterReqMasterDataVolumeCountEnum() CreateClusterReqMasterDataVolumeCountEnum
type CreateClusterReqMasterDataVolumeType ¶
type CreateClusterReqMasterDataVolumeType struct {
// contains filtered or unexported fields
}
func (CreateClusterReqMasterDataVolumeType) MarshalJSON ¶
func (c CreateClusterReqMasterDataVolumeType) MarshalJSON() ([]byte, error)
func (*CreateClusterReqMasterDataVolumeType) UnmarshalJSON ¶
func (c *CreateClusterReqMasterDataVolumeType) UnmarshalJSON(b []byte) error
type CreateClusterReqMasterDataVolumeTypeEnum ¶
type CreateClusterReqMasterDataVolumeTypeEnum struct { SATA CreateClusterReqMasterDataVolumeType SAS CreateClusterReqMasterDataVolumeType SSD CreateClusterReqMasterDataVolumeType GPSSD CreateClusterReqMasterDataVolumeType }
func GetCreateClusterReqMasterDataVolumeTypeEnum ¶
func GetCreateClusterReqMasterDataVolumeTypeEnum() CreateClusterReqMasterDataVolumeTypeEnum
type CreateClusterReqSafeMode ¶
type CreateClusterReqSafeMode struct {
// contains filtered or unexported fields
}
func (CreateClusterReqSafeMode) MarshalJSON ¶
func (c CreateClusterReqSafeMode) MarshalJSON() ([]byte, error)
func (*CreateClusterReqSafeMode) UnmarshalJSON ¶
func (c *CreateClusterReqSafeMode) UnmarshalJSON(b []byte) error
type CreateClusterReqSafeModeEnum ¶
type CreateClusterReqSafeModeEnum struct { E_0 CreateClusterReqSafeMode E_1 CreateClusterReqSafeMode }
func GetCreateClusterReqSafeModeEnum ¶
func GetCreateClusterReqSafeModeEnum() CreateClusterReqSafeModeEnum
type CreateClusterReqVolumeType ¶
type CreateClusterReqVolumeType struct {
// contains filtered or unexported fields
}
func (CreateClusterReqVolumeType) MarshalJSON ¶
func (c CreateClusterReqVolumeType) MarshalJSON() ([]byte, error)
func (*CreateClusterReqVolumeType) UnmarshalJSON ¶
func (c *CreateClusterReqVolumeType) UnmarshalJSON(b []byte) error
type CreateClusterReqVolumeTypeEnum ¶
type CreateClusterReqVolumeTypeEnum struct { SATA CreateClusterReqVolumeType SAS CreateClusterReqVolumeType SSD CreateClusterReqVolumeType GPSSD CreateClusterReqVolumeType }
func GetCreateClusterReqVolumeTypeEnum ¶
func GetCreateClusterReqVolumeTypeEnum() CreateClusterReqVolumeTypeEnum
type CreateClusterRequest ¶
type CreateClusterRequest struct {
Body *CreateClusterReq `json:"body,omitempty"`
}
Request Object
func (CreateClusterRequest) String ¶
func (o CreateClusterRequest) String() string
type CreateClusterResponse ¶
type CreateClusterResponse struct { Result *bool `json:"result,omitempty"` Msg *string `json:"msg,omitempty"` ClusterId *string `json:"cluster_id,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateClusterResponse) String ¶
func (o CreateClusterResponse) String() string
type CreateClusterTagRequest ¶
type CreateClusterTagRequest struct { ClusterId string `json:"cluster_id"` Body *CreateTagReq `json:"body,omitempty"` }
Request Object
func (CreateClusterTagRequest) String ¶
func (o CreateClusterTagRequest) String() string
type CreateClusterTagResponse ¶
type CreateClusterTagResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (CreateClusterTagResponse) String ¶
func (o CreateClusterTagResponse) String() string
type CreateScalingPolicyRequest ¶ added in v0.0.73
type CreateScalingPolicyRequest struct { ClusterId string `json:"cluster_id"` Body *AutoScalingPolicyReqV11 `json:"body,omitempty"` }
Request Object
func (CreateScalingPolicyRequest) String ¶ added in v0.0.73
func (o CreateScalingPolicyRequest) String() string
type CreateScalingPolicyResponse ¶ added in v0.0.73
type CreateScalingPolicyResponse struct { Body *string `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateScalingPolicyResponse) String ¶ added in v0.0.73
func (o CreateScalingPolicyResponse) String() string
type CreateTagReq ¶
type CreateTagReq struct {
Tag *Tag `json:"tag"`
}
func (CreateTagReq) String ¶
func (o CreateTagReq) String() string
type DeleteClusterRequest ¶
type DeleteClusterRequest struct {
ClusterId string `json:"cluster_id"`
}
Request Object
func (DeleteClusterRequest) String ¶
func (o DeleteClusterRequest) String() string
type DeleteClusterResponse ¶
type DeleteClusterResponse struct { Body *string `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (DeleteClusterResponse) String ¶
func (o DeleteClusterResponse) String() string
type DeleteClusterTagRequest ¶
type DeleteClusterTagRequest struct { ClusterId string `json:"cluster_id"` Key string `json:"key"` }
Request Object
func (DeleteClusterTagRequest) String ¶
func (o DeleteClusterTagRequest) String() string
type DeleteClusterTagResponse ¶
type DeleteClusterTagResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteClusterTagResponse) String ¶
func (o DeleteClusterTagResponse) String() string
type DeleteJobExecutionRequest ¶ added in v0.0.73
type DeleteJobExecutionRequest struct {
JobExecutionId string `json:"job_execution_id"`
}
Request Object
func (DeleteJobExecutionRequest) String ¶ added in v0.0.73
func (o DeleteJobExecutionRequest) String() string
type DeleteJobExecutionResponse ¶ added in v0.0.73
type DeleteJobExecutionResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteJobExecutionResponse) String ¶ added in v0.0.73
func (o DeleteJobExecutionResponse) String() string
type HostModel ¶ added in v0.0.73
type HostModel struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` Ip *string `json:"ip,omitempty"` Status *string `json:"status,omitempty"` Flavor *string `json:"flavor,omitempty"` Type *string `json:"type,omitempty"` Mem *string `json:"mem,omitempty"` Cpu *string `json:"cpu,omitempty"` RootVolumeSize *string `json:"root_volume_size,omitempty"` DataVolumeType *string `json:"data_volume_type,omitempty"` DataVolumeSize *int32 `json:"data_volume_size,omitempty"` DataVolumeCount *int32 `json:"data_volume_count,omitempty"` }
type JobExeResult ¶ added in v0.0.73
type JobExeResult struct { Id string `json:"id"` CreateAt int64 `json:"create_at"` UpdateAt int64 `json:"update_at"` TenantId string `json:"tenant_id"` JobId string `json:"job_id"` JobName string `json:"job_name"` StartTime int64 `json:"start_time"` EndTime int64 `json:"end_time"` ClusterId string `json:"cluster_id"` GroupId string `json:"group_id"` JarPath string `json:"jar_path"` Input string `json:"input"` Output *string `json:"output,omitempty"` JobLog string `json:"job_log"` JobType int32 `json:"job_type"` FileAction string `json:"file_action"` Arguments string `json:"arguments"` Hql string `json:"hql"` JobState int32 `json:"job_state"` JobFinalStatus int32 `json:"job_final_status"` HiveScriptPath string `json:"hive_script_path"` CreateBy string `json:"create_by"` FinishedStep int32 `json:"finished_step"` JobMainId string `json:"job_main_id"` JobStepId string `json:"job_step_id"` PostponeAt int64 `json:"postpone_at"` StepName string `json:"step_name"` StepNum int32 `json:"step_num"` TaskNum int32 `json:"task_num"` UpdateBy string `json:"update_by"` SpendTime float32 `json:"spend_time"` StepSeq int32 `json:"step_seq"` Progress string `json:"progress"` }
func (JobExeResult) String ¶ added in v0.0.73
func (o JobExeResult) String() string
type ListAllTagsRequest ¶
type ListAllTagsRequest struct { }
Request Object
func (ListAllTagsRequest) String ¶
func (o ListAllTagsRequest) String() string
type ListAllTagsResponse ¶
type ListAllTagsResponse struct { Tags *[]TagWithMultiValue `json:"tags,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListAllTagsResponse) String ¶
func (o ListAllTagsResponse) String() string
type ListClusterTagsRequest ¶
type ListClusterTagsRequest struct {
ClusterId string `json:"cluster_id"`
}
Request Object
func (ListClusterTagsRequest) String ¶
func (o ListClusterTagsRequest) String() string
type ListClusterTagsResponse ¶
type ListClusterTagsResponse struct { Tags *[]TagPlain `json:"tags,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListClusterTagsResponse) String ¶
func (o ListClusterTagsResponse) String() string
type ListClustersByTagsRequest ¶
type ListClustersByTagsRequest struct {
Body *ListResourceReq `json:"body,omitempty"`
}
Request Object
func (ListClustersByTagsRequest) String ¶
func (o ListClustersByTagsRequest) String() string
type ListClustersByTagsResponse ¶
type ListClustersByTagsResponse struct { Resources *[]MrsResource `json:"resources,omitempty"` TotalCount *int32 `json:"total_count,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListClustersByTagsResponse) String ¶
func (o ListClustersByTagsResponse) String() string
type ListClustersRequest ¶ added in v0.0.51
type ListClustersRequest struct { Tags *string `json:"tags,omitempty"` PageSize *string `json:"pageSize,omitempty"` CurrentPage *string `json:"currentPage,omitempty"` ClusterName *string `json:"clusterName,omitempty"` ClusterState *string `json:"clusterState,omitempty"` EnterpriseProjectId *string `json:"enterpriseProjectId,omitempty"` }
Request Object
func (ListClustersRequest) String ¶ added in v0.0.51
func (o ListClustersRequest) String() string
type ListClustersResponse ¶ added in v0.0.51
type ListClustersResponse struct { ClusterTotal *int32 `json:"clusterTotal,omitempty"` Clusters *[]Cluster `json:"clusters,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListClustersResponse) String ¶ added in v0.0.51
func (o ListClustersResponse) String() string
type ListExecuteJobRequest ¶ added in v0.0.73
type ListExecuteJobRequest struct { PageSize *string `json:"page_size,omitempty"` CurrentPage *string `json:"current_page,omitempty"` JobName *string `json:"job_name,omitempty"` ClusterId string `json:"cluster_id"` State *string `json:"state,omitempty"` Id *string `json:"id,omitempty"` }
Request Object
func (ListExecuteJobRequest) String ¶ added in v0.0.73
func (o ListExecuteJobRequest) String() string
type ListExecuteJobResponse ¶ added in v0.0.73
type ListExecuteJobResponse struct { TotalRecord *int32 `json:"totalRecord,omitempty"` JobExecutions *[]JobExeResult `json:"job_executions,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListExecuteJobResponse) String ¶ added in v0.0.73
func (o ListExecuteJobResponse) String() string
type ListHostsRequest ¶ added in v0.0.73
type ListHostsRequest struct { ClusterId string `json:"cluster_id"` PageSize *string `json:"pageSize,omitempty"` CurrentPage *string `json:"currentPage,omitempty"` }
Request Object
func (ListHostsRequest) String ¶ added in v0.0.73
func (o ListHostsRequest) String() string
type ListHostsResponse ¶ added in v0.0.73
type ListHostsResponse struct { Hosts *[]HostModel `json:"hosts,omitempty"` Total *int32 `json:"total,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListHostsResponse) String ¶ added in v0.0.73
func (o ListHostsResponse) String() string
type ListResourceReq ¶
type ListResourceReq struct { Tags *[]TagWithMultiValue `json:"tags,omitempty"` TagsAny *[]TagWithMultiValue `json:"tags_any,omitempty"` NotTags *[]TagWithMultiValue `json:"not_tags,omitempty"` NotTagsAny *[]TagWithMultiValue `json:"not_tags_any,omitempty"` Action ListResourceReqAction `json:"action"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` Matches *[]Match `json:"matches,omitempty"` }
func (ListResourceReq) String ¶
func (o ListResourceReq) String() string
type ListResourceReqAction ¶
type ListResourceReqAction struct {
// contains filtered or unexported fields
}
func (ListResourceReqAction) MarshalJSON ¶
func (c ListResourceReqAction) MarshalJSON() ([]byte, error)
func (*ListResourceReqAction) UnmarshalJSON ¶
func (c *ListResourceReqAction) UnmarshalJSON(b []byte) error
type ListResourceReqActionEnum ¶
type ListResourceReqActionEnum struct { FILTER ListResourceReqAction COUNT ListResourceReqAction }
func GetListResourceReqActionEnum ¶
func GetListResourceReqActionEnum() ListResourceReqActionEnum
type MrsResource ¶
type MrsResource struct { ResourceId *string `json:"resource_id,omitempty"` ResourceDetail *string `json:"resource_detail,omitempty"` Tags *[]TagPlain `json:"tags,omitempty"` ResourceName *string `json:"resource_name,omitempty"` }
func (MrsResource) String ¶
func (o MrsResource) String() string
type NodeGroupV10 ¶ added in v0.0.51
type NodeGroupV10 struct { GroupName *string `json:"groupName,omitempty"` NodeNum *int32 `json:"nodeNum,omitempty"` NodeSize *string `json:"nodeSize,omitempty"` NodeSpecId *string `json:"nodeSpecId,omitempty"` VmProductId *string `json:"vmProductId,omitempty"` VmSpecCode *string `json:"vmSpecCode,omitempty"` NodeProductId *string `json:"nodeProductId,omitempty"` RootVolumeSize *int32 `json:"rootVolumeSize,omitempty"` RootVolumeProductId *string `json:"rootVolumeProductId,omitempty"` RootVolumeType *string `json:"rootVolumeType,omitempty"` RootVolumeResourceSpecCode *string `json:"rootVolumeResourceSpecCode,omitempty"` RootVolumeResourceType *string `json:"rootVolumeResourceType,omitempty"` DataVolumeType *NodeGroupV10DataVolumeType `json:"dataVolumeType,omitempty"` DataVolumeCount *int32 `json:"dataVolumeCount,omitempty"` DataVolumeSize *int32 `json:"dataVolumeSize,omitempty"` DataVolumeProductId *string `json:"dataVolumeProductId,omitempty"` DataVolumeResourceSpecCode *string `json:"dataVolumeResourceSpecCode,omitempty"` DataVolumeResourceType *string `json:"dataVolumeResourceType,omitempty"` }
func (NodeGroupV10) String ¶ added in v0.0.51
func (o NodeGroupV10) String() string
type NodeGroupV10DataVolumeType ¶ added in v0.0.51
type NodeGroupV10DataVolumeType struct {
// contains filtered or unexported fields
}
func (NodeGroupV10DataVolumeType) MarshalJSON ¶ added in v0.0.51
func (c NodeGroupV10DataVolumeType) MarshalJSON() ([]byte, error)
func (*NodeGroupV10DataVolumeType) UnmarshalJSON ¶ added in v0.0.51
func (c *NodeGroupV10DataVolumeType) UnmarshalJSON(b []byte) error
type NodeGroupV10DataVolumeTypeEnum ¶ added in v0.0.51
type NodeGroupV10DataVolumeTypeEnum struct { SATA NodeGroupV10DataVolumeType SAS NodeGroupV10DataVolumeType SSD NodeGroupV10DataVolumeType GPSSD NodeGroupV10DataVolumeType }
func GetNodeGroupV10DataVolumeTypeEnum ¶ added in v0.0.51
func GetNodeGroupV10DataVolumeTypeEnum() NodeGroupV10DataVolumeTypeEnum
type NodeGroupV11 ¶ added in v0.0.47
type NodeGroupV11 struct { GroupName string `json:"group_name"` NodeNum int32 `json:"node_num"` NodeSize string `json:"node_size"` RootVolumeSize *string `json:"root_volume_size,omitempty"` RootVolumeType *string `json:"root_volume_type,omitempty"` DataVolumeType *string `json:"data_volume_type,omitempty"` DataVolumeCount *int32 `json:"data_volume_count,omitempty"` DataVolumeSize *int32 `json:"data_volume_size,omitempty"` AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy,omitempty"` }
func (NodeGroupV11) String ¶ added in v0.0.47
func (o NodeGroupV11) String() string
type ResourcesPlan ¶
type ResourcesPlan struct { PeriodType string `json:"period_type"` StartTime string `json:"start_time"` EndTime string `json:"end_time"` MinCapacity int32 `json:"min_capacity"` MaxCapacity int32 `json:"max_capacity"` }
func (ResourcesPlan) String ¶
func (o ResourcesPlan) String() string
type Rules ¶
type RulesAdjustmentType ¶
type RulesAdjustmentType struct {
// contains filtered or unexported fields
}
func (RulesAdjustmentType) MarshalJSON ¶
func (c RulesAdjustmentType) MarshalJSON() ([]byte, error)
func (*RulesAdjustmentType) UnmarshalJSON ¶
func (c *RulesAdjustmentType) UnmarshalJSON(b []byte) error
type RulesAdjustmentTypeEnum ¶
type RulesAdjustmentTypeEnum struct { SCALE_OUT RulesAdjustmentType SCALE_IN RulesAdjustmentType }
func GetRulesAdjustmentTypeEnum ¶
func GetRulesAdjustmentTypeEnum() RulesAdjustmentTypeEnum
type ScaleScript ¶
type ScaleScript struct { Name string `json:"name"` Uri string `json:"uri"` Parameters *string `json:"parameters,omitempty"` Nodes []string `json:"nodes"` ActiveMaster *bool `json:"active_master,omitempty"` FailAction ScaleScriptFailAction `json:"fail_action"` 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
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
type ScaleScriptFailActionEnum ¶
type ScaleScriptFailActionEnum struct { CONTINUE ScaleScriptFailAction ERROROUT ScaleScriptFailAction }
func GetScaleScriptFailActionEnum ¶
func GetScaleScriptFailActionEnum() ScaleScriptFailActionEnum
type ShowClusterDetailsRequest ¶ added in v0.0.73
type ShowClusterDetailsRequest struct {
ClusterId string `json:"cluster_id"`
}
Request Object
func (ShowClusterDetailsRequest) String ¶ added in v0.0.73
func (o ShowClusterDetailsRequest) String() string
type ShowClusterDetailsResponse ¶ added in v0.0.73
type ShowClusterDetailsResponse struct { Cluster *Cluster `json:"cluster,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowClusterDetailsResponse) String ¶ added in v0.0.73
func (o ShowClusterDetailsResponse) String() string
type ShowJobExesRequest ¶ added in v0.0.73
type ShowJobExesRequest struct {
JobExeId string `json:"job_exe_id"`
}
Request Object
func (ShowJobExesRequest) String ¶ added in v0.0.73
func (o ShowJobExesRequest) String() string
type ShowJobExesResponse ¶ added in v0.0.73
type ShowJobExesResponse struct { JobExecution *JobExeResult `json:"job_execution,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowJobExesResponse) String ¶ added in v0.0.73
func (o ShowJobExesResponse) String() string
type SubmitJobReqV11 ¶ added in v0.0.73
type SubmitJobReqV11 struct { JobName string `json:"job_name"` ClusterId string `json:"cluster_id"` JarPath *string `json:"jar_path,omitempty"` Input *string `json:"input,omitempty"` Output *string `json:"output,omitempty"` JobLog *string `json:"job_log,omitempty"` JobType int32 `json:"job_type"` FileAction *string `json:"file_action,omitempty"` Arguments *string `json:"arguments,omitempty"` Hql *string `json:"hql,omitempty"` HiveScriptPath *string `json:"hive_script_path,omitempty"` }
func (SubmitJobReqV11) String ¶ added in v0.0.73
func (o SubmitJobReqV11) String() string
type TagWithMultiValue ¶
type TagWithMultiValue struct { Key string `json:"key"` Values *[]string `json:"values,omitempty"` }
func (TagWithMultiValue) String ¶
func (o TagWithMultiValue) String() string
type TaskNodeGroups ¶
type TaskNodeGroups struct { NodeNum int32 `json:"node_num"` NodeSize string `json:"node_size"` DataVolumeType TaskNodeGroupsDataVolumeType `json:"data_volume_type"` DataVolumeCount int32 `json:"data_volume_count"` DataVolumeSize int32 `json:"data_volume_size"` AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy,omitempty"` }
func (TaskNodeGroups) String ¶
func (o TaskNodeGroups) String() string
type TaskNodeGroupsDataVolumeType ¶
type TaskNodeGroupsDataVolumeType struct {
// contains filtered or unexported fields
}
func (TaskNodeGroupsDataVolumeType) MarshalJSON ¶
func (c TaskNodeGroupsDataVolumeType) MarshalJSON() ([]byte, error)
func (*TaskNodeGroupsDataVolumeType) UnmarshalJSON ¶
func (c *TaskNodeGroupsDataVolumeType) UnmarshalJSON(b []byte) error
type TaskNodeGroupsDataVolumeTypeEnum ¶
type TaskNodeGroupsDataVolumeTypeEnum struct { SATA TaskNodeGroupsDataVolumeType SAS TaskNodeGroupsDataVolumeType SSD TaskNodeGroupsDataVolumeType GPSSD TaskNodeGroupsDataVolumeType }
func GetTaskNodeGroupsDataVolumeTypeEnum ¶
func GetTaskNodeGroupsDataVolumeTypeEnum() TaskNodeGroupsDataVolumeTypeEnum
type TaskNodeInfo ¶ added in v0.0.73
type TaskNodeInfo struct { NodeSize string `json:"node_size"` DataVolumeType *TaskNodeInfoDataVolumeType `json:"data_volume_type,omitempty"` DataVolumeCount *int32 `json:"data_volume_count,omitempty"` DataVolumeSize *int32 `json:"data_volume_size,omitempty"` }
func (TaskNodeInfo) String ¶ added in v0.0.73
func (o TaskNodeInfo) String() string
type TaskNodeInfoDataVolumeType ¶ added in v0.0.73
type TaskNodeInfoDataVolumeType struct {
// contains filtered or unexported fields
}
func (TaskNodeInfoDataVolumeType) MarshalJSON ¶ added in v0.0.73
func (c TaskNodeInfoDataVolumeType) MarshalJSON() ([]byte, error)
func (*TaskNodeInfoDataVolumeType) UnmarshalJSON ¶ added in v0.0.73
func (c *TaskNodeInfoDataVolumeType) UnmarshalJSON(b []byte) error
type TaskNodeInfoDataVolumeTypeEnum ¶ added in v0.0.73
type TaskNodeInfoDataVolumeTypeEnum struct { SATA TaskNodeInfoDataVolumeType SAS TaskNodeInfoDataVolumeType SSD TaskNodeInfoDataVolumeType GPSSD TaskNodeInfoDataVolumeType }
func GetTaskNodeInfoDataVolumeTypeEnum ¶ added in v0.0.73
func GetTaskNodeInfoDataVolumeTypeEnum() TaskNodeInfoDataVolumeTypeEnum
type Trigger ¶
type UpdateClusterScalingRequest ¶ added in v0.0.73
type UpdateClusterScalingRequest struct { ClusterId string `json:"cluster_id"` Body *ClusterScalingReq `json:"body,omitempty"` }
Request Object
func (UpdateClusterScalingRequest) String ¶ added in v0.0.73
func (o UpdateClusterScalingRequest) String() string
type UpdateClusterScalingResponse ¶ added in v0.0.73
type UpdateClusterScalingResponse struct { Result *string `json:"result,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (UpdateClusterScalingResponse) String ¶ added in v0.0.73
func (o UpdateClusterScalingResponse) String() string
Source Files ¶
- model_add_jobs.go
- model_auto_scaling_policy.go
- model_auto_scaling_policy_req_v11.go
- model_batch_create_cluster_tags_req.go
- model_batch_create_cluster_tags_request.go
- model_batch_create_cluster_tags_response.go
- model_batch_delete_cluster_tags_req.go
- model_batch_delete_cluster_tags_request.go
- model_batch_delete_cluster_tags_response.go
- model_bootstrap_script.go
- model_bootstrap_script_resp.go
- model_cluster.go
- model_cluster_scaling_params.go
- model_cluster_scaling_req.go
- model_component_amb.go
- model_component_list.go
- model_create_and_execute_job_request.go
- model_create_and_execute_job_response.go
- model_create_cluster_req.go
- model_create_cluster_request.go
- model_create_cluster_response.go
- model_create_cluster_tag_request.go
- model_create_cluster_tag_response.go
- model_create_scaling_policy_request.go
- model_create_scaling_policy_response.go
- model_create_tag_req.go
- model_delete_cluster_request.go
- model_delete_cluster_response.go
- model_delete_cluster_tag_request.go
- model_delete_cluster_tag_response.go
- model_delete_job_execution_request.go
- model_delete_job_execution_response.go
- model_host_model.go
- model_job_exe_result.go
- model_list_all_tags_request.go
- model_list_all_tags_response.go
- model_list_cluster_tags_request.go
- model_list_cluster_tags_response.go
- model_list_clusters_by_tags_request.go
- model_list_clusters_by_tags_response.go
- model_list_clusters_request.go
- model_list_clusters_response.go
- model_list_execute_job_request.go
- model_list_execute_job_response.go
- model_list_hosts_request.go
- model_list_hosts_response.go
- model_list_resource_req.go
- model_match.go
- model_mrs_resource.go
- model_node_group_v10.go
- model_node_group_v11.go
- model_resources_plan.go
- model_rules.go
- model_scale_script.go
- model_show_cluster_details_request.go
- model_show_cluster_details_response.go
- model_show_job_exes_request.go
- model_show_job_exes_response.go
- model_submit_job_req_v11.go
- model_tag.go
- model_tag_plain.go
- model_tag_with_multi_value.go
- model_task_node_groups.go
- model_task_node_info.go
- model_trigger.go
- model_update_cluster_scaling_request.go
- model_update_cluster_scaling_response.go
Click to show internal directories.
Click to hide internal directories.