model

package
v0.0.4-beta Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssociateQueueToEnhancedConnectionRequest 

type AssociateQueueToEnhancedConnectionRequest struct {
	ConnectionId string `json:"connection_id"`

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

func (AssociateQueueToEnhancedConnectionRequest) String 

func (o AssociateQueueToEnhancedConnectionRequest) String() string

type AssociateQueueToEnhancedConnectionRequestBody 

type AssociateQueueToEnhancedConnectionRequestBody struct {
	Queues *[]string `json:"queues,omitempty"`

	ElasticResourcePools *[]string `json:"elastic_resource_pools,omitempty"`
}

func (AssociateQueueToEnhancedConnectionRequestBody) String 

func (o AssociateQueueToEnhancedConnectionRequestBody) String() string

type AssociateQueueToEnhancedConnectionResponse 

type AssociateQueueToEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (AssociateQueueToEnhancedConnectionResponse) String 

func (o AssociateQueueToEnhancedConnectionResponse) String() string

type CancelSparkJobRequest 

type CancelSparkJobRequest struct {
	BatchId string `json:"batch_id"`
}

func (CancelSparkJobRequest) String 

func (o CancelSparkJobRequest) String() string

type CancelSparkJobResponse 

type CancelSparkJobResponse struct {
	Msg            *string `json:"msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CancelSparkJobResponse) String 

func (o CancelSparkJobResponse) String() string

type CancelSqlJobRequest 

type CancelSqlJobRequest struct {
	JobId string `json:"job_id"`
}

func (CancelSqlJobRequest) String 

func (o CancelSqlJobRequest) String() string

type CancelSqlJobResponse 

type CancelSqlJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CancelSqlJobResponse) String 

func (o CancelSqlJobResponse) String() string

type CheckSqlRequest 

type CheckSqlRequest struct {
	Body *CheckSqlRequestBody `json:"body,omitempty"`
}

func (CheckSqlRequest) String 

func (o CheckSqlRequest) String() string

type CheckSqlRequestBody 

type CheckSqlRequestBody struct {
	Sql string `json:"sql"`

	Currentdb *string `json:"currentdb,omitempty"`
}

func (CheckSqlRequestBody) String 

func (o CheckSqlRequestBody) String() string

type CheckSqlResponse 

type CheckSqlResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobType        *string `json:"job_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CheckSqlResponse) String 

func (o CheckSqlResponse) String() string

type CreateEnhancedConnectionRequest 

type CreateEnhancedConnectionRequest struct {
	Body *CreateEnhancedConnectionRequestBody `json:"body,omitempty"`
}

func (CreateEnhancedConnectionRequest) String 

func (o CreateEnhancedConnectionRequest) String() string

type CreateEnhancedConnectionRequestBody 

type CreateEnhancedConnectionRequestBody struct {
	Name string `json:"name"`

	DestVpcId string `json:"dest_vpc_id"`

	DestNetworkId string `json:"dest_network_id"`

	Queues *[]string `json:"queues,omitempty"`

	Hosts *[]EnhancedConnectionHost `json:"hosts,omitempty"`

	RoutetableId *string `json:"routetable_id,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`
}

func (CreateEnhancedConnectionRequestBody) String 

func (o CreateEnhancedConnectionRequestBody) String() string

type CreateEnhancedConnectionResponse 

type CreateEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	ConnectionId   *string `json:"connection_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CreateEnhancedConnectionResponse) String 

func (o CreateEnhancedConnectionResponse) String() string

type CreateFlinkJarJobRequest 

type CreateFlinkJarJobRequest struct {
	Body *CreateFlinkJarJobRequestBody `json:"body,omitempty"`
}

func (CreateFlinkJarJobRequest) String 

func (o CreateFlinkJarJobRequest) String() string

type CreateFlinkJarJobRequestBody 

type CreateFlinkJarJobRequestBody struct {
	Name string `json:"name"`

	Desc *string `json:"desc,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	MainClass *string `json:"main_class,omitempty"`

	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	Entrypoint *string `json:"entrypoint,omitempty"`

	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	FlinkVersion *string `json:"flink_version,omitempty"`

	Image *string `json:"image,omitempty"`

	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	TmCus *int32 `json:"tm_cus,omitempty"`

	Feature *string `json:"feature,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	RuntimeConfig *string `json:"runtime_config,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`
}

func (CreateFlinkJarJobRequestBody) String 

func (o CreateFlinkJarJobRequestBody) String() string

type CreateFlinkJarJobResponse 

type CreateFlinkJarJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Job            *FlinkSqlJobStatusInfo `json:"job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

func (CreateFlinkJarJobResponse) String 

func (o CreateFlinkJarJobResponse) String() string

type CreateFlinkSqlJobRequest 

type CreateFlinkSqlJobRequest struct {
	Body *CreateFlinkSqlJobRequestBody `json:"body,omitempty"`
}

func (CreateFlinkSqlJobRequest) String 

func (o CreateFlinkSqlJobRequest) String() string

type CreateFlinkSqlJobRequestBody 

type CreateFlinkSqlJobRequestBody struct {
	Name string `json:"name"`

	Desc *string `json:"desc,omitempty"`

	TemplateId *int64 `json:"template_id,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	RunMode *string `json:"run_mode,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	CheckpointMode *int32 `json:"checkpoint_mode,omitempty"`

	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	TmCus *int32 `json:"tm_cus,omitempty"`

	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	RuntimeConfig *string `json:"runtime_config,omitempty"`

	FlinkVersion *string `json:"flink_version,omitempty"`
}

func (CreateFlinkSqlJobRequestBody) String 

func (o CreateFlinkSqlJobRequestBody) String() string

type CreateFlinkSqlJobResponse 

type CreateFlinkSqlJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Job            *FlinkSqlJobStatusInfo `json:"job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

func (CreateFlinkSqlJobResponse) String 

func (o CreateFlinkSqlJobResponse) String() string

type CreateFlinkSqlJobTemplateRequest 

type CreateFlinkSqlJobTemplateRequest struct {
	Body *CreateFlinkSqlJobTemplateRequestBody `json:"body,omitempty"`
}

func (CreateFlinkSqlJobTemplateRequest) String 

func (o CreateFlinkSqlJobTemplateRequest) String() string

type CreateFlinkSqlJobTemplateRequestBody 

type CreateFlinkSqlJobTemplateRequestBody struct {
	Name string `json:"name"`

	Desc *string `json:"desc,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`

	JobType *CreateFlinkSqlJobTemplateRequestBodyJobType `json:"job_type,omitempty"`
}

func (CreateFlinkSqlJobTemplateRequestBody) String 

func (o CreateFlinkSqlJobTemplateRequestBody) String() string

type CreateFlinkSqlJobTemplateRequestBodyJobType 

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

func (CreateFlinkSqlJobTemplateRequestBodyJobType) MarshalJSON 

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

func (*CreateFlinkSqlJobTemplateRequestBodyJobType) UnmarshalJSON 

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

func (CreateFlinkSqlJobTemplateRequestBodyJobType) Value 

func (c CreateFlinkSqlJobTemplateRequestBodyJobType) Value() string

type CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum 

type CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum struct {
	FLINK_SQL_JOB            CreateFlinkSqlJobTemplateRequestBodyJobType
	FLINK_OPENSOURCE_SQL_JOB CreateFlinkSqlJobTemplateRequestBodyJobType
}

func GetCreateFlinkSqlJobTemplateRequestBodyJobTypeEnum 

func GetCreateFlinkSqlJobTemplateRequestBodyJobTypeEnum() CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum

type CreateFlinkSqlJobTemplateResponse 

type CreateFlinkSqlJobTemplateResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Template       *FlinkSqlJobTemplate `json:"template,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

func (CreateFlinkSqlJobTemplateResponse) String 

func (o CreateFlinkSqlJobTemplateResponse) String() string

type CreateGlobalVariableRequest 

type CreateGlobalVariableRequest struct {
	Body *CreateGlobalVariableRequestBody `json:"body,omitempty"`
}

func (CreateGlobalVariableRequest) String 

func (o CreateGlobalVariableRequest) String() string

type CreateGlobalVariableRequestBody 

type CreateGlobalVariableRequestBody struct {
	VarName string `json:"var_name"`

	VarValue string `json:"var_value"`

	IsSensitive *bool `json:"is_sensitive,omitempty"`
}

func (CreateGlobalVariableRequestBody) String 

func (o CreateGlobalVariableRequestBody) String() string

type CreateGlobalVariableResponse 

type CreateGlobalVariableResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CreateGlobalVariableResponse) String 

func (o CreateGlobalVariableResponse) String() string

type CreateQueueRequest 

type CreateQueueRequest struct {
	Body *CreateQueueRequestBody `json:"body,omitempty"`
}

func (CreateQueueRequest) String 

func (o CreateQueueRequest) String() string

type CreateQueueRequestBody 

type CreateQueueRequestBody struct {
	QueueName string `json:"queue_name"`

	QueueType *string `json:"queue_type,omitempty"`

	Description *string `json:"description,omitempty"`

	CuCount int32 `json:"cu_count"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	Platform *string `json:"platform,omitempty"`

	ResourceMode *int32 `json:"resource_mode,omitempty"`

	Labels *[]interface{} `json:"labels,omitempty"`

	Feature *string `json:"feature,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`

	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`
}

func (CreateQueueRequestBody) String 

func (o CreateQueueRequestBody) String() string

type CreateQueueResponse 

type CreateQueueResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	QueueName      *string `json:"queue_name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CreateQueueResponse) String 

func (o CreateQueueResponse) String() string

type CreateSparkJobRequest 

type CreateSparkJobRequest struct {
	UserId *string `json:"USER-ID,omitempty"`

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

func (CreateSparkJobRequest) String 

func (o CreateSparkJobRequest) String() string

type CreateSparkJobRequestBody 

type CreateSparkJobRequestBody struct {
	File string `json:"file"`

	ClassName string `json:"className"`

	ClusterName *string `json:"cluster_name,omitempty"`

	Args *[]string `json:"args,omitempty"`

	ScType *string `json:"sc_type,omitempty"`

	Jars *[]string `json:"jars,omitempty"`

	PyFiles *[]string `json:"pyFiles,omitempty"`

	Files *[]string `json:"files,omitempty"`

	Modules *[]string `json:"modules,omitempty"`

	Resources *[]SparkJobResource `json:"resources,omitempty"`

	Groups *[]SparkJobGroup `json:"groups,omitempty"`

	Conf map[string]interface{} `json:"conf,omitempty"`

	Name *string `json:"name,omitempty"`

	DriverMemory *string `json:"driverMemory,omitempty"`

	DriverCores *int32 `json:"driverCores,omitempty"`

	ExecutorMemory *string `json:"executorMemory,omitempty"`

	ExecutorCores *int32 `json:"executorCores,omitempty"`

	NumExecutors *int32 `json:"numExecutors,omitempty"`

	Feature *CreateSparkJobRequestBodyFeature `json:"feature,omitempty"`

	SparkVersion *string `json:"spark_version,omitempty"`

	Queue *string `json:"queue,omitempty"`

	AutoRecovery *bool `json:"auto_recovery,omitempty"`

	MaxRetryTimes *int32 `json:"max_retry_times,omitempty"`

	Image *string `json:"image,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	CatalogName *string `json:"catalog_name,omitempty"`
}

func (CreateSparkJobRequestBody) String 

func (o CreateSparkJobRequestBody) String() string

type CreateSparkJobRequestBodyFeature 

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

func (CreateSparkJobRequestBodyFeature) MarshalJSON 

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

func (*CreateSparkJobRequestBodyFeature) UnmarshalJSON 

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

func (CreateSparkJobRequestBodyFeature) Value 

func (c CreateSparkJobRequestBodyFeature) Value() string

type CreateSparkJobRequestBodyFeatureEnum 

type CreateSparkJobRequestBodyFeatureEnum struct {
	BASIC  CreateSparkJobRequestBodyFeature
	AI     CreateSparkJobRequestBodyFeature
	CUSTOM CreateSparkJobRequestBodyFeature
}

func GetCreateSparkJobRequestBodyFeatureEnum 

func GetCreateSparkJobRequestBodyFeatureEnum() CreateSparkJobRequestBodyFeatureEnum

type CreateSparkJobResponse 

type CreateSparkJobResponse struct {
	Id *string `json:"id,omitempty"`

	State *string `json:"state,omitempty"`

	AppId *string `json:"appId,omitempty"`

	Log *[]string `json:"log,omitempty"`

	ScType *string `json:"sc_type,omitempty"`

	ClusterName *string `json:"cluster_name,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Name *string `json:"name,omitempty"`

	Owner *string `json:"owner,omitempty"`

	ProxyUser *string `json:"proxyUser,omitempty"`

	Kind *string `json:"kind,omitempty"`

	Queue *string `json:"queue,omitempty"`

	Image *string `json:"image,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	Duration       *int64 `json:"duration,omitempty"`
	HttpStatusCode int    `json:"-"`
}

func (CreateSparkJobResponse) String 

func (o CreateSparkJobResponse) String() string

type CreateSqlJobRequest 

type CreateSqlJobRequest struct {
	Body *CreateSqlJobRequestBody `json:"body,omitempty"`
}

func (CreateSqlJobRequest) String 

func (o CreateSqlJobRequest) String() string

type CreateSqlJobRequestBody 

type CreateSqlJobRequestBody struct {
	Sql string `json:"sql"`

	Currentdb *string `json:"currentdb,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	Conf *[]string `json:"conf,omitempty"`

	Tags *[]TmsTag `json:"tags,omitempty"`
}

func (CreateSqlJobRequestBody) String 

func (o CreateSqlJobRequestBody) String() string

type CreateSqlJobResponse 

type CreateSqlJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	JobType *CreateSqlJobResponseJobType `json:"job_type,omitempty"`

	Schema *[]interface{} `json:"schema,omitempty"`

	Rows *[][]string `json:"rows,omitempty"`

	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (CreateSqlJobResponse) String 

func (o CreateSqlJobResponse) String() string

type CreateSqlJobResponseJobType 

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

func (CreateSqlJobResponseJobType) MarshalJSON 

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

func (*CreateSqlJobResponseJobType) UnmarshalJSON 

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

func (CreateSqlJobResponseJobType) Value 

func (c CreateSqlJobResponseJobType) Value() string

type CreateSqlJobResponseJobTypeEnum 

type CreateSqlJobResponseJobTypeEnum struct {
	DDL    CreateSqlJobResponseJobType
	DCL    CreateSqlJobResponseJobType
	IMPORT CreateSqlJobResponseJobType
	EXPORT CreateSqlJobResponseJobType
	QUERY  CreateSqlJobResponseJobType
	INSERT CreateSqlJobResponseJobType
}

func GetCreateSqlJobResponseJobTypeEnum 

func GetCreateSqlJobResponseJobTypeEnum() CreateSqlJobResponseJobTypeEnum

type DeleteEnhancedConnectionRequest 

type DeleteEnhancedConnectionRequest struct {
	ConnectionId string `json:"connection_id"`
}

func (DeleteEnhancedConnectionRequest) String 

func (o DeleteEnhancedConnectionRequest) String() string

type DeleteEnhancedConnectionResponse 

type DeleteEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (DeleteEnhancedConnectionResponse) String 

func (o DeleteEnhancedConnectionResponse) String() string

type DeleteFlinkJobRequest 

type DeleteFlinkJobRequest struct {
	JobId int64 `json:"job_id"`
}

func (DeleteFlinkJobRequest) String 

func (o DeleteFlinkJobRequest) String() string

type DeleteFlinkJobResponse 

type DeleteFlinkJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (DeleteFlinkJobResponse) String 

func (o DeleteFlinkJobResponse) String() string

type DeleteFlinkSqlJobTemplateRequest 

type DeleteFlinkSqlJobTemplateRequest struct {
	TemplateId int64 `json:"template_id"`
}

func (DeleteFlinkSqlJobTemplateRequest) String 

func (o DeleteFlinkSqlJobTemplateRequest) String() string

type DeleteFlinkSqlJobTemplateResponse 

type DeleteFlinkSqlJobTemplateResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Template       *TemplateId `json:"template,omitempty"`
	HttpStatusCode int         `json:"-"`
}

func (DeleteFlinkSqlJobTemplateResponse) String 

func (o DeleteFlinkSqlJobTemplateResponse) String() string

type DeleteGlobalVariableRequest 

type DeleteGlobalVariableRequest struct {
	VarName string `json:"var_name"`
}

func (DeleteGlobalVariableRequest) String 

func (o DeleteGlobalVariableRequest) String() string

type DeleteGlobalVariableResponse 

type DeleteGlobalVariableResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (DeleteGlobalVariableResponse) String 

func (o DeleteGlobalVariableResponse) String() string

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	QueueName string `json:"queue_name"`
}

func (DeleteQueueRequest) String 

func (o DeleteQueueRequest) String() string

type DeleteQueueResponse 

type DeleteQueueResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (DeleteQueueResponse) String 

func (o DeleteQueueResponse) String() string

type DisassociateQueueFromEnhancedConnectionRequest 

type DisassociateQueueFromEnhancedConnectionRequest struct {
	ConnectionId string `json:"connection_id"`

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

func (DisassociateQueueFromEnhancedConnectionRequest) String 

func (o DisassociateQueueFromEnhancedConnectionRequest) String() string

type DisassociateQueueFromEnhancedConnectionRequestBody 

type DisassociateQueueFromEnhancedConnectionRequestBody struct {
	Queues *[]string `json:"queues,omitempty"`

	ElasticResourcePools *[]string `json:"elastic_resource_pools,omitempty"`
}

func (DisassociateQueueFromEnhancedConnectionRequestBody) String 

func (o DisassociateQueueFromEnhancedConnectionRequestBody) String() string

type DisassociateQueueFromEnhancedConnectionResponse 

type DisassociateQueueFromEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (DisassociateQueueFromEnhancedConnectionResponse) String 

func (o DisassociateQueueFromEnhancedConnectionResponse) String() string

type EnhancedConnectionHost 

type EnhancedConnectionHost struct {
	Name *string `json:"name,omitempty"`

	Ip *string `json:"ip,omitempty"`
}

func (EnhancedConnectionHost) String 

func (o EnhancedConnectionHost) String() string

type EnhancedConnectionInfo 

type EnhancedConnectionInfo struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Status *string `json:"status,omitempty"`

	AvailableQueueInfo *[]EnhancedConnectionResourceInfo `json:"available_queue_info,omitempty"`

	ElasticResourcePools *[]EnhancedConnectionResourceInfo `json:"elastic_resource_pools,omitempty"`

	DestVpcId *string `json:"dest_vpc_id,omitempty"`

	DestNetworkId *string `json:"dest_network_id,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Hosts *[]EnhancedConnectionHost `json:"hosts,omitempty"`

	IsPrivis *bool `json:"isPrivis,omitempty"`
}

func (EnhancedConnectionInfo) String 

func (o EnhancedConnectionInfo) String() string

type EnhancedConnectionResourceInfo 

type EnhancedConnectionResourceInfo struct {
	PeerId *string `json:"peer_id,omitempty"`

	Status *string `json:"status,omitempty"`

	Name *string `json:"name,omitempty"`

	ErrMsg *string `json:"err_msg,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`
}

func (EnhancedConnectionResourceInfo) String 

func (o EnhancedConnectionResourceInfo) String() string

type FlinkJobConfigInfo 

type FlinkJobConfigInfo struct {
	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	CheckpointMode *string `json:"checkpoint_mode,omitempty"`

	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	RootId *int32 `json:"root_id,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	Entrypoint *string `json:"entrypoint,omitempty"`

	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	ExecutorNumber *int32 `json:"executor_number,omitempty"`

	ExecutorCuNumber *int32 `json:"executor_cu_number,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`
}

func (FlinkJobConfigInfo) String 

func (o FlinkJobConfigInfo) String() string

type FlinkJobDetail 

type FlinkJobDetail struct {
	JobId int64 `json:"job_id"`

	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	Status *string `json:"status,omitempty"`

	StatusDesc *string `json:"status_desc,omitempty"`

	CreateTime int64 `json:"create_time"`

	StartTime *int64 `json:"start_time,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	ProjectId *string `json:"project_id,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	RunMode *string `json:"run_mode,omitempty"`

	JobConfig *FlinkJobDetailConfig `json:"job_config,omitempty"`

	MainClass *string `json:"main_class,omitempty"`

	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	ExecutionGraph *string `json:"execution_graph,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	SavepointPath *string `json:"savepoint_path,omitempty"`
}

func (FlinkJobDetail) String 

func (o FlinkJobDetail) String() string

type FlinkJobDetailConfig 

type FlinkJobDetailConfig struct {
	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	CheckpointMode *string `json:"checkpoint_mode,omitempty"`

	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	RootId *int32 `json:"root_id,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	Entrypoint *string `json:"entrypoint,omitempty"`

	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	ExecutorNumber *int32 `json:"executor_number,omitempty"`

	ExecutorCuNumber *int32 `json:"executor_cu_number,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	RuntimeConfig *string `json:"runtime_config,omitempty"`

	GraphEditorEnabled *bool `json:"graph_editor_enabled,omitempty"`

	GraphEditorData *string `json:"graph_editor_data,omitempty"`

	ResumeMaxNum *int64 `json:"resume_max_num,omitempty"`

	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	ConfigUrl *string `json:"config_url,omitempty"`

	TmCus *int32 `json:"tm_cus,omitempty"`

	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	Image *string `json:"image,omitempty"`

	Feature *string `json:"feature,omitempty"`

	FlinkVersion *string `json:"flink_version,omitempty"`

	OperatorConfig *string `json:"operator_config,omitempty"`

	StaticEstimatorConfig *string `json:"static_estimator_config,omitempty"`
}

func (FlinkJobDetailConfig) String 

func (o FlinkJobDetailConfig) String() string

type FlinkJobInfo 

type FlinkJobInfo struct {
	JobId int64 `json:"job_id"`

	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	UserName *string `json:"user_name,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	Status *string `json:"status,omitempty"`

	StatusDesc *string `json:"status_desc,omitempty"`

	CreateTime int64 `json:"create_time"`

	StartTime *int64 `json:"start_time,omitempty"`

	Duration *int64 `json:"duration,omitempty"`

	RootId *int64 `json:"root_id,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	ProjectId *string `json:"project_id,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	RunMode *string `json:"run_mode,omitempty"`

	JobConfig *FlinkJobConfigInfo `json:"job_config,omitempty"`

	MainClass *string `json:"main_class,omitempty"`

	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	ExecutionGraph *string `json:"execution_graph,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	GraphEditorEnabled *bool `json:"graph_editor_enabled,omitempty"`

	HasSavepoint *bool `json:"has_savepoint,omitempty"`
}

func (FlinkJobInfo) String 

func (o FlinkJobInfo) String() string

type FlinkJobInfoList 

type FlinkJobInfoList struct {
	TotalCount *int32 `json:"total_count,omitempty"`

	Jobs *[]FlinkJobInfo `json:"jobs,omitempty"`
}

func (FlinkJobInfoList) String 

func (o FlinkJobInfoList) String() string

type FlinkSqlJobStatusInfo 

type FlinkSqlJobStatusInfo struct {
	JobId *int64 `json:"job_id,omitempty"`

	StatusName *string `json:"status_name,omitempty"`

	StatusDesc *string `json:"status_desc,omitempty"`
}

func (FlinkSqlJobStatusInfo) String 

func (o FlinkSqlJobStatusInfo) String() string

type FlinkSqlJobTemplate 

type FlinkSqlJobTemplate struct {
	TemplateId *int64 `json:"template_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	JobType *string `json:"job_type,omitempty"`
}

func (FlinkSqlJobTemplate) String 

func (o FlinkSqlJobTemplate) String() string

type FlinkSqlJobTemplateInfo 

type FlinkSqlJobTemplateInfo struct {
	TemplateId *int32 `json:"template_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	JobType *string `json:"job_type,omitempty"`
}

func (FlinkSqlJobTemplateInfo) String 

func (o FlinkSqlJobTemplateInfo) String() string

type FlinkSqlJobTemplateList 

type FlinkSqlJobTemplateList struct {
	TotalCount *int32 `json:"total_count,omitempty"`

	Templates *[]FlinkSqlJobTemplateInfo `json:"templates,omitempty"`
}

func (FlinkSqlJobTemplateList) String 

func (o FlinkSqlJobTemplateList) String() string

type FlinkSqlJobUpdateTime 

type FlinkSqlJobUpdateTime struct {
	UpdateTime *int64 `json:"update_time,omitempty"`
}

func (FlinkSqlJobUpdateTime) String 

func (o FlinkSqlJobUpdateTime) String() string

type GlobalVariablesInfo 

type GlobalVariablesInfo struct {
	Id *int64 `json:"id,omitempty"`

	VarName *string `json:"var_name,omitempty"`

	VarValue *string `json:"var_value,omitempty"`

	ProjectId *string `json:"project_id,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	IsSensitive *bool `json:"is_sensitive,omitempty"`

	UserName *string `json:"user_name,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`
}

func (GlobalVariablesInfo) String 

func (o GlobalVariablesInfo) String() string

type ListEnhancedConnectionsRequest 

type ListEnhancedConnectionsRequest struct {
	Limit *int32 `json:"limit,omitempty"`

	Name *string `json:"name,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Status *string `json:"status,omitempty"`

	Tags *string `json:"tags,omitempty"`
}

func (ListEnhancedConnectionsRequest) String 

func (o ListEnhancedConnectionsRequest) String() string

type ListEnhancedConnectionsResponse 

type ListEnhancedConnectionsResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Connections *[]EnhancedConnectionInfo `json:"connections,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

func (ListEnhancedConnectionsResponse) String 

func (o ListEnhancedConnectionsResponse) String() string

type ListFlinkJobsRequest 

type ListFlinkJobsRequest struct {
	JobType *string `json:"job_type,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Name *string `json:"name,omitempty"`

	Offset *int64 `json:"offset,omitempty"`

	Order *string `json:"order,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	RootJobId *int64 `json:"root_job_id,omitempty"`

	ShowDetail *bool `json:"show_detail,omitempty"`

	Status *string `json:"status,omitempty"`

	SysEnterpriseProjectName *string `json:"sys_enterprise_project_name,omitempty"`

	Tags *string `json:"tags,omitempty"`

	UserName *string `json:"user_name,omitempty"`
}

func (ListFlinkJobsRequest) String 

func (o ListFlinkJobsRequest) String() string

type ListFlinkJobsResponse 

type ListFlinkJobsResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobList        *FlinkJobInfoList `json:"job_list,omitempty"`
	HttpStatusCode int               `json:"-"`
}

func (ListFlinkJobsResponse) String 

func (o ListFlinkJobsResponse) String() string

type ListFlinkSqlJobTemplatesRequest 

type ListFlinkSqlJobTemplatesRequest struct {
	Limit *int32 `json:"limit,omitempty"`

	Name *string `json:"name,omitempty"`

	Offset *int64 `json:"offset,omitempty"`

	Order *string `json:"order,omitempty"`

	Tags *string `json:"tags,omitempty"`
}

func (ListFlinkSqlJobTemplatesRequest) String 

func (o ListFlinkSqlJobTemplatesRequest) String() string

type ListFlinkSqlJobTemplatesResponse 

type ListFlinkSqlJobTemplatesResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	TemplateList   *FlinkSqlJobTemplateList `json:"template_list,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

func (ListFlinkSqlJobTemplatesResponse) String 

func (o ListFlinkSqlJobTemplatesResponse) String() string

type ListGlobalVariablesRequest 

type ListGlobalVariablesRequest struct {
	Limit *int32 `json:"limit,omitempty"`

	Offset *int32 `json:"offset,omitempty"`
}

func (ListGlobalVariablesRequest) String 

func (o ListGlobalVariablesRequest) String() string

type ListGlobalVariablesResponse 

type ListGlobalVariablesResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	GlobalVars *[]GlobalVariablesInfo `json:"global_vars,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

func (ListGlobalVariablesResponse) String 

func (o ListGlobalVariablesResponse) String() string

type ListQueuesRequest 

type ListQueuesRequest struct {
	QueueType *string `json:"queue_type,omitempty"`

	Tags *string `json:"tags,omitempty"`

	WithChargeInfo *bool `json:"with-charge-info,omitempty"`

	WithPriv *bool `json:"with-priv,omitempty"`
}

func (ListQueuesRequest) String 

func (o ListQueuesRequest) String() string

type ListQueuesResponse 

type ListQueuesResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Queues         *[]QueueInfo `json:"queues,omitempty"`
	HttpStatusCode int          `json:"-"`
}

func (ListQueuesResponse) String 

func (o ListQueuesResponse) String() string

type ListSparkJobsRequest 

type ListSparkJobsRequest struct {
	ClusterName *string `json:"cluster_name,omitempty"`

	End *int64 `json:"end,omitempty"`

	From *int32 `json:"from,omitempty"`

	JobName *string `json:"job-name,omitempty"`

	JobId *string `json:"job-id,omitempty"`

	Order *string `json:"order,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	Size *int32 `json:"size,omitempty"`

	Start *int64 `json:"start,omitempty"`

	State *string `json:"state,omitempty"`
}

func (ListSparkJobsRequest) String 

func (o ListSparkJobsRequest) String() string

type ListSparkJobsResponse 

type ListSparkJobsResponse struct {
	From *int32 `json:"from,omitempty"`

	Total *int32 `json:"total,omitempty"`

	Sessions *[]SparkJobInfo `json:"sessions,omitempty"`

	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

func (ListSparkJobsResponse) String 

func (o ListSparkJobsResponse) String() string

type ListSqlJobsRequest 

type ListSqlJobsRequest struct {
	CurrentPage *int32 `json:"current-page,omitempty"`

	DbName *string `json:"db_name,omitempty"`

	End *int64 `json:"end,omitempty"`

	EngineType *string `json:"engine-type,omitempty"`

	JobStatus *string `json:"job-status,omitempty"`

	JobType *ListSqlJobsRequestJobType `json:"job-type,omitempty"`

	Order *ListSqlJobsRequestOrder `json:"order,omitempty"`

	Owner *string `json:"owner,omitempty"`

	PageSize *int32 `json:"page-size,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	SqlPattern *string `json:"sql_pattern,omitempty"`

	Start *int64 `json:"start,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	Tags *string `json:"tags,omitempty"`
}

func (ListSqlJobsRequest) String 

func (o ListSqlJobsRequest) String() string

type ListSqlJobsRequestJobType 

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

func (ListSqlJobsRequestJobType) MarshalJSON 

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

func (*ListSqlJobsRequestJobType) UnmarshalJSON 

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

func (ListSqlJobsRequestJobType) Value 

func (c ListSqlJobsRequestJobType) Value() string

type ListSqlJobsRequestJobTypeEnum 

type ListSqlJobsRequestJobTypeEnum struct {
	DDL    ListSqlJobsRequestJobType
	DCL    ListSqlJobsRequestJobType
	IMPORT ListSqlJobsRequestJobType
	EXPORT ListSqlJobsRequestJobType
	QUERY  ListSqlJobsRequestJobType
	INSERT ListSqlJobsRequestJobType
}

func GetListSqlJobsRequestJobTypeEnum 

func GetListSqlJobsRequestJobTypeEnum() ListSqlJobsRequestJobTypeEnum

type ListSqlJobsRequestOrder 

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

func (ListSqlJobsRequestOrder) MarshalJSON 

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

func (*ListSqlJobsRequestOrder) UnmarshalJSON 

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

func (ListSqlJobsRequestOrder) Value 

func (c ListSqlJobsRequestOrder) Value() string

type ListSqlJobsRequestOrderEnum 

type ListSqlJobsRequestOrderEnum struct {
	DURATION_DESC   ListSqlJobsRequestOrder
	DURATION_ASC    ListSqlJobsRequestOrder
	START_TIME_DESC ListSqlJobsRequestOrder
	START_TIME_ASC  ListSqlJobsRequestOrder
}

func GetListSqlJobsRequestOrderEnum 

func GetListSqlJobsRequestOrderEnum() ListSqlJobsRequestOrderEnum

type ListSqlJobsResponse 

type ListSqlJobsResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobCount *int32 `json:"job_count,omitempty"`

	Jobs           *[]SqlJobInfo `json:"jobs,omitempty"`
	HttpStatusCode int           `json:"-"`
}

func (ListSqlJobsResponse) String 

func (o ListSqlJobsResponse) String() string

type ProjectPrivilege 

type ProjectPrivilege struct {
	Object *string `json:"object,omitempty"`

	ApplicantProjectId *string `json:"applicant_project_id,omitempty"`

	Privileges *[]string `json:"privileges,omitempty"`
}

func (ProjectPrivilege) String 

func (o ProjectPrivilege) String() string

type QueueInfo 

type QueueInfo struct {
	QueueId *int64 `json:"queue_id,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	Description *string `json:"description,omitempty"`

	Owner *string `json:"owner,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	QueueType *string `json:"queue_type,omitempty"`

	CuCount *int32 `json:"cu_count,omitempty"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	ResourceId *string `json:"resource_id,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	CidrInVpc *string `json:"cidr_in_vpc,omitempty"`

	CidrInMgntsubnet *string `json:"cidr_in_mgntsubnet,omitempty"`

	CidrInSubnet *string `json:"cidr_in_subnet,omitempty"`

	ResourceMode *int32 `json:"resource_mode,omitempty"`

	Platform *string `json:"platform,omitempty"`

	IsRestarting *bool `json:"is_restarting,omitempty"`

	Labels *string `json:"labels,omitempty"`

	Feature *string `json:"feature,omitempty"`

	ResourceType *string `json:"resource_type,omitempty"`

	CuSpec *int32 `json:"cu_spec,omitempty"`

	CuScaleOutLimit *int32 `json:"cu_scale_out_limit,omitempty"`

	CuScaleInLimit *int32 `json:"cu_scale_in_limit,omitempty"`

	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`
}

func (QueueInfo) String 

func (o QueueInfo) String() string

type ShowEnhancedConnectionPrivilegeRequest 

type ShowEnhancedConnectionPrivilegeRequest struct {
	ConnectionId string `json:"connection_id"`
}

func (ShowEnhancedConnectionPrivilegeRequest) String 

func (o ShowEnhancedConnectionPrivilegeRequest) String() string

type ShowEnhancedConnectionPrivilegeResponse 

type ShowEnhancedConnectionPrivilegeResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	ConnectionId *string `json:"connection_id,omitempty"`

	Privileges     *[]ProjectPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

func (ShowEnhancedConnectionPrivilegeResponse) String 

func (o ShowEnhancedConnectionPrivilegeResponse) String() string

type ShowEnhancedConnectionRequest 

type ShowEnhancedConnectionRequest struct {
	ConnectionId string `json:"connection_id"`
}

func (ShowEnhancedConnectionRequest) String 

func (o ShowEnhancedConnectionRequest) String() string

type ShowEnhancedConnectionResponse 

type ShowEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Status *string `json:"status,omitempty"`

	AvailableQueueInfo *[]EnhancedConnectionResourceInfo `json:"available_queue_info,omitempty"`

	ElasticResourcePools *[]EnhancedConnectionResourceInfo `json:"elastic_resource_pools,omitempty"`

	DestVpcId *string `json:"dest_vpc_id,omitempty"`

	DestNetworkId *string `json:"dest_network_id,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Hosts          *[]EnhancedConnectionHost `json:"hosts,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

func (ShowEnhancedConnectionResponse) String 

func (o ShowEnhancedConnectionResponse) String() string

type ShowFlinkJobRequest 

type ShowFlinkJobRequest struct {
	JobId int64 `json:"job_id"`
}

func (ShowFlinkJobRequest) String 

func (o ShowFlinkJobRequest) String() string

type ShowFlinkJobResponse 

type ShowFlinkJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobDetail      *FlinkJobDetail `json:"job_detail,omitempty"`
	HttpStatusCode int             `json:"-"`
}

func (ShowFlinkJobResponse) String 

func (o ShowFlinkJobResponse) String() string

type ShowQueueRequest 

type ShowQueueRequest struct {
	QueueName string `json:"queue_name"`
}

func (ShowQueueRequest) String 

func (o ShowQueueRequest) String() string

type ShowQueueResponse 

type ShowQueueResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	QueueId *int64 `json:"queue_id,omitempty"`

	QueueName *string `json:"queueName,omitempty"`

	Description *string `json:"description,omitempty"`

	Owner *string `json:"owner,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	QueueType *string `json:"queueType,omitempty"`

	CuCount *int32 `json:"cuCount,omitempty"`

	ChargingMode *int32 `json:"chargingMode,omitempty"`

	ResourceId *string `json:"resource_id,omitempty"`

	ResourceMode *int32 `json:"resource_mode,omitempty"`

	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	ResourceType *string `json:"resource_type,omitempty"`

	CuSpec *int32 `json:"cu_spec,omitempty"`

	CuScaleOutLimit *int32 `json:"cu_scale_out_limit,omitempty"`

	CuScaleInLimit *int32 `json:"cu_scale_in_limit,omitempty"`

	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`
	HttpStatusCode          int     `json:"-"`
}

func (ShowQueueResponse) String 

func (o ShowQueueResponse) String() string

type ShowSparkJobRequest 

type ShowSparkJobRequest struct {
	BatchId string `json:"batch_id"`
}

func (ShowSparkJobRequest) String 

func (o ShowSparkJobRequest) String() string

type ShowSparkJobResponse 

type ShowSparkJobResponse struct {
	Id *string `json:"id,omitempty"`

	State *string `json:"state,omitempty"`

	AppId *string `json:"appId,omitempty"`

	Log *[]string `json:"log,omitempty"`

	ScType *string `json:"sc_type,omitempty"`

	ClusterName *string `json:"cluster_name,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Name *string `json:"name,omitempty"`

	Owner *string `json:"owner,omitempty"`

	ProxyUser *string `json:"proxyUser,omitempty"`

	Kind *string `json:"kind,omitempty"`

	Queue *string `json:"queue,omitempty"`

	Image *string `json:"image,omitempty"`

	ReqBody *string `json:"req_body,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	Feature *string `json:"feature,omitempty"`

	SparkVersion   *string `json:"spark_version,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (ShowSparkJobResponse) String 

func (o ShowSparkJobResponse) String() string

type ShowSparkJobStatusRequest 

type ShowSparkJobStatusRequest struct {
	BatchId string `json:"batch_id"`
}

func (ShowSparkJobStatusRequest) String 

func (o ShowSparkJobStatusRequest) String() string

type ShowSparkJobStatusResponse 

type ShowSparkJobStatusResponse struct {
	Id *string `json:"id,omitempty"`

	State          *string `json:"state,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (ShowSparkJobStatusResponse) String 

func (o ShowSparkJobStatusResponse) String() string

type ShowSqlJobDetailRequest 

type ShowSqlJobDetailRequest struct {
	JobId string `json:"job_id"`
}

func (ShowSqlJobDetailRequest) String 

func (o ShowSqlJobDetailRequest) String() string

type ShowSqlJobDetailResponse 

type ShowSqlJobDetailResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	Owner *string `json:"owner,omitempty"`

	StartTime *int64 `json:"start_time,omitempty"`

	Duration *int64 `json:"duration,omitempty"`

	ExportMode *string `json:"export_mode,omitempty"`

	DatabaseName *string `json:"database_name,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	DataPath *string `json:"data_path,omitempty"`

	DataType *string `json:"data_type,omitempty"`

	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	Delimiter *string `json:"delimiter,omitempty"`

	QuoteChar *string `json:"quote_char,omitempty"`

	EscapeChar *string `json:"escape_char,omitempty"`

	DateFormat *string `json:"date_format,omitempty"`

	TimestampFormat *string `json:"timestamp_format,omitempty"`

	Compress *string `json:"compress,omitempty"`

	Tags           *[]TmsTag `json:"tags,omitempty"`
	HttpStatusCode int       `json:"-"`
}

func (ShowSqlJobDetailResponse) String 

func (o ShowSqlJobDetailResponse) String() string

type ShowSqlJobProgressRequest 

type ShowSqlJobProgressRequest struct {
	JobId string `json:"job_id"`
}

func (ShowSqlJobProgressRequest) String 

func (o ShowSqlJobProgressRequest) String() string

type ShowSqlJobProgressResponse 

type ShowSqlJobProgressResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	Status *string `json:"status,omitempty"`

	SubJobId *int32 `json:"sub_job_id,omitempty"`

	Progress *float64 `json:"progress,omitempty"`

	SubJobs        *[]SubJobInfo `json:"sub_jobs,omitempty"`
	HttpStatusCode int           `json:"-"`
}

func (ShowSqlJobProgressResponse) String 

func (o ShowSqlJobProgressResponse) String() string

type ShowSqlJobStatusRequest 

type ShowSqlJobStatusRequest struct {
	JobId string `json:"job_id"`
}

func (ShowSqlJobStatusRequest) String 

func (o ShowSqlJobStatusRequest) String() string

type ShowSqlJobStatusResponse 

type ShowSqlJobStatusResponse struct {
	JobId *string `json:"job_id,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	Owner *string `json:"owner,omitempty"`

	StartTime *int64 `json:"start_time,omitempty"`

	Duration *int64 `json:"duration,omitempty"`

	Status *ShowSqlJobStatusResponseStatus `json:"status,omitempty"`

	InputRowCount *int64 `json:"input_row_count,omitempty"`

	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	InputSize *int64 `json:"input_size,omitempty"`

	ResultCount *int32 `json:"result_count,omitempty"`

	DatabaseName *string `json:"database_name,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	Detail *string `json:"detail,omitempty"`

	UserConf *string `json:"user_conf,omitempty"`

	ResultPath *string `json:"result_path,omitempty"`

	ResultFormat *string `json:"result_format,omitempty"`

	Statement *string `json:"statement,omitempty"`

	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	JobMode *string `json:"job_mode,omitempty"`

	Tags           *[]TmsTag `json:"tags,omitempty"`
	HttpStatusCode int       `json:"-"`
}

func (ShowSqlJobStatusResponse) String 

func (o ShowSqlJobStatusResponse) String() string

type ShowSqlJobStatusResponseStatus 

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

func (ShowSqlJobStatusResponseStatus) MarshalJSON 

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

func (*ShowSqlJobStatusResponseStatus) UnmarshalJSON 

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

func (ShowSqlJobStatusResponseStatus) Value 

func (c ShowSqlJobStatusResponseStatus) Value() string

type ShowSqlJobStatusResponseStatusEnum 

type ShowSqlJobStatusResponseStatusEnum struct {
	LAUNCHING ShowSqlJobStatusResponseStatus
	RUNNING   ShowSqlJobStatusResponseStatus
	FINISHED  ShowSqlJobStatusResponseStatus
	FAILED    ShowSqlJobStatusResponseStatus
	CANCELLED ShowSqlJobStatusResponseStatus
}

func GetShowSqlJobStatusResponseStatusEnum 

func GetShowSqlJobStatusResponseStatusEnum() ShowSqlJobStatusResponseStatusEnum

type SparkJobGroup 

type SparkJobGroup struct {
	Name *string `json:"name,omitempty"`

	Resources *[]SparkJobResource `json:"resources,omitempty"`
}

func (SparkJobGroup) String 

func (o SparkJobGroup) String() string

type SparkJobInfo 

type SparkJobInfo struct {
	Id *string `json:"id,omitempty"`

	State *string `json:"state,omitempty"`

	AppId *string `json:"appId,omitempty"`

	Log *[]string `json:"log,omitempty"`

	ScType *string `json:"sc_type,omitempty"`

	ClusterName *string `json:"cluster_name,omitempty"`

	CreateTime *int64 `json:"create_time,omitempty"`

	Name *string `json:"name,omitempty"`

	Owner *string `json:"owner,omitempty"`

	ProxyUser *string `json:"proxyUser,omitempty"`

	Kind *string `json:"kind,omitempty"`

	Queue *string `json:"queue,omitempty"`

	Image *string `json:"image,omitempty"`

	ReqBody *string `json:"req_body,omitempty"`

	UpdateTime *int64 `json:"update_time,omitempty"`

	Duration *int64 `json:"duration,omitempty"`
}

func (SparkJobInfo) String 

func (o SparkJobInfo) String() string

type SparkJobResource 

type SparkJobResource struct {
	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`
}

func (SparkJobResource) String 

func (o SparkJobResource) String() string

type SqlJobInfo 

type SqlJobInfo struct {
	JobId string `json:"job_id"`

	JobType string `json:"job_type"`

	QueueName string `json:"queue_name"`

	Owner string `json:"owner"`

	StartTime int64 `json:"start_time"`

	Duration *int32 `json:"duration,omitempty"`

	Status SqlJobInfoStatus `json:"status"`

	InputRowCount *int64 `json:"input_row_count,omitempty"`

	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	InputSize int64 `json:"input_size"`

	ResultCount int32 `json:"result_count"`

	DatabaseName *string `json:"database_name,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	Detail string `json:"detail"`

	Statement string `json:"statement"`

	Tags *[]TmsTag `json:"tags,omitempty"`

	Message *string `json:"message,omitempty"`

	EndTime *int64 `json:"end_time,omitempty"`

	CpuCost *string `json:"cpu_cost,omitempty"`

	OutputByte *string `json:"output_byte,omitempty"`
}

func (SqlJobInfo) String 

func (o SqlJobInfo) String() string

type SqlJobInfoStatus 

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

func (SqlJobInfoStatus) MarshalJSON 

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

func (*SqlJobInfoStatus) UnmarshalJSON 

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

func (SqlJobInfoStatus) Value 

func (c SqlJobInfoStatus) Value() string

type SqlJobInfoStatusEnum 

type SqlJobInfoStatusEnum struct {
	LAUNCHING SqlJobInfoStatus
	RUNNING   SqlJobInfoStatus
	FINISHED  SqlJobInfoStatus
	FAILED    SqlJobInfoStatus
	CANCELLED SqlJobInfoStatus
}

func GetSqlJobInfoStatusEnum 

func GetSqlJobInfoStatusEnum() SqlJobInfoStatusEnum

type SubJobInfo 

type SubJobInfo struct {
	Id *int32 `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`

	SubmissionTime *string `json:"submission_time,omitempty"`

	CompletionTime *string `json:"completion_time,omitempty"`

	StageIds *[]int32 `json:"stage_ids,omitempty"`

	JobGroup *string `json:"job_group,omitempty"`

	Status *string `json:"status,omitempty"`

	NumTasks *int32 `json:"num_tasks,omitempty"`

	NumActiveTasks *int32 `json:"num_active_tasks,omitempty"`

	NumCompletedTasks *int32 `json:"num_completed_tasks,omitempty"`

	NumSkippedTasks *int32 `json:"num_skipped_tasks,omitempty"`

	NumFailedTasks *int32 `json:"num_failed_tasks,omitempty"`

	NumKilledTasks *int32 `json:"num_killed_tasks,omitempty"`

	NumCompletedIndices *int32 `json:"num_completed_indices,omitempty"`

	NumActiveStages *int32 `json:"num_active_stages,omitempty"`

	NumCompletedStages *int32 `json:"num_completed_stages,omitempty"`

	NumSkippedStages *int32 `json:"num_skipped_stages,omitempty"`

	NumFailedStages *int32 `json:"num_failed_stages,omitempty"`

	KilledTasksSummary map[string]int32 `json:"killed_tasks_summary,omitempty"`
}

func (SubJobInfo) String 

func (o SubJobInfo) String() string

type TemplateId 

type TemplateId struct {
	TemplateId *int64 `json:"template_id,omitempty"`
}

func (TemplateId) String 

func (o TemplateId) String() string

type TmsTag 

type TmsTag struct {
	Key string `json:"key"`

	Value string `json:"value"`
}

func (TmsTag) String 

func (o TmsTag) String() string

type UpdateEnhancedConnectionRequest 

type UpdateEnhancedConnectionRequest struct {
	ConnectionId string `json:"connection_id"`

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

func (UpdateEnhancedConnectionRequest) String 

func (o UpdateEnhancedConnectionRequest) String() string

type UpdateEnhancedConnectionRequestBody 

type UpdateEnhancedConnectionRequestBody struct {
	Hosts []EnhancedConnectionHost `json:"hosts"`
}

func (UpdateEnhancedConnectionRequestBody) String 

func (o UpdateEnhancedConnectionRequestBody) String() string

type UpdateEnhancedConnectionResponse 

type UpdateEnhancedConnectionResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (UpdateEnhancedConnectionResponse) String 

func (o UpdateEnhancedConnectionResponse) String() string

type UpdateFlinkJarJobRequest 

type UpdateFlinkJarJobRequest struct {
	JobId int64 `json:"job_id"`

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

func (UpdateFlinkJarJobRequest) String 

func (o UpdateFlinkJarJobRequest) String() string

type UpdateFlinkJarJobRequestBody 

type UpdateFlinkJarJobRequestBody struct {
	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	MainClass *string `json:"main_class,omitempty"`

	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	Entrypoint *string `json:"entrypoint,omitempty"`

	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	TmCus *int32 `json:"tm_cus,omitempty"`

	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	Feature *string `json:"feature,omitempty"`

	FlinkVersion *string `json:"flink_version,omitempty"`

	Image *string `json:"image,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	RuntimeConfig *string `json:"runtime_config,omitempty"`

	JobType *string `json:"job_type,omitempty"`
}

func (UpdateFlinkJarJobRequestBody) String 

func (o UpdateFlinkJarJobRequestBody) String() string

type UpdateFlinkJarJobResponse 

type UpdateFlinkJarJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Job            *FlinkSqlJobUpdateTime `json:"job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

func (UpdateFlinkJarJobResponse) String 

func (o UpdateFlinkJarJobResponse) String() string

type UpdateFlinkSqlJobRequest 

type UpdateFlinkSqlJobRequest struct {
	JobId int64 `json:"job_id"`

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

func (UpdateFlinkSqlJobRequest) String 

func (o UpdateFlinkSqlJobRequest) String() string

type UpdateFlinkSqlJobRequestBody 

type UpdateFlinkSqlJobRequestBody struct {
	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	QueueName *string `json:"queue_name,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`

	RunMode *string `json:"run_mode,omitempty"`

	CuNumber *int32 `json:"cu_number,omitempty"`

	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	CheckpointMode *int32 `json:"checkpoint_mode,omitempty"`

	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	ObsBucket *string `json:"obs_bucket,omitempty"`

	LogEnabled *bool `json:"log_enabled,omitempty"`

	SmnTopic *string `json:"smn_topic,omitempty"`

	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	TmCus *int32 `json:"tm_cus,omitempty"`

	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	RuntimeConfig *string `json:"runtime_config,omitempty"`

	OperatorConfig *string `json:"operator_config,omitempty"`

	StaticEstimatorConfig *string `json:"static_estimator_config,omitempty"`

	FlinkVersion *string `json:"flink_version,omitempty"`
}

func (UpdateFlinkSqlJobRequestBody) String 

func (o UpdateFlinkSqlJobRequestBody) String() string

type UpdateFlinkSqlJobResponse 

type UpdateFlinkSqlJobResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message *string `json:"message,omitempty"`

	Job            *FlinkSqlJobUpdateTime `json:"job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

func (UpdateFlinkSqlJobResponse) String 

func (o UpdateFlinkSqlJobResponse) String() string

type UpdateFlinkSqlJobTemplateRequest 

type UpdateFlinkSqlJobTemplateRequest struct {
	TemplateId int64 `json:"template_id"`

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

func (UpdateFlinkSqlJobTemplateRequest) String 

func (o UpdateFlinkSqlJobTemplateRequest) String() string

type UpdateFlinkSqlJobTemplateRequestBody 

type UpdateFlinkSqlJobTemplateRequestBody struct {
	Name *string `json:"name,omitempty"`

	Desc *string `json:"desc,omitempty"`

	SqlBody *string `json:"sql_body,omitempty"`
}

func (UpdateFlinkSqlJobTemplateRequestBody) String 

func (o UpdateFlinkSqlJobTemplateRequestBody) String() string

type UpdateFlinkSqlJobTemplateResponse 

type UpdateFlinkSqlJobTemplateResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (UpdateFlinkSqlJobTemplateResponse) String 

func (o UpdateFlinkSqlJobTemplateResponse) String() string

type UpdateGlobalVariableRequest 

type UpdateGlobalVariableRequest struct {
	VarName string `json:"var_name"`

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

func (UpdateGlobalVariableRequest) String 

func (o UpdateGlobalVariableRequest) String() string

type UpdateGlobalVariableRequestBody 

type UpdateGlobalVariableRequestBody struct {
	VarValue string `json:"var_value"`
}

func (UpdateGlobalVariableRequestBody) String 

func (o UpdateGlobalVariableRequestBody) String() string

type UpdateGlobalVariableResponse 

type UpdateGlobalVariableResponse struct {
	IsSuccess *bool `json:"is_success,omitempty"`

	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

func (UpdateGlobalVariableResponse) String 

func (o UpdateGlobalVariableResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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