Documentation ¶
Index ¶
- type AddJobs
- type AgencyMapping
- type AgencyMappingArray
- type AutoScalingPolicy
- type BatchDeleteJobsRequest
- type BatchDeleteJobsResponse
- type BootstrapScript
- type BootstrapScriptActionStages
- type BootstrapScriptActionStagesEnum
- type BootstrapScriptFailAction
- type BootstrapScriptFailActionEnum
- type CancelSqlRequest
- type CancelSqlResponse
- type CancelSqlResponseStatus
- type CancelSqlResponseStatusEnum
- type ChargeInfo
- type CreateClusterReqV2
- type CreateClusterReqV2LogCollection
- type CreateClusterReqV2LogCollectionEnum
- type CreateClusterRequest
- type CreateClusterResponse
- type CreateExecuteJobRequest
- type CreateExecuteJobResponse
- type ExecuteSqlRequest
- type ExecuteSqlResponse
- type FileStatusV2
- type JobBatchDelete
- type JobExecution
- type JobQueryBean
- type JobSubmitResult
- type JobSubmitResultState
- type JobSubmitResultStateEnum
- type NodeGroupV2
- type ResourcesPlan
- type Rules
- type RulesAdjustmentType
- type RulesAdjustmentTypeEnum
- type ScaleScript
- type ScaleScriptActionStage
- type ScaleScriptActionStageEnum
- type ScaleScriptFailAction
- type ScaleScriptFailActionEnum
- type ShowAgencyMappingRequest
- type ShowAgencyMappingResponse
- type ShowHdfsFileListRequest
- type ShowHdfsFileListRequestOrder
- type ShowHdfsFileListRequestOrderEnum
- type ShowHdfsFileListRequestSortKey
- type ShowHdfsFileListRequestSortKeyEnum
- type ShowHdfsFileListResponse
- type ShowJobExeListNewRequest
- type ShowJobExeListNewRequestJobResult
- type ShowJobExeListNewRequestJobResultEnum
- type ShowJobExeListNewRequestJobState
- type ShowJobExeListNewRequestJobStateEnum
- type ShowJobExeListNewResponse
- type ShowSingleJobExeRequest
- type ShowSingleJobExeResponse
- type ShowSqlResultRequest
- type ShowSqlResultResponse
- type ShowSqlResultWithJobRequest
- type ShowSqlResultWithJobResponse
- type SqlExecutionReq
- type StopJobRequest
- type StopJobResponse
- type Tag
- type Trigger
- type UpdateAgencyMappingRequest
- type UpdateAgencyMappingResponse
- type Volume
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 AgencyMapping ¶
type AgencyMapping struct { Agency string `json:"agency"` IdentifierType string `json:"identifier_type"` Identifiers []string `json:"identifiers"` AgencyId string `json:"agency_id"` }
用户(组)与IAM委托的映射关系结构体
func (AgencyMapping) String ¶
func (o AgencyMapping) String() string
type AgencyMappingArray ¶
type AgencyMappingArray struct {
AgencyMappings []AgencyMapping `json:"agency_mappings"`
}
用户(组)与IAM委托的映射关系数组结构体
func (AgencyMappingArray) String ¶
func (o AgencyMappingArray) String() string
type AutoScalingPolicy ¶
type AutoScalingPolicy struct { AutoScalingEnable bool `json:"auto_scaling_enable"` 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 BatchDeleteJobsRequest ¶
type BatchDeleteJobsRequest struct { ClusterId string `json:"cluster_id"` Body *JobBatchDelete `json:"body,omitempty"` }
Request Object
func (BatchDeleteJobsRequest) String ¶
func (o BatchDeleteJobsRequest) String() string
type BatchDeleteJobsResponse ¶
type BatchDeleteJobsResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (BatchDeleteJobsResponse) String ¶
func (o BatchDeleteJobsResponse) String() string
type BootstrapScript ¶
type BootstrapScript struct { 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 ¶
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
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
type BootstrapScriptFailActionEnum ¶
type BootstrapScriptFailActionEnum struct { CONTINUE BootstrapScriptFailAction ERROROUT BootstrapScriptFailAction }
func GetBootstrapScriptFailActionEnum ¶
func GetBootstrapScriptFailActionEnum() BootstrapScriptFailActionEnum
type CancelSqlRequest ¶
Request Object
func (CancelSqlRequest) String ¶
func (o CancelSqlRequest) String() string
type CancelSqlResponse ¶
type CancelSqlResponse struct { Message *string `json:"message,omitempty"` Status *CancelSqlResponseStatus `json:"status,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CancelSqlResponse) String ¶
func (o CancelSqlResponse) String() string
type CancelSqlResponseStatus ¶
type CancelSqlResponseStatus struct {
// contains filtered or unexported fields
}
func (CancelSqlResponseStatus) MarshalJSON ¶
func (c CancelSqlResponseStatus) MarshalJSON() ([]byte, error)
func (*CancelSqlResponseStatus) UnmarshalJSON ¶
func (c *CancelSqlResponseStatus) UnmarshalJSON(b []byte) error
type CancelSqlResponseStatusEnum ¶
type CancelSqlResponseStatusEnum struct { SUCCEED CancelSqlResponseStatus FAILED CancelSqlResponseStatus }
func GetCancelSqlResponseStatusEnum ¶
func GetCancelSqlResponseStatusEnum() CancelSqlResponseStatusEnum
type ChargeInfo ¶
type ChargeInfo struct {
ChargeMode string `json:"charge_mode"`
}
func (ChargeInfo) String ¶
func (o ChargeInfo) String() string
type CreateClusterReqV2 ¶
type CreateClusterReqV2 struct { IsDecProject *bool `json:"is_dec_project,omitempty"` ClusterVersion string `json:"cluster_version"` ClusterName string `json:"cluster_name"` ClusterType string `json:"cluster_type"` ChargeInfo *ChargeInfo `json:"charge_info,omitempty"` Region string `json:"region"` VpcName string `json:"vpc_name"` SubnetId *string `json:"subnet_id,omitempty"` SubnetName string `json:"subnet_name"` Components string `json:"components"` AvailabilityZone string `json:"availability_zone"` SecurityGroupsId *string `json:"security_groups_id,omitempty"` AutoCreateDefaultSecurityGroup *bool `json:"auto_create_default_security_group,omitempty"` SafeMode string `json:"safe_mode"` ManagerAdminPassword string `json:"manager_admin_password"` LoginMode string `json:"login_mode"` NodeRootPassword *string `json:"node_root_password,omitempty"` NodeKeypairName *string `json:"node_keypair_name,omitempty"` EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` EipAddress *string `json:"eip_address,omitempty"` EipId *string `json:"eip_id,omitempty"` MrsEcsDefaultAgency *string `json:"mrs_ecs_default_agency,omitempty"` TemplateId *string `json:"template_id,omitempty"` Tags *[]Tag `json:"tags,omitempty"` LogCollection *CreateClusterReqV2LogCollection `json:"log_collection,omitempty"` NodeGroups []NodeGroupV2 `json:"node_groups"` BootstrapScripts *[]BootstrapScript `json:"bootstrap_scripts,omitempty"` AddJobs *[]AddJobs `json:"add_jobs,omitempty"` }
func (CreateClusterReqV2) String ¶
func (o CreateClusterReqV2) String() string
type CreateClusterReqV2LogCollection ¶
type CreateClusterReqV2LogCollection struct {
// contains filtered or unexported fields
}
func (CreateClusterReqV2LogCollection) MarshalJSON ¶
func (c CreateClusterReqV2LogCollection) MarshalJSON() ([]byte, error)
func (*CreateClusterReqV2LogCollection) UnmarshalJSON ¶
func (c *CreateClusterReqV2LogCollection) UnmarshalJSON(b []byte) error
type CreateClusterReqV2LogCollectionEnum ¶
type CreateClusterReqV2LogCollectionEnum struct { E_0 CreateClusterReqV2LogCollection E_1 CreateClusterReqV2LogCollection }
func GetCreateClusterReqV2LogCollectionEnum ¶
func GetCreateClusterReqV2LogCollectionEnum() CreateClusterReqV2LogCollectionEnum
type CreateClusterRequest ¶
type CreateClusterRequest struct {
Body *CreateClusterReqV2 `json:"body,omitempty"`
}
Request Object
func (CreateClusterRequest) String ¶
func (o CreateClusterRequest) String() string
type CreateClusterResponse ¶
type CreateClusterResponse struct { Type *string `json:"type,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateClusterResponse) String ¶
func (o CreateClusterResponse) String() string
type CreateExecuteJobRequest ¶
type CreateExecuteJobRequest struct { ClusterId string `json:"cluster_id"` Body *JobExecution `json:"body,omitempty"` }
Request Object
func (CreateExecuteJobRequest) String ¶
func (o CreateExecuteJobRequest) String() string
type CreateExecuteJobResponse ¶
type CreateExecuteJobResponse struct { JobSubmitResult *JobSubmitResult `json:"job_submit_result,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateExecuteJobResponse) String ¶
func (o CreateExecuteJobResponse) String() string
type ExecuteSqlRequest ¶
type ExecuteSqlRequest struct { ClusterId string `json:"cluster_id"` Body *SqlExecutionReq `json:"body,omitempty"` }
Request Object
func (ExecuteSqlRequest) String ¶
func (o ExecuteSqlRequest) String() string
type ExecuteSqlResponse ¶
type ExecuteSqlResponse struct { Id *string `json:"id,omitempty"` Message *string `json:"message,omitempty"` Statement *string `json:"statement,omitempty"` Status *string `json:"status,omitempty"` ResultLocation *string `json:"result_location,omitempty"` Content *[][]string `json:"content,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ExecuteSqlResponse) String ¶
func (o ExecuteSqlResponse) String() string
type FileStatusV2 ¶
type FileStatusV2 struct { 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"` Type *string `json:"type,omitempty"` ChildrenNum *int32 `json:"children_num,omitempty"` AccessTime *int64 `json:"access_time,omitempty"` ModificationTime *int64 `json:"modification_time,omitempty"` }
func (FileStatusV2) String ¶
func (o FileStatusV2) String() string
type JobBatchDelete ¶
type JobBatchDelete struct {
JobIdList *[]string `json:"job_id_list,omitempty"`
}
func (JobBatchDelete) String ¶
func (o JobBatchDelete) String() string
type JobExecution ¶
type JobExecution struct { JobType string `json:"job_type"` JobName string `json:"job_name"` Arguments *[]string `json:"arguments,omitempty"` Properties map[string]string `json:"properties,omitempty"` }
func (JobExecution) String ¶
func (o JobExecution) String() string
type JobQueryBean ¶
type JobQueryBean struct { JobId *string `json:"job_id,omitempty"` User *string `json:"user,omitempty"` JobName *string `json:"job_name,omitempty"` JobResult *string `json:"job_result,omitempty"` JobState *string `json:"job_state,omitempty"` JobProgress *float32 `json:"job_progress,omitempty"` 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"` Properties *string `json:"properties,omitempty"` AppId *string `json:"app_id,omitempty"` TrackingUrl *string `json:"tracking_url,omitempty"` Queue *string `json:"queue,omitempty"` }
func (JobQueryBean) String ¶
func (o JobQueryBean) String() string
type JobSubmitResult ¶
type JobSubmitResult struct { JobId *string `json:"job_id,omitempty"` 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
type JobSubmitResultStateEnum ¶
type JobSubmitResultStateEnum struct { COMPLETE JobSubmitResultState FAILED JobSubmitResultState }
func GetJobSubmitResultStateEnum ¶
func GetJobSubmitResultStateEnum() JobSubmitResultStateEnum
type NodeGroupV2 ¶
type NodeGroupV2 struct { GroupName string `json:"group_name"` NodeNum int32 `json:"node_num"` NodeSize string `json:"node_size"` RootVolume *Volume `json:"root_volume,omitempty"` DataVolume *Volume `json:"data_volume,omitempty"` DataVolumeCount *int32 `json:"data_volume_count,omitempty"` ChargeInfo *ChargeInfo `json:"charge_info,omitempty"` AutoScalingPolicy *AutoScalingPolicy `json:"auto_scaling_policy,omitempty"` AssignedRoles *[]string `json:"assigned_roles,omitempty"` }
func (NodeGroupV2) String ¶
func (o NodeGroupV2) 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 ShowAgencyMappingRequest ¶
type ShowAgencyMappingRequest struct {
ClusterId string `json:"cluster_id"`
}
Request Object
func (ShowAgencyMappingRequest) String ¶
func (o ShowAgencyMappingRequest) String() string
type ShowAgencyMappingResponse ¶
type ShowAgencyMappingResponse struct { AgencyMappings *[]AgencyMapping `json:"agency_mappings,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowAgencyMappingResponse) String ¶
func (o ShowAgencyMappingResponse) String() string
type ShowHdfsFileListRequest ¶
type ShowHdfsFileListRequest struct { ClusterId string `json:"cluster_id"` Path string `json:"path"` Offset *string `json:"offset,omitempty"` Limit *string `json:"limit,omitempty"` SortKey *ShowHdfsFileListRequestSortKey `json:"sort_key,omitempty"` Order *ShowHdfsFileListRequestOrder `json:"order,omitempty"` }
Request Object
func (ShowHdfsFileListRequest) String ¶
func (o ShowHdfsFileListRequest) String() string
type ShowHdfsFileListRequestOrder ¶
type ShowHdfsFileListRequestOrder struct {
// contains filtered or unexported fields
}
func (ShowHdfsFileListRequestOrder) MarshalJSON ¶
func (c ShowHdfsFileListRequestOrder) MarshalJSON() ([]byte, error)
func (*ShowHdfsFileListRequestOrder) UnmarshalJSON ¶
func (c *ShowHdfsFileListRequestOrder) UnmarshalJSON(b []byte) error
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
type ShowHdfsFileListRequestSortKeyEnum ¶
type ShowHdfsFileListRequestSortKeyEnum struct { PATH_SUFFIX ShowHdfsFileListRequestSortKey LENGTH ShowHdfsFileListRequestSortKey MODIFICATION_TIME ShowHdfsFileListRequestSortKey }
func GetShowHdfsFileListRequestSortKeyEnum ¶
func GetShowHdfsFileListRequestSortKeyEnum() ShowHdfsFileListRequestSortKeyEnum
type ShowHdfsFileListResponse ¶
type ShowHdfsFileListResponse struct { TotalCount *int64 `json:"total_count,omitempty"` Files *[]FileStatusV2 `json:"files,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowHdfsFileListResponse) String ¶
func (o ShowHdfsFileListResponse) String() string
type ShowJobExeListNewRequest ¶
type ShowJobExeListNewRequest struct { ClusterId string `json:"cluster_id"` JobName *string `json:"job_name,omitempty"` JobId *string `json:"job_id,omitempty"` User *string `json:"user,omitempty"` JobType *string `json:"job_type,omitempty"` JobState *ShowJobExeListNewRequestJobState `json:"job_state,omitempty"` JobResult *ShowJobExeListNewRequestJobResult `json:"job_result,omitempty"` Queue *string `json:"queue,omitempty"` Limit *string `json:"limit,omitempty"` Offset *string `json:"offset,omitempty"` SortBy *string `json:"sort_by,omitempty"` SubmittedTimeBegin *int64 `json:"submitted_time_begin,omitempty"` SubmittedTimeEnd *int64 `json:"submitted_time_end,omitempty"` }
Request Object
func (ShowJobExeListNewRequest) String ¶
func (o ShowJobExeListNewRequest) String() string
type ShowJobExeListNewRequestJobResult ¶
type ShowJobExeListNewRequestJobResult struct {
// contains filtered or unexported fields
}
func (ShowJobExeListNewRequestJobResult) MarshalJSON ¶
func (c ShowJobExeListNewRequestJobResult) MarshalJSON() ([]byte, error)
func (*ShowJobExeListNewRequestJobResult) UnmarshalJSON ¶
func (c *ShowJobExeListNewRequestJobResult) UnmarshalJSON(b []byte) error
type ShowJobExeListNewRequestJobResultEnum ¶
type ShowJobExeListNewRequestJobResultEnum struct { FAILED ShowJobExeListNewRequestJobResult KILLED ShowJobExeListNewRequestJobResult UNDEFINED ShowJobExeListNewRequestJobResult SUCCEEDED ShowJobExeListNewRequestJobResult }
func GetShowJobExeListNewRequestJobResultEnum ¶
func GetShowJobExeListNewRequestJobResultEnum() ShowJobExeListNewRequestJobResultEnum
type ShowJobExeListNewRequestJobState ¶
type ShowJobExeListNewRequestJobState struct {
// contains filtered or unexported fields
}
func (ShowJobExeListNewRequestJobState) MarshalJSON ¶
func (c ShowJobExeListNewRequestJobState) MarshalJSON() ([]byte, error)
func (*ShowJobExeListNewRequestJobState) UnmarshalJSON ¶
func (c *ShowJobExeListNewRequestJobState) UnmarshalJSON(b []byte) error
type ShowJobExeListNewRequestJobStateEnum ¶
type ShowJobExeListNewRequestJobStateEnum struct { FAILED ShowJobExeListNewRequestJobState KILLED ShowJobExeListNewRequestJobState NEW ShowJobExeListNewRequestJobState NEW_SAVING ShowJobExeListNewRequestJobState SUBMITTED ShowJobExeListNewRequestJobState ACCEPTED ShowJobExeListNewRequestJobState RUNNING ShowJobExeListNewRequestJobState FINISHED ShowJobExeListNewRequestJobState }
func GetShowJobExeListNewRequestJobStateEnum ¶
func GetShowJobExeListNewRequestJobStateEnum() ShowJobExeListNewRequestJobStateEnum
type ShowJobExeListNewResponse ¶
type ShowJobExeListNewResponse struct { JobList *[]JobQueryBean `json:"job_list,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowJobExeListNewResponse) String ¶
func (o ShowJobExeListNewResponse) String() string
type ShowSingleJobExeRequest ¶
type ShowSingleJobExeRequest struct { JobExecutionId string `json:"job_execution_id"` ClusterId string `json:"cluster_id"` }
Request Object
func (ShowSingleJobExeRequest) String ¶
func (o ShowSingleJobExeRequest) String() string
type ShowSingleJobExeResponse ¶
type ShowSingleJobExeResponse struct { JobDetail *JobQueryBean `json:"job_detail,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowSingleJobExeResponse) String ¶
func (o ShowSingleJobExeResponse) String() string
type ShowSqlResultRequest ¶
type ShowSqlResultRequest struct { ClusterId string `json:"cluster_id"` SqlId string `json:"sql_id"` }
Request Object
func (ShowSqlResultRequest) String ¶
func (o ShowSqlResultRequest) String() string
type ShowSqlResultResponse ¶
type ShowSqlResultResponse struct { Id *string `json:"id,omitempty"` Message *string `json:"message,omitempty"` Statement *string `json:"statement,omitempty"` Status *string `json:"status,omitempty"` ResultLocation *string `json:"result_location,omitempty"` Content *[][]string `json:"content,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowSqlResultResponse) String ¶
func (o ShowSqlResultResponse) String() string
type ShowSqlResultWithJobRequest ¶
type ShowSqlResultWithJobRequest struct { JobExecutionId string `json:"job_execution_id"` ClusterId string `json:"cluster_id"` }
Request Object
func (ShowSqlResultWithJobRequest) String ¶
func (o ShowSqlResultWithJobRequest) String() string
type ShowSqlResultWithJobResponse ¶
type ShowSqlResultWithJobResponse struct { SqlResults *interface{} `json:"sql_results,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowSqlResultWithJobResponse) String ¶
func (o ShowSqlResultWithJobResponse) String() string
type SqlExecutionReq ¶
type SqlExecutionReq struct { SqlType string `json:"sql_type"` SqlContent string `json:"sql_content"` Database *string `json:"database,omitempty"` ArchivePath *string `json:"archive_path,omitempty"` }
func (SqlExecutionReq) String ¶
func (o SqlExecutionReq) String() string
type StopJobRequest ¶
type StopJobRequest struct { JobExecutionId string `json:"job_execution_id"` ClusterId string `json:"cluster_id"` }
Request Object
func (StopJobRequest) String ¶
func (o StopJobRequest) String() string
type StopJobResponse ¶
type StopJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (StopJobResponse) String ¶
func (o StopJobResponse) String() string
type Trigger ¶
type UpdateAgencyMappingRequest ¶
type UpdateAgencyMappingRequest struct { ClusterId string `json:"cluster_id"` Body *AgencyMappingArray `json:"body,omitempty"` }
Request Object
func (UpdateAgencyMappingRequest) String ¶
func (o UpdateAgencyMappingRequest) String() string
type UpdateAgencyMappingResponse ¶
type UpdateAgencyMappingResponse struct { Result *string `json:"result,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (UpdateAgencyMappingResponse) String ¶
func (o UpdateAgencyMappingResponse) String() string
Source Files ¶
- model_add_jobs.go
- model_agency_mapping.go
- model_agency_mapping_array.go
- model_auto_scaling_policy.go
- model_batch_delete_jobs_request.go
- model_batch_delete_jobs_response.go
- model_bootstrap_script.go
- model_cancel_sql_request.go
- model_cancel_sql_response.go
- model_charge_info.go
- model_create_cluster_req_v2.go
- model_create_cluster_request.go
- model_create_cluster_response.go
- model_create_execute_job_request.go
- model_create_execute_job_response.go
- model_execute_sql_request.go
- model_execute_sql_response.go
- model_file_status_v2.go
- model_job_batch_delete.go
- model_job_execution.go
- model_job_query_bean.go
- model_job_submit_result.go
- model_node_group_v2.go
- model_resources_plan.go
- model_rules.go
- model_scale_script.go
- model_show_agency_mapping_request.go
- model_show_agency_mapping_response.go
- model_show_hdfs_file_list_request.go
- model_show_hdfs_file_list_response.go
- model_show_job_exe_list_new_request.go
- model_show_job_exe_list_new_response.go
- model_show_single_job_exe_request.go
- model_show_single_job_exe_response.go
- model_show_sql_result_request.go
- model_show_sql_result_response.go
- model_show_sql_result_with_job_request.go
- model_show_sql_result_with_job_response.go
- model_sql_execution_req.go
- model_stop_job_request.go
- model_stop_job_response.go
- model_tag.go
- model_trigger.go
- model_update_agency_mapping_request.go
- model_update_agency_mapping_response.go
- model_volume.go
Click to show internal directories.
Click to hide internal directories.