model

package
v0.1.101 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 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 

func (o AssociateQueueToElasticResourcePoolRequest) String() string

type AssociateQueueToElasticResourcePoolRequestBody 

type AssociateQueueToElasticResourcePoolRequestBody struct {

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

AssociateQueueToElasticResourcePoolRequestBody 队列关联弹性资源池

func (AssociateQueueToElasticResourcePoolRequestBody) String 

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

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

func (o AssociateQueueToEnhancedConnectionRequest) String() string

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 

func (o AssociateQueueToEnhancedConnectionRequestBody) String() string

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 

func (o AssociateQueueToEnhancedConnectionResponse) String() string

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 

func (o BatchDeleteFlinkJobsRequest) String() string

type BatchDeleteFlinkJobsRequestBody 

type BatchDeleteFlinkJobsRequestBody struct {

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

BatchDeleteFlinkJobsRequestBody

func (BatchDeleteFlinkJobsRequestBody) String 

func (o BatchDeleteFlinkJobsRequestBody) String() string

type BatchDeleteFlinkJobsResponse 

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

BatchDeleteFlinkJobsResponse Response Object

func (BatchDeleteFlinkJobsResponse) String 

func (o BatchDeleteFlinkJobsResponse) String() string

type BatchDeleteQueuePlansRequest 

type BatchDeleteQueuePlansRequest struct {

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

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

BatchDeleteQueuePlansRequest Request Object

func (BatchDeleteQueuePlansRequest) String 

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

func (o BatchDeleteQueuePlansRequestBody) String() string

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 

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

func (o BatchDeleteSqlJobTemplatesRequest) String() string

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 

func (o BatchDeleteSqlJobTemplatesRequestBody) String() string

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 

func (o BatchDeleteSqlJobTemplatesResponse) String() string

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 

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

func (o BatchStopFlinkJobsResponse) String() string

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 

func (o ChangeFlinkJobStatusReportRequestBody) String() string

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 

func (o CreateConnectivityTaskRequest) String() string

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 

func (o CreateConnectivityTaskRequestBody) String() string

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 

func (o CreateConnectivityTaskResponse) String() string

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 

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

func (o CreateDatasourceConnectionRequestBody) String() string

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 

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

func (o CreateDliAgencyRequestBody) String() string

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 

func (o CreateElasticResourcePoolRequest) String() 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"`

	// 最大CU大于等于该资源池下任意一个队列的最大CU之和且大于min_cu。最小值为64
	MaxCu int32 `json:"max_cu"`

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

	// 最小CU大于等于该资源池下所有队列最小CU之和,最小值为64
	MinCu int32 `json:"min_cu"`

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

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

CreateElasticResourcePoolRequestBody 创建弹性资源池消息

func (CreateElasticResourcePoolRequestBody) String 

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

func (o CreateElasticResourcePoolResponse) String() string

type CreateEnhancedConnectionRequest 

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

CreateEnhancedConnectionRequest Request Object

func (CreateEnhancedConnectionRequest) String 

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

func (o CreateEnhancedConnectionRequestBody) String() string

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 

func (o CreateEnhancedConnectionResponse) String() string

type CreateEnhancedConnectionRoutesRequest 

type CreateEnhancedConnectionRoutesRequest struct {

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

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

CreateEnhancedConnectionRoutesRequest Request Object

func (CreateEnhancedConnectionRoutesRequest) String 

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

func (o CreateEnhancedConnectionRoutesRequestBody) String() string

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 

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

func (o CreateFlinkJarJobRequestBody) String() string

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 

func (o CreateFlinkSqlJobGraphRequest) String() string

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 

func (o CreateFlinkSqlJobGraphRequestBody) String() string

type CreateFlinkSqlJobGraphRequestBodyFlinkVersion added in v0.1.88 

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

func (CreateFlinkSqlJobGraphRequestBodyFlinkVersion) MarshalJSON added in v0.1.88 

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

func (*CreateFlinkSqlJobGraphRequestBodyFlinkVersion) UnmarshalJSON added in v0.1.88 

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

func (CreateFlinkSqlJobGraphRequestBodyFlinkVersion) Value added in v0.1.88 

func (c CreateFlinkSqlJobGraphRequestBodyFlinkVersion) Value() string

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 (c CreateFlinkSqlJobGraphRequestBodyGraphType) MarshalJSON() ([]byte, error)

func (*CreateFlinkSqlJobGraphRequestBodyGraphType) UnmarshalJSON added in v0.1.88 

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

func (CreateFlinkSqlJobGraphRequestBodyGraphType) Value added in v0.1.88 

func (c CreateFlinkSqlJobGraphRequestBodyGraphType) Value() string

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 

func (o CreateFlinkSqlJobGraphResponse) String() string

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_sql_edge_job。 run_mode为edge_node时，作业类型须为flink_sql_edge_job。 run_mode为shared_cluster跟exclusive_cluster时，作业类型须为flink_sql_job。 默认值：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 

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

func (o CreateFlinkSqlJobTemplateRequest) String() string

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 

func (o CreateFlinkSqlJobTemplateRequestBody) String() string

type CreateFlinkSqlJobTemplateRequestBodyJobType added in v0.1.88 

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

func (CreateFlinkSqlJobTemplateRequestBodyJobType) MarshalJSON added in v0.1.88 

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

func (*CreateFlinkSqlJobTemplateRequestBodyJobType) UnmarshalJSON added in v0.1.88 

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

func (CreateFlinkSqlJobTemplateRequestBodyJobType) Value added in v0.1.88 

func (c CreateFlinkSqlJobTemplateRequestBodyJobType) Value() string

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 

func (o CreateFlinkSqlJobTemplateResponse) String() string

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 

func (o CreateGlobalVariableRequest) String() string

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 

func (o CreateGlobalVariableRequestBody) String() string

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 

func (o CreateGlobalVariableResponse) String() string

type CreateIefMessageChannelRequest 

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

CreateIefMessageChannelRequest Request Object

func (CreateIefMessageChannelRequest) String 

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

func (o CreateIefMessageChannelRequestBody) String() string

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 

func (o CreateIefMessageChannelResponse) String() string

type CreateIefSystemEventsRequest 

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

CreateIefSystemEventsRequest Request Object

func (CreateIefSystemEventsRequest) String 

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

func (o CreateIefSystemEventsRequestBody) String() string

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 

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

func (o CreateJobAuthInfoRequestBody) String() string

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 

func (o CreateQueuePropertyRequest) String() string

type CreateQueuePropertyRequestBody added in v0.1.88 

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

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

func (CreateQueuePropertyRequestBody) String added in v0.1.88 

func (o CreateQueuePropertyRequestBody) String() string

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 

func (o CreateQueuePropertyResponse) String() string

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 

func (o CreateRouteToEnhancedConnectionRequest) String() string

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 

func (o CreateRouteToEnhancedConnectionRequestBody) String() string

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 

func (o CreateRouteToEnhancedConnectionResponse) String() string

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 

func (c CreateSparkJobRequestBodyFeature) Value() string

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 

func (o CreateSparkJobTemplateRequest) String() string

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 

func (o CreateSparkJobTemplateRequestBody) String() string

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 

func (o CreateSparkJobTemplateResponse) String() string

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 

func (c CreateSqlJobRequestBodyEngineType) Value() string

type CreateSqlJobRequestBodyEngineTypeEnum added in v0.1.90 

type CreateSqlJobRequestBodyEngineTypeEnum struct {
	TRINO 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 

func (c CreateSqlJobResponseJobType) Value() string

type CreateSqlJobResponseJobTypeEnum 

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

func GetCreateSqlJobResponseJobTypeEnum 

func GetCreateSqlJobResponseJobTypeEnum() CreateSqlJobResponseJobTypeEnum

type 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 

func (o CreateSqlJobTemplateRequest) String() string

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 

func (o CreateSqlJobTemplateRequestBody) String() string

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 

func (o CreateSqlJobTemplateResponse) String() string

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 

func (o DataAuthorizationPrivilege) String() string

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 

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

func (o DeleteDatasourceConnectionResponse) String() string

type DeleteElasticResourcePoolRequest 

type DeleteElasticResourcePoolRequest struct {

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

DeleteElasticResourcePoolRequest Request Object

func (DeleteElasticResourcePoolRequest) String 

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

func (o DeleteElasticResourcePoolResponse) String() string

type DeleteEnhancedConnectionRequest 

type DeleteEnhancedConnectionRequest struct {

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

DeleteEnhancedConnectionRequest Request Object

func (DeleteEnhancedConnectionRequest) String 

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

func (o DeleteEnhancedConnectionResponse) String() string

type DeleteEnhancedConnectionRoutesRequest 

type DeleteEnhancedConnectionRoutesRequest struct {

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

	Name string `json:"name"`
}

DeleteEnhancedConnectionRoutesRequest Request Object

func (DeleteEnhancedConnectionRoutesRequest) String 

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

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

func (o DeleteFlinkSqlJobTemplateRequest) String() string

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 

func (o DeleteFlinkSqlJobTemplateResponse) String() string

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 

func (o DeleteGlobalVariableRequest) String() string

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 

func (o DeleteGlobalVariableResponse) String() string

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 

func (o DeleteQueuePropertyRequest) String() string

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 

func (o DeleteQueuePropertyRequestBody) String() string

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 

func (o DeleteQueuePropertyResponse) String() string

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 

func (o DeleteRouteFromEnhancedConnectionRequest) String() string

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 

func (o DeleteRouteFromEnhancedConnectionResponse) String() string

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 

func (o DisassociateQueueFromEnhancedConnectionRequest) String() string

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 

func (o DisassociateQueueFromEnhancedConnectionRequestBody) String() string

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 

func (o DisassociateQueueFromEnhancedConnectionResponse) String() string

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

	// 标识弹性资源池，目前只支持 开发者标签，\"label\": {\"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 

func (o ElasticResourcePoolScaleRecord) String() string

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 

func (o EnhancedConnectionPrivilege) String() string

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 

func (o EnhancedConnectionResource) String() string

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 

func (o ExecuteFlinkJobSavepointRequest) String() string

type ExecuteFlinkJobSavepointRequestBody added in v0.1.95 

type ExecuteFlinkJobSavepointRequestBody struct {

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

	// Savepoint路径
	SavepointPath string `json:"savepoint_path"`
}

ExecuteFlinkJobSavepointRequestBody 创建savepoint请求体

func (ExecuteFlinkJobSavepointRequestBody) String added in v0.1.95 

func (o ExecuteFlinkJobSavepointRequestBody) String() string

type ExecuteFlinkJobSavepointRequestBodyAction added in v0.1.95 

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

func (ExecuteFlinkJobSavepointRequestBodyAction) MarshalJSON added in v0.1.95 

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

func (*ExecuteFlinkJobSavepointRequestBodyAction) UnmarshalJSON added in v0.1.95 

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

func (ExecuteFlinkJobSavepointRequestBodyAction) Value added in v0.1.95 

func (c ExecuteFlinkJobSavepointRequestBodyAction) Value() string

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 

func (o ExecuteFlinkJobSavepointResponse) String() string

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 

func (o ExportFlinkJobsRequestBody) String() string

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 

func (o ExportSqlJobResultRequestBody) String() string

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 

func (c ExportSqlJobResultRequestBodyExportMode) Value() string

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 

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

func (o ImportFlinkJobSavepointRequest) String() string

type ImportFlinkJobSavepointRequestBody added in v0.1.95 

type ImportFlinkJobSavepointRequestBody struct {

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

	// Savepoint路径
	SavepointPath string `json:"savepoint_path"`
}

ImportFlinkJobSavepointRequestBody 导入savepoint接口的请求体

func (ImportFlinkJobSavepointRequestBody) String added in v0.1.95 

func (o ImportFlinkJobSavepointRequestBody) String() string

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 

func (o ImportFlinkJobSavepointResponse) String() string

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 

func (o ImportFlinkJobsRequestBody) String() string

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 

func (o ListAuthorizationPrivilegesRequest) String() string

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 

func (o ListAuthorizationPrivilegesResponse) String() string

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 

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

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

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

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

func (o ListElasticResourcePoolScaleRecordsRequest) String() string

type ListElasticResourcePoolScaleRecordsRequestStatus 

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

func (ListElasticResourcePoolScaleRecordsRequestStatus) MarshalJSON 

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

func (*ListElasticResourcePoolScaleRecordsRequestStatus) UnmarshalJSON 

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

func (ListElasticResourcePoolScaleRecordsRequestStatus) Value 

func (c ListElasticResourcePoolScaleRecordsRequestStatus) Value() string

type ListElasticResourcePoolScaleRecordsRequestStatusEnum 

type ListElasticResourcePoolScaleRecordsRequestStatusEnum struct {
	SUCCESS ListElasticResourcePoolScaleRecordsRequestStatus
	FAIL    ListElasticResourcePoolScaleRecordsRequestStatus
}

func GetListElasticResourcePoolScaleRecordsRequestStatusEnum 

func GetListElasticResourcePoolScaleRecordsRequestStatusEnum() ListElasticResourcePoolScaleRecordsRequestStatusEnum

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 

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

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

func (c ListElasticResourcePoolsRequestStatus) Value() string

type ListElasticResourcePoolsRequestStatusEnum 

type ListElasticResourcePoolsRequestStatusEnum struct {
	AVAILABLE ListElasticResourcePoolsRequestStatus
	SCALING   ListElasticResourcePoolsRequestStatus
	CREATING  ListElasticResourcePoolsRequestStatus
	FAILED    ListElasticResourcePoolsRequestStatus
}

func GetListElasticResourcePoolsRequestStatusEnum 

func GetListElasticResourcePoolsRequestStatusEnum() ListElasticResourcePoolsRequestStatusEnum

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 

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

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

func (o ListEnhancedConnectionsResponse) String() 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"`

	// 作业状态码。
	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 

func (o ListFlinkSqlJobTemplatesRequest) String() string

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 

func (o ListFlinkSqlJobTemplatesResponse) String() string

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 

func (o ListGlobalVariablesRequest) String() string

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 

func (o ListGlobalVariablesResponse) String() string

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 

func (o ListQueuePropertiesRequest) String() string

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 

func (o ListQueuePropertiesResponse) String() string

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 

func (o ListSparkJobTemplatesRequest) String() string

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 

func (o ListSparkJobTemplatesResponse) String() string

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 

func (o ListSqlJobTemplatesRequest) String() string

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 

func (o ListSqlJobTemplatesResponse) String() string

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 

func (c ListSqlJobsRequestJobType) Value() string

type ListSqlJobsRequestJobTypeEnum 

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

func GetListSqlJobsRequestJobTypeEnum 

func GetListSqlJobsRequestJobTypeEnum() ListSqlJobsRequestJobTypeEnum

type ListSqlJobsRequestOrder 

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

func (ListSqlJobsRequestOrder) MarshalJSON 

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

func (*ListSqlJobsRequestOrder) UnmarshalJSON 

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

func (ListSqlJobsRequestOrder) Value 

func (c ListSqlJobsRequestOrder) Value() string

type ListSqlJobsRequestOrderEnum 

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

func GetListSqlJobsRequestOrderEnum 

func GetListSqlJobsRequestOrderEnum() ListSqlJobsRequestOrderEnum

type ListSqlJobsResponse 

type ListSqlJobsResponse struct {

	// 请求发送是否成功。“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 

func (o ListSqlSampleTemplatesRequest) String() string

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 

func (o ListSqlSampleTemplatesResponse) String() string

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 

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

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

func (o PreviewSqlJobResultRequest) String() string

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 

func (o PreviewSqlJobResultResponse) String() string

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 

func (c PreviewSqlJobResultResponseJobType) Value() string

type PreviewSqlJobResultResponseJobTypeEnum added in v0.1.68 

type PreviewSqlJobResultResponseJobTypeEnum struct {
	DDL    PreviewSqlJobResultResponseJobType
	DCL    PreviewSqlJobResultResponseJobType
	IMPORT PreviewSqlJobResultResponseJobType
	EXPORT PreviewSqlJobResultResponseJobType
	QUERY  PreviewSqlJobResultResponseJobType
	INSERT PreviewSqlJobResultResponseJobType
}

func GetPreviewSqlJobResultResponseJobTypeEnum added in v0.1.68 

func GetPreviewSqlJobResultResponseJobTypeEnum() PreviewSqlJobResultResponseJobTypeEnum

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

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 

func (c QueuePlanRequestBodyRepeatDay) Value() string

type QueuePlanRequestBodyRepeatDayEnum added in v0.1.88 

type QueuePlanRequestBodyRepeatDayEnum struct {
	SUNDAY    QueuePlanRequestBodyRepeatDay
	MONDAY    QueuePlanRequestBodyRepeatDay
	TUESDAY   QueuePlanRequestBodyRepeatDay
	WEDNESDAY QueuePlanRequestBodyRepeatDay
	THURSDAY  QueuePlanRequestBodyRepeatDay
	FRIDAY    QueuePlanRequestBodyRepeatDay
	SATURDAY  QueuePlanRequestBodyRepeatDay
}

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 

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

func (o RegisterAuthorizedQueueRequestBody) String() string

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 

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

func (o RunAuthorizationActionRequest) String() string

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 

func (o RunAuthorizationActionRequestBody) String() string

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 

func (c RunAuthorizationActionRequestBodyAction) Value() string

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 

func (o RunAuthorizationActionResponse) String() string

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 

func (o RunCatalogActionRequestBody) String() string

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 

func (c RunCatalogActionRequestBodyAction) Value() string

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 

func (o RunDataAuthorizationActionRequest) String() string

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 

func (o RunDataAuthorizationActionRequestBody) String() string

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 

func (o RunDataAuthorizationActionResponse) String() string

type RunIefJobActionCallBackRequest 

type RunIefJobActionCallBackRequest struct {
	Body *RunIefJobActionCallBackRequestBody `json:"body,omitempty"`
}

RunIefJobActionCallBackRequest Request Object

func (RunIefJobActionCallBackRequest) String 

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

func (o RunIefJobActionCallBackRequestBody) String() string

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 

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

func (o ShowConnectivityTaskRequest) String() string

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 

func (o ShowConnectivityTaskResponse) String() string

type ShowDatasourceConnectionRequest 

type ShowDatasourceConnectionRequest struct {

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

ShowDatasourceConnectionRequest Request Object

func (ShowDatasourceConnectionRequest) String 

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

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

func (o ShowEnhancedConnectionPrivilegeRequest) String() string

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 

func (o ShowEnhancedConnectionPrivilegeResponse) String() string

type ShowEnhancedConnectionRequest 

type ShowEnhancedConnectionRequest struct {

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

ShowEnhancedConnectionRequest Request Object

func (ShowEnhancedConnectionRequest) String 

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

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

func (o ShowFlinkJobExecutionGraphRequest) String() string

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 

func (o ShowFlinkJobExecutionGraphResponse) String() string

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 

func (o ShowFlinkMetricRequestBody) String() string

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

func (o ShowSparkJobStatusResponse) String() string

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 

func (o ShowSparkJobTemplateRequest) String() string

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 

func (o ShowSparkJobTemplateResponse) String() string

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 

func (o ShowSqlJobProgressResponse) String() string

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

	// 查询结果格式
	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 

func (c ShowSqlJobStatusResponseStatus) Value() string

type ShowSqlJobStatusResponseStatusEnum 

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

func GetShowSqlJobStatusResponseStatusEnum 

func GetShowSqlJobStatusResponseStatusEnum() ShowSqlJobStatusResponseStatusEnum

type 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 

func (c SparkJobTemplateDetailFeature) Value() string

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 

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

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

func (o UpdateElasticResourcePoolQueueRequest) String() string

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 

func (o UpdateElasticResourcePoolQueueRequestBody) String() string

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 

func (o UpdateElasticResourcePoolQueueResponse) String() string

type UpdateElasticResourcePoolRequest 

type UpdateElasticResourcePoolRequest struct {

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

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

UpdateElasticResourcePoolRequest Request Object

func (UpdateElasticResourcePoolRequest) String 

func (o UpdateElasticResourcePoolRequest) String() string

type UpdateElasticResourcePoolRequestBody 

type UpdateElasticResourcePoolRequestBody struct {

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

	// 弹性资源池的最大CU数
	MaxCu *int32 `json:"max_cu,omitempty"`

	// 弹性资源池的最小CU数
	MinCu *int32 `json:"min_cu,omitempty"`
}

UpdateElasticResourcePoolRequestBody 更新弹性资源池请求

func (UpdateElasticResourcePoolRequestBody) String 

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

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

func (o UpdateEnhancedConnectionRequest) String() string

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 

func (o UpdateEnhancedConnectionRequestBody) String() string

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 

func (o UpdateEnhancedConnectionResponse) String() string

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 

func (o UpdateFlinkJarJobRequestBody) String() string

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 

func (o UpdateFlinkJobStatusReportRequest) String() string

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 

func (o UpdateFlinkJobStatusReportResponse) String() string

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 

func (o UpdateFlinkSqlJobRequestBody) String() string

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 

func (o UpdateFlinkSqlJobTemplateRequest) String() string

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 

func (o UpdateFlinkSqlJobTemplateRequestBody) String() string

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 

func (o UpdateFlinkSqlJobTemplateResponse) String() string

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 

func (o UpdateGlobalVariableRequest) String() string

type UpdateGlobalVariableRequestBody added in v0.1.88 

type UpdateGlobalVariableRequestBody struct {

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

func (UpdateGlobalVariableRequestBody) String added in v0.1.88 

func (o UpdateGlobalVariableRequestBody) String() string

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 

func (o UpdateGlobalVariableResponse) String() string

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 

func (o UpdateJobAuthInfoRequestBody) String() string

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 

func (o UpdateJobResourceOwnerRequest) String() string

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 

func (o UpdateJobResourceOwnerRequestBody) String() string

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 

func (o UpdateJobResourceOwnerResponse) String() string

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 

func (o UpdateQueueCidrRequestBody) String() string

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 

func (o UpdateQueuePropertyRequest) String() string

type UpdateQueuePropertyRequestBody added in v0.1.65 

type UpdateQueuePropertyRequestBody struct {
	Properties *AdvancedQueueProperty `json:"properties,omitempty"`
}

UpdateQueuePropertyRequestBody 队列待更新属性

func (UpdateQueuePropertyRequestBody) String added in v0.1.65 

func (o UpdateQueuePropertyRequestBody) String() string

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 

func (o UpdateQueuePropertyResponse) String() string

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 

func (o UpdateSparkJobTemplateRequest) String() string

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 

func (o UpdateSparkJobTemplateRequestBody) String() string

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 

func (o UpdateSparkJobTemplateResponse) String() string

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 

func (o UpdateSqlJobTemplateRequest) String() string

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 

func (o UpdateSqlJobTemplateRequestBody) String() string

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 

func (o UpdateSqlJobTemplateResponse) String() string

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 

func (o UploadFileJobResourcesRequest) String() string

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 

func (o UploadFileJobResourcesResponse) String() string

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 

func (o UploadJarJobResourcesRequest) String() string

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 

func (o UploadJarJobResourcesResponse) String() string

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 

func (o UploadJobResourcesRequestBody) String() string

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 

func (o UploadJobResourcesResponse) String() string

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 

func (o UploadPythonFileJobResourcesRequest) String() string

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 

func (o UploadPythonFileJobResourcesResponse) String() string

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 

func (o UploadResourcesRequestBody) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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