model

package
v0.1.114 Latest Latest
Warning

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

Go to latest
Published: Sep 12, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdvancedQueueProperty added in v0.1.90

type AdvancedQueueProperty struct {

	// 队列能启动的最大spark driver数量
	ComputeEngineMaxInstance *int32 `json:"computeEngine.maxInstance,omitempty"`

	// 单个spark driver能同时运行的最大任务数量
	JobMaxConcurrent *int32 `json:"job.maxConcurrent,omitempty"`

	// 队列预先启动的最大spark driver数量
	ComputeEngineMaxPrefetchInstance *int32 `json:"computeEngine.maxPrefetchInstance,omitempty"`

	// 设置队列网段
	NetworkCidrInVpc *string `json:"network.cidrInVpc,omitempty"`
}

func (AdvancedQueueProperty) String added in v0.1.90

func (o AdvancedQueueProperty) String() string

type AssociateQueueToElasticResourcePoolRequest

type AssociateQueueToElasticResourcePoolRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

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

AssociateQueueToElasticResourcePoolRequest Request Object

func (AssociateQueueToElasticResourcePoolRequest) String

type AssociateQueueToElasticResourcePoolRequestBody

type AssociateQueueToElasticResourcePoolRequestBody struct {

	// 队列名称
	QueueName string `json:"queue_name"`
}

AssociateQueueToElasticResourcePoolRequestBody 队列关联弹性资源池

func (AssociateQueueToElasticResourcePoolRequestBody) String

type AssociateQueueToElasticResourcePoolResponse

type AssociateQueueToElasticResourcePoolResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

AssociateQueueToElasticResourcePoolResponse Response Object

func (AssociateQueueToElasticResourcePoolResponse) String

type AssociateQueueToEnhancedConnectionRequest added in v0.1.68

type AssociateQueueToEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

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

AssociateQueueToEnhancedConnectionRequest Request Object

func (AssociateQueueToEnhancedConnectionRequest) String added in v0.1.68

type AssociateQueueToEnhancedConnectionRequestBody added in v0.1.88

type AssociateQueueToEnhancedConnectionRequestBody struct {

	// 需要使用跨源的队列名列表。
	Queues *[]string `json:"queues,omitempty"`

	// 需要使用跨源的弹性资源池名列表。
	ElasticResourcePools *[]string `json:"elastic_resource_pools,omitempty"`
}

func (AssociateQueueToEnhancedConnectionRequestBody) String added in v0.1.88

type AssociateQueueToEnhancedConnectionResponse added in v0.1.68

type AssociateQueueToEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

AssociateQueueToEnhancedConnectionResponse Response Object

func (AssociateQueueToEnhancedConnectionResponse) String added in v0.1.68

type AuthInfo added in v0.1.88

type AuthInfo struct {

	// 用户安全集群的登录用户名
	AuthInfoName *string `json:"auth_info_name,omitempty"`

	// 用户安全集群的登录密码
	UserName *string `json:"user_name,omitempty"`

	// 用户安全集群的证书路径,目前只支持OBS路径,cer类型文件
	CertificateLocation *string `json:"certificate_location,omitempty"`

	// 数据源类型,目前支持CSS,KRB,passwd,Kafka_SSL
	DatasourceType *string `json:"datasource_type,omitempty"`

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

	// 更新时间戳
	UpdateTime *int64 `json:"update_time,omitempty"`

	// krb5配置文件obs路径
	Krb5Conf *string `json:"krb5_conf,omitempty"`

	// keytab配置文件obs路径
	Keytab *string `json:"keytab,omitempty"`

	// truststore配置文件obs路径
	TruststoreLocation *string `json:"truststore_location,omitempty"`

	// keystore配置文件obs路径
	KeystoreLocation *string `json:"keystore_location,omitempty"`

	// 所属用户名
	Owner *string `json:"owner,omitempty"`
}

func (AuthInfo) String added in v0.1.88

func (o AuthInfo) String() string

type AuthorizationPrivilege added in v0.1.85

type AuthorizationPrivilege struct {

	// 授权对象,和赋权API中的“object”对应。
	Object *string `json:"object,omitempty"`

	// 判断用户是否为管理员。
	IsAdmin *bool `json:"is_admin,omitempty"`

	// 用户名称,即该用户在当前数据库上有权限。
	UserName *string `json:"user_name,omitempty"`

	// 该用户在数据库上的权限。
	Privileges *[]string `json:"privileges,omitempty"`
}

AuthorizationPrivilege 查看数据库的使用者的权限信息。

func (AuthorizationPrivilege) String added in v0.1.85

func (o AuthorizationPrivilege) String() string

type AvailableQueueInfo

type AvailableQueueInfo struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	Status *string `json:"status,omitempty"`

	// 队列名称。
	Name *string `json:"name,omitempty"`

	// uuid。
	Uuid *string `json:"uuid,omitempty"`

	// 状态为失败时的详细报错信息。
	ErrMsg *string `json:"err_msg,omitempty"`

	// 作业更新时间, 毫秒数。
	UpdateTime *int64 `json:"update_time,omitempty"`
}

func (AvailableQueueInfo) String

func (o AvailableQueueInfo) String() string

type BatchDeleteFlinkJobsRequest

type BatchDeleteFlinkJobsRequest struct {
	Body *BatchDeleteFlinkJobsRequestBody `json:"body,omitempty"`
}

BatchDeleteFlinkJobsRequest Request Object

func (BatchDeleteFlinkJobsRequest) String

type BatchDeleteFlinkJobsRequestBody

type BatchDeleteFlinkJobsRequestBody struct {

	//
	JobIds []int64 `json:"job_ids"`
}

BatchDeleteFlinkJobsRequestBody

func (BatchDeleteFlinkJobsRequestBody) String

type BatchDeleteFlinkJobsResponse

type BatchDeleteFlinkJobsResponse struct {
	Body           *[]FlinkSuccessResponse `json:"body,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

BatchDeleteFlinkJobsResponse Response Object

func (BatchDeleteFlinkJobsResponse) String

type BatchDeleteQueuePlansRequest

type BatchDeleteQueuePlansRequest struct {

	// 待删除定时扩缩计划的队列名称
	QueueName string `json:"queue_name"`

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

BatchDeleteQueuePlansRequest Request Object

func (BatchDeleteQueuePlansRequest) String

type BatchDeleteQueuePlansRequestBody added in v0.1.88

type BatchDeleteQueuePlansRequestBody struct {

	// 表示SQL语句的类型
	PlanIds []int64 `json:"plan_ids"`
}

func (BatchDeleteQueuePlansRequestBody) String added in v0.1.88

type BatchDeleteQueuePlansResponse

type BatchDeleteQueuePlansResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

BatchDeleteQueuePlansResponse Response Object

func (BatchDeleteQueuePlansResponse) String

type BatchDeleteSqlJobTemplatesRequest added in v0.1.68

type BatchDeleteSqlJobTemplatesRequest struct {
	Body *BatchDeleteSqlJobTemplatesRequestBody `json:"body,omitempty"`
}

BatchDeleteSqlJobTemplatesRequest Request Object

func (BatchDeleteSqlJobTemplatesRequest) String added in v0.1.68

type BatchDeleteSqlJobTemplatesRequestBody added in v0.1.88

type BatchDeleteSqlJobTemplatesRequestBody struct {

	// 待删除的sql模板ID列表。
	SqlIds []string `json:"sql_ids"`
}

func (BatchDeleteSqlJobTemplatesRequestBody) String added in v0.1.88

type BatchDeleteSqlJobTemplatesResponse added in v0.1.68

type BatchDeleteSqlJobTemplatesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

BatchDeleteSqlJobTemplatesResponse Response Object

func (BatchDeleteSqlJobTemplatesResponse) String added in v0.1.68

type BatchRunFlinkJobsRequest

type BatchRunFlinkJobsRequest struct {
	Body *BatchRunFlinkJobsRequestBody `json:"body,omitempty"`
}

BatchRunFlinkJobsRequest Request Object

func (BatchRunFlinkJobsRequest) String

func (o BatchRunFlinkJobsRequest) String() string

type BatchRunFlinkJobsRequestBody

type BatchRunFlinkJobsRequestBody struct {

	// 是否将作业从最近创建的保存点恢复。类型为boolean。  当resume_savepoint为true时,表示作业从最近创建的保存点恢复。 当resume_savepoint为false时,表示不恢复正常启动。默认为false。
	ResumeSavepoint *bool `json:"resume_savepoint,omitempty"`

	//
	JobIds []int64 `json:"job_ids"`
}

BatchRunFlinkJobsRequestBody

func (BatchRunFlinkJobsRequestBody) String

type BatchRunFlinkJobsResponse

type BatchRunFlinkJobsResponse struct {
	Body           *[]FlinkSuccessResponse `json:"body,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

BatchRunFlinkJobsResponse Response Object

func (BatchRunFlinkJobsResponse) String

func (o BatchRunFlinkJobsResponse) String() string

type BatchStopFlinkJobsRequest added in v0.1.88

type BatchStopFlinkJobsRequest struct {
	Body *StopFlinkJobsRequestBody `json:"body,omitempty"`
}

BatchStopFlinkJobsRequest Request Object

func (BatchStopFlinkJobsRequest) String added in v0.1.88

func (o BatchStopFlinkJobsRequest) String() string

type BatchStopFlinkJobsResponse added in v0.1.88

type BatchStopFlinkJobsResponse struct {
	Body           *[]FlinkSuccessResponse `json:"body,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

BatchStopFlinkJobsResponse Response Object

func (BatchStopFlinkJobsResponse) String added in v0.1.88

type CancelSparkJobRequest added in v0.1.68

type CancelSparkJobRequest struct {

	// 批处理作业的ID。
	BatchId string `json:"batch_id"`
}

CancelSparkJobRequest Request Object

func (CancelSparkJobRequest) String added in v0.1.68

func (o CancelSparkJobRequest) String() string

type CancelSparkJobResponse added in v0.1.68

type CancelSparkJobResponse struct {

	// 取消成功,返回“deleted”。
	Msg            *string `json:"msg,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CancelSparkJobResponse Response Object

func (CancelSparkJobResponse) String added in v0.1.68

func (o CancelSparkJobResponse) String() string

type CancelSqlJobRequest

type CancelSqlJobRequest struct {

	// 作业ID
	JobId string `json:"job_id"`
}

CancelSqlJobRequest Request Object

func (CancelSqlJobRequest) String

func (o CancelSqlJobRequest) String() string

type CancelSqlJobResponse

type CancelSqlJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CancelSqlJobResponse Response Object

func (CancelSqlJobResponse) String

func (o CancelSqlJobResponse) String() string

type Catalog added in v0.1.88

type Catalog struct {

	// DLI侧catalog映射名称。
	Name *string `json:"name,omitempty"`

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

	// 属性中包含type和externalCatalog
	Parameters map[string]string `json:"parameters,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`
}

func (Catalog) String added in v0.1.88

func (o Catalog) String() string

type ChangeFlinkJobStatusReportRequestBody added in v0.1.88

type ChangeFlinkJobStatusReportRequestBody struct {

	// 作业信息列表
	Jobs []Job `json:"jobs"`

	// 消息id
	MessageId string `json:"message_id"`

	// 消息确认topic
	MsgConfirmTopic *string `json:"msg_confirm_topic,omitempty"`
}

ChangeFlinkJobStatusReportRequestBody IEF Flink job状态上报的请求body体。

func (ChangeFlinkJobStatusReportRequestBody) String added in v0.1.88

type CheckSqlRequest

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

CheckSqlRequest Request Object

func (CheckSqlRequest) String

func (o CheckSqlRequest) String() string

type CheckSqlRequestBody

type CheckSqlRequestBody struct {

	// 待执行的SQL语句。
	Sql string `json:"sql"`

	// SQL语句执行所在的数据库。
	Currentdb *string `json:"currentdb,omitempty"`
}

CheckSqlRequestBody 检查SQL语法

func (CheckSqlRequestBody) String

func (o CheckSqlRequestBody) String() string

type CheckSqlResponse

type CheckSqlResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 表示SQL语句的类型
	JobType        *string `json:"job_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CheckSqlResponse Response Object

func (CheckSqlResponse) String

func (o CheckSqlResponse) String() string

type Column added in v0.1.88

type Column struct {

	// 列的名称。
	ColumnName string `json:"column_name"`

	// 列的数据类型。
	Type string `json:"type"`

	// 列的描述信息。
	Description *string `json:"description,omitempty"`

	// 表示该列是否为分区列。“true”表示为分区列,“false”为非分区列,默认为“false”。
	IsPartitionColumn *bool `json:"is_partition_column,omitempty"`
}

Column 新增表的列的相关参数。

func (Column) String added in v0.1.88

func (o Column) String() string

type CommonQueueProperty added in v0.1.90

type CommonQueueProperty struct {

	// 队列能启动的最大spark driver数量
	ComputeEngineMaxInstance *int32 `json:"computeEngine.maxInstance,omitempty"`

	// 单个spark driver能同时运行的最大任务数量
	JobMaxConcurrent *int32 `json:"job.maxConcurrent,omitempty"`

	// 队列预先启动的最大spark driver数量
	ComputeEngineMaxPrefetchInstance *int32 `json:"computeEngine.maxPrefetchInstance,omitempty"`
}

func (CommonQueueProperty) String added in v0.1.90

func (o CommonQueueProperty) String() string

type CreateAuthInfoRequest

type CreateAuthInfoRequest struct {
	Body *CreateAuthInfoRequestBody `json:"body,omitempty"`
}

CreateAuthInfoRequest Request Object

func (CreateAuthInfoRequest) String

func (o CreateAuthInfoRequest) String() string

type CreateAuthInfoRequestBody added in v0.1.88

type CreateAuthInfoRequestBody struct {

	// 证书名
	AuthInfoName string `json:"auth_info_name"`

	// 用户安全集群的新登录用户名
	UserName *string `json:"user_name,omitempty"`

	// 用户安全集群的新登录密码
	Password *string `json:"password,omitempty"`

	// krb5配置文件obs路径
	Krb5Conf *string `json:"krb5_conf,omitempty"`

	// keytab配置文件obs路径
	Keytab *string `json:"keytab,omitempty"`

	// truststore配置文件obs路径
	TruststoreLocation *string `json:"truststore_location,omitempty"`

	// truststore配置文件密码
	TruststorePassword *string `json:"truststore_password,omitempty"`

	// keystore配置文件obs路径
	KeystoreLocation *string `json:"keystore_location,omitempty"`

	// keystore配置文件密码
	KeystorePassword *string `json:"keystore_password,omitempty"`

	// 用户安全集群的证书路径,目前只支持OBS路径,cer类型文件
	CertificateLocation *string `json:"certificate_location,omitempty"`

	// 数据源类型,目前支持CSS,KRB,passwd,Kafka_SSL
	DatasourceType string `json:"datasource_type"`

	// key密码
	KeyPassword *string `json:"key_password,omitempty"`
}

func (CreateAuthInfoRequestBody) String added in v0.1.88

func (o CreateAuthInfoRequestBody) String() string

type CreateAuthInfoResponse

type CreateAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateAuthInfoResponse Response Object

func (CreateAuthInfoResponse) String

func (o CreateAuthInfoResponse) String() string

type CreateConnectivityTaskRequest added in v0.1.68

type CreateConnectivityTaskRequest struct {

	// 队列名称
	QueueName string `json:"queue_name"`

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

CreateConnectivityTaskRequest Request Object

func (CreateConnectivityTaskRequest) String added in v0.1.68

type CreateConnectivityTaskRequestBody added in v0.1.88

type CreateConnectivityTaskRequestBody struct {

	// 测试地址
	Address string `json:"address"`
}

CreateConnectivityTaskRequestBody 测试地址连通性 { \"address\": \"iam.cn-north-7.ulanqab.huawei.com:443\" }

func (CreateConnectivityTaskRequestBody) String added in v0.1.88

type CreateConnectivityTaskResponse added in v0.1.68

type CreateConnectivityTaskResponse struct {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 请求id
	TaskId         *int64 `json:"task_id,omitempty"`
	HttpStatusCode int    `json:"-"`
}

CreateConnectivityTaskResponse Response Object

func (CreateConnectivityTaskResponse) String added in v0.1.68

type CreateDatabaseRequest

type CreateDatabaseRequest struct {
	Body *CreateDatabaseRequestBody `json:"body,omitempty"`
}

CreateDatabaseRequest Request Object

func (CreateDatabaseRequest) String

func (o CreateDatabaseRequest) String() string

type CreateDatabaseRequestBody

type CreateDatabaseRequestBody struct {

	// 新增数据库名称。 说明: “default”为内置数据库,不能创建名为“default”的数据库。
	DatabaseName string `json:"database_name"`

	// 新增数据库的描述信息。
	Description *string `json:"description,omitempty"`

	// 企业项目ID,“0”表示default,即默认的企业项目。关于如何设置企业项目请参考《企业管理用户指南》。 说明: 开通了企业管理服务的用户可设置该参数绑定指定的项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

CreateDatabaseRequestBody 创建数据库的请求body体。

func (CreateDatabaseRequestBody) String

func (o CreateDatabaseRequestBody) String() string

type CreateDatabaseResponse

type CreateDatabaseResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateDatabaseResponse Response Object

func (CreateDatabaseResponse) String

func (o CreateDatabaseResponse) String() string

type CreateDatasourceConnectionRequest

type CreateDatasourceConnectionRequest struct {
	Body *CreateDatasourceConnectionRequestBody `json:"body,omitempty"`
}

CreateDatasourceConnectionRequest Request Object

func (CreateDatasourceConnectionRequest) String

type CreateDatasourceConnectionRequestBody added in v0.1.88

type CreateDatasourceConnectionRequestBody struct {

	// 连接名称。
	Name string `json:"name"`

	// 服务名称,目前为CloudTable.OpenTSDB/CloudTable,MRS.OPENTSDB,DWS,RDS,CSS。 说明: 大小写不敏感。
	Service string `json:"service"`

	// 用户指定安全组ID,即为需要建立连接的服务所在的安全组。
	SecurityGroupId string `json:"security_group_id"`

	// 对应服务的子网网络ID,即为需要建立连接的服务所在的子网。
	NetworkId string `json:"network_id"`

	// 对应服务对外提供的访问url。长度不能超过512个字符。
	Url string `json:"url"`

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

CreateDatasourceConnectionRequestBody 创建经典型跨源连接的请求body体。

func (CreateDatasourceConnectionRequestBody) String added in v0.1.88

type CreateDatasourceConnectionResponse

type CreateDatasourceConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId   *string `json:"connection_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateDatasourceConnectionResponse Response Object

func (CreateDatasourceConnectionResponse) String

type CreateDliAgencyRequest

type CreateDliAgencyRequest struct {
	Body *CreateDliAgencyRequestBody `json:"body,omitempty"`
}

CreateDliAgencyRequest Request Object

func (CreateDliAgencyRequest) String

func (o CreateDliAgencyRequest) String() string

type CreateDliAgencyRequestBody added in v0.1.88

type CreateDliAgencyRequestBody struct {

	// 角色目前只支持,obs_adm、dis_adm、ctable_adm、vpc_netadm、smn_adm、te_admin
	Roles []string `json:"roles"`
}

func (CreateDliAgencyRequestBody) String added in v0.1.88

type CreateDliAgencyResponse

type CreateDliAgencyResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateDliAgencyResponse Response Object

func (CreateDliAgencyResponse) String

func (o CreateDliAgencyResponse) String() string

type CreateElasticResourcePoolRequest

type CreateElasticResourcePoolRequest struct {
	Body *CreateElasticResourcePoolRequestBody `json:"body,omitempty"`
}

CreateElasticResourcePoolRequest Request Object

func (CreateElasticResourcePoolRequest) String

type CreateElasticResourcePoolRequestBody

type CreateElasticResourcePoolRequestBody struct {

	// 新建的弹性资源池名称,名称只能包含数字、小写英文字母和下划线,但不能是纯数字,且不能以下划线开头。长度限制:1~128个字符。
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

	// 描述信息。长度限制:256个字符以内。
	Description *string `json:"description,omitempty"`

	// 虚拟集群关联的vpc cidr.如果不填,默认值为172.16.0.0//12
	CidrInVpc *string `json:"cidr_in_vpc,omitempty"`

	// max_cu大于等于该弹性资源池下任意一个队列的最大CU。标准版弹性资源池最小值为64,最大值为32000;基础版弹性资源池最小值为16,最大值为64。
	MaxCu int32 `json:"max_cu"`

	// 计费类型 1、按需计费
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// min_cu大于等于该弹性资源池下所有队列最小CU之和,且小于等于max_cu。标准版弹性资源池最小值为64,最大值为32000;基础版弹性资源池最小值为16,最大值为64。
	MinCu int32 `json:"min_cu"`

	// 企业ID,不填默认为“0”
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

	// 弹性资源池属性字段。默认为标准版弹性资源池;{\"spec\":\"basic\"}标识基础版弹性资源池;{\"billing_spec_code\":\"developer\"}标识开发者弹性资源池。目前不支持其它属性设置。
	Label map[string]string `json:"label,omitempty"`
}

CreateElasticResourcePoolRequestBody 创建弹性资源池消息

func (CreateElasticResourcePoolRequestBody) String

type CreateElasticResourcePoolResponse

type CreateElasticResourcePoolResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 响应消息
	Message *string `json:"message,omitempty"`

	// 创建成功的弹性资源池名称
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`
	HttpStatusCode          int     `json:"-"`
}

CreateElasticResourcePoolResponse Response Object

func (CreateElasticResourcePoolResponse) String

type CreateEnhancedConnectionRequest

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

CreateEnhancedConnectionRequest Request Object

func (CreateEnhancedConnectionRequest) String

type CreateEnhancedConnectionRequestBody added in v0.1.88

type CreateEnhancedConnectionRequestBody struct {

	// 连接名称。长度64,数字字母下划线组成。
	Name string `json:"name"`

	// 对应服务的vpc的ID。
	DestVpcId string `json:"dest_vpc_id"`

	// 对应服务的子网网络ID,即为需要建立连接的服务所在的子网。
	DestNetworkId string `json:"dest_network_id"`

	// 弹性资源池列表。
	ElasticResourcePools *[]string `json:"elastic_resource_pools,omitempty"`

	// 需要使用跨源的队列列表。
	Queues *[]string `json:"queues,omitempty"`

	// 用户自定义主机信息,最大支持2万条记录。
	Hosts *[]EnhancedConnectionHost `json:"hosts,omitempty"`

	// 对应服务的子网关联的路由表。
	RoutetableId *string `json:"routetable_id,omitempty"`

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

CreateEnhancedConnectionRequestBody 创建增强型跨源连接的请求body体。

func (CreateEnhancedConnectionRequestBody) String added in v0.1.88

type CreateEnhancedConnectionResponse

type CreateEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId   *string `json:"connection_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateEnhancedConnectionResponse Response Object

func (CreateEnhancedConnectionResponse) String

type CreateEnhancedConnectionRoutesRequest

type CreateEnhancedConnectionRoutesRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

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

CreateEnhancedConnectionRoutesRequest Request Object

func (CreateEnhancedConnectionRoutesRequest) String

type CreateEnhancedConnectionRoutesRequestBody added in v0.1.88

type CreateEnhancedConnectionRoutesRequestBody struct {

	// 路由名称,长度限制:1-64个字符。
	Name string `json:"name"`

	// 路由网段范围。
	Cidr string `json:"cidr"`
}

func (CreateEnhancedConnectionRoutesRequestBody) String added in v0.1.88

type CreateEnhancedConnectionRoutesResponse

type CreateEnhancedConnectionRoutesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateEnhancedConnectionRoutesResponse Response Object

func (CreateEnhancedConnectionRoutesResponse) String

type CreateFlinkJarJobRequest added in v0.1.68

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

CreateFlinkJarJobRequest Request Object

func (CreateFlinkJarJobRequest) String added in v0.1.68

func (o CreateFlinkJarJobRequest) String() string

type CreateFlinkJarJobRequestBody added in v0.1.88

type CreateFlinkJarJobRequestBody struct {

	// 作业名称。长度限制:0-57个字符。
	Name string `json:"name"`

	// 作业描述。长度限制:0-512个字符。
	Desc *string `json:"desc,omitempty"`

	// 队列名称。长度限制:1-128个字符。
	QueueName *string `json:"queue_name,omitempty"`

	// 用户为作业选择的CU数量,默认值为2。
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 用户为作业选择的管理节点CU数量,对应为flink jobmanager数量,默认值为1。
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 用户为作业选择的并发量,默认值为1.
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 是否开启作业日志。 开启:true 关闭:false 默认:false
	LogEnabled *bool `json:"log_enabled,omitempty"`

	// 当“log_enabled”为“true”时, 用户授权保存作业日志的OBS桶名。
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 当作业异常时,向该SMN主题推送告警信息。
	SmnTopic *string `json:"smn_topic,omitempty"`

	// 作业入口类。
	MainClass *string `json:"main_class,omitempty"`

	// 作业入口类参数,多个参数之间空格分隔。
	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	// 是否开启异常重启功能,默认值为“false”。
	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业主类所在的jar包。
	Entrypoint *string `json:"entrypoint,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的其他依赖包。示例:[Group/test.jar,myGroup/test1.jar]
	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的依赖文件,示例:[myGroup/test.cvs,myGroup/test1.csv]
	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	// Flink版本。当用户设置“feature”为“basic”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用的DLI基础Flink镜像的版本。
	FlinkVersion *string `json:"flink_version,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Flink镜像。关于如何使用自定义镜像,请参考《数据湖探索用户指南》
	Image *string `json:"image,omitempty"`

	// 每个taskmanager的slot数,默认值为“(parallel_number*tm_cus)/(cu_number-manager_cu_number)”。
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	// 每个taskmanager的CU数,默认值为“1”。
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 作业特性。表示用户作业使用的Flink镜像类型。basic:表示使用DLI提供的基础Flink镜像。custom:表示使用用户自定义的Flink镜像。
	Feature *string `json:"feature,omitempty"`

	// 异常重启是否从checkpoint恢复。
	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	// 异常重试最大次数,单位:次/小时。取值范围:-1或大于0。默认值为“-1”,表示无限次数。
	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	// 用户Jar中checkpoint的储存地址,不同作业路径需要保持不同。
	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	// Flink作业运行时自定义优化参数。
	RuntimeConfig *string `json:"runtime_config,omitempty"`

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

CreateFlinkJarJobRequestBody 新建Flink Jar作业的请求参数。

func (CreateFlinkJarJobRequestBody) String added in v0.1.88

type CreateFlinkJarJobResponse added in v0.1.68

type CreateFlinkJarJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容
	Message *string `json:"message,omitempty"`

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

CreateFlinkJarJobResponse Response Object

func (CreateFlinkJarJobResponse) String added in v0.1.68

func (o CreateFlinkJarJobResponse) String() string

type CreateFlinkSqlJobGraphRequest added in v0.1.68

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

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

CreateFlinkSqlJobGraphRequest Request Object

func (CreateFlinkSqlJobGraphRequest) String added in v0.1.68

type CreateFlinkSqlJobGraphRequestBody added in v0.1.88

type CreateFlinkSqlJobGraphRequestBody struct {

	// SQL
	SqlBody string `json:"sql_body"`

	// Flink版本。当前只支持1.10和1.12。
	FlinkVersion *CreateFlinkSqlJobGraphRequestBodyFlinkVersion `json:"flink_version,omitempty"`

	// CU总数
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 管理单元CU数量
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 最大并行度
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 单个taskManagerCU数量
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 单个taskManager Slot数量
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	// 算子的配置
	OperatorConfig *string `json:"operator_config,omitempty"`

	// 是否静态资源预估
	StaticEstimator *bool `json:"static_estimator,omitempty"`

	// 作业类型
	JobType *string `json:"job_type,omitempty"`

	// 流图类型。当前支持以下两种流图类型。 简化流图:simple_graph 静态流图:job_graph。
	GraphType *CreateFlinkSqlJobGraphRequestBodyGraphType `json:"graph_type,omitempty"`

	// 每个算子的流量/命中率配置,json格式的字符串。
	StaticEstimatorConfig *string `json:"static_estimator_config,omitempty"`
}

CreateFlinkSqlJobGraphRequestBody 生成SQL静态流图请求参数

func (CreateFlinkSqlJobGraphRequestBody) String added in v0.1.88

type CreateFlinkSqlJobGraphRequestBodyFlinkVersion added in v0.1.88

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

func (CreateFlinkSqlJobGraphRequestBodyFlinkVersion) MarshalJSON added in v0.1.88

func (*CreateFlinkSqlJobGraphRequestBodyFlinkVersion) UnmarshalJSON added in v0.1.88

func (CreateFlinkSqlJobGraphRequestBodyFlinkVersion) Value added in v0.1.88

type CreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum added in v0.1.88

type CreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum struct {
	E_1_1  CreateFlinkSqlJobGraphRequestBodyFlinkVersion
	E_1_12 CreateFlinkSqlJobGraphRequestBodyFlinkVersion
}

func GetCreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum added in v0.1.88

func GetCreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum() CreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum

type CreateFlinkSqlJobGraphRequestBodyGraphType added in v0.1.88

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

func (CreateFlinkSqlJobGraphRequestBodyGraphType) MarshalJSON added in v0.1.88

func (*CreateFlinkSqlJobGraphRequestBodyGraphType) UnmarshalJSON added in v0.1.88

func (CreateFlinkSqlJobGraphRequestBodyGraphType) Value added in v0.1.88

type CreateFlinkSqlJobGraphRequestBodyGraphTypeEnum added in v0.1.88

type CreateFlinkSqlJobGraphRequestBodyGraphTypeEnum struct {
	SIMPLE_GRAPH CreateFlinkSqlJobGraphRequestBodyGraphType
	JOB_GRAPH    CreateFlinkSqlJobGraphRequestBodyGraphType
}

func GetCreateFlinkSqlJobGraphRequestBodyGraphTypeEnum added in v0.1.88

func GetCreateFlinkSqlJobGraphRequestBodyGraphTypeEnum() CreateFlinkSqlJobGraphRequestBodyGraphTypeEnum

type CreateFlinkSqlJobGraphResponse added in v0.1.68

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

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

	ErrorCode *string `json:"error_code,omitempty"`

	// 静态流图的描述信息
	StreamGraph    *string `json:"stream_graph,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateFlinkSqlJobGraphResponse Response Object

func (CreateFlinkSqlJobGraphResponse) String added in v0.1.68

type CreateFlinkSqlJobRequest

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

CreateFlinkSqlJobRequest Request Object

func (CreateFlinkSqlJobRequest) String

func (o CreateFlinkSqlJobRequest) String() string

type CreateFlinkSqlJobRequestBody

type CreateFlinkSqlJobRequestBody struct {

	// 作业名称。长度限制:0-57个字符。
	Name string `json:"name"`

	// 作业描述。长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// 模板Id。  如果template_id和sql_body都不为空,优先sql_body;如果template_id不空,sql_body为空,以template_id内容填充sql_body。
	TemplateId *int64 `json:"template_id,omitempty"`

	// 队列名称。长度限制:1-128个字符。
	QueueName *string `json:"queue_name,omitempty"`

	// Stream SQL语句。长度限制:1024*1024个字符。
	SqlBody *string `json:"sql_body,omitempty"`

	// 作业运行模式: shared_cluster:共享。 exclusive_cluster:独享。 edge_node:边缘节点。 默认值为:shared_cluster
	RunMode *string `json:"run_mode,omitempty"`

	// 用户为作业选择的CU数量,默认值为2。
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 用户设置的作业并行数目。默认值为1。
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 是否开启作业自动快照功能。 开启:true; 关闭:false; 默认:false。
	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	// 快照模式: 1表示ExactlyOnce:数据只被消费一次。 2表示AtLeastOnce:数据至少被消费一次。 默认值为1。
	CheckpointMode *int32 `json:"checkpoint_mode,omitempty"`

	// 快照时间间隔, 单位为秒。默认值为10。
	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	// 当checkpoint_enabled==true时,该参数是用户授权保存快照的OBS路径。当log_enabled ==true时,该参数是用户授权保存作业日志的OBS路径。
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 是否开启作业的日志上传到用户的OBS功能。默认为false。
	LogEnabled *bool `json:"log_enabled,omitempty"`

	// 当作业异常时,向该SMN主题推送告警信息。
	SmnTopic *string `json:"smn_topic,omitempty"`

	// 是否开启作业异常自动重启。默认为false。
	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	// 空闲状态过期周期,单位为秒,默认值为3600。
	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	// 作业类型:flink_sql_job、flink_opensource_sql_job。 默认值:“flink_opensource_sql_job”。  “run_mode”为“exclusive_cluster”时,作业类型须为“flink_sql_job”或“flink_opensource_sql_job”。  “run_mode””为“shared_cluster”时作业类型必须为”flink_sql_job“。
	JobType *string `json:"job_type,omitempty"`

	// 边缘计算组ID列表。
	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	// 作业脏数据策略。 “2”:保存; “1”:抛出异常; “0”:忽略; 默认值为“0”。
	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户sql作业的udf jar通过该参数传入。
	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	// 用户为作业选择的管理单元(jobmanager)CU数量,默认值为“1”。
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 每个taskmanager的CU数,默认值为“1”。
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 每个taskmanager的slot数,默认值为“(parallel_number*tm_cus)/(cu_number-manager_cu_number)”
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

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

	// 异常重启是否从checkpoint恢复。
	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	// 异常重试最大次数,单位:次/小时。取值范围:-1或大于0。默认值为“-1”,表示无限次数。
	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	// Flink作业运行时自定义优化参数。
	RuntimeConfig *string `json:"runtime_config,omitempty"`

	// Flink版本。当前只支持1.10和1.12。
	FlinkVersion *string `json:"flink_version,omitempty"`
}

CreateFlinkSqlJobRequestBody 创建SQL作业的请求参数。

func (CreateFlinkSqlJobRequestBody) String

type CreateFlinkSqlJobResponse

type CreateFlinkSqlJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容
	Message *string `json:"message,omitempty"`

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

CreateFlinkSqlJobResponse Response Object

func (CreateFlinkSqlJobResponse) String

func (o CreateFlinkSqlJobResponse) String() string

type CreateFlinkSqlJobTemplateRequest added in v0.1.68

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

CreateFlinkSqlJobTemplateRequest Request Object

func (CreateFlinkSqlJobTemplateRequest) String added in v0.1.68

type CreateFlinkSqlJobTemplateRequestBody added in v0.1.88

type CreateFlinkSqlJobTemplateRequestBody struct {

	// 模块名称,长度限制:0-57个字符 。
	Name string `json:"name"`

	// 模板描述,长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// Stream SQL语句,至少包含source,query,sink三个部分, 长度限制:0-2048个字符。
	SqlBody *string `json:"sql_body,omitempty"`

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

	// 作业模板的类型,默认为flink_sql_job,仅支持flink_sql_job和flink_opensource_sql_job
	JobType *CreateFlinkSqlJobTemplateRequestBodyJobType `json:"job_type,omitempty"`
}

CreateFlinkSqlJobTemplateRequestBody 新建模板

func (CreateFlinkSqlJobTemplateRequestBody) String added in v0.1.88

type CreateFlinkSqlJobTemplateRequestBodyJobType added in v0.1.88

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

func (CreateFlinkSqlJobTemplateRequestBodyJobType) MarshalJSON added in v0.1.88

func (*CreateFlinkSqlJobTemplateRequestBodyJobType) UnmarshalJSON added in v0.1.88

func (CreateFlinkSqlJobTemplateRequestBodyJobType) Value added in v0.1.88

type CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum added in v0.1.88

type CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum struct {
	FLINK_SQL_JOB            CreateFlinkSqlJobTemplateRequestBodyJobType
	FLINK_OPENSOURCE_SQL_JOB CreateFlinkSqlJobTemplateRequestBodyJobType
}

func GetCreateFlinkSqlJobTemplateRequestBodyJobTypeEnum added in v0.1.88

func GetCreateFlinkSqlJobTemplateRequestBodyJobTypeEnum() CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum

type CreateFlinkSqlJobTemplateResponse added in v0.1.68

type CreateFlinkSqlJobTemplateResponse struct {

	// 请求是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 消息内容
	Message *string `json:"message,omitempty"`

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

CreateFlinkSqlJobTemplateResponse Response Object

func (CreateFlinkSqlJobTemplateResponse) String added in v0.1.68

type CreateGlobalVariableRequest added in v0.1.68

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

CreateGlobalVariableRequest Request Object

func (CreateGlobalVariableRequest) String added in v0.1.68

type CreateGlobalVariableRequestBody added in v0.1.88

type CreateGlobalVariableRequestBody struct {

	// 变量名称
	VarName string `json:"var_name"`

	// 变量的值
	VarValue string `json:"var_value"`

	// 是否为敏感变量
	IsSensitive *bool `json:"is_sensitive,omitempty"`
}

CreateGlobalVariableRequestBody 创建全局变量

func (CreateGlobalVariableRequestBody) String added in v0.1.88

type CreateGlobalVariableResponse added in v0.1.68

type CreateGlobalVariableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateGlobalVariableResponse Response Object

func (CreateGlobalVariableResponse) String added in v0.1.68

type CreateIefMessageChannelRequest

type CreateIefMessageChannelRequest struct {
	Body *CreateIefMessageChannelRequestBody `json:"body,omitempty"`
}

CreateIefMessageChannelRequest Request Object

func (CreateIefMessageChannelRequest) String

type CreateIefMessageChannelRequestBody added in v0.1.88

type CreateIefMessageChannelRequestBody struct {

	// 创建IEF消息通道指定的边缘节点ID,uuid格式
	NodeId string `json:"node_id"`
}

CreateIefMessageChannelRequestBody 创建IEF消息通道请求body体。

func (CreateIefMessageChannelRequestBody) String added in v0.1.88

type CreateIefMessageChannelResponse

type CreateIefMessageChannelResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateIefMessageChannelResponse Response Object

func (CreateIefMessageChannelResponse) String

type CreateIefSystemEventsRequest

type CreateIefSystemEventsRequest struct {
	Body *CreateIefSystemEventsRequestBody `json:"body,omitempty"`
}

CreateIefSystemEventsRequest Request Object

func (CreateIefSystemEventsRequest) String

type CreateIefSystemEventsRequestBody added in v0.1.88

type CreateIefSystemEventsRequestBody struct {
	Data *IefEvent `json:"data"`
}

CreateIefSystemEventsRequestBody IEF系统事件的请求body体。

func (CreateIefSystemEventsRequestBody) String added in v0.1.88

type CreateIefSystemEventsResponse

type CreateIefSystemEventsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateIefSystemEventsResponse Response Object

func (CreateIefSystemEventsResponse) String

type CreateJobAuthInfoRequest added in v0.1.71

type CreateJobAuthInfoRequest struct {
	Body *CreateJobAuthInfoRequestBody `json:"body,omitempty"`
}

CreateJobAuthInfoRequest Request Object

func (CreateJobAuthInfoRequest) String added in v0.1.71

func (o CreateJobAuthInfoRequest) String() string

type CreateJobAuthInfoRequestBody added in v0.1.71

type CreateJobAuthInfoRequestBody struct {

	// 证书名
	AuthInfoName string `json:"auth_info_name"`

	// 用户安全集群的新登录用户名
	UserName *string `json:"user_name,omitempty"`

	// 用户安全集群的新登录密码
	Password *string `json:"password,omitempty"`

	// krb5配置文件obs路径
	Krb5Conf *string `json:"krb5_conf,omitempty"`

	// keytab配置文件obs路径
	Keytab *string `json:"keytab,omitempty"`

	// truststore配置文件obs路径
	TruststoreLocation *string `json:"truststore_location,omitempty"`

	// truststore配置文件密码
	TruststorePassword *string `json:"truststore_password,omitempty"`

	// keystore配置文件obs路径
	KeystoreLocation *string `json:"keystore_location,omitempty"`

	// keystore配置文件密码
	KeystorePassword *string `json:"keystore_password,omitempty"`

	// 用户安全集群的证书路径,目前只支持OBS路径,cer类型文件
	CertificateLocation *string `json:"certificate_location,omitempty"`

	// 数据源类型,目前支持CSS,KRB,passwd,Kafka_SSL
	DatasourceType string `json:"datasource_type"`

	// key密码
	KeyPassword *string `json:"key_password,omitempty"`
}

func (CreateJobAuthInfoRequestBody) String added in v0.1.71

type CreateJobAuthInfoResponse added in v0.1.71

type CreateJobAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateJobAuthInfoResponse Response Object

func (CreateJobAuthInfoResponse) String added in v0.1.71

func (o CreateJobAuthInfoResponse) String() string

type CreateQueuePlanRequest

type CreateQueuePlanRequest struct {

	// 需要设置定时扩缩计划的队列名称,名称只能包含数字、英文字母和下划线,但不能是纯数字,且不能以下划线开头。
	QueueName string `json:"queue_name"`

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

CreateQueuePlanRequest Request Object

func (CreateQueuePlanRequest) String

func (o CreateQueuePlanRequest) String() string

type CreateQueuePlanResponse

type CreateQueuePlanResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateQueuePlanResponse Response Object

func (CreateQueuePlanResponse) String

func (o CreateQueuePlanResponse) String() string

type CreateQueuePropertyRequest added in v0.1.65

type CreateQueuePropertyRequest struct {

	// 队列名称
	QueueName string `json:"queue_name"`

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

CreateQueuePropertyRequest Request Object

func (CreateQueuePropertyRequest) String added in v0.1.65

type CreateQueuePropertyRequestBody added in v0.1.88

type CreateQueuePropertyRequestBody struct {
	Properties *CommonQueueProperty `json:"properties,omitempty"`
}

CreateQueuePropertyRequestBody 新加队列属性值时对应的属性信息

func (CreateQueuePropertyRequestBody) String added in v0.1.88

type CreateQueuePropertyResponse added in v0.1.65

type CreateQueuePropertyResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateQueuePropertyResponse Response Object

func (CreateQueuePropertyResponse) String added in v0.1.65

type CreateQueueRequest

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

CreateQueueRequest Request Object

func (CreateQueueRequest) String

func (o CreateQueueRequest) String() string

type CreateQueueRequestBody added in v0.1.88

type CreateQueueRequestBody struct {

	// 新建的队列名称,名称只能包含数字、英文字母和下划线,但不能是纯数字,且不能以下划线开头。长度限制:1~128个字符。\\n说明: \\n队列名称不区分大小写,系统会自动转换为小写。
	QueueName string `json:"queue_name"`

	// 队列的类型,。有如下两种类型: sql general 如果不指定,默认为sql。
	QueueType *string `json:"queue_type,omitempty"`

	// 队列的描述信息。
	Description *string `json:"description,omitempty"`

	// 队列的实际CU。
	CuCount int32 `json:"cu_count"`

	// 队列的收费模式。只能设置为“1”,表示按照CU时收费。
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 企业项目ID,“0”表示default,即默认的企业项目。 说明: 开通了企业管理服务的用户可设置该参数绑定指定的项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 队列计算资源的cpu架构。
	Platform *string `json:"platform,omitempty"`

	// 队列资源模式。支持以下两种类型:0:共享资源模式1:专属资源模式
	ResourceMode *int32 `json:"resource_mode,omitempty"`

	// 创建队列的标签信息,目前包括队列是否跨AZ的标签信息(Json字符串),且只支持值为“2”,即创建一个计算资源分布在2个可用区的双AZ队列
	Labels *[]interface{} `json:"labels,omitempty"`

	// 队列特性。支持以下两种类型:basic:基础型ai:AI增强型(仅SQL的x86_64专属队列支持选择)默认值为“basic”。
	Feature *string `json:"feature,omitempty"`

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

	// 新建的弹性资源池名称,名称只能包含数字、小写英文字母和下划线,但不能是纯数字,且不能以下划线开头。长度限制:1~128个字符。
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`
}

CreateQueueRequestBody 创建队列的请求参数。

func (CreateQueueRequestBody) String added in v0.1.88

func (o CreateQueueRequestBody) String() string

type CreateQueueResponse

type CreateQueueResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 新增队列的名称。
	QueueName      *string `json:"queue_name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateQueueResponse Response Object

func (CreateQueueResponse) String

func (o CreateQueueResponse) String() string

type CreateRouteToEnhancedConnectionRequest added in v0.1.72

type CreateRouteToEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

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

CreateRouteToEnhancedConnectionRequest Request Object

func (CreateRouteToEnhancedConnectionRequest) String added in v0.1.72

type CreateRouteToEnhancedConnectionRequestBody added in v0.1.72

type CreateRouteToEnhancedConnectionRequestBody struct {

	// 路由名称,长度限制:1-64个字符。
	Name string `json:"name"`

	// 路由网段范围。
	Cidr string `json:"cidr"`
}

func (CreateRouteToEnhancedConnectionRequestBody) String added in v0.1.72

type CreateRouteToEnhancedConnectionResponse added in v0.1.72

type CreateRouteToEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateRouteToEnhancedConnectionResponse Response Object

func (CreateRouteToEnhancedConnectionResponse) String added in v0.1.72

type CreateSparkJobRequest added in v0.1.68

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

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

CreateSparkJobRequest Request Object

func (CreateSparkJobRequest) String added in v0.1.68

func (o CreateSparkJobRequest) String() string

type CreateSparkJobRequestBody added in v0.1.88

type CreateSparkJobRequestBody struct {

	// 用户已上传到DLI资源管理系统的类型为jar的资源包名。
	File string `json:"file"`

	// 批处理作业的Java/Spark主类。
	ClassName string `json:"className"`

	// 用于指定队列,填写已创建DLI的队列名。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 传入主类的参数。
	Args *[]string `json:"args,omitempty"`

	// 计算资源类型,目前可接受参数A, B, C。如果不指定,则按最小类型创建。 资源类型: A:物理资源:8核32G内存,driverCores:2;executorCores:1;driverMemory:7G;executorMemory:4G;numExecutor:6。 B:16核64G内存,2,2,7G,8G,7。 C:32核128G内存,4,2,15G,8G,14。
	ScType *string `json:"sc_type,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为jar的资源包名。
	Jars *[]string `json:"jars,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为pyFile的资源包名。
	PyFiles *[]string `json:"pyFiles,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为file的资源包名。
	Files *[]string `json:"files,omitempty"`

	// 依赖的系统资源模块名,具体模块名可通过查询所有资源包接口查看。 DLI系统提供了用于执行跨源作业的依赖模块,各个不同的服务对应的模块列表如下: CloudTable/MRS HBase: sys.datasource.hbase CloudTable/MRS OpenTSDB: sys.datasource.opentsdb RDS MySQL: sys.datasource.rds RDS PostGre: 不需要选 DWS: 不需要选 CSS: sys.datasource.css
	Modules *[]string `json:"modules,omitempty"`

	// JSON对象列表,填写用户已上传到队列的类型为JSON的资源包名和类型。
	Resources *[]JobResource `json:"resources,omitempty"`

	// JSON对象列表,填写用户组类型资源,格式详见请求示例。resources中的name未进行type校验,只要此分组中存在这个名字的包即可。
	Groups *[]JobResourcesGroup `json:"groups,omitempty"`

	// batch配置项。
	Conf map[string]interface{} `json:"conf,omitempty"`

	// 创建时用户指定的批处理名称,不能超过128个字符。
	Name *string `json:"name,omitempty"`

	// Spark应用的Driver内存, 参数配置例如2G, 2048M。该配置项会替换“sc_type”中对应的默认参数,使用时必需带单位,否则会启动失败。
	DriverMemory *string `json:"driverMemory,omitempty"`

	// Spark应用Driver的CPU核数。该配置项会替换sc_type中对应的默认参数。
	DriverCores *int32 `json:"driverCores,omitempty"`

	// Spark应用的Executor内存, 参数配置例如2G, 2048M。该配置项会替换“sc_type”中对应的默认参数,使用时必需带单位,否则会启动失败。
	ExecutorMemory *string `json:"executorMemory,omitempty"`

	// Spark应用每个Executor的CPU核数。该配置项会替换sc_type中对应的默认参数。
	ExecutorCores *int32 `json:"executorCores,omitempty"`

	// Spark应用Executor的个数。该配置项会替换sc_type中对应的默认参数。
	NumExecutors *int32 `json:"numExecutors,omitempty"`

	// 作业特性,作业运行在vm队列上支持basic,在container队列上支持basic、ai、custom,其中填写custom时需要同时填写image参数。
	Feature *CreateSparkJobRequestBodyFeature `json:"feature,omitempty"`

	// 作业使用spark组件的版本号,在feature为“basic”或“ai”时填写,若不填写,则使用默认的spark组件版本号2.3.2。
	SparkVersion *string `json:"spark_version,omitempty"`

	// 用于指定队列,填写已创建DLI的队列名
	Queue *string `json:"queue,omitempty"`

	// 是否开启重试功能,如果开启,可在Spark作业异常失败后自动重试。默认值为“false”。
	AutoRecovery *bool `json:"auto_recovery,omitempty"`

	// 最大重试次数。最大值为“100”,默认值为“20”。
	MaxRetryTimes *int32 `json:"max_retry_times,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Spark镜像。关于如何使用自定义镜像,请参考《数据湖探索用户指南》。
	Image *string `json:"image,omitempty"`

	// 保存Spark作业的obs桶,需要保存作业时配置该参数
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 访问元数据时,需要将该参数配置为dli。
	CatalogName *string `json:"catalog_name,omitempty"`
}

CreateSparkJobRequestBody 创建批处理作业请求body体。

func (CreateSparkJobRequestBody) String added in v0.1.88

func (o CreateSparkJobRequestBody) String() string

type CreateSparkJobRequestBodyFeature added in v0.1.88

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

func (CreateSparkJobRequestBodyFeature) MarshalJSON added in v0.1.88

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

func (*CreateSparkJobRequestBodyFeature) UnmarshalJSON added in v0.1.88

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

func (CreateSparkJobRequestBodyFeature) Value added in v0.1.88

type CreateSparkJobRequestBodyFeatureEnum added in v0.1.88

type CreateSparkJobRequestBodyFeatureEnum struct {
	BASIC  CreateSparkJobRequestBodyFeature
	AI     CreateSparkJobRequestBodyFeature
	CUSTOM CreateSparkJobRequestBodyFeature
}

func GetCreateSparkJobRequestBodyFeatureEnum added in v0.1.88

func GetCreateSparkJobRequestBodyFeatureEnum() CreateSparkJobRequestBodyFeatureEnum

type CreateSparkJobResponse added in v0.1.68

type CreateSparkJobResponse struct {

	// Batch作业的id。
	Id *string `json:"id,omitempty"`

	// Batch作业的状态。包括: starting:正在启动;running:正在执行任务;dead:session已退出;success:session停止成功;recovering:正在恢复。
	State *string `json:"state,omitempty"`

	// 批处理作业的后台app id。
	AppId *string `json:"appId,omitempty"`

	// 显示当前Batch作业的最后10条记录。
	Log *[]string `json:"log,omitempty"`

	// 计算资源类型。用户自定义时返回CUSTOMIZED。
	ScType *string `json:"sc_type,omitempty"`

	// 会话所在队列。
	ClusterName *string `json:"cluster_name,omitempty"`

	// Batch的创建时间。是单位为“毫秒”的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 创建时用户指定的批处理名称,不能超过128个字符。
	Name *string `json:"name,omitempty"`

	// 批处理作业所属用户
	Owner *string `json:"owner,omitempty"`

	// 批处理作业所属代理用户(资源租户)。
	ProxyUser *string `json:"proxyUser,omitempty"`

	// 批处理作业类型,只支持spark类型参数。
	Kind *string `json:"kind,omitempty"`

	// 用于指定队列,填写已创建DLI的队列名
	Queue *string `json:"queue,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。
	Image *string `json:"image,omitempty"`

	// 更新时间
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 作业运行时长,单位毫秒。
	Duration       *int64 `json:"duration,omitempty"`
	HttpStatusCode int    `json:"-"`
}

CreateSparkJobResponse Response Object

func (CreateSparkJobResponse) String added in v0.1.68

func (o CreateSparkJobResponse) String() string

type CreateSparkJobTemplateRequest added in v0.1.68

type CreateSparkJobTemplateRequest struct {
	Body *CreateSparkJobTemplateRequestBody `json:"body,omitempty"`
}

CreateSparkJobTemplateRequest Request Object

func (CreateSparkJobTemplateRequest) String added in v0.1.68

type CreateSparkJobTemplateRequestBody added in v0.1.88

type CreateSparkJobTemplateRequestBody struct {

	// 类型。SQL:sql模板。SPARK:spark模板。
	Type string `json:"type"`

	// 名字
	Name string `json:"name"`

	// 模板内容
	Body string `json:"body"`

	// 分组
	Group *string `json:"group,omitempty"`

	// 描述信息
	Description *string `json:"description,omitempty"`

	// 语言
	Language *string `json:"language,omitempty"`
}

func (CreateSparkJobTemplateRequestBody) String added in v0.1.88

type CreateSparkJobTemplateResponse added in v0.1.68

type CreateSparkJobTemplateResponse struct {

	// 模板ID。
	Id             *string `json:"id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateSparkJobTemplateResponse Response Object

func (CreateSparkJobTemplateResponse) String added in v0.1.68

type CreateSqlJobRequest

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

CreateSqlJobRequest Request Object

func (CreateSqlJobRequest) String

func (o CreateSqlJobRequest) String() string

type CreateSqlJobRequestBody

type CreateSqlJobRequestBody struct {

	// 待执行的SQL语句。
	Sql string `json:"sql"`

	// 待提交作业的队列引擎名称,名称只能包含英文字母。
	EngineType *CreateSqlJobRequestBodyEngineType `json:"engine_type,omitempty"`

	// 待提交作业的表默认catalog。
	CurrentCatalog *string `json:"current_catalog,omitempty"`

	// SQL语句执行所在的数据库。当创建新数据库时,不需要提供此参数。
	Currentdb *string `json:"currentdb,omitempty"`

	// 待提交作业的队列名称,名称只能包含数字、英文字母和下划线,但不能是纯数字,且不能以下划线开头。
	QueueName *string `json:"queue_name,omitempty"`

	// 用户以“key/value”的形式设置用于此作业的配置参数。目前支持的配置项请参考表3。
	Conf *[]string `json:"conf,omitempty"`

	// 作业标签
	Tags *[]Tag `json:"tags,omitempty"`
}

CreateSqlJobRequestBody 提交SQL作业

func (CreateSqlJobRequestBody) String

func (o CreateSqlJobRequestBody) String() string

type CreateSqlJobRequestBodyEngineType added in v0.1.90

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

func (CreateSqlJobRequestBodyEngineType) MarshalJSON added in v0.1.90

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

func (*CreateSqlJobRequestBodyEngineType) UnmarshalJSON added in v0.1.90

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

func (CreateSqlJobRequestBodyEngineType) Value added in v0.1.90

type CreateSqlJobRequestBodyEngineTypeEnum added in v0.1.90

type CreateSqlJobRequestBodyEngineTypeEnum struct {
	HETU_ENGINE CreateSqlJobRequestBodyEngineType
	SPARK       CreateSqlJobRequestBodyEngineType
}

func GetCreateSqlJobRequestBodyEngineTypeEnum added in v0.1.90

func GetCreateSqlJobRequestBodyEngineTypeEnum() CreateSqlJobRequestBodyEngineTypeEnum

type CreateSqlJobResponse

type CreateSqlJobResponse struct {

	// 当“job_type”为“DCL”时,为请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 此SQL语句将生成并提交一个新作业,返回此作业的ID,可用于获取作业状态和作业结果。
	JobId *string `json:"job_id,omitempty"`

	// 作业类型。  DDL DCL IMPORT EXPORT QUERY INSERT
	JobType *CreateSqlJobResponseJobType `json:"job_type,omitempty"`

	// 当语句类型为DDL时,返回其结果的列名称及类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 当语句类型为DDL时,直接返回其执行结果。
	Rows *[][]interface{} `json:"rows,omitempty"`

	// 表示作业执行方式,是同步还是异步的
	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateSqlJobResponse Response Object

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

type CreateSqlJobTemplateRequest added in v0.1.68

type CreateSqlJobTemplateRequest struct {
	Body *CreateSqlJobTemplateRequestBody `json:"body,omitempty"`
}

CreateSqlJobTemplateRequest Request Object

func (CreateSqlJobTemplateRequest) String added in v0.1.68

type CreateSqlJobTemplateRequestBody added in v0.1.88

type CreateSqlJobTemplateRequestBody struct {

	// 新增的SQL模板。
	Sql string `json:"sql"`

	// 新增SQL模板名称,该名称在当前工程下必须唯一。
	SqlName string `json:"sql_name"`

	// 新增SQL模板的描述信息,可以为空字符串。
	Description *string `json:"description,omitempty"`

	// 分组名称。
	Group *string `json:"group,omitempty"`
}

func (CreateSqlJobTemplateRequestBody) String added in v0.1.88

type CreateSqlJobTemplateResponse added in v0.1.68

type CreateSqlJobTemplateResponse struct {

	// 是否成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。执行失败时,用于显示执行失败的原因。
	Message *string `json:"message,omitempty"`

	// 新增SQL模板的ID。
	SqlId *string `json:"sql_id,omitempty"`

	// SQL模板分组名称。
	Group          *string `json:"group,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateSqlJobTemplateResponse Response Object

func (CreateSqlJobTemplateResponse) String added in v0.1.68

type CreateTableRequest

type CreateTableRequest struct {

	// 新增表所在的数据库名称。
	DatabaseName string `json:"database_name"`

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

CreateTableRequest Request Object

func (CreateTableRequest) String

func (o CreateTableRequest) String() string

type CreateTableRequestBody added in v0.1.88

type CreateTableRequestBody struct {

	// 新增表名称。
	TableName string `json:"table_name"`

	// 数据存储的地方,分VIEW视图,OBS表和DLI表。
	DataLocation string `json:"data_location"`

	// 新增表的描述信息。
	Description *string `json:"description,omitempty"`

	// OBS表和DLI表必选参数。新增表的列。
	Columns []Column `json:"columns"`

	// OBS表必选参数。新增OBS表数据的类型,目前支持:Parquet、ORC、CSV、JSON、Carbon和Avro格式。
	DataType *string `json:"data_type,omitempty"`

	// OBS表必选参数。新增OBS表数据的存储路径,必须是OBS上的路径,以s3a开头。
	DataPath *string `json:"data_path,omitempty"`

	// OBS表非必选参数。OBS表数据是否包含表头。只有CSV类型数据具有该属性。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// OBS表非必选参数。用户自定义数据分隔符。只有CSV类型数据具有该属性。
	Delimiter *string `json:"delimiter,omitempty"`

	// OBS表非必选参数。用户自定义引用字符,默认为双引号(即“\\\"”)。只有CSV类型数据具有该属性。
	QuoteChar *string `json:"quote_char,omitempty"`

	// OBS表非必选参数。用户自定义转义字符,默认为反斜杠(即\"\\\\\")。只有CSV类型数据具有该属性。
	EscapeChar *string `json:"escape_char,omitempty"`

	// OBS表非必选参数。用户自定义日期类型,默认格式为“yyyy-MM-dd”。只有CSV和JSON类型数据具有该属性。
	DateFormat *string `json:"date_format,omitempty"`

	// OBS表非必选参数。用户自定义时间类型。默认格式为“yyyy-MM-dd HH:mm:ss”。只有CSV和JSON类型数据具有该属性。
	TimestampFormat *string `json:"timestamp_format,omitempty"`

	// VIEW视图必选参数,创建视图时的数据选择语句。语句中涉及表需要使用“表=库名.表名”的格式
	SelectStatement *string `json:"select_statement,omitempty"`

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

CreateTableRequestBody 创建表的请求body体。

func (CreateTableRequestBody) String added in v0.1.88

func (o CreateTableRequestBody) String() string

type CreateTableResponse

type CreateTableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateTableResponse Response Object

func (CreateTableResponse) String

func (o CreateTableResponse) String() string

type DataAuthorizationPrivilege added in v0.1.88

type DataAuthorizationPrivilege struct {

	// 被赋权的数据对象,命名方式为: “databases.数据库名”,则数据库下面的所有数据都将被共享。 “databases.数据库名.tables.表名”, 指定的表的数据将被共享。 “databases.数据库名.tables.表名.columns.列名”,指定的列将被共享。 \"jobs.flink.flink作业ID\",指定的作业将被共享。 \"groups.程序包组名\",指定的程序包组将被共享。 \"resources.程序包名\",指定程序包将被共享。
	Object string `json:"object"`

	// 待赋权、回收或更新的权限列表。 说明: 若“action”为“update”,更新列表为空,则表示回收用户在该数据库或表的所有权限
	Privileges []string `json:"privileges"`
}

DataAuthorizationPrivilege 数据赋权的赋权信息。

func (DataAuthorizationPrivilege) String added in v0.1.88

type Database

type Database struct {

	// 数据库名称。
	DatabaseName *string `json:"database_name,omitempty"`

	// 数据库的创建者。
	Owner *string `json:"owner,omitempty"`

	// 数据库中表的个数。
	TableNumber *int32 `json:"table_number,omitempty"`

	// 数据库相关的描述信息。
	Description *string `json:"description,omitempty"`

	// 企业项目ID,“0”表示default,即默认的企业项目。关于如何设置企业项目请参考《企业管理用户指南》。 说明: 开通了企业管理服务的用户可设置该参数绑定指定的项目。
	EnterpriseProjectId string `json:"enterprise_project_id"`

	// 资源ID。
	ResourceId string `json:"resource_id"`
}

Database 查询所有数据库的响应参数。

func (Database) String

func (o Database) String() string

type DatabaseUserPrivilege added in v0.1.88

type DatabaseUserPrivilege struct {

	// 判断用户是否为管理员。
	IsAdmin *bool `json:"is_admin,omitempty"`

	// 用户名称,即该用户在当前数据库上有权限。
	UserName *string `json:"user_name,omitempty"`

	// 该用户在数据库上的权限。
	Privileges *[]string `json:"privileges,omitempty"`
}

DatabaseUserPrivilege 查看数据库的使用者的权限信息。

func (DatabaseUserPrivilege) String added in v0.1.88

func (o DatabaseUserPrivilege) String() string

type DatasourceConnection added in v0.1.88

type DatasourceConnection struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息为空。
	Message *string `json:"message,omitempty"`

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId *string `json:"connection_id,omitempty"`

	// 创建连接时,用户填写的队列的访问地址。
	Destination *string `json:"destination,omitempty"`

	// 连接状态。CREATING:跨源连接正在创建中;ACTIVE:跨源连接创建成功,与目的地址连接正常;FAILED:跨源连接创建失败;DELETED:跨源连接已被删除。
	State *string `json:"state,omitempty"`

	// 正在创建的跨源连接进度,显示0.0至1.0代表0%至100%。
	Process *float64 `json:"process,omitempty"`

	// 创建连接时,用户自定义的连接名称。
	Name *string `json:"name,omitempty"`

	// 用于建立跨源关联表时,需要使用到的连接url。
	ConnectionUrl *string `json:"connection_url,omitempty"`

	// Serverless Spark队列名称。SQL队列模式下建立的跨源连接,该字段为空。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 创建连接时,用户指定的对端服务(CloudTable/CloudTable.OpenTSDB/MRS.OpenTSDB/DWS/RDS/CSS)。
	Service *string `json:"service,omitempty"`

	// 创建连接的时间。为UTC的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 当前跨源已绑定的队列名
	QueueList *[]string `json:"queue_list,omitempty"`
}

DatasourceConnection 查询经典型跨源连接的响应参数。

func (DatasourceConnection) String added in v0.1.88

func (o DatasourceConnection) String() string

type DeleteAuthInfoRequest

type DeleteAuthInfoRequest struct {

	// 即将删除的认证信息名
	AuthInfoName string `json:"auth_info_name"`
}

DeleteAuthInfoRequest Request Object

func (DeleteAuthInfoRequest) String

func (o DeleteAuthInfoRequest) String() string

type DeleteAuthInfoResponse

type DeleteAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteAuthInfoResponse Response Object

func (DeleteAuthInfoResponse) String

func (o DeleteAuthInfoResponse) String() string

type DeleteDatabaseRequest

type DeleteDatabaseRequest struct {

	// 删除的数据库名称。
	DatabaseName string `json:"database_name"`

	Async *bool `json:"async,omitempty"`

	Cascade *bool `json:"cascade,omitempty"`
}

DeleteDatabaseRequest Request Object

func (DeleteDatabaseRequest) String

func (o DeleteDatabaseRequest) String() string

type DeleteDatabaseResponse

type DeleteDatabaseResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息为空。
	Message *string `json:"message,omitempty"`

	// 异步删除数据库的时候返回的删除作业ID
	JobId *string `json:"job_id,omitempty"`

	// 删除数据库的时候的方式,是同步删除还是异步删除
	JobMode *string `json:"job_mode,omitempty"`

	// 异步执行作业时返回执行删除作业类型
	JobType        *string `json:"job_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteDatabaseResponse Response Object

func (DeleteDatabaseResponse) String

func (o DeleteDatabaseResponse) String() string

type DeleteDatasourceConnectionRequest

type DeleteDatasourceConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`
}

DeleteDatasourceConnectionRequest Request Object

func (DeleteDatasourceConnectionRequest) String

type DeleteDatasourceConnectionResponse

type DeleteDatasourceConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteDatasourceConnectionResponse Response Object

func (DeleteDatasourceConnectionResponse) String

type DeleteElasticResourcePoolRequest

type DeleteElasticResourcePoolRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`
}

DeleteElasticResourcePoolRequest Request Object

func (DeleteElasticResourcePoolRequest) String

type DeleteElasticResourcePoolResponse

type DeleteElasticResourcePoolResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteElasticResourcePoolResponse Response Object

func (DeleteElasticResourcePoolResponse) String

type DeleteEnhancedConnectionRequest

type DeleteEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`
}

DeleteEnhancedConnectionRequest Request Object

func (DeleteEnhancedConnectionRequest) String

type DeleteEnhancedConnectionResponse

type DeleteEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteEnhancedConnectionResponse Response Object

func (DeleteEnhancedConnectionResponse) String

type DeleteEnhancedConnectionRoutesRequest

type DeleteEnhancedConnectionRoutesRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

	Name string `json:"name"`
}

DeleteEnhancedConnectionRoutesRequest Request Object

func (DeleteEnhancedConnectionRoutesRequest) String

type DeleteEnhancedConnectionRoutesResponse

type DeleteEnhancedConnectionRoutesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteEnhancedConnectionRoutesResponse Response Object

func (DeleteEnhancedConnectionRoutesResponse) String

type DeleteFlinkJobRequest

type DeleteFlinkJobRequest struct {

	// 作业ID。
	JobId int64 `json:"job_id"`
}

DeleteFlinkJobRequest Request Object

func (DeleteFlinkJobRequest) String

func (o DeleteFlinkJobRequest) String() string

type DeleteFlinkJobResponse

type DeleteFlinkJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteFlinkJobResponse Response Object

func (DeleteFlinkJobResponse) String

func (o DeleteFlinkJobResponse) String() string

type DeleteFlinkSqlJobTemplateRequest added in v0.1.68

type DeleteFlinkSqlJobTemplateRequest struct {

	// 模板ID。
	TemplateId int64 `json:"template_id"`
}

DeleteFlinkSqlJobTemplateRequest Request Object

func (DeleteFlinkSqlJobTemplateRequest) String added in v0.1.68

type DeleteFlinkSqlJobTemplateResponse added in v0.1.68

type DeleteFlinkSqlJobTemplateResponse struct {

	// 响应正确与否的标志,true表示成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

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

DeleteFlinkSqlJobTemplateResponse Response Object

func (DeleteFlinkSqlJobTemplateResponse) String added in v0.1.68

type DeleteGlobalVariableRequest added in v0.1.68

type DeleteGlobalVariableRequest struct {

	// 全局变量名,名称只能包含数字、英文字母和下划线,但不能是纯数字,不能以下划线开头,且不能超过128字符
	VarName string `json:"var_name"`
}

DeleteGlobalVariableRequest Request Object

func (DeleteGlobalVariableRequest) String added in v0.1.68

type DeleteGlobalVariableResponse added in v0.1.68

type DeleteGlobalVariableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteGlobalVariableResponse Response Object

func (DeleteGlobalVariableResponse) String added in v0.1.68

type DeleteJobAuthInfoRequest added in v0.1.71

type DeleteJobAuthInfoRequest struct {

	// 即将删除的认证信息名
	AuthInfoName string `json:"auth_info_name"`
}

DeleteJobAuthInfoRequest Request Object

func (DeleteJobAuthInfoRequest) String added in v0.1.71

func (o DeleteJobAuthInfoRequest) String() string

type DeleteJobAuthInfoResponse added in v0.1.71

type DeleteJobAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteJobAuthInfoResponse Response Object

func (DeleteJobAuthInfoResponse) String added in v0.1.71

func (o DeleteJobAuthInfoResponse) String() string

type DeleteJobResourceRequest added in v0.1.88

type DeleteJobResourceRequest struct {

	// 资源名。
	ResourceName string `json:"resource_name"`

	// 资源所在分组
	Group *string `json:"group,omitempty"`
}

DeleteJobResourceRequest Request Object

func (DeleteJobResourceRequest) String added in v0.1.88

func (o DeleteJobResourceRequest) String() string

type DeleteJobResourceResponse added in v0.1.88

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

DeleteJobResourceResponse Response Object

func (DeleteJobResourceResponse) String added in v0.1.88

func (o DeleteJobResourceResponse) String() string

type DeleteQueuePlanRequest

type DeleteQueuePlanRequest struct {

	// 待删除的队列扩缩容计划的ID
	PlanId int64 `json:"plan_id"`

	// 待删除定时扩缩计划的队列名称
	QueueName string `json:"queue_name"`
}

DeleteQueuePlanRequest Request Object

func (DeleteQueuePlanRequest) String

func (o DeleteQueuePlanRequest) String() string

type DeleteQueuePlanResponse

type DeleteQueuePlanResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteQueuePlanResponse Response Object

func (DeleteQueuePlanResponse) String

func (o DeleteQueuePlanResponse) String() string

type DeleteQueuePropertyRequest added in v0.1.65

type DeleteQueuePropertyRequest struct {

	// 队列名称
	QueueName string `json:"queue_name"`

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

DeleteQueuePropertyRequest Request Object

func (DeleteQueuePropertyRequest) String added in v0.1.65

type DeleteQueuePropertyRequestBody added in v0.1.90

type DeleteQueuePropertyRequestBody struct {

	// 待删除队列属性key值。 范围如下: computeEngine.maxInstance computeEngine.maxPrefetchInstance job.maxConcurrent
	Keys []string `json:"keys"`
}

DeleteQueuePropertyRequestBody 待删除属性

func (DeleteQueuePropertyRequestBody) String added in v0.1.90

type DeleteQueuePropertyResponse added in v0.1.65

type DeleteQueuePropertyResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteQueuePropertyResponse Response Object

func (DeleteQueuePropertyResponse) String added in v0.1.65

type DeleteQueueRequest

type DeleteQueueRequest struct {

	// 指定删除的队列名称。
	QueueName string `json:"queue_name"`
}

DeleteQueueRequest Request Object

func (DeleteQueueRequest) String

func (o DeleteQueueRequest) String() string

type DeleteQueueResponse

type DeleteQueueResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteQueueResponse Response Object

func (DeleteQueueResponse) String

func (o DeleteQueueResponse) String() string

type DeleteRouteFromEnhancedConnectionRequest added in v0.1.72

type DeleteRouteFromEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

	Name string `json:"name"`
}

DeleteRouteFromEnhancedConnectionRequest Request Object

func (DeleteRouteFromEnhancedConnectionRequest) String added in v0.1.72

type DeleteRouteFromEnhancedConnectionResponse added in v0.1.72

type DeleteRouteFromEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteRouteFromEnhancedConnectionResponse Response Object

func (DeleteRouteFromEnhancedConnectionResponse) String added in v0.1.72

type DeleteTableRequest

type DeleteTableRequest struct {

	// 待删除的表所在的数据库名称。
	DatabaseName string `json:"database_name"`

	// 待删除的表名称。
	TableName string `json:"table_name"`

	// 是否异步执行
	Async *bool `json:"async,omitempty"`
}

DeleteTableRequest Request Object

func (DeleteTableRequest) String

func (o DeleteTableRequest) String() string

type DeleteTableResponse

type DeleteTableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 删除表作业的时候类型,是同步删除还是异步删除
	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteTableResponse Response Object

func (DeleteTableResponse) String

func (o DeleteTableResponse) String() string

type DisassociateQueueFromEnhancedConnectionRequest added in v0.1.68

type DisassociateQueueFromEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

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

DisassociateQueueFromEnhancedConnectionRequest Request Object

func (DisassociateQueueFromEnhancedConnectionRequest) String added in v0.1.68

type DisassociateQueueFromEnhancedConnectionRequestBody added in v0.1.88

type DisassociateQueueFromEnhancedConnectionRequestBody struct {

	// 需要使用跨源的队列名列表。
	Queues *[]string `json:"queues,omitempty"`

	// 需要使用跨源的弹性资源池名列表。
	ElasticResourcePools *[]string `json:"elastic_resource_pools,omitempty"`
}

func (DisassociateQueueFromEnhancedConnectionRequestBody) String added in v0.1.88

type DisassociateQueueFromEnhancedConnectionResponse added in v0.1.68

type DisassociateQueueFromEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DisassociateQueueFromEnhancedConnectionResponse Response Object

func (DisassociateQueueFromEnhancedConnectionResponse) String added in v0.1.68

type ElasticResourcePool added in v0.1.88

type ElasticResourcePool struct {

	// 资源池名称
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`

	// 资源池id
	Id *int32 `json:"id,omitempty"`

	// 更新时间
	UpdateTime *int64 `json:"update_time,omitempty"`

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

	// 用户名
	Owner *string `json:"owner,omitempty"`

	// 资源池描述
	Description *string `json:"description,omitempty"`

	// 最大cu数量
	MaxCu *int32 `json:"max_cu,omitempty"`

	// 最小cu数量
	MinCu *int32 `json:"min_cu,omitempty"`

	// 实际cu数量
	ActualCu *int32 `json:"actual_cu,omitempty"`

	// 子网
	CidrInVpc *string `json:"cidr_in_vpc,omitempty"`

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

	// 当前cu数量
	CurrentCu *int32 `json:"current_cu,omitempty"`

	// 状态
	Status *string `json:"status,omitempty"`

	// 资源ID
	ResourceId *string `json:"resource_id,omitempty"`

	// 创建失败原因
	FailReason *string `json:"fail_reason,omitempty"`

	// 企业项目ID
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 预付费cu数量
	PrepayCu *int32 `json:"prepay_cu,omitempty"`

	// 计费类型
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 弹性资源池类型
	Manager *string `json:"manager,omitempty"`

	// 弹性资源池属性字段。默认为标准版弹性资源池;{\"spec\":\"basic\"}标识基础版弹性资源池;{\"billing_spec_code\":\"developer\"}标识开发者弹性资源池。目前不支持其它属性设置。
	Label map[string]string `json:"label,omitempty"`
}

ElasticResourcePool 弹性资源池列表

func (ElasticResourcePool) String added in v0.1.88

func (o ElasticResourcePool) String() string

type ElasticResourcePoolQueue added in v0.1.88

type ElasticResourcePoolQueue struct {

	// 队列名称
	QueueName *string `json:"queue_name,omitempty"`

	// 企业项目ID
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 队列类型
	QueueType *string `json:"queue_type,omitempty"`

	// 队列扩缩容策略
	QueueScalingPolicies *[]QueueScalingPolicy `json:"queue_scaling_policies,omitempty"`

	// 所有者
	Owner *string `json:"owner,omitempty"`

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

	// 引擎类型
	Engine *string `json:"engine,omitempty"`
}

func (ElasticResourcePoolQueue) String added in v0.1.88

func (o ElasticResourcePoolQueue) String() string

type ElasticResourcePoolScaleRecord added in v0.1.87

type ElasticResourcePoolScaleRecord struct {

	// 最大Cu
	MaxCu int32 `json:"max_cu"`

	// 最小CU
	MinCu int32 `json:"min_cu"`

	// 扩缩容后CU
	CurrentCu int32 `json:"current_cu"`

	// 扩缩容前CU
	OriginCu int32 `json:"origin_cu"`

	// 扩缩容预期CU
	TargetCu int32 `json:"target_cu"`

	// 操作完成时间
	RecordTime int64 `json:"record_time"`

	// 扩缩容成功或者失败的状态
	Status string `json:"status"`

	// 失败原因
	FailReason *string `json:"fail_reason,omitempty"`
}

ElasticResourcePoolScaleRecord 扩缩容历史记录接口返回数组中的数据

func (ElasticResourcePoolScaleRecord) String added in v0.1.87

type EnhancedConnection added in v0.1.88

type EnhancedConnection struct {

	// 连接ID,用于标识跨源连接的UUID。
	Id *string `json:"id,omitempty"`

	// 创建连接时,用户自定义的连接名称。
	Name *string `json:"name,omitempty"`

	// 连接状态,包括以下两种状态: ACTIVE:已激活 DELETED:已删除
	Status *string `json:"status,omitempty"`

	// 各个队列创建对等连接的信息。
	AvailableQueueInfo *[]EnhancedConnectionResource `json:"available_queue_info,omitempty"`

	// 各个弹性资源池创建对等连接的信息。
	ElasticResourcePools *[]EnhancedConnectionResource `json:"elastic_resource_pools,omitempty"`

	// 对应服务的虚拟私有云标识。
	DestVpcId *string `json:"dest_vpc_id,omitempty"`

	// 对应服务的子网网络标识。
	DestNetworkId *string `json:"dest_network_id,omitempty"`

	// 创建连接的时间。为UTC的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 用户自定义主机信息
	Hosts *[]EnhancedConnectionHost `json:"hosts,omitempty"`

	// 该增强跨源连接如果做过项目赋权,则该字段是\"false\",否则为\"true\"。
	IsPrivis *bool `json:"isPrivis,omitempty"`
}

EnhancedConnection 跨源连接信息列表的连接具体信息。

func (EnhancedConnection) String added in v0.1.88

func (o EnhancedConnection) String() string

type EnhancedConnectionHost added in v0.1.88

type EnhancedConnectionHost struct {

	// 自定义主机名称。长度128,数字字母下划线(\"_\")横杠(\"-\")句点(\".\")组成,字母开头。
	Name *string `json:"name,omitempty"`

	// 主机对应的IPv4地址。
	Ip *string `json:"ip,omitempty"`
}

EnhancedConnectionHost 用户自定义主机信息。

func (EnhancedConnectionHost) String added in v0.1.88

func (o EnhancedConnectionHost) String() string

type EnhancedConnectionPrivilege added in v0.1.88

type EnhancedConnectionPrivilege struct {

	// 授权时object的信息。
	Object *string `json:"object,omitempty"`

	// 授权的项目ID。
	ApplicantProjectId *string `json:"applicant_project_id,omitempty"`

	// 授权操作信息。
	Privileges *[]string `json:"privileges,omitempty"`
}

EnhancedConnectionPrivilege 增强型跨源连接各个授权项目的信息。

func (EnhancedConnectionPrivilege) String added in v0.1.88

type EnhancedConnectionResource added in v0.1.88

type EnhancedConnectionResource struct {

	// 对等连接ID。
	PeerId *string `json:"peer_id,omitempty"`

	// 连接状态。CREATING:跨源连接正在创建中;ACTIVE:跨源连接创建成功,与目的地址连接正常;FAILED:跨源连接创建失败。
	Status *string `json:"status,omitempty"`

	// 队列名称。
	Name *string `json:"name,omitempty"`

	// 状态为失败时的详细报错信息。
	ErrMsg *string `json:"err_msg,omitempty"`

	// 更新时间。
	UpdateTime *int64 `json:"update_time,omitempty"`
}

EnhancedConnectionResource 增强型跨源连接各个队列创建对等连接的信息。

func (EnhancedConnectionResource) String added in v0.1.88

type ExecuteFlinkJobSavepointRequest added in v0.1.95

type ExecuteFlinkJobSavepointRequest struct {

	// 正在运行的Flink作业的作业ID。
	JobId string `json:"job_id"`

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

ExecuteFlinkJobSavepointRequest Request Object

func (ExecuteFlinkJobSavepointRequest) String added in v0.1.95

type ExecuteFlinkJobSavepointRequestBody added in v0.1.95

type ExecuteFlinkJobSavepointRequestBody struct {

	// 操作类型
	Action ExecuteFlinkJobSavepointRequestBodyAction `json:"action"`

	// obs桶路径.例 \"bucket_name/file_name/\"
	SavepointPath string `json:"savepoint_path"`
}

ExecuteFlinkJobSavepointRequestBody 创建savepoint请求体

func (ExecuteFlinkJobSavepointRequestBody) String added in v0.1.95

type ExecuteFlinkJobSavepointRequestBodyAction added in v0.1.95

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

func (ExecuteFlinkJobSavepointRequestBodyAction) MarshalJSON added in v0.1.95

func (*ExecuteFlinkJobSavepointRequestBodyAction) UnmarshalJSON added in v0.1.95

func (ExecuteFlinkJobSavepointRequestBodyAction) Value added in v0.1.95

type ExecuteFlinkJobSavepointRequestBodyActionEnum added in v0.1.95

type ExecuteFlinkJobSavepointRequestBodyActionEnum struct {
	TRIGGER ExecuteFlinkJobSavepointRequestBodyAction
}

func GetExecuteFlinkJobSavepointRequestBodyActionEnum added in v0.1.95

func GetExecuteFlinkJobSavepointRequestBodyActionEnum() ExecuteFlinkJobSavepointRequestBodyActionEnum

type ExecuteFlinkJobSavepointResponse added in v0.1.95

type ExecuteFlinkJobSavepointResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExecuteFlinkJobSavepointResponse Response Object

func (ExecuteFlinkJobSavepointResponse) String added in v0.1.95

type ExportFlinkJobsRequest added in v0.1.68

type ExportFlinkJobsRequest struct {
	Body *ExportFlinkJobsRequestBody `json:"body,omitempty"`
}

ExportFlinkJobsRequest Request Object

func (ExportFlinkJobsRequest) String added in v0.1.68

func (o ExportFlinkJobsRequest) String() string

type ExportFlinkJobsRequestBody added in v0.1.88

type ExportFlinkJobsRequestBody struct {

	// 导出作业文件的OBS保存路径。
	ObsDir string `json:"obs_dir"`

	// 是否导出指定的作业。
	IsSelected bool `json:"is_selected"`

	// 当is_selected=true时,该参数是待导出作业的作业ID集合。当is_selected=true时,此参数必填。
	JobSelected *[]int64 `json:"job_selected,omitempty"`
}

ExportFlinkJobsRequestBody 导出作业的请求参数。

func (ExportFlinkJobsRequestBody) String added in v0.1.88

type ExportFlinkJobsResponse added in v0.1.68

type ExportFlinkJobsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容
	Message *string `json:"message,omitempty"`

	// OBS上导出作业zip文件名。
	ZipFile        *[]string `json:"zip_file,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ExportFlinkJobsResponse Response Object

func (ExportFlinkJobsResponse) String added in v0.1.68

func (o ExportFlinkJobsResponse) String() string

type ExportSqlJobResultRequest

type ExportSqlJobResultRequest struct {

	// 作业ID
	JobId string `json:"job_id"`

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

ExportSqlJobResultRequest Request Object

func (ExportSqlJobResultRequest) String

func (o ExportSqlJobResultRequest) String() string

type ExportSqlJobResultRequestBody added in v0.1.88

type ExportSqlJobResultRequestBody struct {

	// ExportResult
	DataPath string `json:"data_path"`

	// 导出数据的压缩格式,目前支持gzip,bzip2和deflate压缩方式; 默认值为none,表示不压缩。
	Compress *string `json:"compress,omitempty"`

	// 导出数据的存储格式,暂时只支持csv格式。
	DataType string `json:"data_type"`

	// 指定执行该任务的队列。若不指定队列,将采用default队列执行操作。
	QueueName *string `json:"queue_name,omitempty"`

	// 导出模式,目前支持“ErrorIfExists”,“Overwrite”,不指定“export_mode”则默认为“ErrorIfExists”。  “ErrorIfExists”:存在即报错。指定的导出目录必须不存在,如果指定目录已经存在,系统将返回错误信息,无法执行导出操作。 “Overwrite”:覆盖。在指定目录下新建文件,会删除已有文件。
	ExportMode *ExportSqlJobResultRequestBodyExportMode `json:"export_mode,omitempty"`

	// 导出csv格式数据时,是否导出列名。  设置为“true”,表示导出列名。 设置为“false”,表示不导出列名。 若为空,默认为“false”。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// 导出数据条数,默认为0表示全部
	LimitNum *int32 `json:"limit_num,omitempty"`

	// 导出数据的编码格式。支持\"utf-8\",\"gb2312\",\"gbk\"三种,如果不填写默认为\"utf-8\"。
	EncodingType *string `json:"encoding_type,omitempty"`

	// 用户自定义引用字符
	QuoteChar *string `json:"quote_char,omitempty"`

	// 用户自定义转义字符
	EscapeChar *string `json:"escape_char,omitempty"`
}

ExportSqlJobResultRequestBody 导出查询结果

func (ExportSqlJobResultRequestBody) String added in v0.1.88

type ExportSqlJobResultRequestBodyExportMode added in v0.1.88

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

func (ExportSqlJobResultRequestBodyExportMode) MarshalJSON added in v0.1.88

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

func (*ExportSqlJobResultRequestBodyExportMode) UnmarshalJSON added in v0.1.88

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

func (ExportSqlJobResultRequestBodyExportMode) Value added in v0.1.88

type ExportSqlJobResultRequestBodyExportModeEnum added in v0.1.88

type ExportSqlJobResultRequestBodyExportModeEnum struct {
	ERROR_IF_EXISTS ExportSqlJobResultRequestBodyExportMode
	OVERWRITE       ExportSqlJobResultRequestBodyExportMode
}

func GetExportSqlJobResultRequestBodyExportModeEnum added in v0.1.88

func GetExportSqlJobResultRequestBodyExportModeEnum() ExportSqlJobResultRequestBodyExportModeEnum

type ExportSqlJobResultResponse

type ExportSqlJobResultResponse struct {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 此SQL将生成并提交一个新的作业,返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。
	JobId *string `json:"job_id,omitempty"`

	// 作业执行方式,是同步还是异步执行
	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExportSqlJobResultResponse Response Object

func (ExportSqlJobResultResponse) String

type ExportTableRequest

type ExportTableRequest struct {
	Body *ExportTableRequestBody `json:"body,omitempty"`
}

ExportTableRequest Request Object

func (ExportTableRequest) String

func (o ExportTableRequest) String() string

type ExportTableRequestBody

type ExportTableRequestBody struct {

	// 导出数据的储存路径(当前仅支持将数据存储在OBS上,且OBS路径须以s3a开头)。另外,“export_mode”配置为“errorifexists”时,该路径下的文件夹须不存在,如请求样例中的“test”文件夹。
	DataPath string `json:"data_path"`

	// 导出数据的类型(当前仅支持csv格式数据)。
	DataType string `json:"data_type"`

	// 被导出数据的表所在的数据库名称。
	DatabaseName string `json:"database_name"`

	// 被导出数据的表名称。
	TableName string `json:"table_name"`

	// 导出数据的压缩方法。目前支持gzip、bzip2、deflate压缩方式;若不希望压缩,则输入none。
	Compress string `json:"compress"`

	// 指定执行该任务的队列。若不指定队列,将采用default队列执行操作。
	QueueName *string `json:"queue_name,omitempty"`

	// 导出模式,目前支持“ErrorIfExists”,“Overwrite”,不指定“export_mode”则默认为“ErrorIfExists”。  “ErrorIfExists”:存在即报错。指定的导出目录必须不存在,如果指定目录已经存在,系统将返回错误信息,无法执行导出操作。 “Overwrite”:覆盖。在指定目录下新建文件,会删除已有文件。
	ExportMode *string `json:"export_mode,omitempty"`

	// 导出csv格式数据时,是否导出列名。  设置为“true”,表示导出列名。 设置为“false”,表示不导出列名。 若为空,默认为“false”。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`
}

ExportTableRequestBody 导出数据

func (ExportTableRequestBody) String

func (o ExportTableRequestBody) String() string

type ExportTableResponse

type ExportTableResponse struct {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 此SQL将生成并提交一个新的作业,返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。
	JobId *string `json:"job_id,omitempty"`

	// 作业执行方式,是同步还是异步执行
	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ExportTableResponse Response Object

func (ExportTableResponse) String

func (o ExportTableResponse) String() string

type FlinkJob added in v0.1.88

type FlinkJob struct {

	// 作业ID。
	JobId int64 `json:"job_id"`

	// 作业名称。长度限制:0-57个字符。
	Name *string `json:"name,omitempty"`

	// 作业描述。长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// 用户名,当“show_detail”为“false”时独有。
	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"`

	// 作业运行时长, 单位ms,当“show_detail”为“false”时独有。
	Duration *int64 `json:"duration,omitempty"`

	// 父作业ID,“show_detail”为“false”时独有。
	RootId *int64 `json:"root_id,omitempty"`

	// 作业所属用户标识,“show_detail”为“true”时独有。
	UserId *string `json:"user_id,omitempty"`

	// 作业所属项目标识,“show_detail”为“true”时独有。
	ProjectId *string `json:"project_id,omitempty"`

	// Stream SQL语句,“show_detail”为“false”时独有。
	SqlBody *string `json:"sql_body,omitempty"`

	// 作业运行模式: shared_cluster:共享。 exclusive_cluster:独享。 edge_node:边缘节点。 show_detail为true时独有.
	RunMode *string `json:"run_mode,omitempty"`

	// jar包主类,“show_detail”为“false”时独有。
	MainClass *string `json:"main_class,omitempty"`

	// jar包作业运行参数,多个参数之间用空格分隔。show_detail为true时独有的。
	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	// 作业执行计划,“show_detail”为“false”时独有。
	ExecutionGraph *string `json:"execution_graph,omitempty"`

	// 作业更新时间,“show_detail”为“false”时独有。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 作业的流图是否可编辑。“true”表示作业的流图可以编辑,“false”表示作业的流图不可以编辑。
	GraphEditorEnabled *bool `json:"graph_editor_enabled,omitempty"`

	// 作业是否有保存点。“true”表示作业有保存点,“false”表示作业没有保存点。
	HasSavepoint *bool `json:"has_savepoint,omitempty"`

	// 队列名字。
	QueueName *string `json:"queue_name,omitempty"`

	// 边缘计算组ID列表。
	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	// 重启次数。
	RestartTimes *int64 `json:"restart_times,omitempty"`

	// 保存点路径。
	SavepointPath *string `json:"savepoint_path,omitempty"`

	JobConfig *FlinkJobConfig `json:"job_config,omitempty"`
}

FlinkJob 作业列表信息。

func (FlinkJob) String added in v0.1.88

func (o FlinkJob) String() string

type FlinkJobConfig

type FlinkJobConfig struct {

	// 是否开启作业自动快照功能。 开启:true; 关闭:false; 默认:false。
	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	// 快照模式: exactly_once:数据只被消费一次。 at_least_once:数据至少被消费一次。 默认值为exactly_once。
	CheckpointMode *string `json:"checkpoint_mode,omitempty"`

	// 快照时间间隔, 单位为秒,默认值为10。
	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	// 是否启用日志存储。默认为false。
	LogEnabled *bool `json:"log_enabled,omitempty"`

	// OBS桶名。
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 当作业异常时,向该SMN主题推送告警信息。
	SmnTopic *string `json:"smn_topic,omitempty"`

	// 边缘计算组ID列表。
	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	// 父作业ID。
	RootId *int64 `json:"root_id,omitempty"`

	// 管理单元CU数。默认为1。
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 用户为作业选择的CU数量, “show_detail”。默认为2。
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 用户设置的作业并行数, “show_detail”为“true”时独有。默认值为1。 最小值:1,最大值:2000。
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 是否开启异常重启功能。
	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	// 空闲状态过期周期。
	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户sql作业的udf jar通过该参数传入。
	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	// 作业脏数据策略。 “2:obs-wan-wulan3/jobs”:保存 “1”:抛出异常 “0”:忽略
	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业主类所在的jar包.
	Entrypoint *string `json:"entrypoint,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的其他依赖包
	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的依赖文件.
	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	// 作业使用计算节点个数
	ExecutorNumber *int32 `json:"executor_number,omitempty"`

	// 计算节点cu数
	ExecutorCuNumber *int32 `json:"executor_cu_number,omitempty"`

	// 异常自动重启时,是否从最新checkpoint恢复,默认false
	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	// Flink作业运行时自定义优化参数。
	RuntimeConfig *string `json:"runtime_config,omitempty"`

	// 流图编辑开关。默认为“false。
	GraphEditorEnabled *bool `json:"graph_editor_enabled,omitempty"`

	// 流图编辑数据。默认为null。
	GraphEditorData *string `json:"graph_editor_data,omitempty"`

	// 异常重试最大次数。-1代表无限。
	ResumeMaxNum *int64 `json:"resume_max_num,omitempty"`

	// 检查点保存路径。
	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	// 用户上传的config包OBS路径。
	ConfigUrl *string `json:"config_url,omitempty"`

	// 单TM所占CU数。
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 单TM Slot数。
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Flink镜像。
	Image *string `json:"image,omitempty"`

	// 自定义作业特性。表示用户作业使用的Flink镜像类型。basic:表示使用DLI提供的基础Flink镜像。custom:表示使用用户自定义的Flink镜像。
	Feature *string `json:"feature,omitempty"`

	// Flink版本。当用户设置“feature”为“basic”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用的DLI基础Flink镜像的版本。
	FlinkVersion *string `json:"flink_version,omitempty"`

	// 各算子并行度参数,以json的形式展示各算子id和并行度。
	OperatorConfig *string `json:"operator_config,omitempty"`

	// 静态流图资源预估参数,以json的形式展示。
	StaticEstimatorConfig *string `json:"static_estimator_config,omitempty"`

	RealCuNumber *int32 `json:"real_cu_number,omitempty"`
}

FlinkJobConfig 作业配置,当“show_detail”为“true”时才有该参数配置。

func (FlinkJobConfig) String

func (o FlinkJobConfig) String() string

type FlinkJobExecutionGraph added in v0.1.88

type FlinkJobExecutionGraph struct {

	// flink作业id。
	Jid *string `json:"jid,omitempty"`

	// flink作业名字。
	Name *string `json:"name,omitempty"`

	// 是否可停止。
	IsStoppable *bool `json:"isStoppable,omitempty"`

	// 作业运行状态。
	State *string `json:"state,omitempty"`

	// 作业启动时间。
	StartTime *int64 `json:"start-time,omitempty"`

	// 作业停止时间。
	EndTime *int64 `json:"end-time,omitempty"`

	// 作业运行时长。
	Duration *int64 `json:"duration,omitempty"`
}

FlinkJobExecutionGraph 查询作业执行计划。

func (FlinkJobExecutionGraph) String added in v0.1.88

func (o FlinkJobExecutionGraph) String() string

type FlinkJobList

type FlinkJobList struct {

	// 作业查询结果条数。
	TotalCount *int64 `json:"total_count,omitempty"`

	// 作业信息
	Jobs *[]FlinkJob `json:"jobs,omitempty"`
}

FlinkJobList 作业列表详情。

func (FlinkJobList) String

func (o FlinkJobList) String() string

type FlinkJobMetricInfo added in v0.1.88

type FlinkJobMetricInfo struct {

	// 输入流或输出流名称。
	Name *string `json:"name,omitempty"`

	// 总记录数。
	Records *int64 `json:"records,omitempty"`

	// 脏数据记录数。
	CorruptedRecords *int64 `json:"corrupted_records,omitempty"`
}

FlinkJobMetricInfo 所有输入流。

func (FlinkJobMetricInfo) String added in v0.1.88

func (o FlinkJobMetricInfo) String() string

type FlinkJobStatus added in v0.1.90

type FlinkJobStatus struct {

	// 作业Id。
	JobId *int64 `json:"job_id,omitempty"`

	// 作业状态名称。
	StatusName *string `json:"status_name,omitempty"`

	// 当前状态描述,包含异常状态原因及建议。
	StatusDesc *string `json:"status_desc,omitempty"`
}

FlinkJobStatus 创建作业的job模型。

func (FlinkJobStatus) String added in v0.1.90

func (o FlinkJobStatus) String() string

type FlinkJobUpdateTime added in v0.1.88

type FlinkJobUpdateTime struct {

	// 作业更新时间, 毫秒数。
	UpdateTime *int64 `json:"update_time,omitempty"`
}

FlinkJobUpdateTime 作业更新信息。

func (FlinkJobUpdateTime) String added in v0.1.88

func (o FlinkJobUpdateTime) String() string

type FlinkMetric added in v0.1.88

type FlinkMetric struct {

	// 所有作业监控信息。
	Jobs *[]FlinkMetricList `json:"jobs,omitempty"`
}

FlinkMetric 作业审计日志信息。

func (FlinkMetric) String added in v0.1.88

func (o FlinkMetric) String() string

type FlinkMetricList added in v0.1.88

type FlinkMetricList struct {

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

	Metrics *Metric `json:"metrics,omitempty"`
}

FlinkMetricList 所有作业监控信息。

func (FlinkMetricList) String added in v0.1.88

func (o FlinkMetricList) String() string

type FlinkSqlJobTemplate added in v0.1.88

type FlinkSqlJobTemplate struct {

	// 模板ID。
	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"`

	// Stream SQL语句, 至少包含source, query, sink三个部分。
	SqlBody *string `json:"sql_body,omitempty"`

	// 作业模板的类型。
	JobType *string `json:"job_type,omitempty"`
}

func (FlinkSqlJobTemplate) String added in v0.1.88

func (o FlinkSqlJobTemplate) String() string

type FlinkSqlJobTemplateId added in v0.1.88

type FlinkSqlJobTemplateId struct {

	// 模板ID。
	TemplateId *int64 `json:"template_id,omitempty"`
}

FlinkSqlJobTemplateId 删除模板信息。

func (FlinkSqlJobTemplateId) String added in v0.1.88

func (o FlinkSqlJobTemplateId) String() string

type FlinkSqlJobTemplateList added in v0.1.88

type FlinkSqlJobTemplateList struct {

	// 模板总数。
	TotalCount *int32 `json:"total_count,omitempty"`

	// 模板详细信息
	Templates *[]FlinkSqlJobTemplate `json:"templates,omitempty"`
}

func (FlinkSqlJobTemplateList) String added in v0.1.88

func (o FlinkSqlJobTemplateList) String() string

type FlinkSuccessResponse added in v0.1.95

type FlinkSuccessResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`
}

func (FlinkSuccessResponse) String added in v0.1.95

func (o FlinkSuccessResponse) String() string

type FlinkTemplate

type FlinkTemplate struct {

	// 模板ID
	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"`
}

FlinkTemplate 创建模板信息。

func (FlinkTemplate) String

func (o FlinkTemplate) String() string

type GlobalVariable added in v0.1.88

type GlobalVariable struct {

	// 全局变量ID
	Id *int64 `json:"id,omitempty"`

	// 变量名称
	VarName *string `json:"var_name,omitempty"`

	// 变量的值
	VarValue *string `json:"var_value,omitempty"`

	// 项目ID
	ProjectId *string `json:"project_id,omitempty"`

	// 用户ID
	UserId *string `json:"user_id,omitempty"`

	// 是否为敏感变量
	IsSensitive *bool `json:"is_sensitive,omitempty"`

	// 用户名称
	UserName *string `json:"user_name,omitempty"`

	// 创建时间。为UTC的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 更新时间。为UTC的时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`
}

GlobalVariable 全局变量

func (GlobalVariable) String added in v0.1.88

func (o GlobalVariable) String() string

type IefEvent added in v0.1.88

type IefEvent struct {

	// 资源类型
	EventType string `json:"event_type"`

	// 资源的操作类型
	Operation string `json:"operation"`

	// 事件产生的时间戳
	Timestamp int64 `json:"timestamp"`

	// 消息发送的Topic
	Topic string `json:"topic"`

	// 资源名称
	Name string `json:"name"`

	// 资源的属性
	Attributes *string `json:"attributes,omitempty"`
}

IefEvent IEF系统事件的数据

func (IefEvent) String added in v0.1.88

func (o IefEvent) String() string

type ImportFlinkJobSavepointRequest added in v0.1.95

type ImportFlinkJobSavepointRequest struct {

	// 非运行阶段的Flink作业的作业ID
	JobId string `json:"job_id"`

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

ImportFlinkJobSavepointRequest Request Object

func (ImportFlinkJobSavepointRequest) String added in v0.1.95

type ImportFlinkJobSavepointRequestBody added in v0.1.95

type ImportFlinkJobSavepointRequestBody struct {

	// Flink作业的id
	JobId int64 `json:"job_id"`

	// Savepoint路径。需指定到_metaData文件的上级目录 例:\"obs://bucket_name/file_name/\"
	SavepointPath string `json:"savepoint_path"`
}

ImportFlinkJobSavepointRequestBody 导入savepoint接口的请求体

func (ImportFlinkJobSavepointRequestBody) String added in v0.1.95

type ImportFlinkJobSavepointResponse added in v0.1.95

type ImportFlinkJobSavepointResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ImportFlinkJobSavepointResponse Response Object

func (ImportFlinkJobSavepointResponse) String added in v0.1.95

type ImportFlinkJobsRequest added in v0.1.68

type ImportFlinkJobsRequest struct {
	Body *ImportFlinkJobsRequestBody `json:"body,omitempty"`
}

ImportFlinkJobsRequest Request Object

func (ImportFlinkJobsRequest) String added in v0.1.68

func (o ImportFlinkJobsRequest) String() string

type ImportFlinkJobsRequestBody added in v0.1.88

type ImportFlinkJobsRequestBody struct {

	// OBS上导入作业zip文件路径,支持填写目录,导入目录下所有zip文件。
	ZipFile string `json:"zip_file"`

	// 若导入作业中存在与服务已有作业同名情况,是否将服务中已有作业覆盖。
	IsCover *bool `json:"is_cover,omitempty"`
}

ImportFlinkJobsRequestBody 导入作业的请求参数。

func (ImportFlinkJobsRequestBody) String added in v0.1.88

type ImportFlinkJobsResponse added in v0.1.68

type ImportFlinkJobsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

	// 作业导入结果。
	JobMapping     *[]JobMap `json:"job_mapping,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ImportFlinkJobsResponse Response Object

func (ImportFlinkJobsResponse) String added in v0.1.68

func (o ImportFlinkJobsResponse) String() string

type ImportTableRequest

type ImportTableRequest struct {
	Body *ImportTableRequestBody `json:"body,omitempty"`
}

ImportTableRequest Request Object

func (ImportTableRequest) String

func (o ImportTableRequest) String() string

type ImportTableRequestBody

type ImportTableRequestBody struct {

	// 导入的数据路径(当前仅支持导入OBS上的数据,且OBS路径须以s3a开头)。
	DataPath string `json:"data_path"`

	// 导入的数据类型(当前支持csv、parquet、orc、json、avro数据类型)。
	DataType string `json:"data_type"`

	// 导入表所属的数据库名称。
	DatabaseName string `json:"database_name"`

	// 导入表的名称。
	TableName string `json:"table_name"`

	// 导入数据中的第一行数据是否包括列名,即表头。默认为“false”,表示不包括列名。导入CSV类型数据时可指定。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// 用户自定义数据分隔符,默认为逗号。导入CSV类型数据时可指定。
	Delimiter *string `json:"delimiter,omitempty"`

	// 用户自定义引用字符,默认为双引号。导入CSV类型数据时可指定。
	QuoteChar *string `json:"quote_char,omitempty"`

	// 用户自定义转义字符,默认为反斜杠。导入CSV类型数据时可指定。
	EscapeChar *string `json:"escape_char,omitempty"`

	// 指定特定的日期格式,默认为“yyyy-MM-dd”。日期格式字符定义详见表3。导入CSV及JSON类型数据时可指定。
	DateFormat *string `json:"date_format,omitempty"`

	// 作业执行过程中的bad records存储目录。设置该配置项后,bad records不会导入到目标表。
	BadRecordsPath *string `json:"bad_records_path,omitempty"`

	// 指定特定的时间格式,默认为“yyyy-MM-dd HH:mm:ss”。时间格式字符定义详见表3。导入CSV及JSON类型数据时可指定。
	TimestampFormat *string `json:"timestamp_format,omitempty"`

	// 指定执行该任务的队列。若不指定队列,将采用default队列执行操作。
	QueueName *string `json:"queue_name,omitempty"`

	// 是否覆盖之前的数据
	Overwrite *bool `json:"overwrite,omitempty"`

	// 表示需要导入到哪个分区
	PartitionSpec *string `json:"partition_spec,omitempty"`

	// 用于定义此配置项的参数
	Conf *[]string `json:"conf,omitempty"`
}

ImportTableRequestBody 导入数据

func (ImportTableRequestBody) String

func (o ImportTableRequestBody) String() string

type ImportTableResponse

type ImportTableResponse struct {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 此SQL将生成并提交一个新的作业,返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。
	JobId *string `json:"job_id,omitempty"`

	// 作业执行方式,是同步还是异步执行
	JobMode        *string `json:"job_mode,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ImportTableResponse Response Object

func (ImportTableResponse) String

func (o ImportTableResponse) String() string

type Job added in v0.1.88

type Job struct {

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

	// 作业状态
	Status string `json:"status"`

	// 时间戳
	CreateTime int64 `json:"create_time"`

	// 作业异常信息
	Exceptions *string `json:"exceptions,omitempty"`

	// 作业指标信息
	Metrics *string `json:"metrics,omitempty"`

	// 作业执行计划
	Plan *string `json:"plan,omitempty"`
}

Job 作业信息列表

func (Job) String added in v0.1.88

func (o Job) String() string

type JobMap added in v0.1.88

type JobMap struct {

	// 导入文件中的作业ID。
	OldJobId *int64 `json:"old_job_id,omitempty"`

	// 导入完成后作业ID,若is_cover=false,服务中已有同名的作业,则为-1。
	NewJobId *int64 `json:"new_job_id,omitempty"`

	// 导入作业结果信息。
	Remark *string `json:"remark,omitempty"`
}

JobMap 导入job作业结果的模型。

func (JobMap) String added in v0.1.88

func (o JobMap) String() string

type JobResource added in v0.1.90

type JobResource struct {

	// 资源名称。
	Name *string `json:"name,omitempty"`

	// 资源类型。
	Type *string `json:"type,omitempty"`
}

JobResource 创建会话请求参数resources的元素。

func (JobResource) String added in v0.1.90

func (o JobResource) String() string

type JobResourcesGroup added in v0.1.90

type JobResourcesGroup struct {

	// 用户组名称。
	Name *string `json:"name,omitempty"`

	// 用户组资源。
	Resources *[]JobResource `json:"resources,omitempty"`
}

JobResourcesGroup 创建会话请求参数groups的元素。

func (JobResourcesGroup) String added in v0.1.90

func (o JobResourcesGroup) String() string

type ListAuthInfoRequest

type ListAuthInfoRequest struct {

	// 认证信息名称
	AuthInfoName *string `json:"auth_info_name,omitempty"`

	// 默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 默认为100
	Limit *int32 `json:"limit,omitempty"`
}

ListAuthInfoRequest Request Object

func (ListAuthInfoRequest) String

func (o ListAuthInfoRequest) String() string

type ListAuthInfoResponse

type ListAuthInfoResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 请求消息
	Message *string `json:"message,omitempty"`

	// 认证信息个数
	Count *int32 `json:"count,omitempty"`

	// 认证信息列表
	AuthInfos      *[]AuthInfo `json:"auth_infos,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ListAuthInfoResponse Response Object

func (ListAuthInfoResponse) String

func (o ListAuthInfoResponse) String() string

type ListAuthorizationPrivilegesRequest added in v0.1.68

type ListAuthorizationPrivilegesRequest struct {

	// 授权对象,和授权接口中的object对应 \"jobs.flink.flink作业ID\",查询指定的作业。 \"groups.程序包组名\",查询指定的程序包组。 \"resources.程序包名\",查询指定程序包。
	Object string `json:"object"`
}

ListAuthorizationPrivilegesRequest Request Object

func (ListAuthorizationPrivilegesRequest) String added in v0.1.68

type ListAuthorizationPrivilegesResponse added in v0.1.68

type ListAuthorizationPrivilegesResponse struct {

	// 成功标识
	IsSuccess *bool `json:"is_success,omitempty"`

	// 响应信息
	Message *string `json:"message,omitempty"`

	// 对象名称
	ObjectName *string `json:"object_name,omitempty"`

	// 对象类型
	ObjectType *string `json:"object_type,omitempty"`

	// 对象类型
	Count *int32 `json:"count,omitempty"`

	// 权限信息
	Privileges     *[]AuthorizationPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

ListAuthorizationPrivilegesResponse Response Object

func (ListAuthorizationPrivilegesResponse) String added in v0.1.68

type ListCatalogsRequest added in v0.1.87

type ListCatalogsRequest struct {

	// 偏移量
	Offset *int32 `json:"offset,omitempty"`

	// 分页的单页数量。
	Limit *int32 `json:"limit,omitempty"`
}

ListCatalogsRequest Request Object

func (ListCatalogsRequest) String added in v0.1.87

func (o ListCatalogsRequest) String() string

type ListCatalogsResponse added in v0.1.87

type ListCatalogsResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// catalog总数量
	TotalCount *int64 `json:"total_count,omitempty"`

	// 项目下所有catalog信息
	Catalogs       *[]Catalog `json:"catalogs,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ListCatalogsResponse Response Object

func (ListCatalogsResponse) String added in v0.1.87

func (o ListCatalogsResponse) String() string

type ListDatabaseUsersRequest

type ListDatabaseUsersRequest struct {

	// 被查询的数据库名称。
	DatabaseName string `json:"database_name"`
}

ListDatabaseUsersRequest Request Object

func (ListDatabaseUsersRequest) String

func (o ListDatabaseUsersRequest) String() string

type ListDatabaseUsersResponse

type ListDatabaseUsersResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 被查询的数据库名称。
	DatabaseName *string `json:"database_name,omitempty"`

	// 权限信息。
	Privileges     *[]DatabaseUserPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

ListDatabaseUsersResponse Response Object

func (ListDatabaseUsersResponse) String

func (o ListDatabaseUsersResponse) String() string

type ListDatabasesRequest

type ListDatabasesRequest struct {

	// 过滤关键字
	Keyword *string `json:"keyword,omitempty"`

	// 查询数量
	Limit *int32 `json:"limit,omitempty"`

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

	// 标签过滤
	Tags *string `json:"tags,omitempty"`

	// 是否返回隐私信息
	WithPriv *bool `json:"with-priv,omitempty"`
}

ListDatabasesRequest Request Object

func (ListDatabasesRequest) String

func (o ListDatabasesRequest) String() string

type ListDatabasesResponse

type ListDatabasesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 数据库的总数。
	DatabaseCount *int32 `json:"database_count,omitempty"`

	// 查询所有数据库的响应参数。
	Databases      *[]Database `json:"databases,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ListDatabasesResponse Response Object

func (ListDatabasesResponse) String

func (o ListDatabasesResponse) String() string

type ListDatasourceConnectionsRequest

type ListDatasourceConnectionsRequest struct {

	// 标签
	Tags *string `json:"tags,omitempty"`
}

ListDatasourceConnectionsRequest Request Object

func (ListDatasourceConnectionsRequest) String

type ListDatasourceConnectionsResponse

type ListDatasourceConnectionsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 跨源连接信息列表。
	Connections *[]DatasourceConnection `json:"connections,omitempty"`

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

ListDatasourceConnectionsResponse Response Object

func (ListDatasourceConnectionsResponse) String

type ListElasticResourcePoolQueuesRequest

type ListElasticResourcePoolQueuesRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

	// 默认为100
	Limit *int32 `json:"limit,omitempty"`

	// 默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 可以根据queueName进行过滤
	QueueName *string `json:"queue_name,omitempty"`
}

ListElasticResourcePoolQueuesRequest Request Object

func (ListElasticResourcePoolQueuesRequest) String

type ListElasticResourcePoolQueuesResponse

type ListElasticResourcePoolQueuesResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 请求消息
	Message *string `json:"message,omitempty"`

	// 该弹性资源池下所有queue信息及队列扩缩容策略信息。
	Queues *[]ElasticResourcePoolQueue `json:"queues,omitempty"`

	// 该资源池下关联的队列数量
	Count          *int64 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListElasticResourcePoolQueuesResponse Response Object

func (ListElasticResourcePoolQueuesResponse) String

type ListElasticResourcePoolScaleRecordsRequest

type ListElasticResourcePoolScaleRecordsRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

	// start_time用于查询扩缩容历史的开始时间,该时间点需大于当前时间点减30天,必须小于end_time 。时间格式为unix时间戳,单位:毫秒。 ①若start_time为空,则查询end_time前七天到end_time的数据(end_time最大不能大于当前时间30天)。 ②查询当前时间点前15天到当前时间点的数据(start_time和end_time同时为空)。
	StartTime *int64 `json:"start_time,omitempty"`

	// end_time用于查询扩缩容历史的结束时间,该时间点不能小于开始时间,不能大于当前时间。时间格式为unix时间戳,单位:毫秒。 ①若end_time为空,则查询start_time到当前时间点的数据。 ②查询当前时间点前15天到当前时间的数据(start_time和end_time同时为空)。
	EndTime *int64 `json:"end_time,omitempty"`

	// 弹性资源池扩缩容的状态
	Status *ListElasticResourcePoolScaleRecordsRequestStatus `json:"status,omitempty"`

	// 偏移量
	Offset *int32 `json:"offset,omitempty"`

	// 当前分页条数
	Limit *int32 `json:"limit,omitempty"`
}

ListElasticResourcePoolScaleRecordsRequest Request Object

func (ListElasticResourcePoolScaleRecordsRequest) String

type ListElasticResourcePoolScaleRecordsRequestStatus

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

func (ListElasticResourcePoolScaleRecordsRequestStatus) MarshalJSON

func (*ListElasticResourcePoolScaleRecordsRequestStatus) UnmarshalJSON

func (ListElasticResourcePoolScaleRecordsRequestStatus) Value

type ListElasticResourcePoolScaleRecordsResponse

type ListElasticResourcePoolScaleRecordsResponse struct {

	// 返回数组长度
	Count *int64 `json:"count,omitempty"`

	// 数组中返回的数据
	Items *[]ElasticResourcePoolScaleRecord `json:"items,omitempty"`

	XAuthToken     *string `json:"X-Auth-Token,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListElasticResourcePoolScaleRecordsResponse Response Object

func (ListElasticResourcePoolScaleRecordsResponse) String

type ListElasticResourcePoolsRequest

type ListElasticResourcePoolsRequest struct {

	// 默认为100
	Limit *int32 `json:"limit,omitempty"`

	// 通过弹性资源池名称进行模糊匹配
	Name *string `json:"name,omitempty"`

	// 默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 弹性资源池状态
	Status *ListElasticResourcePoolsRequestStatus `json:"status,omitempty"`

	// 查询根据标签进行过滤。
	Tags *string `json:"tags,omitempty"`
}

ListElasticResourcePoolsRequest Request Object

func (ListElasticResourcePoolsRequest) String

type ListElasticResourcePoolsRequestStatus

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

func (ListElasticResourcePoolsRequestStatus) MarshalJSON

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

func (*ListElasticResourcePoolsRequestStatus) UnmarshalJSON

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

func (ListElasticResourcePoolsRequestStatus) Value

type ListElasticResourcePoolsResponse

type ListElasticResourcePoolsResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 消息
	Message *string `json:"message,omitempty"`

	// 数量
	Count *int32 `json:"count,omitempty"`

	// 弹性资源池列表
	ElasticResourcePools *[]ElasticResourcePool `json:"elastic_resource_pools,omitempty"`
	HttpStatusCode       int                    `json:"-"`
}

ListElasticResourcePoolsResponse Response Object

func (ListElasticResourcePoolsResponse) String

type ListEnhancedConnectionsRequest

type ListEnhancedConnectionsRequest struct {

	// 查询最大连接个数,默认100。
	Limit *int32 `json:"limit,omitempty"`

	// 连接名。
	Name *string `json:"name,omitempty"`

	// 查询结果偏移量,默认为0(连接以创建时间进行排序)
	Offset *int32 `json:"offset,omitempty"`

	// 连接状态,包括以下两种状态: ACTIVE:已激活 DELETED:已删除
	Status *string `json:"status,omitempty"`

	// 标签
	Tags *string `json:"tags,omitempty"`
}

ListEnhancedConnectionsRequest Request Object

func (ListEnhancedConnectionsRequest) String

type ListEnhancedConnectionsResponse

type ListEnhancedConnectionsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 跨源连接信息列表。
	Connections *[]EnhancedConnection `json:"connections,omitempty"`

	// 返回的跨源连接个数。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListEnhancedConnectionsResponse Response Object

func (ListEnhancedConnectionsResponse) String

type ListFlinkJobsRequest

type ListFlinkJobsRequest struct {

	// 作业类型
	JobType *string `json:"job_type,omitempty"`

	// 返回的数据条数。默认为10。
	Limit *int32 `json:"limit,omitempty"`

	// 作业名称。长度限制:0-57个字符。
	Name *string `json:"name,omitempty"`

	// 作业偏移量。
	Offset *int64 `json:"offset,omitempty"`

	// 查询结果排序,升序asc和降序desc两种可选,默认降序。
	Order *string `json:"order,omitempty"`

	// 队列名称。
	QueueName *string `json:"queue_name,omitempty"`

	// 边缘父作业ID, 用于查询指定边缘作业的子作业。不带该参数时, 查询所有非边缘作业和边缘父作业, 不包括边缘子作业。
	RootJobId *int64 `json:"root_job_id,omitempty"`

	// 是否返回作业详情信息。默认为false。
	ShowDetail *bool `json:"show_detail,omitempty"`

	// 作业状态。 作业的状态如下: job_init:草稿 job_submitting:提交中 job_submit_fail:提交失败 job_running:运行中(开始计费,提交作业后,返回正常结果) job_running_exception:运行异常(停止计费。作业发生运行时异常,停止运行作业) job_downloading:下载中 job_idle:空闲 job_canceling:停止中 job_cancel_success:已停止 job_cancel_fail:停止失败 job_savepointing:保存点创建中 job_arrearage_stopped:因欠费被停止(结束计费。用户账户欠费,作业停止) job_arrearage_recovering:欠费作业恢复中(用户账户欠费,账户充值,作业恢复中) job_finish:已完成
	Status *string `json:"status,omitempty"`

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

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

	// 用户名,可作为筛选条件
	UserName *string `json:"user_name,omitempty"`
}

ListFlinkJobsRequest Request Object

func (ListFlinkJobsRequest) String

func (o ListFlinkJobsRequest) String() string

type ListFlinkJobsResponse

type ListFlinkJobsResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

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

ListFlinkJobsResponse Response Object

func (ListFlinkJobsResponse) String

func (o ListFlinkJobsResponse) String() string

type ListFlinkSqlJobTemplatesRequest added in v0.1.68

type ListFlinkSqlJobTemplatesRequest struct {

	// 返回的数据条数。默认为10。
	Limit *int32 `json:"limit,omitempty"`

	// 模板名字
	Name *string `json:"name,omitempty"`

	// 作业偏移量。
	Offset *int64 `json:"offset,omitempty"`

	// 查询结果排序,升序asc和降序desc两种可选,默认降序。
	Order *string `json:"order,omitempty"`

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

ListFlinkSqlJobTemplatesRequest Request Object

func (ListFlinkSqlJobTemplatesRequest) String added in v0.1.68

type ListFlinkSqlJobTemplatesResponse added in v0.1.68

type ListFlinkSqlJobTemplatesResponse struct {

	// 请求是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

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

ListFlinkSqlJobTemplatesResponse Response Object

func (ListFlinkSqlJobTemplatesResponse) String added in v0.1.68

type ListGlobalVariablesRequest added in v0.1.68

type ListGlobalVariablesRequest struct {

	// 每页显示的返回信息的个数,默认值为“100”。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,默认值为“0”。
	Offset *int32 `json:"offset,omitempty"`
}

ListGlobalVariablesRequest Request Object

func (ListGlobalVariablesRequest) String added in v0.1.68

type ListGlobalVariablesResponse added in v0.1.68

type ListGlobalVariablesResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 全局变量
	GlobalVars *[]GlobalVariable `json:"global_vars,omitempty"`

	// 全局变量总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListGlobalVariablesResponse Response Object

func (ListGlobalVariablesResponse) String added in v0.1.68

type ListJobAuthInfosRequest added in v0.1.71

type ListJobAuthInfosRequest struct {

	// 认证信息名称
	AuthInfoName *string `json:"auth_info_name,omitempty"`

	// 默认为0
	Offset *int32 `json:"offset,omitempty"`

	// 默认为100
	Limit *int32 `json:"limit,omitempty"`
}

ListJobAuthInfosRequest Request Object

func (ListJobAuthInfosRequest) String added in v0.1.71

func (o ListJobAuthInfosRequest) String() string

type ListJobAuthInfosResponse added in v0.1.71

type ListJobAuthInfosResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 请求消息
	Message *string `json:"message,omitempty"`

	// 认证信息个数
	Count *int32 `json:"count,omitempty"`

	// 认证信息列表
	AuthInfos      *[]AuthInfo `json:"auth_infos,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ListJobAuthInfosResponse Response Object

func (ListJobAuthInfosResponse) String added in v0.1.71

func (o ListJobAuthInfosResponse) String() string

type ListJobResourcesRequest added in v0.1.88

type ListJobResourcesRequest struct {
	Kind *string `json:"kind,omitempty"`

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

ListJobResourcesRequest Request Object

func (ListJobResourcesRequest) String added in v0.1.88

func (o ListJobResourcesRequest) String() string

type ListJobResourcesResponse added in v0.1.88

type ListJobResourcesResponse struct {

	// 资源包返回总数
	Total *int32 `json:"total,omitempty"`

	// 已上传的用户资源名列表。
	Resources *[]PackageResource `json:"resources,omitempty"`

	// 系统内置资源模块列表
	Modules *[]PackageResourceMoudle `json:"modules,omitempty"`

	// 已上传的用户分组资源。
	Groups         *[]PackageResourceGroup `json:"groups,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

ListJobResourcesResponse Response Object

func (ListJobResourcesResponse) String added in v0.1.88

func (o ListJobResourcesResponse) String() string

type ListPartitionsRequest added in v0.1.88

type ListPartitionsRequest struct {

	// 数据库名
	DatabaseName string `json:"database_name"`

	// 表名
	TableName string `json:"table_name"`

	// 显示个数,默认值为100
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量
	Offset *int32 `json:"offset,omitempty"`
}

ListPartitionsRequest Request Object

func (ListPartitionsRequest) String added in v0.1.88

func (o ListPartitionsRequest) String() string

type ListPartitionsResponse added in v0.1.88

type ListPartitionsResponse struct {

	// 请求结果,true为成功,false为失败
	IsSuccess *bool `json:"is_success,omitempty"`

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

	Partitions     *PartitionList `json:"partitions,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ListPartitionsResponse Response Object

func (ListPartitionsResponse) String added in v0.1.88

func (o ListPartitionsResponse) String() string

type ListQueuePlansRequest

type ListQueuePlansRequest struct {

	// 待查询定时扩缩计划的队列名称
	QueueName string `json:"queue_name"`
}

ListQueuePlansRequest Request Object

func (ListQueuePlansRequest) String

func (o ListQueuePlansRequest) String() string

type ListQueuePlansResponse

type ListQueuePlansResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 定时扩缩容信息
	Plans          *[]QueuePlan `json:"plans,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ListQueuePlansResponse Response Object

func (ListQueuePlansResponse) String

func (o ListQueuePlansResponse) String() string

type ListQueuePropertiesRequest added in v0.1.68

type ListQueuePropertiesRequest struct {

	// 队列名称
	QueueName string `json:"queue_name"`

	// 偏移量
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示条数
	Limit *int32 `json:"limit,omitempty"`
}

ListQueuePropertiesRequest Request Object

func (ListQueuePropertiesRequest) String added in v0.1.68

type ListQueuePropertiesResponse added in v0.1.68

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

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

	Properties     *[]QueueProperty `json:"properties,omitempty"`
	HttpStatusCode int              `json:"-"`
}

ListQueuePropertiesResponse Response Object

func (ListQueuePropertiesResponse) String added in v0.1.68

type ListQueueUsersRequest

type ListQueueUsersRequest struct {

	// 队列名称。
	QueueName string `json:"queue_name"`
}

ListQueueUsersRequest Request Object

func (ListQueueUsersRequest) String

func (o ListQueueUsersRequest) String() string

type ListQueueUsersResponse

type ListQueueUsersResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 队列名称。
	QueueName *string `json:"queue_name,omitempty"`

	// 有权限使用该队列的用户及其对应的权限数组。
	Privileges     *[]QueueUserPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

ListQueueUsersResponse Response Object

func (ListQueueUsersResponse) String

func (o ListQueueUsersResponse) String() string

type ListQueuesRequest

type ListQueuesRequest struct {

	// 队列的类型,。有如下三种类型: sql general all 如果不指定,默认为sql。
	QueueType *string `json:"queue_type,omitempty"`

	// 查询根据标签进行过滤
	Tags *string `json:"tags,omitempty"`

	// 是否返回收费信息
	WithChargeInfo *bool `json:"with-charge-info,omitempty"`

	// 是否返回权限信息。
	WithPriv *bool `json:"with-priv,omitempty"`
}

ListQueuesRequest Request Object

func (ListQueuesRequest) String

func (o ListQueuesRequest) String() string

type ListQueuesResponse

type ListQueuesResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 队列信息。
	Queues         *[]Queue `json:"queues,omitempty"`
	HttpStatusCode int      `json:"-"`
}

ListQueuesResponse Response Object

func (ListQueuesResponse) String

func (o ListQueuesResponse) String() string

type ListSparkJobTemplatesRequest added in v0.1.68

type ListSparkJobTemplatesRequest struct {

	// 类型。
	Type *string `json:"type,omitempty"`

	// 模板名过滤关键字,模糊匹配,获取模板名含有该关键字的所有模板。
	Keyword *string `json:"keyword,omitempty"`

	// 每页显示的最大结果行数,范围: [1, 100]。默认值为:50。
	PageSize *int32 `json:"page-size,omitempty"`

	// 当前页码,默认为第一页。
	CurrentPage *int32 `json:"current-page,omitempty"`
}

ListSparkJobTemplatesRequest Request Object

func (ListSparkJobTemplatesRequest) String added in v0.1.68

type ListSparkJobTemplatesResponse added in v0.1.68

type ListSparkJobTemplatesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 返回的模板个数
	Count *int32 `json:"count,omitempty"`

	// 模板信息列表。
	Templates      *[]SparkJobTemplate `json:"templates,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ListSparkJobTemplatesResponse Response Object

func (ListSparkJobTemplatesResponse) String added in v0.1.68

type ListSparkJobsRequest added in v0.1.68

type ListSparkJobsRequest struct {

	// DLI队列名称,不填写则获取当前Project下所有批处理作业(不推荐使用)。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 用于查询开始时间在该时间点之前的作业。时间格式为unix时间戳,单位:毫秒。
	End *int64 `json:"end,omitempty"`

	// 起始批处理作业的索引号,默认从0开始。
	From *int32 `json:"from,omitempty"`

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

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

	// 指定作业排序方式,默认为CREATE_TIME_DESC(作业提交时间降序),支持DURATION_DESC(作业运行时长降序)、DURATION_ASC(作业运行时长升序)、CREATE_TIME_DESC(作业提交时间降序)、CREATE_TIME_ASC(作业提交时间升序)四种排序方式。
	Order *string `json:"order,omitempty"`

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

	// 查询批处理作业的数量。
	Size *int32 `json:"size,omitempty"`

	// 用于查询开始时间在该时间点之后的作业。时间格式为unix时间戳,单位:毫秒。
	Start *int64 `json:"start,omitempty"`

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

ListSparkJobsRequest Request Object

func (ListSparkJobsRequest) String added in v0.1.68

func (o ListSparkJobsRequest) String() string

type ListSparkJobsResponse added in v0.1.68

type ListSparkJobsResponse struct {

	// 起始批处理作业的索引号。
	From *int32 `json:"from,omitempty"`

	// 返回批处理作业的总数。
	Total *int32 `json:"total,omitempty"`

	// 批处理作业信息。
	Sessions *[]SparkJob `json:"sessions,omitempty"`

	// 批处理作业的创建时间。
	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListSparkJobsResponse Response Object

func (ListSparkJobsResponse) String added in v0.1.68

func (o ListSparkJobsResponse) String() string

type ListSqlJobTemplatesRequest added in v0.1.68

type ListSqlJobTemplatesRequest struct {

	// 用于过滤SQL模板的名字。
	Keyword *string `json:"keyword,omitempty"`
}

ListSqlJobTemplatesRequest Request Object

func (ListSqlJobTemplatesRequest) String added in v0.1.68

type ListSqlJobTemplatesResponse added in v0.1.68

type ListSqlJobTemplatesResponse struct {

	// 是否成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。执行失败时,用于显示执行失败的原因。
	Message *string `json:"message,omitempty"`

	// SQL模板总数。
	SqlCount *int32 `json:"sql_count,omitempty"`

	Sqls           *[]SqlJobTemplate `json:"sqls,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ListSqlJobTemplatesResponse Response Object

func (ListSqlJobTemplatesResponse) String added in v0.1.68

type ListSqlJobsRequest

type ListSqlJobsRequest struct {

	// 当前页码,默认为第一页。
	CurrentPage *int32 `json:"current-page,omitempty"`

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

	// 用于查询开始时间在该时间点之前的作业。时间格式为unix时间戳,单位:毫秒。
	End *int64 `json:"end,omitempty"`

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

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

	// 指定查询的作业类型,包含DDL、DCL、IMPORT、EXPORT、QUERY、INSERT,若要查询所有类型的作业,则传入ALL。
	JobType *ListSqlJobsRequestJobType `json:"job-type,omitempty"`

	// 指定作业排序方式,默认为start_time_desc(作业提交时间降序),支持duration_desc(作业运行时长降序)、duration_asc(作业运行时长升序)、start_time_desc(作业提交时间降序)、start_time_asc(作业提交时间升序)四种排序方式。
	Order *ListSqlJobsRequestOrder `json:"order,omitempty"`

	// 提交作业的用户名称
	Owner *string `json:"owner,omitempty"`

	// 每页显示的最大作业个数,范围: [1, 100]。默认值:50。
	PageSize *int32 `json:"page-size,omitempty"`

	// 指定queue_name作为作业过滤条件,查询在指定queue上运行的作业。
	QueueName *string `json:"queue_name,omitempty"`

	// 指定sql片段作为作业过滤条件,不区分大小写。
	SqlPattern *string `json:"sql_pattern,omitempty"`

	// 用于查询开始时间在该时间点之后的作业。时间格式为unix时间戳,单位:毫秒。
	Start *int64 `json:"start,omitempty"`

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

	// 指定作业标签作为过滤条件,支持多标签过滤。格式为“key=value”,如:GET /v1.0/{project_id}/jobs?tags=k1%3Dv1,“=”需要转义为“%3D”,“k1”为标签键,“v1”为标签值。
	Tags *string `json:"tags,omitempty"`
}

ListSqlJobsRequest Request Object

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

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 {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 作业总个数。
	JobCount *int32 `json:"job_count,omitempty"`

	// 作业信息。
	Jobs           *[]SqlJob `json:"jobs,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ListSqlJobsResponse Response Object

func (ListSqlJobsResponse) String

func (o ListSqlJobsResponse) String() string

type ListSqlSampleTemplatesRequest added in v0.1.88

type ListSqlSampleTemplatesRequest struct {
}

ListSqlSampleTemplatesRequest Request Object

func (ListSqlSampleTemplatesRequest) String added in v0.1.88

type ListSqlSampleTemplatesResponse added in v0.1.88

type ListSqlSampleTemplatesResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 样例模板信息。
	Sqls *[]SqlSampleTemplate `json:"sqls,omitempty"`

	// 样例模板个数。
	SqlCount       *int32 `json:"sqlCount,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListSqlSampleTemplatesResponse Response Object

func (ListSqlSampleTemplatesResponse) String added in v0.1.88

type ListTablePrivilegesRequest

type ListTablePrivilegesRequest struct {

	// 被查询的数据库名称。
	DatabaseName string `json:"database_name"`

	// 被查询的表名称。
	TableName string `json:"table_name"`

	// 被查询的用户名称。
	UserName string `json:"user_name"`
}

ListTablePrivilegesRequest Request Object

func (ListTablePrivilegesRequest) String

type ListTablePrivilegesResponse

type ListTablePrivilegesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 被查询的用户名称。
	UserName *string `json:"user_name,omitempty"`

	// 权限信息。
	Privileges     *[]TablePrivilege `json:"privileges,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ListTablePrivilegesResponse Response Object

func (ListTablePrivilegesResponse) String

type ListTableUsersRequest

type ListTableUsersRequest struct {

	// 被查询的数据库名称。
	DatabaseName string `json:"database_name"`

	// 被查询的表名称。
	TableName string `json:"table_name"`
}

ListTableUsersRequest Request Object

func (ListTableUsersRequest) String

func (o ListTableUsersRequest) String() string

type ListTableUsersResponse

type ListTableUsersResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 权限信息。
	Privileges     *[]TableUserPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

ListTableUsersResponse Response Object

func (ListTableUsersResponse) String

func (o ListTableUsersResponse) String() string

type ListTablesRequest added in v0.1.88

type ListTablesRequest struct {

	// 查看表所在的数据库名称。
	DatabaseName string `json:"database_name"`

	CurrentPage *int32 `json:"current-page,omitempty"`

	// 过滤表名称的关键词。
	Keyword *string `json:"keyword,omitempty"`

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

	TableType *string `json:"table-type,omitempty"`

	// 是否获取表的详细信息(所有者,size等)。
	WithDetail *bool `json:"with-detail,omitempty"`

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

ListTablesRequest Request Object

func (ListTablesRequest) String added in v0.1.88

func (o ListTablesRequest) String() string

type ListTablesResponse added in v0.1.88

type ListTablesResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 表的总个数。
	TableCount *int32 `json:"table_count,omitempty"`

	// 表的信息。
	Tables         *[]Table `json:"tables,omitempty"`
	HttpStatusCode int      `json:"-"`
}

ListTablesResponse Response Object

func (ListTablesResponse) String added in v0.1.88

func (o ListTablesResponse) String() string

type Metric added in v0.1.88

type Metric struct {

	// 所有输入流。
	Sources *[]FlinkJobMetricInfo `json:"sources,omitempty"`

	// 所有输出流。
	Sinks *[]FlinkJobMetricInfo `json:"sinks,omitempty"`

	// 总输入速率
	TotalReadRate *float64 `json:"total_read_rate,omitempty"`

	// 总输出速率
	TotalWriteRate *float64 `json:"total_write_rate,omitempty"`
}

Metric 作业的所有输入输出监控信息。

func (Metric) String added in v0.1.88

func (o Metric) String() string

type PackageResource added in v0.1.88

type PackageResource struct {

	// 资源包上传的unix时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 更新已上传资源包的unix时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 资源类型。
	ResourceType *string `json:"resource_type,omitempty"`

	// 资源名。
	ResourceName *string `json:"resource_name,omitempty"`

	// \"UPLOADING\"表示正在上传。 \"READY\"表示资源包已上传 。 \"FAILED\"表示资源包上传失败。
	Status *string `json:"status,omitempty"`

	// 资源包在队列中的名字。
	UnderlyingName *string `json:"underlying_name,omitempty"`

	// 资源包拥有者。
	Owner *string `json:"owner,omitempty"`
}

PackageResource 已上传的用户资源名列表。

func (PackageResource) String added in v0.1.88

func (o PackageResource) String() string

type PackageResourceGroup added in v0.1.90

type PackageResourceGroup struct {
	GroupName *string `json:"group_name,omitempty"`

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

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

	Details *[]PackageResource `json:"details,omitempty"`

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

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

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

	IsAsync *bool `json:"is_async,omitempty"`
}

func (PackageResourceGroup) String added in v0.1.90

func (o PackageResourceGroup) String() string

type PackageResourceMoudle added in v0.1.88

type PackageResourceMoudle struct {

	// 模块名。
	ModuleName *string `json:"module_name,omitempty"`

	// 模块类型。
	ModuleType *string `json:"module_type,omitempty"`

	// \"UPLOADING\"表示正在上传 \"READY\"表示模块包已上传 \"FAILED\"表示模块包上传失败
	Status *string `json:"status,omitempty"`

	// 模块描述。
	Description *string `json:"description,omitempty"`

	// 该模块包含的资源包名列表。
	Resources *[]string `json:"resources,omitempty"`

	// 模块上传的unix时间。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 模块更新的unix时间。
	UpdateTime *int64 `json:"update_time,omitempty"`
}

PackageResourceMoudle 系统内置资源模块列表。

func (PackageResourceMoudle) String added in v0.1.88

func (o PackageResourceMoudle) String() string

type Partition added in v0.1.88

type Partition struct {

	// 分区名
	PartitionName string `json:"partition_name"`

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

	// 最后改动时间
	LastAccessTime int64 `json:"last_access_time"`

	// 路径,外表显示,内表不显示
	Locations *[]string `json:"locations,omitempty"`

	// 最后一个ddl语句执行时间,时间戳单位:秒
	LastDdlTime *int64 `json:"last_ddl_time,omitempty"`

	// 该分区数据总行数
	NumRows *int64 `json:"num_rows,omitempty"`

	// 分区文件数
	NumFiles *int64 `json:"num_files,omitempty"`

	// 该分区总的数据大小(单位:字节)
	TotalSize *int64 `json:"total_size,omitempty"`
}

func (Partition) String added in v0.1.88

func (o Partition) String() string

type PartitionList added in v0.1.90

type PartitionList struct {

	// 总个数
	TotalCount int64 `json:"total_count"`

	// 分区信息列表
	PartitionInfos []Partition `json:"partition_infos"`
}

func (PartitionList) String added in v0.1.90

func (o PartitionList) String() string

type PreviewSqlJobResultRequest added in v0.1.68

type PreviewSqlJobResultRequest struct {

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

	// 指定获取作业结果的执行队列名称。若不指定则使用默认的系统队列
	QueueName *string `json:"queue-name,omitempty"`
}

PreviewSqlJobResultRequest Request Object

func (PreviewSqlJobResultRequest) String added in v0.1.68

type PreviewSqlJobResultResponse added in v0.1.68

type PreviewSqlJobResultResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	JobId *string `json:"job_id,omitempty"`

	// 作业类型,包含DDL、DCL、IMPORT、EXPORT、QUERY、INSERT。  目前仅支持查看“QUERY”类型作业的执行结果。
	JobType *PreviewSqlJobResultResponseJobType `json:"job_type,omitempty"`

	// 作业结果总条数。
	RowCount *int32 `json:"row_count,omitempty"`

	// 作业执行过程中扫描的数据量。
	InputSize *int64 `json:"input_size,omitempty"`

	// 作业结果列名称和类型。
	Schema *[]map[string]string `json:"schema,omitempty"`

	// 作业结果集。
	Rows           *[][]interface{} `json:"rows,omitempty"`
	HttpStatusCode int              `json:"-"`
}

PreviewSqlJobResultResponse Response Object

func (PreviewSqlJobResultResponse) String added in v0.1.68

type PreviewSqlJobResultResponseJobType added in v0.1.68

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

func (PreviewSqlJobResultResponseJobType) MarshalJSON added in v0.1.68

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

func (*PreviewSqlJobResultResponseJobType) UnmarshalJSON added in v0.1.68

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

func (PreviewSqlJobResultResponseJobType) Value added in v0.1.68

type PreviewTableRequest added in v0.1.88

type PreviewTableRequest struct {

	// 待预览的表所在的数据库名称。
	DatabaseName string `json:"database_name"`

	// 待预览的表名称。
	TableName string `json:"table_name"`

	// 预览表的模式,取值为““SYNC””或者““ASYNC””默认值为:“SYNC”。
	Mode *string `json:"mode,omitempty"`
}

PreviewTableRequest Request Object

func (PreviewTableRequest) String added in v0.1.88

func (o PreviewTableRequest) String() string

type PreviewTableResponse added in v0.1.88

type PreviewTableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 表的列名称和类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 预览的表内容。
	Rows           *[]interface{} `json:"rows,omitempty"`
	HttpStatusCode int            `json:"-"`
}

PreviewTableResponse Response Object

func (PreviewTableResponse) String added in v0.1.88

func (o PreviewTableResponse) String() string

type Privilege

type Privilege struct {

	// 赋权的DLI资源,具体可参考https://support.huaweicloud.com/usermanual-dli/dli_01_0417.html
	Object string `json:"object"`

	// 待赋权,回收或更新的权限列表。 说明: 若“action”为“update”,更新列表为空,则表示回收用户在DLI的所有资源权限。
	Privileges []string `json:"privileges"`
}

func (Privilege) String

func (o Privilege) String() string

type Queue added in v0.1.88

type Queue struct {

	// 队列ID。
	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"`

	// 队列的类型。: sql general all 如果不指定,默认为“sql”。
	QueueType *string `json:"queue_type,omitempty"`

	// 队列的实际CU。
	CuCount *int32 `json:"cu_count,omitempty"`

	// 队列的收费模式。 “1”表示按照CU时收费。 “2”表示按照包年包月收费。
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 队列的资源ID。
	ResourceId *string `json:"resource_id,omitempty"`

	// 企业项目ID。0”表示default,即默认的企业项目。 说明: 开通了企业管理服务的用户可设置该参数绑定指定的项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 队列的虚拟私有云(VPC)的网段。建议使用网段:10.0.0.0/8~28,172.16.0.0/12~28,192.168.0.0/16~28。
	CidrInVpc *string `json:"cidr_in_vpc,omitempty"`

	// 管理子网的网段。
	CidrInMgntsubnet *string `json:"cidr_in_mgntsubnet,omitempty"`

	// 子网网段。
	CidrInSubnet *string `json:"cidr_in_subnet,omitempty"`

	// 队列类型。 0:共享队列 1:专属队列
	ResourceMode *int32 `json:"resource_mode,omitempty"`

	// 队列计算资源的cpu架构。
	Platform *string `json:"platform,omitempty"`

	// 是否在重启状态。默认值为“false”。
	IsRestarting *bool `json:"is_restarting,omitempty"`

	// 队列的标签信息,目前只支持设置跨az配置,multi_az=2
	Labels *string `json:"labels,omitempty"`

	// 队列特性。支持以下两种类型:basic:基础型ai:AI增强型(仅SQL的x86_64专属队列支持选择)默认值为“basic”。
	Feature *string `json:"feature,omitempty"`

	// 队列所属资源类型, vm或container。
	ResourceType *string `json:"resource_type,omitempty"`

	// 队列的规格大小。对于包周期队列,表示包周期部分的CU值;对于按需队列,表示用户购买队列时的初始值。
	CuSpec *int32 `json:"cu_spec,omitempty"`

	// 当前队列弹性扩缩容的CU值上限。
	CuScaleOutLimit *int32 `json:"cu_scale_out_limit,omitempty"`

	// 当前队列弹性扩缩容的CU值下限。
	CuScaleInLimit *int32 `json:"cu_scale_in_limit,omitempty"`

	// 弹性资源池名称。
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`

	// 队列支持的Spark版本。
	SupportSparkVersions *[]string `json:"support_spark_versions,omitempty"`

	// 队列默认的Spark版本。
	DefaultSparkVersion *string `json:"default_spark_version,omitempty"`

	// 队列支持的HetuEngine版本。
	SupportHetuEngineVersions *[]string `json:"support_hetu_engine_versions,omitempty"`

	// 队列默认的HetuEngine版本。
	DefaultHetuEngineVersion *string `json:"default_hetu_engine_version,omitempty"`

	// 队列支持的Flink SQL版本。
	SupportFlinkSqlVersions *[]string `json:"support_flink_sql_versions,omitempty"`

	// 队列默认的Flink SQL版本。
	DefaultFlinkSqlVersion *string `json:"default_flink_sql_version,omitempty"`

	// 队列支持的Flink JAR版本。
	SupportFlinkJarVersions *[]string `json:"support_flink_jar_versions,omitempty"`

	// 队列默认的Flink JAR版本。
	DefaultFlinkJarVersion *string `json:"default_flink_jar_version,omitempty"`
}

Queue 查询所有队列的响应参数。

func (Queue) String added in v0.1.88

func (o Queue) String() string

type QueuePlan added in v0.1.88

type QueuePlan struct {

	// 扩缩容计划的ID编号。
	Id *int64 `json:"id,omitempty"`

	// 扩缩容计划的名称。
	PlanName *string `json:"plan_name,omitempty"`

	// 队列扩缩容计划的目标CU值。
	TargetCu *int32 `json:"target_cu,omitempty"`

	// 队列扩缩容计划的起始时(24小时制)。
	StartHour *int32 `json:"start_hour,omitempty"`

	// 定时扩缩容计划的起始分。
	StartMinute *int32 `json:"start_minute,omitempty"`

	// 定时扩缩容计划的重复周期规律
	RepeatDay []QueuePlanRepeatDay `json:"repeat_day"`

	// 有效期开始时间(13位时间戳)
	ValidDateBegin *int64 `json:"valid_date_begin,omitempty"`

	// 有效期结束时间(13位时间戳)
	ValidDateEnd *int64 `json:"valid_date_end,omitempty"`

	// 当前的扩缩容计划是否激活。
	Activate *bool `json:"activate,omitempty"`

	// 当前扩缩容计划最近一次执行的时间。
	LastExecuteTime *int64 `json:"last_execute_time,omitempty"`
}

QueuePlan 查询指定队列定时扩缩容信息的响应参数。

func (QueuePlan) String added in v0.1.88

func (o QueuePlan) String() string

type QueuePlanRepeatDay added in v0.1.88

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

func (QueuePlanRepeatDay) MarshalJSON added in v0.1.88

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

func (*QueuePlanRepeatDay) UnmarshalJSON added in v0.1.88

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

func (QueuePlanRepeatDay) Value added in v0.1.88

func (c QueuePlanRepeatDay) Value() string

type QueuePlanRepeatDayEnum added in v0.1.88

type QueuePlanRepeatDayEnum struct {
	SUNDAY    QueuePlanRepeatDay
	MONDAY    QueuePlanRepeatDay
	TUESDAY   QueuePlanRepeatDay
	WEDNESDAY QueuePlanRepeatDay
	THURSDAY  QueuePlanRepeatDay
	FRIDAY    QueuePlanRepeatDay
	SATURDAY  QueuePlanRepeatDay
}

func GetQueuePlanRepeatDayEnum added in v0.1.88

func GetQueuePlanRepeatDayEnum() QueuePlanRepeatDayEnum

type QueuePlanRequestBody added in v0.1.88

type QueuePlanRequestBody struct {

	// 队列扩缩容计划名称,名称只能包含数字、英文字母和下划线,但不能是纯数字,且不能以下划线开头。
	PlanName string `json:"plan_name"`

	// 队列扩缩容计划CU的目标值
	TargetCu int32 `json:"target_cu"`

	// 队列扩缩容计划起始小时时间
	StartHour int32 `json:"start_hour"`

	// 队列扩缩容计划的起始分钟时间
	StartMinute int32 `json:"start_minute"`

	// 定时扩缩容计划的重复周期规律,可以选择周一到周日的某一天、某几天、或者不选择。如果不选择,则会在当前时间后的start_hour:start_minute时间点执行扩缩容计划。如:\"repeat_day\": [\"MONDAY\", \"TUESDAY\", \"WEDNESDAY\",\"SUNDAY\"]
	RepeatDay []QueuePlanRequestBodyRepeatDay `json:"repeat_day"`

	// 有效期开始时间(13位时间戳)
	ValidDateBegin *int64 `json:"valid_date_begin,omitempty"`

	// 有效期结束时间(13位时间戳)
	ValidDateEnd *int64 `json:"valid_date_end,omitempty"`

	// 当前设置的扩缩容计划是否激活,默认为激活
	Activate *bool `json:"activate,omitempty"`
}

QueuePlanRequestBody 创建扩缩容计划的body体。

func (QueuePlanRequestBody) String added in v0.1.88

func (o QueuePlanRequestBody) String() string

type QueuePlanRequestBodyRepeatDay added in v0.1.88

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

func (QueuePlanRequestBodyRepeatDay) MarshalJSON added in v0.1.88

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

func (*QueuePlanRequestBodyRepeatDay) UnmarshalJSON added in v0.1.88

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

func (QueuePlanRequestBodyRepeatDay) Value added in v0.1.88

type QueuePlanRequestBodyRepeatDayEnum added in v0.1.88

func GetQueuePlanRequestBodyRepeatDayEnum added in v0.1.88

func GetQueuePlanRequestBodyRepeatDayEnum() QueuePlanRequestBodyRepeatDayEnum

type QueueProperty added in v0.1.90

type QueueProperty struct {

	// 返回属性值对应的key值 computeEngine.maxInstances, 队列能启动的最大spark driver数量 computeEngine.maxPrefetchInstance, 队列预先启动的最大spark driver数量 job.maxConcurrent,单个spark driver能同时运行的最大任务数量 multipleSc.support,是否支持设置多个spark driver
	Key QueuePropertyKey `json:"key"`

	Value string `json:"value"`
}

func (QueueProperty) String added in v0.1.90

func (o QueueProperty) String() string

type QueuePropertyKey added in v0.1.90

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

func (QueuePropertyKey) MarshalJSON added in v0.1.90

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

func (*QueuePropertyKey) UnmarshalJSON added in v0.1.90

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

func (QueuePropertyKey) Value added in v0.1.90

func (c QueuePropertyKey) Value() string

type QueuePropertyKeyEnum added in v0.1.90

type QueuePropertyKeyEnum struct {
	COMPUTE_ENGINE_MAX_INSTANCES         QueuePropertyKey
	COMPUTE_ENGINE_MAX_PREFETCH_INSTANCE QueuePropertyKey
	JOB_MAX_CONCURRENT                   QueuePropertyKey
	MULTIPLE_SC_SUPPORT                  QueuePropertyKey
}

func GetQueuePropertyKeyEnum added in v0.1.90

func GetQueuePropertyKeyEnum() QueuePropertyKeyEnum

type QueueScalingPolicy added in v0.1.88

type QueueScalingPolicy struct {

	// 策略优先级1-100,100优先级最高
	Priority int32 `json:"priority"`

	// 开始时间
	ImpactStartTime string `json:"impact_start_time"`

	// 结束时间
	ImpactStopTime string `json:"impact_stop_time"`

	// 最小cu数量
	MinCu int32 `json:"min_cu"`

	// 最大cu数量
	MaxCu int32 `json:"max_cu"`
}

func (QueueScalingPolicy) String added in v0.1.88

func (o QueueScalingPolicy) String() string

type QueueUserPrivilege added in v0.1.88

type QueueUserPrivilege struct {

	// 判断用户是否为管理员。
	IsAdmin *bool `json:"is_admin,omitempty"`

	// 用户名称,即该用户在当前数据库上有权限。
	UserName *string `json:"user_name,omitempty"`

	// 该用户在数据库上的权限
	Privileges *[]string `json:"privileges,omitempty"`
}

QueueUserPrivilege 权限信息

func (QueueUserPrivilege) String added in v0.1.88

func (o QueueUserPrivilege) String() string

type QuotaInfo added in v0.1.88

type QuotaInfo struct {
	Type *string `json:"type,omitempty"`

	// 配额的最小值
	Min *int32 `json:"min,omitempty"`

	// 配额的最大值
	Max *int32 `json:"max,omitempty"`

	// 目前的配额
	Quota *int32 `json:"quota,omitempty"`

	// 已用的配额
	Used *int32 `json:"used,omitempty"`
}

func (QuotaInfo) String added in v0.1.88

func (o QuotaInfo) String() string

type QuotaList added in v0.1.90

type QuotaList struct {
	Resources *[]QuotaInfo `json:"resources,omitempty"`
}

func (QuotaList) String added in v0.1.90

func (o QuotaList) String() string

type RegisterAuthorizedQueueRequest

type RegisterAuthorizedQueueRequest struct {
	Body *RegisterAuthorizedQueueRequestBody `json:"body,omitempty"`
}

RegisterAuthorizedQueueRequest Request Object

func (RegisterAuthorizedQueueRequest) String

type RegisterAuthorizedQueueRequestBody added in v0.1.88

type RegisterAuthorizedQueueRequestBody struct {

	// 队列名称。
	QueueName string `json:"queue_name"`

	// 被赋权用户名称。给该用户赋使用队列的权限,回收其使用权限,或者更新其使用权限。
	UserName string `json:"user_name"`

	// 指定赋权或回收。值为:grant,revoke或update。当用户同时拥有grant和revoke权限的时候才有权限使用update操作。 grant:赋权。 revoke:回收权限。 update:清空原来的所有权限,赋予本次提供的权限数组中的权限。
	Action string `json:"action"`

	// 待赋权、回收或更新的权限列表。可操作的权限可以是以下三种权限中的一种或多种。 SUBMIT_JOB:提交作业 CANCEL_JOB :取消作业 DROP_QUEUE :删除队列 说明: 若需更新的权限列表为空,则表示回收用户在该队列的所有权限。
	Privileges []string `json:"privileges"`
}

RegisterAuthorizedQueueRequestBody 队列赋权的请求参数。

func (RegisterAuthorizedQueueRequestBody) String added in v0.1.88

type RegisterAuthorizedQueueResponse

type RegisterAuthorizedQueueResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RegisterAuthorizedQueueResponse Response Object

func (RegisterAuthorizedQueueResponse) String

type RegisterBucketRequest

type RegisterBucketRequest struct {
	Body *RegisterBucketRequestBody `json:"body,omitempty"`
}

RegisterBucketRequest Request Object

func (RegisterBucketRequest) String

func (o RegisterBucketRequest) String() string

type RegisterBucketRequestBody added in v0.1.88

type RegisterBucketRequestBody struct {
	ObsBuckets []string `json:"obs_buckets"`
}

func (RegisterBucketRequestBody) String added in v0.1.88

func (o RegisterBucketRequestBody) String() string

type RegisterBucketResponse

type RegisterBucketResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RegisterBucketResponse Response Object

func (RegisterBucketResponse) String

func (o RegisterBucketResponse) String() string

type RunAuthorizationActionRequest added in v0.1.68

type RunAuthorizationActionRequest struct {
	Body *RunAuthorizationActionRequestBody `json:"body,omitempty"`
}

RunAuthorizationActionRequest Request Object

func (RunAuthorizationActionRequest) String added in v0.1.68

type RunAuthorizationActionRequestBody added in v0.1.88

type RunAuthorizationActionRequestBody struct {

	// 被赋权的用户名称,该用户将有权访问指定的DLI资源权限,被收回或者更新访问权限。
	UserName *string `json:"user_name,omitempty"`

	// 被赋权的项目ID,数据赋权给其他项目后,该项目的管理员将 有权访问指定的DLI资源权限,被收回或者更新访问权限。
	GrantProjectId *string `json:"grant_project_id,omitempty"`

	// 指定赋权或回收。值为:grant,revoke或update。  说明:当用户同时拥有grant和revoke权限的时候才有权限使用update操作。
	Action RunAuthorizationActionRequestBodyAction `json:"action"`

	// 赋权信息。具体参数请参考Privilege参数。
	Privileges []Privilege `json:"privileges"`
}

func (RunAuthorizationActionRequestBody) String added in v0.1.88

type RunAuthorizationActionRequestBodyAction added in v0.1.88

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

func (RunAuthorizationActionRequestBodyAction) MarshalJSON added in v0.1.88

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

func (*RunAuthorizationActionRequestBodyAction) UnmarshalJSON added in v0.1.88

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

func (RunAuthorizationActionRequestBodyAction) Value added in v0.1.88

type RunAuthorizationActionRequestBodyActionEnum added in v0.1.88

type RunAuthorizationActionRequestBodyActionEnum struct {
	GRANT  RunAuthorizationActionRequestBodyAction
	REVOKE RunAuthorizationActionRequestBodyAction
	UPDATE RunAuthorizationActionRequestBodyAction
}

func GetRunAuthorizationActionRequestBodyActionEnum added in v0.1.88

func GetRunAuthorizationActionRequestBodyActionEnum() RunAuthorizationActionRequestBodyActionEnum

type RunAuthorizationActionResponse added in v0.1.68

type RunAuthorizationActionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RunAuthorizationActionResponse Response Object

func (RunAuthorizationActionResponse) String added in v0.1.68

type RunCatalogActionRequest added in v0.1.87

type RunCatalogActionRequest struct {
	Body *RunCatalogActionRequestBody `json:"body,omitempty"`
}

RunCatalogActionRequest Request Object

func (RunCatalogActionRequest) String added in v0.1.87

func (o RunCatalogActionRequest) String() string

type RunCatalogActionRequestBody added in v0.1.87

type RunCatalogActionRequestBody struct {

	// catalog操作:bind或者unbind。
	Action RunCatalogActionRequestBodyAction `json:"action"`

	// DLI侧catalog映射名称.
	Name string `json:"name"`

	Parameters map[string]string `json:"parameters"`
}

func (RunCatalogActionRequestBody) String added in v0.1.87

type RunCatalogActionRequestBodyAction added in v0.1.87

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

func (RunCatalogActionRequestBodyAction) MarshalJSON added in v0.1.87

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

func (*RunCatalogActionRequestBodyAction) UnmarshalJSON added in v0.1.87

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

func (RunCatalogActionRequestBodyAction) Value added in v0.1.87

type RunCatalogActionRequestBodyActionEnum added in v0.1.87

type RunCatalogActionRequestBodyActionEnum struct {
	BIND   RunCatalogActionRequestBodyAction
	UNBIND RunCatalogActionRequestBodyAction
}

func GetRunCatalogActionRequestBodyActionEnum added in v0.1.87

func GetRunCatalogActionRequestBodyActionEnum() RunCatalogActionRequestBodyActionEnum

type RunCatalogActionResponse added in v0.1.87

type RunCatalogActionResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RunCatalogActionResponse Response Object

func (RunCatalogActionResponse) String added in v0.1.87

func (o RunCatalogActionResponse) String() string

type RunDataAuthorizationActionRequest added in v0.1.88

type RunDataAuthorizationActionRequest struct {
	Body *RunDataAuthorizationActionRequestBody `json:"body,omitempty"`
}

RunDataAuthorizationActionRequest Request Object

func (RunDataAuthorizationActionRequest) String added in v0.1.88

type RunDataAuthorizationActionRequestBody added in v0.1.88

type RunDataAuthorizationActionRequestBody struct {

	// 被赋权的用户名称,该用户将有权访问指定的数据库或数据表,被收回或者更新访问权限。
	UserName string `json:"user_name"`

	// 指定赋权或回收。值为:grant,revoke或update。 说明: 当用户同时拥有grant和revoke权限的时候才有权限使用update操作。
	Action string `json:"action"`

	// 赋权信息。
	Privileges []DataAuthorizationPrivilege `json:"privileges"`
}

RunDataAuthorizationActionRequestBody 数据授权的请求body体。

func (RunDataAuthorizationActionRequestBody) String added in v0.1.88

type RunDataAuthorizationActionResponse added in v0.1.88

type RunDataAuthorizationActionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RunDataAuthorizationActionResponse Response Object

func (RunDataAuthorizationActionResponse) String added in v0.1.88

type RunIefJobActionCallBackRequest

type RunIefJobActionCallBackRequest struct {
	Body *RunIefJobActionCallBackRequestBody `json:"body,omitempty"`
}

RunIefJobActionCallBackRequest Request Object

func (RunIefJobActionCallBackRequest) String

type RunIefJobActionCallBackRequestBody added in v0.1.88

type RunIefJobActionCallBackRequestBody struct {

	// 消息id
	MessageId string `json:"message_id"`

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

RunIefJobActionCallBackRequestBody IEF Flink job action回调的请求body体。

func (RunIefJobActionCallBackRequestBody) String added in v0.1.88

type RunIefJobActionCallBackResponse

type RunIefJobActionCallBackResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

RunIefJobActionCallBackResponse Response Object

func (RunIefJobActionCallBackResponse) String

type RunQueueActionRequest

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

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

RunQueueActionRequest Request Object

func (RunQueueActionRequest) String

func (o RunQueueActionRequest) String() string

type RunQueueActionRequestBody added in v0.1.88

type RunQueueActionRequestBody struct {

	// 执行动作:restart:重启scale_out:扩容scale_in:缩容,目前只支持restart、scale_out、scale_in。
	Action string `json:"action"`

	// 是否强制重启,action为restart时可选择配置,默认为false。
	Force *bool `json:"force,omitempty"`

	// 队列的实际CU。
	CuCount *int32 `json:"cu_count,omitempty"`
}

func (RunQueueActionRequestBody) String added in v0.1.88

func (o RunQueueActionRequestBody) String() string

type RunQueueActionResponse

type RunQueueActionResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 当force为true的时候返回的jobId,可以根据job_id的状态来看最终结果
	JobId *string `json:"job_id,omitempty"`

	// 扩缩容的队列名称。
	QueueName *string `json:"queue_name,omitempty"`

	// 扩缩容结果
	Result         *bool `json:"result,omitempty"`
	HttpStatusCode int   `json:"-"`
}

RunQueueActionResponse Response Object

func (RunQueueActionResponse) String

func (o RunQueueActionResponse) String() string

type ShowCatalogRequest added in v0.1.87

type ShowCatalogRequest struct {

	// catalog名称。
	CatalogName string `json:"catalog_name"`
}

ShowCatalogRequest Request Object

func (ShowCatalogRequest) String added in v0.1.87

func (o ShowCatalogRequest) String() string

type ShowCatalogResponse added in v0.1.87

type ShowCatalogResponse struct {

	// 是否成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// DLI侧catalog映射名称。
	Name *string `json:"name,omitempty"`

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

	Parameters     map[string]string `json:"parameters,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ShowCatalogResponse Response Object

func (ShowCatalogResponse) String added in v0.1.87

func (o ShowCatalogResponse) String() string

type ShowConnectivityTaskRequest added in v0.1.68

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

	TaskId string `json:"task_id"`
}

ShowConnectivityTaskRequest Request Object

func (ShowConnectivityTaskRequest) String added in v0.1.68

type ShowConnectivityTaskResponse added in v0.1.68

type ShowConnectivityTaskResponse struct {

	// 请求发送是否成功。“true”表示请求发送成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 连通性测试结果
	Connectivity   *string `json:"connectivity,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowConnectivityTaskResponse Response Object

func (ShowConnectivityTaskResponse) String added in v0.1.68

type ShowDatasourceConnectionRequest

type ShowDatasourceConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`
}

ShowDatasourceConnectionRequest Request Object

func (ShowDatasourceConnectionRequest) String

type ShowDatasourceConnectionResponse

type ShowDatasourceConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息为空。
	Message *string `json:"message,omitempty"`

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId *string `json:"connection_id,omitempty"`

	// 创建连接时,用户填写的队列的访问地址。
	Destination *string `json:"destination,omitempty"`

	// 连接状态。CREATING:跨源连接正在创建中;ACTIVE:跨源连接创建成功,与目的地址连接正常;FAILED:跨源连接创建失败;DELETED:跨源连接已被删除。
	State *string `json:"state,omitempty"`

	// 正在创建的跨源连接进度,显示0.0至1.0代表0%至100%。
	Process *float64 `json:"process,omitempty"`

	// 创建连接时,用户自定义的连接名称。
	Name *string `json:"name,omitempty"`

	// 用于建立跨源关联表时,需要使用到的连接url。
	ConnectionUrl *string `json:"connection_url,omitempty"`

	// Serverless Spark队列名称。SQL队列模式下建立的跨源连接,该字段为空。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 创建连接时,用户指定的对端服务(CloudTable/CloudTable.OpenTSDB/MRS.OpenTSDB/DWS/RDS/CSS)。
	Service *string `json:"service,omitempty"`

	// 创建连接的时间。为UTC的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 当前跨源已绑定的队列信息
	AvailableQueueInfo *[]AvailableQueueInfo `json:"available_queue_info,omitempty"`
	HttpStatusCode     int                   `json:"-"`
}

ShowDatasourceConnectionResponse Response Object

func (ShowDatasourceConnectionResponse) String

type ShowDliAgencyRequest

type ShowDliAgencyRequest struct {
}

ShowDliAgencyRequest Request Object

func (ShowDliAgencyRequest) String

func (o ShowDliAgencyRequest) String() string

type ShowDliAgencyResponse

type ShowDliAgencyResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 版本号
	Version *string `json:"version,omitempty"`

	// 当前已有委托
	CurrentRoles   *[]string `json:"current_roles,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowDliAgencyResponse Response Object

func (ShowDliAgencyResponse) String

func (o ShowDliAgencyResponse) String() string

type ShowEnhancedConnectionPrivilegeRequest added in v0.1.68

type ShowEnhancedConnectionPrivilegeRequest struct {

	// 增强型跨源连接ID。
	ConnectionId string `json:"connection_id"`
}

ShowEnhancedConnectionPrivilegeRequest Request Object

func (ShowEnhancedConnectionPrivilegeRequest) String added in v0.1.68

type ShowEnhancedConnectionPrivilegeResponse added in v0.1.68

type ShowEnhancedConnectionPrivilegeResponse struct {

	// 行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 增强型跨源连接ID,用于标识跨源连接的UUID。
	ConnectionId *string `json:"connection_id,omitempty"`

	// 跨源连接各个授权项目的信息。
	Privileges     *[]EnhancedConnectionPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                            `json:"-"`
}

ShowEnhancedConnectionPrivilegeResponse Response Object

func (ShowEnhancedConnectionPrivilegeResponse) String added in v0.1.68

type ShowEnhancedConnectionRequest

type ShowEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`
}

ShowEnhancedConnectionRequest Request Object

func (ShowEnhancedConnectionRequest) String

type ShowEnhancedConnectionResponse

type ShowEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息为空。
	Message *string `json:"message,omitempty"`

	// 连接ID,用于标识跨源连接的UUID。
	Id *string `json:"id,omitempty"`

	// 创建连接时,用户自定义的连接名称。
	Name *string `json:"name,omitempty"`

	// 连接状态,包括以下两种状态: ACTIVE:已激活 DELETED:已删除
	Status *string `json:"status,omitempty"`

	// 各个队列创建对等连接的信息。
	AvailableQueueInfo *[]EnhancedConnectionResource `json:"available_queue_info,omitempty"`

	// 各个弹性资源池创建对等连接的信息。
	ElasticResourcePools *[]EnhancedConnectionResource `json:"elastic_resource_pools,omitempty"`

	// 对应服务的虚拟私有云标识。
	DestVpcId *string `json:"dest_vpc_id,omitempty"`

	// 对应服务的子网网络标识。
	DestNetworkId *string `json:"dest_network_id,omitempty"`

	// 创建连接的时间。为UTC的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 用户自定义主机信息。
	Hosts          *[]EnhancedConnectionHost `json:"hosts,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

ShowEnhancedConnectionResponse Response Object

func (ShowEnhancedConnectionResponse) String

type ShowFlinkJobExecutionGraphRequest added in v0.1.68

type ShowFlinkJobExecutionGraphRequest struct {

	// 作业ID。
	JobId int64 `json:"job_id"`
}

ShowFlinkJobExecutionGraphRequest Request Object

func (ShowFlinkJobExecutionGraphRequest) String added in v0.1.68

type ShowFlinkJobExecutionGraphResponse added in v0.1.68

type ShowFlinkJobExecutionGraphResponse struct {

	// 请求是否成功
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

	ExecuteGraph   *FlinkJobExecutionGraph `json:"execute_graph,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

ShowFlinkJobExecutionGraphResponse Response Object

func (ShowFlinkJobExecutionGraphResponse) String added in v0.1.68

type ShowFlinkJobRequest

type ShowFlinkJobRequest struct {

	// 作业ID。
	JobId int64 `json:"job_id"`
}

ShowFlinkJobRequest Request Object

func (ShowFlinkJobRequest) String

func (o ShowFlinkJobRequest) String() string

type ShowFlinkJobResponse

type ShowFlinkJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

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

ShowFlinkJobResponse Response Object

func (ShowFlinkJobResponse) String

func (o ShowFlinkJobResponse) String() string

type ShowFlinkMetricRequest

type ShowFlinkMetricRequest struct {
	Body *ShowFlinkMetricRequestBody `json:"body,omitempty"`
}

ShowFlinkMetricRequest Request Object

func (ShowFlinkMetricRequest) String

func (o ShowFlinkMetricRequest) String() string

type ShowFlinkMetricRequestBody added in v0.1.88

type ShowFlinkMetricRequestBody struct {

	// 作业ID列表。
	JobIds []int64 `json:"job_ids"`
}

ShowFlinkMetricRequestBody 查询作业监控信息

func (ShowFlinkMetricRequestBody) String added in v0.1.88

type ShowFlinkMetricResponse

type ShowFlinkMetricResponse struct {

	// 请求是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

	Metrics        *FlinkMetric `json:"metrics,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ShowFlinkMetricResponse Response Object

func (ShowFlinkMetricResponse) String

func (o ShowFlinkMetricResponse) String() string

type ShowJobResourceRequest added in v0.1.88

type ShowJobResourceRequest struct {

	// 资源名。
	ResourceName string `json:"resource_name"`

	Group *string `json:"group,omitempty"`
}

ShowJobResourceRequest Request Object

func (ShowJobResourceRequest) String added in v0.1.88

func (o ShowJobResourceRequest) String() string

type ShowJobResourceResponse added in v0.1.88

type ShowJobResourceResponse struct {

	// 资源包上传的unix时间。是单位为“毫秒”的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 更新已上传资源包的unix时间。是单位为“毫秒”的时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 资源类型。
	ResourceType *string `json:"resource_type,omitempty"`

	// 资源名。
	ResourceName *string `json:"resource_name,omitempty"`

	// \"UPLOADING\"表示正在上传 \"READY\"表示资源包已上传 \"FAILED\"表示资源包上传失败
	Status *string `json:"status,omitempty"`

	// 资源包在队列中的名字。
	UnderlyingName *string `json:"underlying_name,omitempty"`

	// 资源包拥有者
	Owner          *string `json:"owner,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowJobResourceResponse Response Object

func (ShowJobResourceResponse) String added in v0.1.88

func (o ShowJobResourceResponse) String() string

type ShowQueueRequest added in v0.1.68

type ShowQueueRequest struct {

	// 指定查询的队列名称。
	QueueName string `json:"queue_name"`
}

ShowQueueRequest Request Object

func (ShowQueueRequest) String added in v0.1.68

func (o ShowQueueRequest) String() string

type ShowQueueResponse added in v0.1.68

type ShowQueueResponse struct {

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 队列ID。
	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"`

	// 队列类型。sql/general/all, 如果不指定,默认为“sql”。
	QueueType *string `json:"queueType,omitempty"`

	// 与队列绑定的最小计算单元个数。设置值当前只支持16,64,256。
	CuCount *int32 `json:"cuCount,omitempty"`

	// 队列的收费模式。 “1”表示按照CU时收费。 “2”表示按照包年包月收费。
	ChargingMode *int32 `json:"chargingMode,omitempty"`

	// 队列的资源ID。
	ResourceId *string `json:"resource_id,omitempty"`

	// 队列类型。 0:共享队列 1:专属队列
	ResourceMode *int32 `json:"resource_mode,omitempty"`

	// 企业项目ID。\"0”表示default,即默认的企业项目。 说明: 开通了企业管理服务的用户可设置该参数绑定指定的项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 资源类型。 vm:ecf集群 container:容器化集群(k8s)
	ResourceType *string `json:"resource_type,omitempty"`

	// 队列的规格大小。对于包周期队列,表示包周期部分的CU值;对于按需队列,表示用户购买队列时的初始值。
	CuSpec *int32 `json:"cu_spec,omitempty"`

	// 当前队列弹性扩缩容的CU值上限。
	CuScaleOutLimit *int32 `json:"cu_scale_out_limit,omitempty"`

	// 当前队列弹性扩缩容的CU值下限。
	CuScaleInLimit *int32 `json:"cu_scale_in_limit,omitempty"`

	// 弹性资源池名称。
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,omitempty"`

	// 队列支持的Spark版本。
	SupportSparkVersions *[]string `json:"support_spark_versions,omitempty"`

	// 队列默认的Spark版本。
	DefaultSparkVersion *string `json:"default_spark_version,omitempty"`

	// 队列支持的HetuEngine版本。
	SupportHetuEngineVersions *[]string `json:"support_hetu_engine_versions,omitempty"`

	// 队列默认的HetuEngine版本。
	DefaultHetuEngineVersion *string `json:"default_hetu_engine_version,omitempty"`

	// 队列支持的Flink SQL版本。
	SupportFlinkSqlVersions *[]string `json:"support_flink_sql_versions,omitempty"`

	// 队列默认的Flink SQL版本。
	DefaultFlinkSqlVersion *string `json:"default_flink_sql_version,omitempty"`

	// 队列支持的Flink JAR版本。
	SupportFlinkJarVersions *[]string `json:"support_flink_jar_versions,omitempty"`

	// 队列默认的Flink JAR版本。
	DefaultFlinkJarVersion *string `json:"default_flink_jar_version,omitempty"`
	HttpStatusCode         int     `json:"-"`
}

ShowQueueResponse Response Object

func (ShowQueueResponse) String added in v0.1.68

func (o ShowQueueResponse) String() string

type ShowQuotaRequest added in v0.1.70

type ShowQuotaRequest struct {
}

ShowQuotaRequest Request Object

func (ShowQuotaRequest) String added in v0.1.70

func (o ShowQuotaRequest) String() string

type ShowQuotaResponse added in v0.1.70

type ShowQuotaResponse struct {

	// 是否成功
	IsSuccess *bool `json:"is_success,omitempty"`

	Quotas         *QuotaList `json:"quotas,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ShowQuotaResponse Response Object

func (ShowQuotaResponse) String added in v0.1.70

func (o ShowQuotaResponse) String() string

type ShowSparkJobLogRequest added in v0.1.88

type ShowSparkJobLogRequest struct {

	// 批处理作业的ID。
	BatchId string `json:"batch_id"`

	// 起始日志的行号,默认显示最后100行日志。如果日志不足100行,从0行开始显示。
	From *int32 `json:"from,omitempty"`

	// 当提交的作业进行重试时,会有多个driver日志。index用于指定driver日志的索引号,默认为0。需与type参数一起使用。
	Index *int32 `json:"index,omitempty"`

	// 查询日志的数量。
	Size *int32 `json:"size,omitempty"`

	// 当type填写driver时,输出Spark Driver日志。
	Type *string `json:"type,omitempty"`
}

ShowSparkJobLogRequest Request Object

func (ShowSparkJobLogRequest) String added in v0.1.88

func (o ShowSparkJobLogRequest) String() string

type ShowSparkJobLogResponse added in v0.1.88

type ShowSparkJobLogResponse struct {

	// 批处理作业的id。
	Id *string `json:"id,omitempty"`

	// 日志起始索引。
	From *int32 `json:"from,omitempty"`

	// 日志的总记录数。
	Total *int64 `json:"total,omitempty"`

	// 显示当前批处理作业日志。
	Log            *[]string `json:"log,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowSparkJobLogResponse Response Object

func (ShowSparkJobLogResponse) String added in v0.1.88

func (o ShowSparkJobLogResponse) String() string

type ShowSparkJobRequest added in v0.1.68

type ShowSparkJobRequest struct {

	// 批处理作业的ID。
	BatchId string `json:"batch_id"`
}

ShowSparkJobRequest Request Object

func (ShowSparkJobRequest) String added in v0.1.68

func (o ShowSparkJobRequest) String() string

type ShowSparkJobResponse added in v0.1.68

type ShowSparkJobResponse struct {

	// Batch作业的id。
	Id *string `json:"id,omitempty"`

	// Batch作业的状态。包括: starting:正在启动;running:正在执行任务;dead:session已退出;success:session停止成功;recovering:正在恢复。
	State *string `json:"state,omitempty"`

	// 批处理作业的后台app id。
	AppId *string `json:"appId,omitempty"`

	// 显示当前Batch作业的最后10条记录。
	Log *[]string `json:"log,omitempty"`

	// 计算资源类型。用户自定义时返回CUSTOMIZED。
	ScType *string `json:"sc_type,omitempty"`

	// 会话所在队列。
	ClusterName *string `json:"cluster_name,omitempty"`

	// Batch的创建时间。是单位为“毫秒”的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 创建时用户指定的批处理名称,不能超过128个字符。
	Name *string `json:"name,omitempty"`

	// 批处理作业所属用户
	Owner *string `json:"owner,omitempty"`

	// 批处理作业所属代理用户(资源租户)。
	ProxyUser *string `json:"proxyUser,omitempty"`

	// 批处理作业类型,只支持spark类型参数。
	Kind *string `json:"kind,omitempty"`

	// 用于指定队列,填写已创建DLI的队列名
	Queue *string `json:"queue,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。
	Image *string `json:"image,omitempty"`

	// 请求参数详情
	ReqBody *string `json:"req_body,omitempty"`

	// 更新时间
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 作业特性。表示用户作业使用的Spark镜像类型。  basic:表示使用DLI提供的基础Spark镜像。 custom:表示使用用户自定义的Spark镜像。 ai:表示使用DLI提供的AI镜像。
	Feature *string `json:"feature,omitempty"`

	// 作业使用spark组件的版本号,在“feature”为“basic”或“ai”时填写,若不填写,则使用默认的spark组件版本号2.3.2。
	SparkVersion   *string `json:"spark_version,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowSparkJobResponse Response Object

func (ShowSparkJobResponse) String added in v0.1.68

func (o ShowSparkJobResponse) String() string

type ShowSparkJobStatusRequest added in v0.1.68

type ShowSparkJobStatusRequest struct {

	// 批处理作业的ID。
	BatchId string `json:"batch_id"`
}

ShowSparkJobStatusRequest Request Object

func (ShowSparkJobStatusRequest) String added in v0.1.68

func (o ShowSparkJobStatusRequest) String() string

type ShowSparkJobStatusResponse added in v0.1.68

type ShowSparkJobStatusResponse struct {

	// 批处理作业的ID,采用UUID(通用唯一识别码)格式。
	Id *string `json:"id,omitempty"`

	// 批处理作业的状态。starting:正在启动;running:正在执行任务;dead:session已退出;success:session停止成功;recovering:正在恢复。
	State          *string `json:"state,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowSparkJobStatusResponse Response Object

func (ShowSparkJobStatusResponse) String added in v0.1.68

type ShowSparkJobTemplateRequest added in v0.1.68

type ShowSparkJobTemplateRequest struct {
	TemplateId string `json:"template_id"`
}

ShowSparkJobTemplateRequest Request Object

func (ShowSparkJobTemplateRequest) String added in v0.1.68

type ShowSparkJobTemplateResponse added in v0.1.68

type ShowSparkJobTemplateResponse struct {

	// 模板类型
	Type *string `json:"type,omitempty"`

	// 模板id
	Id *string `json:"id,omitempty"`

	// 模板名字
	Name *string `json:"name,omitempty"`

	Body *SparkJobTemplateDetail `json:"body,omitempty"`

	// 组名
	Group *string `json:"group,omitempty"`

	// 模板描述
	Description *string `json:"description,omitempty"`

	// 语言
	Language *string `json:"language,omitempty"`

	// 模板拥有者
	Owner          *string `json:"owner,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowSparkJobTemplateResponse Response Object

func (ShowSparkJobTemplateResponse) String added in v0.1.68

type ShowSqlJobDetailRequest

type ShowSqlJobDetailRequest struct {

	// 作业ID
	JobId string `json:"job_id"`
}

ShowSqlJobDetailRequest Request Object

func (ShowSqlJobDetailRequest) String

func (o ShowSqlJobDetailRequest) String() string

type ShowSqlJobDetailResponse

type ShowSqlJobDetailResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 作业ID。
	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"`

	// 记录其操作的表所在的数据库名称。类型为Import和Export作业才有“database_name”属性。
	DatabaseName *string `json:"database_name,omitempty"`

	// 记录其操作的表名称。类型为Import和Export作业才有“table_name”属性。
	TableName *string `json:"table_name,omitempty"`

	// 导入或导出的文件路径。
	DataPath *string `json:"data_path,omitempty"`

	// 导入或导出的数据类型(当前仅支持csv)。
	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           *[]Tag `json:"tags,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowSqlJobDetailResponse Response Object

func (ShowSqlJobDetailResponse) String

func (o ShowSqlJobDetailResponse) String() string

type ShowSqlJobProgressRequest added in v0.1.68

type ShowSqlJobProgressRequest struct {

	// 作业ID
	JobId string `json:"job_id"`
}

ShowSqlJobProgressRequest Request Object

func (ShowSqlJobProgressRequest) String added in v0.1.68

func (o ShowSqlJobProgressRequest) String() string

type ShowSqlJobProgressResponse added in v0.1.68

type ShowSqlJobProgressResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

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

	// 作业状态。
	Status *string `json:"status,omitempty"`

	// 正在运行的子作业ID,如果作业还没开始运行或者运行结束,则子作业ID可能为空。
	SubJobId *int32 `json:"sub_job_id,omitempty"`

	// 正在运行的子作业的进度或者整个作业进度,该值只能粗略的估算子作业进度,不表示作业的详细进度。有两方面的含义: (1)如果整个作业刚开始运行或者在提交中,则进度展示为0;如果作业运行结束,则进度展示为1。此时progress表示整个作业的运行进度,因为没有子作业在运行,sub_job_id不展示。 (2)如果有子作业在运行中,则展示该子作业的运行进度,progress的计算方法为:子作业已经完成的task数除以子作业总的task数。此时progress表示子作业的运行进度,sub_job_id展示。
	Progress *float64 `json:"progress,omitempty"`

	// 正在运行作业的子作业的详细信息,一个作业可能包含多个子作业。
	SubJobs        *[]SubJob `json:"sub_jobs,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowSqlJobProgressResponse Response Object

func (ShowSqlJobProgressResponse) String added in v0.1.68

type ShowSqlJobStatusRequest

type ShowSqlJobStatusRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`
}

ShowSqlJobStatusRequest Request Object

func (ShowSqlJobStatusRequest) String

func (o ShowSqlJobStatusRequest) String() string

type ShowSqlJobStatusResponse

type ShowSqlJobStatusResponse struct {

	// 作业ID。
	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"`

	// 此作业的当前状态,包含提交(LAUNCHING)、运行中(RUNNING)、完成(FINISHED)、失败(FAILED)、取消(CANCELLED)。
	Status *ShowSqlJobStatusResponseStatus `json:"status,omitempty"`

	// Insert作业执行过程中扫描的记录条数。
	InputRowCount *int64 `json:"input_row_count,omitempty"`

	// Insert作业执行过程中扫描到的错误记录数。
	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	// 作业执行过程中扫描文件的大小。
	InputSize *int64 `json:"input_size,omitempty"`

	// 当前作业返回的结果总条数或insert作业插入的总条数。
	ResultCount *int32 `json:"result_count,omitempty"`

	// 记录其操作的表所在的数据库名称。类型为Import和Export作业才有“database_name”属性。
	DatabaseName *string `json:"database_name,omitempty"`

	// 记录其操作的表名称。类型为Import和Export作业才有“table_name”属性。
	TableName *string `json:"table_name,omitempty"`

	// SQL查询的相关列信息的Json字符串。
	Detail *string `json:"detail,omitempty"`

	// SQL配置参数信息Json字符串。
	UserConf *string `json:"user_conf,omitempty"`

	// 查询结果OBS路径
	ResultPath *string `json:"result_path,omitempty"`

	// 查询作业执行计划OBS路径
	ExecutionDetailsPath *string `json:"execution_details_path,omitempty"`

	// 查询结果格式
	ResultFormat *string `json:"result_format,omitempty"`

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

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 作业执行方式
	JobMode *string `json:"job_mode,omitempty"`

	// 作业标签
	Tags           *[]Tag `json:"tags,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowSqlJobStatusResponse Response Object

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

type ShowTableRequest added in v0.1.88

type ShowTableRequest struct {

	// 待描述的表所在的数据库名称。
	DatabaseName string `json:"database_name"`

	// 待描述表的名称。
	TableName string `json:"table_name"`
}

ShowTableRequest Request Object

func (ShowTableRequest) String added in v0.1.88

func (o ShowTableRequest) String() string

type ShowTableResponse added in v0.1.88

type ShowTableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message *string `json:"message,omitempty"`

	// 表的总列数。
	ColumnCount *int32 `json:"column_count,omitempty"`

	// 表的列信息,包含列名称、类型和描述信息。
	Columns *[]Column `json:"columns,omitempty"`

	// 表类型,包括“MANAGED”,“EXTERNAL”和“VIEW”。
	TableType *string `json:"table_type,omitempty"`

	// 数据类型,包括“csv”,“parquet”,“orc”,“json”,“carbon”和“avro”。
	DataType *string `json:"data_type,omitempty"`

	// 数据存储的路径,以“s3a”开头。
	DataLocation *string `json:"data_location,omitempty"`

	// 存储属性,以“key/value”的格式出现,包含delimiter,escape,quote,header,dateformat,timestampformat参数。
	StorageProperties *[]interface{} `json:"storage_properties,omitempty"`

	// 表的注释。
	TableComment *string `json:"table_comment,omitempty"`

	// 建表的语句
	CreateTableSql *string `json:"create_table_sql,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowTableResponse Response Object

func (ShowTableResponse) String added in v0.1.88

func (o ShowTableResponse) String() string

type SparkJob added in v0.1.90

type SparkJob struct {

	// Batch作业的id。
	Id *string `json:"id,omitempty"`

	// Batch作业的状态。包括: starting:正在启动;running:正在执行任务;dead:session已退出;success:session停止成功;recovering:正在恢复。
	State *string `json:"state,omitempty"`

	// 批处理作业的后台app id。
	AppId *string `json:"appId,omitempty"`

	// 显示当前Batch作业的最后10条记录。
	Log *[]string `json:"log,omitempty"`

	// 计算资源类型。用户自定义时返回CUSTOMIZED。
	ScType *string `json:"sc_type,omitempty"`

	// 会话所在队列。
	ClusterName *string `json:"cluster_name,omitempty"`

	// Batch的创建时间。是单位为“毫秒”的时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 创建时用户指定的批处理名称,不能超过128个字符。
	Name *string `json:"name,omitempty"`

	// 批处理作业所属用户
	Owner *string `json:"owner,omitempty"`

	// 批处理作业所属代理用户(资源租户)。
	ProxyUser *string `json:"proxyUser,omitempty"`

	// 批处理作业类型,只支持spark类型参数。
	Kind *string `json:"kind,omitempty"`

	// 用于指定队列,填写已创建DLI的队列名
	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"`
}

SparkJob 创建批处理作业的响应参数。

func (SparkJob) String added in v0.1.90

func (o SparkJob) String() string

type SparkJobTemplate added in v0.1.88

type SparkJobTemplate struct {

	// 模板类型
	Type *string `json:"type,omitempty"`

	// 模板id
	Id *string `json:"id,omitempty"`

	// 模板名字
	Name *string `json:"name,omitempty"`

	Body *SparkJobTemplateDetail `json:"body,omitempty"`

	// 组名
	Group *string `json:"group,omitempty"`

	// 模板描述
	Description *string `json:"description,omitempty"`

	// 语言
	Language *string `json:"language,omitempty"`

	// 模板拥有者
	Owner *string `json:"owner,omitempty"`
}

func (SparkJobTemplate) String added in v0.1.88

func (o SparkJobTemplate) String() string

type SparkJobTemplateDetail added in v0.1.88

type SparkJobTemplateDetail struct {

	// 用户已上传到DLI资源管理系统的类型为jar的资源包名。
	File string `json:"file"`

	// 批处理作业的Java/Spark主类。
	ClassName string `json:"className"`

	// 用于指定队列,填写已创建DLI的队列名。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 传入主类的参数。
	Args *[]string `json:"args,omitempty"`

	// 计算资源类型,目前可接受参数A, B, C。如果不指定,则按最小类型创建。 资源类型: A:物理资源:8核32G内存,driverCores:2;executorCores:1;driverMemory:7G;executorMemory:4G;numExecutor:6。 B:16核64G内存,2,2,7G,8G,7。 C:32核128G内存,4,2,15G,8G,14。
	ScType *string `json:"sc_type,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为jar的资源包名。
	Jars *[]string `json:"jars,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为pyFile的资源包名。
	PyFiles *[]string `json:"pyFiles,omitempty"`

	// 用户已上传到DLI资源管理系统的类型为file的资源包名。
	Files *[]string `json:"files,omitempty"`

	// 依赖的系统资源模块名,具体模块名可通过查询所有资源包接口查看。 DLI系统提供了用于执行跨源作业的依赖模块,各个不同的服务对应的模块列表如下: CloudTable/MRS HBase: sys.datasource.hbase CloudTable/MRS OpenTSDB: sys.datasource.opentsdb RDS MySQL: sys.datasource.rds RDS PostGre: 不需要选 DWS: 不需要选 CSS: sys.datasource.css
	Modules *[]string `json:"modules,omitempty"`

	// JSON对象列表,填写用户已上传到队列的类型为JSON的资源包名和类型。
	Resources *[]JobResource `json:"resources,omitempty"`

	// JSON对象列表,填写用户组类型资源,格式详见请求示例。resources中的name未进行type校验,只要此分组中存在这个名字的包即可。
	Groups *[]JobResourcesGroup `json:"groups,omitempty"`

	// batch配置项。
	Conf map[string]interface{} `json:"conf,omitempty"`

	// 创建时用户指定的批处理名称,不能超过128个字符。
	Name *string `json:"name,omitempty"`

	// Spark应用的Driver内存, 参数配置例如2G, 2048M。该配置项会替换“sc_type”中对应的默认参数,使用时必需带单位,否则会启动失败。
	DriverMemory *string `json:"driverMemory,omitempty"`

	// Spark应用Driver的CPU核数。该配置项会替换sc_type中对应的默认参数。
	DriverCores *int32 `json:"driverCores,omitempty"`

	// Spark应用的Executor内存, 参数配置例如2G, 2048M。该配置项会替换“sc_type”中对应的默认参数,使用时必需带单位,否则会启动失败。
	ExecutorMemory *string `json:"executorMemory,omitempty"`

	// Spark应用每个Executor的CPU核数。该配置项会替换sc_type中对应的默认参数。
	ExecutorCores *int32 `json:"executorCores,omitempty"`

	// Spark应用Executor的个数。该配置项会替换sc_type中对应的默认参数。
	NumExecutors *int32 `json:"numExecutors,omitempty"`

	// 作业特性,作业运行在vm队列上支持basic,在container队列上支持basic、ai、custom,其中填写custom时需要同时填写image参数。
	Feature *SparkJobTemplateDetailFeature `json:"feature,omitempty"`

	// 作业使用spark组件的版本号,在feature为“basic”或“ai”时填写,若不填写,则使用默认的spark组件版本号2.3.2。
	SparkVersion *string `json:"spark_version,omitempty"`

	// 用于指定队列,填写已创建DLI的队列名
	Queue *string `json:"queue,omitempty"`

	// 是否开启重试功能,如果开启,可在Spark作业异常失败后自动重试。默认值为“false”。
	AutoRecovery *bool `json:"auto_recovery,omitempty"`

	// 最大重试次数。最大值为“100”,默认值为“20”。
	MaxRetryTimes *int32 `json:"max_retry_times,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Spark镜像。关于如何使用自定义镜像,请参考《数据湖探索用户指南》。
	Image *string `json:"image,omitempty"`

	// 保存Spark作业的obs桶,需要保存作业时配置该参数
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 访问元数据时,需要将该参数配置为dli。
	CatalogName *string `json:"catalog_name,omitempty"`
}

SparkJobTemplateDetail 创建批处理作业请求body体。

func (SparkJobTemplateDetail) String added in v0.1.88

func (o SparkJobTemplateDetail) String() string

type SparkJobTemplateDetailFeature added in v0.1.88

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

func (SparkJobTemplateDetailFeature) MarshalJSON added in v0.1.88

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

func (*SparkJobTemplateDetailFeature) UnmarshalJSON added in v0.1.88

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

func (SparkJobTemplateDetailFeature) Value added in v0.1.88

type SparkJobTemplateDetailFeatureEnum added in v0.1.88

type SparkJobTemplateDetailFeatureEnum struct {
	BASIC  SparkJobTemplateDetailFeature
	AI     SparkJobTemplateDetailFeature
	CUSTOM SparkJobTemplateDetailFeature
}

func GetSparkJobTemplateDetailFeatureEnum added in v0.1.88

func GetSparkJobTemplateDetailFeatureEnum() SparkJobTemplateDetailFeatureEnum

type SqlJob added in v0.1.88

type SqlJob struct {

	// 作业ID。
	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 *int64 `json:"duration,omitempty"`

	// 此作业的当前状态,包含提交(LAUNCHING)、运行中(RUNNING)、完成(FINISHED)、失败(FAILED)、取消(CANCELLED)。
	Status SqlJobStatus `json:"status"`

	// Insert作业执行过程中扫描的记录条数。
	InputRowCount *int64 `json:"input_row_count,omitempty"`

	// Insert作业执行过程中扫描到的错误记录数。
	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	// 作业执行过程中扫描文件的大小。
	InputSize int64 `json:"input_size"`

	// 当前作业返回的结果总条数或insert作业插入的总条数。
	ResultCount int64 `json:"result_count"`

	// 记录其操作的表所在的数据库名称。类型为Import和Export作业才有“database_name”属性。
	DatabaseName *string `json:"database_name,omitempty"`

	// 记录其操作的表名称。类型为Import和Export作业才有“table_name”属性。
	TableName *string `json:"table_name,omitempty"`

	// Import类型的作业,记录其导入的数据是否包括列名。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// SQL查询的相关列信息的Json字符串。
	Detail string `json:"detail"`

	// 作业执行的SQL语句。
	Statement string `json:"statement"`

	// 作业标签
	Tags *[]Tag `json:"tags,omitempty"`

	// 系统提示信息。
	Message *string `json:"message,omitempty"`

	// 作业结束的时间。是单位为“毫秒”的时间戳。
	EndTime *int64 `json:"end_time,omitempty"`

	// 作业的CPU累计使用量
	CpuCost *string `json:"cpu_cost,omitempty"`

	// 作业的输出字节数
	OutputByte *string `json:"output_byte,omitempty"`
}

SqlJob 作业信息。

func (SqlJob) String added in v0.1.88

func (o SqlJob) String() string

type SqlJobStatus added in v0.1.88

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

func (SqlJobStatus) MarshalJSON added in v0.1.88

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

func (*SqlJobStatus) UnmarshalJSON added in v0.1.88

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

func (SqlJobStatus) Value added in v0.1.88

func (c SqlJobStatus) Value() string

type SqlJobStatusEnum added in v0.1.88

type SqlJobStatusEnum struct {
	LAUNCHING SqlJobStatus
	RUNNING   SqlJobStatus
	FINISHED  SqlJobStatus
	FAILED    SqlJobStatus
	CANCELLED SqlJobStatus
}

func GetSqlJobStatusEnum added in v0.1.88

func GetSqlJobStatusEnum() SqlJobStatusEnum

type SqlJobTemplate added in v0.1.88

type SqlJobTemplate struct {

	// SQL模板ID。
	SqlId *string `json:"sql_id,omitempty"`

	// SQL模板名称。
	SqlName *string `json:"sql_name,omitempty"`

	// SQL模板文本。
	Sql *string `json:"sql,omitempty"`

	// SQL模板描述信息。
	Description *string `json:"description,omitempty"`

	// 分组名称。
	Group *string `json:"group,omitempty"`

	// SQL模板的创建者。
	Owner *string `json:"owner,omitempty"`
}

func (SqlJobTemplate) String added in v0.1.88

func (o SqlJobTemplate) String() string

type SqlSampleTemplate added in v0.1.88

type SqlSampleTemplate struct {

	// 语言。
	Lang *string `json:"lang,omitempty"`

	// 样例模板名称。
	Name *string `json:"name,omitempty"`

	// 样例模板内容。
	Sql *string `json:"sql,omitempty"`

	// 样例模板描述。
	Description *string `json:"description,omitempty"`

	// 样例模板分组。
	Group *string `json:"group,omitempty"`
}

SqlSampleTemplate 样例模板信息。

func (SqlSampleTemplate) String added in v0.1.88

func (o SqlSampleTemplate) String() string

type State

type State struct {
	Phase string `json:"phase"`

	Reason *string `json:"reason,omitempty"`
}

func (State) String

func (o State) String() string

type StopFlinkJobsRequestBody

type StopFlinkJobsRequestBody struct {

	// 在停止作业之前,用户可以选择是否对作业创建保存点,保存作业的状态信息。类型为boolean。  当triggerSavePoint为true时,表示创建保存点。 当triggerSavePoint为false时,表示不创建保存点。默认为false。
	TriggerSavepoint *bool `json:"trigger_savepoint,omitempty"`

	//
	JobIds []int64 `json:"job_ids"`
}

StopFlinkJobsRequestBody

func (StopFlinkJobsRequestBody) String

func (o StopFlinkJobsRequestBody) String() string

type SubJob added in v0.1.88

type SubJob struct {

	// 子作业ID,对应开源spark JobData的jobId。
	Id *int32 `json:"id,omitempty"`

	// 子作业name,对应开源spark JobData的name。
	Name *string `json:"name,omitempty"`

	// 子作业description,对应开源spark JobData的description。
	Description *string `json:"description,omitempty"`

	// 子作业submission_time,对应开源spark JobData的submissionTime。
	SubmissionTime *string `json:"submission_time,omitempty"`

	// 子作业completion_time,对应开源spark JobData的completionTime。
	CompletionTime *string `json:"completion_time,omitempty"`

	// 子作业stage_ids,对应开源spark JobData的stageIds。
	StageIds *[]int32 `json:"stage_ids,omitempty"`

	// 对应DLI的作业ID,对应开源spark JobData的jobGroup。
	JobGroup *string `json:"job_group,omitempty"`

	// 子作业状态,对应开源spark JobData的status。
	Status *string `json:"status,omitempty"`

	// 子作业task的个数,对应开源spark JobData的numTasks。
	NumTasks *int32 `json:"num_tasks,omitempty"`

	// 子作业正在运行的task个数,对应开源spark JobData的numActiveTasks。
	NumActiveTasks *int32 `json:"num_active_tasks,omitempty"`

	// 子作业已经完成的task个数,对应开源spark JobData的numCompletedTasks。
	NumCompletedTasks *int32 `json:"num_completed_tasks,omitempty"`

	// 子作业跳过的task个数,对应开源spark JobData的numSkippedTasks。
	NumSkippedTasks *int32 `json:"num_skipped_tasks,omitempty"`

	// 子作业跳失败的task个数,对应开源spark JobData的numFailedTasks。
	NumFailedTasks *int32 `json:"num_failed_tasks,omitempty"`

	// 子作业kill掉的task个数,对应开源spark JobData的numKilledTasks。
	NumKilledTasks *int32 `json:"num_killed_tasks,omitempty"`

	// 子作业完成指数,对应开源spark JobData的numCompletedIndices。
	NumCompletedIndices *int32 `json:"num_completed_indices,omitempty"`

	// 子作业正在运行的stage个数,对应开源spark JobData的numActiveStages。
	NumActiveStages *int32 `json:"num_active_stages,omitempty"`

	// 子作业已经完成的stage个数,对应开源spark JobData的numCompletedStages。
	NumCompletedStages *int32 `json:"num_completed_stages,omitempty"`

	// 子作业跳过的stage个数,对应开源spark JobData的numSkippedStages。
	NumSkippedStages *int32 `json:"num_skipped_stages,omitempty"`

	// 子作业失败的stage个数,对应开源spark JobData的numFailedStages。
	NumFailedStages *int32 `json:"num_failed_stages,omitempty"`

	// 子作业killed_tasks_summary,对应开源spark JobData的killedTasksSummary。
	KilledTasksSummary map[string]int32 `json:"killed_tasks_summary,omitempty"`
}

SubJob 子作业JobData信息,对应spark的JobData。

func (SubJob) String added in v0.1.88

func (o SubJob) String() string

type Table

type Table struct {

	// 表创建时间。是单位为“毫秒”的时间戳。
	CreateTime int64 `json:"create_time"`

	// 所列OBS表数据的类型,目前支持:parquet、ORC、CSV、JSON、Carbon、Avro格式。只有OBS表有该参数,其他表没有该参数。
	DataType *string `json:"data_type,omitempty"`

	// 数据存储位置,分为MANAGED,EXTERNAL和VIEW,其中EXTERNAL包括OBS表、CLoudTable表。
	DataLocation string `json:"data_location"`

	// 最近更新时间。是单位为“毫秒”的时间戳。
	LastAccessTime int64 `json:"last_access_time"`

	// OBS表上的存储路径。
	Location *string `json:"location,omitempty"`

	// 表创建者。
	Owner string `json:"owner"`

	// 表名称。
	TableName string `json:"table_name"`

	// DLI表的大小。非DLI表该参数值为0。
	TableSize int64 `json:"table_size"`

	// 表类型: OBS表为EXTERNAL DLI表为MANAGED View为VIEW
	TableType string `json:"table_type"`

	// 分区字段。只有OBS分区表有该参数,其他表没有该参数。
	PartitionColumns *[]string `json:"partition_columns,omitempty"`

	// 分页大小,最小为1,最大为100。
	PageSize *int32 `json:"page-size,omitempty"`

	// 当前页码,最小为1。
	CurrentPage *int32 `json:"current-page,omitempty"`
}

Table 查询所有表响应参数的表的信息。 说明: 若URI中的过滤条件“with-detail=false”,则tables相关参数中只返回“data_location”,“table_name”,“table_type”三个参数。

func (Table) String

func (o Table) String() string

type TablePrivilege added in v0.1.88

type TablePrivilege struct {

	// 该用户有权限的对象: “databases.数据库名.tables.表名”,用户在当前表上的权限。 “databases.数据库名.tables.表名.columns.列名”,用户在列上的权限。
	Object *string `json:"object,omitempty"`

	// 用户在指定对象上的权限。
	Privileges *[]string `json:"privileges,omitempty"`
}

TablePrivilege 查看表的用户权限响应的权限信息。

func (TablePrivilege) String added in v0.1.88

func (o TablePrivilege) String() string

type TableUserPrivilege added in v0.1.88

type TableUserPrivilege struct {

	// 判断是否为管理用户。
	IsAdmin *bool `json:"is_admin,omitempty"`

	// 该用户有权限的对象: “databases.数据库名.tables.表名”,用户在当前表上的权限。 “databases.数据库名.tables.表名.columns.列名”,用户在列上的权限。
	Object *string `json:"object,omitempty"`

	// 该用户在相应object上的权限。
	Privileges *[]string `json:"privileges,omitempty"`

	// 拥有该权限的用户名。
	UserName *string `json:"user_name,omitempty"`
}

TableUserPrivilege 查看表的使用者响应的权限信息。

func (TableUserPrivilege) String added in v0.1.88

func (o TableUserPrivilege) String() string

type Tag added in v0.1.88

type Tag struct {

	// 键
	Key string `json:"key"`

	// 值
	Value string `json:"value"`
}

Tag 资源标签

func (Tag) String added in v0.1.88

func (o Tag) String() string

type UpdateAuthInfoRequest

type UpdateAuthInfoRequest struct {
	Body *UpdateAuthInfoRequestBody `json:"body,omitempty"`
}

UpdateAuthInfoRequest Request Object

func (UpdateAuthInfoRequest) String

func (o UpdateAuthInfoRequest) String() string

type UpdateAuthInfoRequestBody

type UpdateAuthInfoRequestBody struct {

	// 证书名
	AuthInfoName string `json:"auth_info_name"`

	// 用户安全集群的新登录用户名
	UserName *string `json:"user_name,omitempty"`

	// 用户安全集群的新登录密码
	Password *string `json:"password,omitempty"`

	// krb5配置文件obs路径
	Krb5Conf *string `json:"krb5_conf,omitempty"`

	// keytab配置文件obs路径
	Keytab *string `json:"keytab,omitempty"`

	// truststore配置文件obs路径
	TruststoreLocation *string `json:"truststore_location,omitempty"`

	// truststore配置文件密码
	TruststorePassword *string `json:"truststore_password,omitempty"`

	// keystore配置文件obs路径
	KeystoreLocation *string `json:"keystore_location,omitempty"`

	// keystore配置文件密码
	KeystorePassword *string `json:"keystore_password,omitempty"`
}

func (UpdateAuthInfoRequestBody) String

func (o UpdateAuthInfoRequestBody) String() string

type UpdateAuthInfoResponse

type UpdateAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateAuthInfoResponse Response Object

func (UpdateAuthInfoResponse) String

func (o UpdateAuthInfoResponse) String() string

type UpdateDatabaseOwnerRequest

type UpdateDatabaseOwnerRequest struct {

	// 删除的数据库名称。
	DatabaseName string `json:"database_name"`

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

UpdateDatabaseOwnerRequest Request Object

func (UpdateDatabaseOwnerRequest) String

type UpdateDatabaseOwnerResponse

type UpdateDatabaseOwnerResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateDatabaseOwnerResponse Response Object

func (UpdateDatabaseOwnerResponse) String

type UpdateElasticResourcePoolQueueRequest added in v0.1.68

type UpdateElasticResourcePoolQueueRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

	// 队列名称
	QueueName string `json:"queue_name"`

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

UpdateElasticResourcePoolQueueRequest Request Object

func (UpdateElasticResourcePoolQueueRequest) String added in v0.1.68

type UpdateElasticResourcePoolQueueRequestBody added in v0.1.88

type UpdateElasticResourcePoolQueueRequestBody struct {

	// 该队列在该弹性资源池下的扩缩容策略信息。单条策略信息包含时间段、优先级和CU范围。每个队列至少要配置一条时间段为[00:00, 24:00]的默认扩缩容策略。
	QueueScalingPolicies []QueueScalingPolicy `json:"queue_scaling_policies"`
}

UpdateElasticResourcePoolQueueRequestBody 更新弹性资源池队列消息请求

func (UpdateElasticResourcePoolQueueRequestBody) String added in v0.1.88

type UpdateElasticResourcePoolQueueResponse added in v0.1.68

type UpdateElasticResourcePoolQueueResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateElasticResourcePoolQueueResponse Response Object

func (UpdateElasticResourcePoolQueueResponse) String added in v0.1.68

type UpdateElasticResourcePoolRequest

type UpdateElasticResourcePoolRequest struct {

	// 弹性资源池名称
	ElasticResourcePoolName string `json:"elastic_resource_pool_name"`

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

UpdateElasticResourcePoolRequest Request Object

func (UpdateElasticResourcePoolRequest) String

type UpdateElasticResourcePoolRequestBody

type UpdateElasticResourcePoolRequestBody struct {

	// 描述信息。长度限制:256个字符以内。
	Description *string `json:"description,omitempty"`

	// max_cu大于等于该弹性资源池下任意一个队列的最大CU。标准版弹性资源池最小值为64,最大值为32000;基础版弹性资源池最小值为16,最大值为64。
	MaxCu *int32 `json:"max_cu,omitempty"`

	// min_cu大于等于该弹性资源池下所有队列最小CU之和,且小于等于max_cu。标准版弹性资源池最小值为64,最大值为32000;基础版弹性资源池最小值为16,最大值为64。
	MinCu *int32 `json:"min_cu,omitempty"`
}

UpdateElasticResourcePoolRequestBody 更新弹性资源池请求

func (UpdateElasticResourcePoolRequestBody) String

type UpdateElasticResourcePoolResponse

type UpdateElasticResourcePoolResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateElasticResourcePoolResponse Response Object

func (UpdateElasticResourcePoolResponse) String

type UpdateEnhancedConnectionRequest added in v0.1.68

type UpdateEnhancedConnectionRequest struct {

	// 连接ID,用于标识跨源连接的UUID。
	ConnectionId string `json:"connection_id"`

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

UpdateEnhancedConnectionRequest Request Object

func (UpdateEnhancedConnectionRequest) String added in v0.1.68

type UpdateEnhancedConnectionRequestBody added in v0.1.88

type UpdateEnhancedConnectionRequestBody struct {

	// 用户自定义主机信息,最大支持2万条记录。内容填空表示清除所有已配置的主机信息。
	Hosts []EnhancedConnectionHost `json:"hosts"`
}

UpdateEnhancedConnectionRequestBody 修改主机信息的请求body体。

func (UpdateEnhancedConnectionRequestBody) String added in v0.1.88

type UpdateEnhancedConnectionResponse added in v0.1.68

type UpdateEnhancedConnectionResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateEnhancedConnectionResponse Response Object

func (UpdateEnhancedConnectionResponse) String added in v0.1.68

type UpdateFlinkJarJobRequest added in v0.1.68

type UpdateFlinkJarJobRequest struct {

	// 作业ID。
	JobId int64 `json:"job_id"`

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

UpdateFlinkJarJobRequest Request Object

func (UpdateFlinkJarJobRequest) String added in v0.1.68

func (o UpdateFlinkJarJobRequest) String() string

type UpdateFlinkJarJobRequestBody added in v0.1.88

type UpdateFlinkJarJobRequestBody struct {

	// 作业名称。长度限制:0-57个字符。
	Name *string `json:"name,omitempty"`

	// 作业描述。长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// 队列名称。长度限制:1-128个字符。
	QueueName *string `json:"queue_name,omitempty"`

	// 用户为作业选择的CU数量。默认值为2。
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 用户为作业选择的管理节点CU数量,对应为flink jobmanager数量。默认为1。
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 用户为作业选择的并发量。默认为1。
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 是否开启作业日志。 开启:true; 关闭:false; 默认:false。
	LogEnabled *bool `json:"log_enabled,omitempty"`

	// 当log_enabled==true时,用户授权保存日志的OBS路。
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 当作业异常时,向该SMN主题推送告警信息。
	SmnTopic *string `json:"smn_topic,omitempty"`

	// 作业入口类。
	MainClass *string `json:"main_class,omitempty"`

	// 作业入口类参数,多个参数之间空格分隔。
	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	// 是否开启异常重启功能,默认值为“false”。
	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业主类所在的jar包。
	Entrypoint *string `json:"entrypoint,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的其他依赖包。示例[Group/test.jar,myGroup/test1.jar]
	DependencyJars *[]string `json:"dependency_jars,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户自定义作业的依赖文件。
	DependencyFiles *[]string `json:"dependency_files,omitempty"`

	// 每个taskmanager的CU数,默认值为“1”。
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 每个taskmanager的slot数,默认值为“(parallel_number*tm_cus)/(cu_number-manager_cu_number)”。
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	// 作业特性。表示用户作业使用的Flink镜像类型。basic:表示使用DLI提供的基础Flink镜像。custom:表示使用用户自定义的Flink镜像。
	Feature *string `json:"feature,omitempty"`

	// Flink版本。当用户设置“feature”为“basic”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用的DLI基础Flink镜像的版本。
	FlinkVersion *string `json:"flink_version,omitempty"`

	// 自定义镜像。格式为:组织名/镜像名:镜像版本。当用户设置“feature”为“custom”时,该参数生效。用户可通过与“feature”参数配合使用,指定作业运行使用自定义的Flink镜像。关于如何使用自定义镜像,请参考《数据湖探索用户指南》。
	Image *string `json:"image,omitempty"`

	// 异常重启是否从checkpoint恢复。
	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	// 异常重试最大次数,单位:次/小时。取值范围:-1或大于0。默认值为“-1”,表示无限次数。
	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	// 用户Jar中checkpoint的储存地址,不同作业路径需要保持不同。
	CheckpointPath *string `json:"checkpoint_path,omitempty"`

	// Flink作业运行时自定义优化参数。
	RuntimeConfig *string `json:"runtime_config,omitempty"`

	// 作业类型。
	JobType *string `json:"job_type,omitempty"`
}

UpdateFlinkJarJobRequestBody 更新Flink Jar作业的响应参数。

func (UpdateFlinkJarJobRequestBody) String added in v0.1.88

type UpdateFlinkJarJobResponse added in v0.1.68

type UpdateFlinkJarJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

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

UpdateFlinkJarJobResponse Response Object

func (UpdateFlinkJarJobResponse) String added in v0.1.68

func (o UpdateFlinkJarJobResponse) String() string

type UpdateFlinkJobStatusReportRequest added in v0.1.88

type UpdateFlinkJobStatusReportRequest struct {
	Body *ChangeFlinkJobStatusReportRequestBody `json:"body,omitempty"`
}

UpdateFlinkJobStatusReportRequest Request Object

func (UpdateFlinkJobStatusReportRequest) String added in v0.1.88

type UpdateFlinkJobStatusReportResponse added in v0.1.88

type UpdateFlinkJobStatusReportResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateFlinkJobStatusReportResponse Response Object

func (UpdateFlinkJobStatusReportResponse) String added in v0.1.88

type UpdateFlinkSqlJobRequest added in v0.1.68

type UpdateFlinkSqlJobRequest struct {

	// 作业ID。
	JobId int64 `json:"job_id"`

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

UpdateFlinkSqlJobRequest Request Object

func (UpdateFlinkSqlJobRequest) String added in v0.1.68

func (o UpdateFlinkSqlJobRequest) String() string

type UpdateFlinkSqlJobRequestBody added in v0.1.88

type UpdateFlinkSqlJobRequestBody struct {

	// 作业名称。长度限制:0-57个字符。
	Name *string `json:"name,omitempty"`

	// 作业描述。长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// 队列名称。长度限制:1-128个字符。
	QueueName *string `json:"queue_name,omitempty"`

	// Stream SQL语句。长度限制:0-1024*1024个字符。
	SqlBody *string `json:"sql_body,omitempty"`

	// 作业运行模式: shared_cluster:共享。 exclusive_cluster:独享。 edge_node:边缘节点。 默认值为shared_cluster。
	RunMode *string `json:"run_mode,omitempty"`

	// 用户为作业选择的CU数量。默认值为2。
	CuNumber *int32 `json:"cu_number,omitempty"`

	// 用户设置的作业并行数目。默认值为1。
	ParallelNumber *int32 `json:"parallel_number,omitempty"`

	// 是否开启作业自动快照功能。 开启:true; 关闭:false; 默认:false.
	CheckpointEnabled *bool `json:"checkpoint_enabled,omitempty"`

	// 快照模式: 1表示ExactlyOnce:数据只被消费一次。 2表示AtLeastOnce:数据至少被消费一次。 默认值为1。
	CheckpointMode *int32 `json:"checkpoint_mode,omitempty"`

	// 快照时间间隔, 单位为秒,默认值为10。
	CheckpointInterval *int32 `json:"checkpoint_interval,omitempty"`

	// 当checkpoint_enabled为true时,该参数是用户授权保存快照的OBS路径。当log_enabled 为true时,该参数是用户授权保存作业日志的OBS路径。
	ObsBucket *string `json:"obs_bucket,omitempty"`

	// 是否开启作业的日志上传到用户的OBS功能,默认为false。
	LogEnabled *bool `json:"log_enabled,omitempty"`

	// 当作业异常时,向该SMN主题推送告警信息。
	SmnTopic *string `json:"smn_topic,omitempty"`

	// 是否开启作业异常自动重启,默认为false。
	RestartWhenException *bool `json:"restart_when_exception,omitempty"`

	// 空闲状态过期周期,单位为秒,默认值为3600。
	IdleStateRetention *int32 `json:"idle_state_retention,omitempty"`

	// 边缘计算组ID列表。
	EdgeGroupIds *[]string `json:"edge_group_ids,omitempty"`

	// 作业脏数据策略。 “2”:保存; “1”:抛出异常; “0”:忽略; 默认值为“0”。
	DirtyDataStrategy *string `json:"dirty_data_strategy,omitempty"`

	// 用户已上传到DLI资源管理系统的资源包名,用户sql作业的udf jar通过该参数传入。
	UdfJarUrl *string `json:"udf_jar_url,omitempty"`

	// 用户为作业选择的管理单元(jobmanager)CU数量,默认值为“1”。
	ManagerCuNumber *int32 `json:"manager_cu_number,omitempty"`

	// 每个taskmanager的CU数,默认值为“1”。
	TmCus *int32 `json:"tm_cus,omitempty"`

	// 每个taskmanager的slot数,默认值为“(parallel_number*tm_cus)/(cu_number-manager_cu_number)”。
	TmSlotNum *int32 `json:"tm_slot_num,omitempty"`

	// 异常重启是否从checkpoint恢复。
	ResumeCheckpoint *bool `json:"resume_checkpoint,omitempty"`

	// 异常重试最大次数,单位:次/小时。取值范围:-1或大于0。默认值为“-1”,表示无限次数。
	ResumeMaxNum *int32 `json:"resume_max_num,omitempty"`

	// Flink作业运行时自定义优化参数。
	RuntimeConfig *string `json:"runtime_config,omitempty"`

	// 算子的并行度配置。
	OperatorConfig *string `json:"operator_config,omitempty"`

	// 每个算子的流量/命中率配置,json格式的字符串。例如: {\"operator_list\":[   {\"id\":\"0a448493b4782967b150582570326227\",\"rate_factor\":0.55},   {\"id\":\"6d2677a0ecc3fd8df0b72ec675edf8f4\",\"rate_factor\":1},   {\"id\":\"ea632d67b7d595e5b851708ae9ad79d6\",\"rate_factor\":0.55},   {\"id\":\"bc764cd8ddf7a0cff126f51c16239658\",\"output_rate\":2000} ]}
	StaticEstimatorConfig *string `json:"static_estimator_config,omitempty"`

	// Flink版本。当前只支持1.10和1.12。
	FlinkVersion *string `json:"flink_version,omitempty"`
}

UpdateFlinkSqlJobRequestBody 更新SQL作业的请求参数。

func (UpdateFlinkSqlJobRequestBody) String added in v0.1.88

type UpdateFlinkSqlJobResponse added in v0.1.68

type UpdateFlinkSqlJobResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *string `json:"is_success,omitempty"`

	// 消息内容。
	Message *string `json:"message,omitempty"`

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

UpdateFlinkSqlJobResponse Response Object

func (UpdateFlinkSqlJobResponse) String added in v0.1.68

func (o UpdateFlinkSqlJobResponse) String() string

type UpdateFlinkSqlJobTemplateRequest added in v0.1.68

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

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

UpdateFlinkSqlJobTemplateRequest Request Object

func (UpdateFlinkSqlJobTemplateRequest) String added in v0.1.68

type UpdateFlinkSqlJobTemplateRequestBody added in v0.1.88

type UpdateFlinkSqlJobTemplateRequestBody struct {

	// 模板名称,长度限制:0-57个字符。
	Name *string `json:"name,omitempty"`

	// 模板描述,长度限制:0-2048个字符。
	Desc *string `json:"desc,omitempty"`

	// Stream SQL语句,至少包含source,query,sink三个部分,长度限制:0-1024*1024个字符。
	SqlBody *string `json:"sql_body,omitempty"`
}

func (UpdateFlinkSqlJobTemplateRequestBody) String added in v0.1.88

type UpdateFlinkSqlJobTemplateResponse added in v0.1.68

type UpdateFlinkSqlJobTemplateResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateFlinkSqlJobTemplateResponse Response Object

func (UpdateFlinkSqlJobTemplateResponse) String added in v0.1.68

type UpdateGlobalVariableRequest added in v0.1.68

type UpdateGlobalVariableRequest struct {

	// 全局变量名,名称只能包含数字、英文字母和下划线,但不能是纯数字,不能以下划线开头,且不能超过128字符
	VarName string `json:"var_name"`

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

UpdateGlobalVariableRequest Request Object

func (UpdateGlobalVariableRequest) String added in v0.1.68

type UpdateGlobalVariableRequestBody added in v0.1.88

type UpdateGlobalVariableRequestBody struct {

	// 变量值
	VarValue string `json:"var_value"`
}

func (UpdateGlobalVariableRequestBody) String added in v0.1.88

type UpdateGlobalVariableResponse added in v0.1.68

type UpdateGlobalVariableResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateGlobalVariableResponse Response Object

func (UpdateGlobalVariableResponse) String added in v0.1.68

type UpdateJobAuthInfoRequest added in v0.1.71

type UpdateJobAuthInfoRequest struct {
	Body *UpdateJobAuthInfoRequestBody `json:"body,omitempty"`
}

UpdateJobAuthInfoRequest Request Object

func (UpdateJobAuthInfoRequest) String added in v0.1.71

func (o UpdateJobAuthInfoRequest) String() string

type UpdateJobAuthInfoRequestBody added in v0.1.71

type UpdateJobAuthInfoRequestBody struct {

	// 证书名
	AuthInfoName string `json:"auth_info_name"`

	// 用户安全集群的新登录用户名
	UserName *string `json:"user_name,omitempty"`

	// 用户安全集群的新登录密码
	Password *string `json:"password,omitempty"`

	// krb5配置文件obs路径
	Krb5Conf *string `json:"krb5_conf,omitempty"`

	// keytab配置文件obs路径
	Keytab *string `json:"keytab,omitempty"`

	// truststore配置文件obs路径
	TruststoreLocation *string `json:"truststore_location,omitempty"`

	// truststore配置文件密码
	TruststorePassword *string `json:"truststore_password,omitempty"`

	// keystore配置文件obs路径
	KeystoreLocation *string `json:"keystore_location,omitempty"`

	// keystore配置文件密码
	KeystorePassword *string `json:"keystore_password,omitempty"`
}

func (UpdateJobAuthInfoRequestBody) String added in v0.1.71

type UpdateJobAuthInfoResponse added in v0.1.71

type UpdateJobAuthInfoResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateJobAuthInfoResponse Response Object

func (UpdateJobAuthInfoResponse) String added in v0.1.71

func (o UpdateJobAuthInfoResponse) String() string

type UpdateJobResourceOwnerRequest added in v0.1.88

type UpdateJobResourceOwnerRequest struct {
	Body *UpdateJobResourceOwnerRequestBody `json:"body,omitempty"`
}

UpdateJobResourceOwnerRequest Request Object

func (UpdateJobResourceOwnerRequest) String added in v0.1.88

type UpdateJobResourceOwnerRequestBody added in v0.1.88

type UpdateJobResourceOwnerRequestBody struct {

	// 新用户名,只能包含数字、英文字母、下划线和中划线且不能以数字开头,长度在5-32字符之间
	NewOwner string `json:"new_owner"`

	// 组名,名称只能包含数字、英文字母、点、下划线和中划线,长度不能超过64字符
	GroupName string `json:"group_name"`

	// 包名,包名,长度(包含文件后缀)不能超过128个字符
	ResourceName *string `json:"resource_name,omitempty"`
}

UpdateJobResourceOwnerRequestBody group_name和resource_name可以单独使用,也可以组合使用 修改组的拥有者:使用group_name 修改资源包拥有者:使用resource_name 修改组下的资源包的拥有者:使用group_name加resource_name

func (UpdateJobResourceOwnerRequestBody) String added in v0.1.88

type UpdateJobResourceOwnerResponse added in v0.1.88

type UpdateJobResourceOwnerResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateJobResourceOwnerResponse Response Object

func (UpdateJobResourceOwnerResponse) String added in v0.1.88

type UpdateOwnerRequestBody

type UpdateOwnerRequestBody struct {

	// 新owner名称。
	NewOwner string `json:"new_owner"`
}

UpdateOwnerRequestBody 修改数据库用户的请求body体。

func (UpdateOwnerRequestBody) String

func (o UpdateOwnerRequestBody) String() string

type UpdateQueueCidrRequest

type UpdateQueueCidrRequest struct {

	// 指定删除的队列名称。
	QueueName string `json:"queue_name"`

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

UpdateQueueCidrRequest Request Object

func (UpdateQueueCidrRequest) String

func (o UpdateQueueCidrRequest) String() string

type UpdateQueueCidrRequestBody added in v0.1.88

type UpdateQueueCidrRequestBody struct {

	// 队列虚拟私有云网段。  不同CU规格队列支持的网段范围:  - 4cu:  10.0.0.0/8 ~ 10.255.255.192/26  172.16.0.0/12 ~ 172.31.255.192/26  192.168.0.0/16 ~ 192.168.255.192/26  - 16cu:  10.0.0.0/8 ~ 10.255.255.0/24  172.16.0.0/12 ~ 172.31.255.0/24  192.168.0.0/16 ~ 192.168.255.0/24  - 64cu:  10.0.0.0/8 ~ 10.255.252.0/22  172.16.0.0/12 ~ 172.31.252.0/22  192.168.0.0/16 ~ 192.168.252.0/22  - 128cu:  10.0.0.0/8 ~ 10.255.252.0/21  172.16.0.0/12 ~ 172.31.252.0/21  192.168.0.0/16 ~ 192.168.252.0/21
	CidrInVpc *string `json:"cidr_in_vpc,omitempty"`
}

UpdateQueueCidrRequestBody 修改队列网段的请求body体。

func (UpdateQueueCidrRequestBody) String added in v0.1.88

type UpdateQueueCidrResponse

type UpdateQueueCidrResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateQueueCidrResponse Response Object

func (UpdateQueueCidrResponse) String

func (o UpdateQueueCidrResponse) String() string

type UpdateQueuePlanRequest added in v0.1.88

type UpdateQueuePlanRequest struct {

	// 待修改的队列扩缩容计划的ID
	PlanId string `json:"plan_id"`

	// 待删除定时扩缩计划的队列名称
	QueueName string `json:"queue_name"`

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

UpdateQueuePlanRequest Request Object

func (UpdateQueuePlanRequest) String added in v0.1.88

func (o UpdateQueuePlanRequest) String() string

type UpdateQueuePlanResponse added in v0.1.88

type UpdateQueuePlanResponse struct {

	// 定时扩缩容计划对应的队列名称
	QueueName *string `json:"queue_name,omitempty"`

	// 扩缩容计划的ID编号
	PlanId *int64 `json:"plan_id,omitempty"`

	// 请求执行是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateQueuePlanResponse Response Object

func (UpdateQueuePlanResponse) String added in v0.1.88

func (o UpdateQueuePlanResponse) String() string

type UpdateQueuePropertyRequest added in v0.1.65

type UpdateQueuePropertyRequest struct {

	// 队列名称
	QueueName string `json:"queue_name"`

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

UpdateQueuePropertyRequest Request Object

func (UpdateQueuePropertyRequest) String added in v0.1.65

type UpdateQueuePropertyRequestBody added in v0.1.65

type UpdateQueuePropertyRequestBody struct {
	Properties *AdvancedQueueProperty `json:"properties,omitempty"`
}

UpdateQueuePropertyRequestBody 队列待更新属性

func (UpdateQueuePropertyRequestBody) String added in v0.1.65

type UpdateQueuePropertyResponse added in v0.1.65

type UpdateQueuePropertyResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateQueuePropertyResponse Response Object

func (UpdateQueuePropertyResponse) String added in v0.1.65

type UpdateSparkJobTemplateRequest added in v0.1.68

type UpdateSparkJobTemplateRequest struct {
	TemplateId string `json:"template_id"`

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

UpdateSparkJobTemplateRequest Request Object

func (UpdateSparkJobTemplateRequest) String added in v0.1.68

type UpdateSparkJobTemplateRequestBody added in v0.1.88

type UpdateSparkJobTemplateRequestBody struct {

	// 名字
	Name string `json:"name"`

	// 模板内容
	Body string `json:"body"`

	// 分组
	Group *string `json:"group,omitempty"`

	// 描述信息
	Description *string `json:"description,omitempty"`
}

func (UpdateSparkJobTemplateRequestBody) String added in v0.1.88

type UpdateSparkJobTemplateResponse added in v0.1.68

type UpdateSparkJobTemplateResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSparkJobTemplateResponse Response Object

func (UpdateSparkJobTemplateResponse) String added in v0.1.68

type UpdateSqlJobTemplateRequest added in v0.1.68

type UpdateSqlJobTemplateRequest struct {
	SqlId string `json:"sql_id"`

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

UpdateSqlJobTemplateRequest Request Object

func (UpdateSqlJobTemplateRequest) String added in v0.1.68

type UpdateSqlJobTemplateRequestBody added in v0.1.88

type UpdateSqlJobTemplateRequestBody struct {

	// 更新后SQL模板文本。
	Sql *string `json:"sql,omitempty"`

	// 更新后SQL模板名称,该名称在当前工程下必须唯一。
	SqlName *string `json:"sql_name,omitempty"`

	// SQL模板的描述信息,可以为空。
	Description *string `json:"description,omitempty"`

	// 分组名称。
	Group *string `json:"group,omitempty"`
}

func (UpdateSqlJobTemplateRequestBody) String added in v0.1.88

type UpdateSqlJobTemplateResponse added in v0.1.68

type UpdateSqlJobTemplateResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSqlJobTemplateResponse Response Object

func (UpdateSqlJobTemplateResponse) String added in v0.1.68

type UpdateTableOwnerRequest

type UpdateTableOwnerRequest struct {

	// 删除的数据库名称。
	DatabaseName string `json:"database_name"`

	TableName string `json:"table_name"`

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

UpdateTableOwnerRequest Request Object

func (UpdateTableOwnerRequest) String

func (o UpdateTableOwnerRequest) String() string

type UpdateTableOwnerResponse

type UpdateTableOwnerResponse struct {

	// 执行请求是否成功。“true”表示请求执行成功。
	IsSuccess *bool `json:"is_success,omitempty"`

	// 系统提示信息,执行成功时,信息可能为空。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateTableOwnerResponse Response Object

func (UpdateTableOwnerResponse) String

func (o UpdateTableOwnerResponse) String() string

type UploadFileJobResourcesRequest added in v0.1.88

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

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

UploadFileJobResourcesRequest Request Object

func (UploadFileJobResourcesRequest) String added in v0.1.88

type UploadFileJobResourcesResponse added in v0.1.88

type UploadFileJobResourcesResponse struct {

	// \"UPLOADING\"表示正在上传。 \"READY\"表示模块包已上传。 \"FAILED\"表示模块包上传失败。
	Status *string `json:"status,omitempty"`

	// 资源模块描述。
	Description *string `json:"description,omitempty"`

	// 该资源模块包含的资源包名列表。
	Resources *[]string `json:"resources,omitempty"`

	// 资源模块上传的unix时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 资源模块更新的unix时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 模块名。
	GroupName *string `json:"group_name,omitempty"`

	// 资源包拥有者
	Owner *string `json:"owner,omitempty"`

	// 是否使用异步方式上传资源包。默认值为“false”,表示不使用异步方式。推荐使用异步方式上传资源包。
	IsAsync *bool `json:"is_async,omitempty"`

	// 分组资源包的详细信息
	Details *[]UploadJobResourcesDetail `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadFileJobResourcesResponse Response Object

func (UploadFileJobResourcesResponse) String added in v0.1.88

type UploadJarJobResourcesRequest added in v0.1.88

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

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

UploadJarJobResourcesRequest Request Object

func (UploadJarJobResourcesRequest) String added in v0.1.88

type UploadJarJobResourcesResponse added in v0.1.88

type UploadJarJobResourcesResponse struct {

	// \"UPLOADING\"表示正在上传。 \"READY\"表示模块包已上传。 \"FAILED\"表示模块包上传失败。
	Status *string `json:"status,omitempty"`

	// 资源模块描述。
	Description *string `json:"description,omitempty"`

	// 该资源模块包含的资源包名列表。
	Resources *[]string `json:"resources,omitempty"`

	// 资源模块上传的unix时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 资源模块更新的unix时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 模块名。
	GroupName *string `json:"group_name,omitempty"`

	// 资源包拥有者
	Owner *string `json:"owner,omitempty"`

	// 是否使用异步方式上传资源包。默认值为“false”,表示不使用异步方式。推荐使用异步方式上传资源包。
	IsAsync *bool `json:"is_async,omitempty"`

	// 分组资源包的详细信息
	Details *[]UploadJobResourcesDetail `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadJarJobResourcesResponse Response Object

func (UploadJarJobResourcesResponse) String added in v0.1.88

type UploadJobResourcesDetail added in v0.1.88

type UploadJobResourcesDetail struct {

	// 资源包上传的unix时间。是单位为“毫秒”的时间戳。
	CreateTime int64 `json:"create_time"`

	// 更新已上传资源包的unix时间。是单位为“毫秒”的时间戳
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 资源类型。
	ResourceType string `json:"resource_type"`

	// 是否异步上传资源包
	IsAsync *bool `json:"is_async,omitempty"`

	// 资源名。
	ResourceName *string `json:"resource_name,omitempty"`

	// \"UPLOADING\"表示正在上传。\"READY\"表示资源包已上传。\"FAILED\"表示资源包上传失败。
	Status *string `json:"status,omitempty"`

	// 资源包在队列中的名字。
	UnderlyingName *string `json:"underlying_name,omitempty"`
}

UploadJobResourcesDetail 上传分组资源的请求返回详细body体。

func (UploadJobResourcesDetail) String added in v0.1.88

func (o UploadJobResourcesDetail) String() string

type UploadJobResourcesRequest added in v0.1.88

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

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

UploadJobResourcesRequest Request Object

func (UploadJobResourcesRequest) String added in v0.1.88

func (o UploadJobResourcesRequest) String() string

type UploadJobResourcesRequestBody added in v0.1.88

type UploadJobResourcesRequestBody struct {

	// 用户OBS对象路径列表,OBS对象路径为OBS对象URL。
	Paths []string `json:"paths"`

	// 分组资源文件的类型。 说明:上传的同一组资源包含不同文件类型时,均选择“file”类型作为这次上传文件的类型。
	Kind string `json:"kind"`

	// 将要创建的分组名。
	Group string `json:"group"`

	// 是否异步上传资源包
	IsAsync *bool `json:"is_async,omitempty"`

	// 资源标签。具体请参考表tags。
	Tags *[]Tag `json:"tags,omitempty"`
}

UploadJobResourcesRequestBody 上传分组资源的请求body体。

func (UploadJobResourcesRequestBody) String added in v0.1.88

type UploadJobResourcesResponse added in v0.1.88

type UploadJobResourcesResponse struct {

	// 模块名。
	GroupName *string `json:"group_name,omitempty"`

	// 上传分组资源状态。
	Status *string `json:"status,omitempty"`

	// 该模块包含的资源包名列表。
	Resources *[]string `json:"resources,omitempty"`

	// 模块上传的unix时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 模块更新的unix时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 本次上传是同步还是异步
	IsAsync *bool `json:"is_async,omitempty"`

	// 资源包拥有者
	Owner *string `json:"owner,omitempty"`

	// 分组资源包的详细信息。
	Details        *[]UploadJobResourcesDetail `json:"details,omitempty"`
	HttpStatusCode int                         `json:"-"`
}

UploadJobResourcesResponse Response Object

func (UploadJobResourcesResponse) String added in v0.1.88

type UploadPythonFileJobResourcesRequest added in v0.1.88

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

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

UploadPythonFileJobResourcesRequest Request Object

func (UploadPythonFileJobResourcesRequest) String added in v0.1.88

type UploadPythonFileJobResourcesResponse added in v0.1.88

type UploadPythonFileJobResourcesResponse struct {

	// \"UPLOADING\"表示正在上传。 \"READY\"表示模块包已上传。 \"FAILED\"表示模块包上传失败。
	Status *string `json:"status,omitempty"`

	// 资源模块描述。
	Description *string `json:"description,omitempty"`

	// 该资源模块包含的资源包名列表。
	Resources *[]string `json:"resources,omitempty"`

	// 资源模块上传的unix时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 资源模块更新的unix时间戳。
	UpdateTime *int64 `json:"update_time,omitempty"`

	// 模块名。
	GroupName *string `json:"group_name,omitempty"`

	// 资源包拥有者
	Owner *string `json:"owner,omitempty"`

	// 是否使用异步方式上传资源包。默认值为“false”,表示不使用异步方式。推荐使用异步方式上传资源包。
	IsAsync *bool `json:"is_async,omitempty"`

	// 分组资源包的详细信息
	Details *[]UploadJobResourcesDetail `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadPythonFileJobResourcesResponse Response Object

func (UploadPythonFileJobResourcesResponse) String added in v0.1.88

type UploadResourcesRequestBody added in v0.1.88

type UploadResourcesRequestBody struct {

	// 用户OBS对象路径列表,OBS对象路径为OBS对象URL。
	Paths []string `json:"paths"`

	// 所属资源分组名。
	Group string `json:"group"`
}

UploadResourcesRequestBody 上传jar类型分组资源请求body体。

func (UploadResourcesRequestBody) String added in v0.1.88

Source Files

Jump to

Keyboard shortcuts

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