model

package
v0.1.50 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2023 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 AssociateConnectionQueueReq 

type AssociateConnectionQueueReq struct {

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

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

func (AssociateConnectionQueueReq) String 

func (o AssociateConnectionQueueReq) String() string

type AssociateConnectionQueueRequest 

type AssociateConnectionQueueRequest struct {

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

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

AssociateConnectionQueueRequest Request Object

func (AssociateConnectionQueueRequest) String 

func (o AssociateConnectionQueueRequest) String() string

type AssociateConnectionQueueResponse 

type AssociateConnectionQueueResponse struct {

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

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

AssociateConnectionQueueResponse Response Object

func (AssociateConnectionQueueResponse) String 

func (o AssociateConnectionQueueResponse) 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 AuthInfos 

type AuthInfos 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 (AuthInfos) String 

func (o AuthInfos) String() string

type AuthorizeResourceRequest 

type AuthorizeResourceRequest struct {
	Body *AuthorizeResourceRequestBody `json:"body,omitempty"`
}

AuthorizeResourceRequest Request Object

func (AuthorizeResourceRequest) String 

func (o AuthorizeResourceRequest) String() string

type AuthorizeResourceRequestBody 

type AuthorizeResourceRequestBody struct {

	// 被赋权的用户名称，该用户将有权访问指定的DLI资源权限，被收回或者更新访问权限。
	UserName *string `json:"user_name,omitempty"`

	// 被赋权的项目ID，数据赋权给其他项目后，该项目的管理员将 有权访问指定的DLI资源权限，被收回或者更新访问权限。
	ProjectId *string `json:"projectId,omitempty"`

	// 指定赋权或回收。值为：grant，revoke或update。  说明：当用户同时拥有grant和revoke权限的时候才有权限使用update操作。
	Action AuthorizeResourceRequestBodyAction `json:"action"`

	// 赋权信息。具体参数请参考Privilege参数。
	Privileges []Privilege `json:"privileges"`
}

func (AuthorizeResourceRequestBody) String 

func (o AuthorizeResourceRequestBody) String() string

type AuthorizeResourceRequestBodyAction 

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

func (AuthorizeResourceRequestBodyAction) MarshalJSON 

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

func (*AuthorizeResourceRequestBodyAction) UnmarshalJSON 

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

func (AuthorizeResourceRequestBodyAction) Value 

func (c AuthorizeResourceRequestBodyAction) Value() string

type AuthorizeResourceRequestBodyActionEnum 

type AuthorizeResourceRequestBodyActionEnum struct {
	GRANT  AuthorizeResourceRequestBodyAction
	REVOKE AuthorizeResourceRequestBodyAction
	UPDATE AuthorizeResourceRequestBodyAction
}

func GetAuthorizeResourceRequestBodyActionEnum 

func GetAuthorizeResourceRequestBodyActionEnum() AuthorizeResourceRequestBodyActionEnum

type AuthorizeResourceResponse 

type AuthorizeResourceResponse struct {

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

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

AuthorizeResourceResponse Response Object

func (AuthorizeResourceResponse) String 

func (o AuthorizeResourceResponse) 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 {

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

	// 系统提示信息，执行成功时，信息可能为空。
	Message        *string `json:"message,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 *QueuePlanIds `json:"body,omitempty"`
}

BatchDeleteQueuePlansRequest Request Object

func (BatchDeleteQueuePlansRequest) String 

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

type BatchJobInfo 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 *[]CreateSessionReqResource `json:"resources,omitempty"`

	// JSON对象列表，填写用户组类型资源，格式详见请求示例。resources中的name未进行type校验，只要此分组中存在这个名字的包即可。
	Groups *[]CreateSessionReqGroup `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 *BatchJobInfoFeature `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"`
}

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

func (BatchJobInfo) String 

func (o BatchJobInfo) String() string

type BatchJobInfoFeature 

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

func (BatchJobInfoFeature) MarshalJSON 

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

func (*BatchJobInfoFeature) UnmarshalJSON 

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

func (BatchJobInfoFeature) Value 

func (c BatchJobInfoFeature) Value() string

type BatchJobInfoFeatureEnum 

type BatchJobInfoFeatureEnum struct {
	BASIC  BatchJobInfoFeature
	AI     BatchJobInfoFeature
	CUSTOM BatchJobInfoFeature
}

func GetBatchJobInfoFeatureEnum 

func GetBatchJobInfoFeatureEnum() BatchJobInfoFeatureEnum

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           *[]CommonResp `json:"body,omitempty"`
	HttpStatusCode int           `json:"-"`
}

BatchRunFlinkJobsResponse Response Object

func (BatchRunFlinkJobsResponse) String 

func (o BatchRunFlinkJobsResponse) String() string

type CancelBatchJobRequest 

type CancelBatchJobRequest struct {

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

CancelBatchJobRequest Request Object

func (CancelBatchJobRequest) String 

func (o CancelBatchJobRequest) String() string

type CancelBatchJobResponse 

type CancelBatchJobResponse struct {

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

CancelBatchJobResponse Response Object

func (CancelBatchJobResponse) String 

func (o CancelBatchJobResponse) 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 ChangeAuthorizationRequest 

type ChangeAuthorizationRequest struct {
	Body *GrantDataPermissionReq `json:"body,omitempty"`
}

ChangeAuthorizationRequest Request Object

func (ChangeAuthorizationRequest) String 

func (o ChangeAuthorizationRequest) String() string

type ChangeAuthorizationResponse 

type ChangeAuthorizationResponse struct {

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

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

ChangeAuthorizationResponse Response Object

func (ChangeAuthorizationResponse) String 

func (o ChangeAuthorizationResponse) String() string

type ChangeFlinkJobStatusReportRequest 

type ChangeFlinkJobStatusReportRequest struct {
	Body *IefFlinkJobStatusReportReq `json:"body,omitempty"`
}

ChangeFlinkJobStatusReportRequest Request Object

func (ChangeFlinkJobStatusReportRequest) String 

func (o ChangeFlinkJobStatusReportRequest) String() string

type ChangeFlinkJobStatusReportResponse 

type ChangeFlinkJobStatusReportResponse struct {

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

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

ChangeFlinkJobStatusReportResponse Response Object

func (ChangeFlinkJobStatusReportResponse) String 

func (o ChangeFlinkJobStatusReportResponse) String() string

type ChangeQueuePlanRequest 

type ChangeQueuePlanRequest struct {

	// 待修改的队列扩缩容计划的ID
	PlanId string `json:"plan_id"`

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

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

ChangeQueuePlanRequest Request Object

func (ChangeQueuePlanRequest) String 

func (o ChangeQueuePlanRequest) String() string

type ChangeQueuePlanResponse 

type ChangeQueuePlanResponse struct {

	// 定时扩缩容计划对应的队列名称
	QueueName *string `json:"queue_name,omitempty"`

	// 扩缩容计划的ID编号
	PlanId *string `json:"plan_id,omitempty"`

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

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

ChangeQueuePlanResponse Response Object

func (ChangeQueuePlanResponse) String 

func (o ChangeQueuePlanResponse) String() string

type CheckConnectionRequest 

type CheckConnectionRequest struct {

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

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

CheckConnectionRequest Request Object

func (CheckConnectionRequest) String 

func (o CheckConnectionRequest) String() string

type CheckConnectionResponse 

type CheckConnectionResponse struct {

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

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

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

CheckConnectionResponse Response Object

func (CheckConnectionResponse) String 

func (o CheckConnectionResponse) 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 CommonResp 

type CommonResp struct {

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

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

CommonResp

func (CommonResp) String 

func (o CommonResp) String() string

type CreateAgencyRequest 

type CreateAgencyRequest struct {

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

CreateAgencyRequest

func (CreateAgencyRequest) String 

func (o CreateAgencyRequest) String() string

type CreateAuthInfoReq 

type CreateAuthInfoReq 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 (CreateAuthInfoReq) String 

func (o CreateAuthInfoReq) String() string

type CreateAuthInfoRequest 

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

CreateAuthInfoRequest Request Object

func (CreateAuthInfoRequest) String 

func (o CreateAuthInfoRequest) 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 CreateBatchJobRequest 

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

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

CreateBatchJobRequest Request Object

func (CreateBatchJobRequest) String 

func (o CreateBatchJobRequest) String() string

type CreateBatchJobResponse 

type CreateBatchJobResponse 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:"-"`
}

CreateBatchJobResponse Response Object

func (CreateBatchJobResponse) String 

func (o CreateBatchJobResponse) 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 *[]TmsTagEntity `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 CreateDatasourceConnectionReq 

type CreateDatasourceConnectionReq 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 *[]TmsTagEntity `json:"tags,omitempty"`
}

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

func (CreateDatasourceConnectionReq) String 

func (o CreateDatasourceConnectionReq) String() string

type CreateDatasourceConnectionRequest 

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

CreateDatasourceConnectionRequest Request Object

func (CreateDatasourceConnectionRequest) String 

func (o CreateDatasourceConnectionRequest) 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 *CreateAgencyRequest `json:"body,omitempty"`
}

CreateDliAgencyRequest Request Object

func (CreateDliAgencyRequest) String 

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

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

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

	// 标签
	Tags *[]TmsTag `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 *CreateEnhancedConnectionsReq `json:"body,omitempty"`
}

CreateEnhancedConnectionRequest Request Object

func (CreateEnhancedConnectionRequest) String 

func (o CreateEnhancedConnectionRequest) 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 *CreateRouteRequestBody `json:"body,omitempty"`
}

CreateEnhancedConnectionRoutesRequest Request Object

func (CreateEnhancedConnectionRoutesRequest) String 

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

type CreateEnhancedConnectionsReq struct {

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

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

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

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

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

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

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

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

func (CreateEnhancedConnectionsReq) String 

func (o CreateEnhancedConnectionsReq) String() string

type CreateFlinkJarRequest 

type CreateFlinkJarRequest struct {
	Body *CreateFlinkJarRequestBody `json:"body,omitempty"`
}

CreateFlinkJarRequest Request Object

func (CreateFlinkJarRequest) String 

func (o CreateFlinkJarRequest) String() string

type CreateFlinkJarRequestBody 

type CreateFlinkJarRequestBody 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 *[]TmsTagEntity `json:"tags,omitempty"`
}

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

func (CreateFlinkJarRequestBody) String 

func (o CreateFlinkJarRequestBody) String() string

type CreateFlinkJarResponse 

type CreateFlinkJarResponse struct {

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

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

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

CreateFlinkJarResponse Response Object

func (CreateFlinkJarResponse) String 

func (o CreateFlinkJarResponse) 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 *[]TmsTagEntity `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 *bool `json:"is_success,omitempty"`

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

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

CreateFlinkSqlJobResponse Response Object

func (CreateFlinkSqlJobResponse) String 

func (o CreateFlinkSqlJobResponse) String() string

type CreateFlinkTemplateRequest 

type CreateFlinkTemplateRequest struct {
	Body *CreateFlinkTemplateRequestBody `json:"body,omitempty"`
}

CreateFlinkTemplateRequest Request Object

func (CreateFlinkTemplateRequest) String 

func (o CreateFlinkTemplateRequest) String() string

type CreateFlinkTemplateRequestBody 

type CreateFlinkTemplateRequestBody 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 *[]TmsTagEntity `json:"tags,omitempty"`

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

CreateFlinkTemplateRequestBody 新建模板

func (CreateFlinkTemplateRequestBody) String 

func (o CreateFlinkTemplateRequestBody) String() string

type CreateFlinkTemplateRequestBodyJobType 

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

func (CreateFlinkTemplateRequestBodyJobType) MarshalJSON 

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

func (*CreateFlinkTemplateRequestBodyJobType) UnmarshalJSON 

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

func (CreateFlinkTemplateRequestBodyJobType) Value 

func (c CreateFlinkTemplateRequestBodyJobType) Value() string

type CreateFlinkTemplateRequestBodyJobTypeEnum 

type CreateFlinkTemplateRequestBodyJobTypeEnum struct {
	FLINK_SQL_JOB            CreateFlinkTemplateRequestBodyJobType
	FLINK_OPENSOURCE_SQL_JOB CreateFlinkTemplateRequestBodyJobType
}

func GetCreateFlinkTemplateRequestBodyJobTypeEnum 

func GetCreateFlinkTemplateRequestBodyJobTypeEnum() CreateFlinkTemplateRequestBodyJobTypeEnum

type CreateFlinkTemplateResponse 

type CreateFlinkTemplateResponse struct {

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

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

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

CreateFlinkTemplateResponse Response Object

func (CreateFlinkTemplateResponse) String 

func (o CreateFlinkTemplateResponse) String() string

type CreateGlobalValueReq 

type CreateGlobalValueReq struct {

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

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

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

CreateGlobalValueReq 创建全局变量

func (CreateGlobalValueReq) String 

func (o CreateGlobalValueReq) String() string

type CreateGlobalValueRequest 

type CreateGlobalValueRequest struct {
	Body *CreateGlobalValueReq `json:"body,omitempty"`
}

CreateGlobalValueRequest Request Object

func (CreateGlobalValueRequest) String 

func (o CreateGlobalValueRequest) String() string

type CreateGlobalValueResponse 

type CreateGlobalValueResponse struct {

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

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

CreateGlobalValueResponse Response Object

func (CreateGlobalValueResponse) String 

func (o CreateGlobalValueResponse) String() string

type CreateIefMessageChannelReq 

type CreateIefMessageChannelReq struct {

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

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

func (CreateIefMessageChannelReq) String 

func (o CreateIefMessageChannelReq) String() string

type CreateIefMessageChannelRequest 

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

CreateIefMessageChannelRequest Request Object

func (CreateIefMessageChannelRequest) String 

func (o CreateIefMessageChannelRequest) String() string

type CreateIefMessageChannelResponse 

type CreateIefMessageChannelResponse struct {

	// 请求是否成功
	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 *IefSystemEventsReq `json:"body,omitempty"`
}

CreateIefSystemEventsRequest Request Object

func (CreateIefSystemEventsRequest) String 

func (o CreateIefSystemEventsRequest) String() string

type CreateIefSystemEventsResponse 

type CreateIefSystemEventsResponse struct {

	// 请求是否成功
	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 CreateJobRespJob 

type CreateJobRespJob struct {

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

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

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

CreateJobRespJob 创建作业的job模型。

func (CreateJobRespJob) String 

func (o CreateJobRespJob) String() string

type CreateJobTemplatesRequest 

type CreateJobTemplatesRequest struct {
	Body *CreateJobTemplatesRequestBody `json:"body,omitempty"`
}

CreateJobTemplatesRequest Request Object

func (CreateJobTemplatesRequest) String 

func (o CreateJobTemplatesRequest) String() string

type CreateJobTemplatesRequestBody 

type CreateJobTemplatesRequestBody 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 (CreateJobTemplatesRequestBody) String 

func (o CreateJobTemplatesRequestBody) String() string

type CreateJobTemplatesResponse 

type CreateJobTemplatesResponse struct {

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

CreateJobTemplatesResponse Response Object

func (CreateJobTemplatesResponse) String 

func (o CreateJobTemplatesResponse) String() string

type CreateQueuePlanRequest 

type CreateQueuePlanRequest struct {

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

	Body *SetQueuePlanReq `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 CreateQueueReq 

type CreateQueueReq 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 *[]TmsTagEntity `json:"tags,omitempty"`

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

CreateQueueReq 创建队列的请求参数。

func (CreateQueueReq) String 

func (o CreateQueueReq) String() string

type CreateQueueRequest 

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

CreateQueueRequest Request Object

func (CreateQueueRequest) String 

func (o CreateQueueRequest) 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 CreateRouteRequestBody 

type CreateRouteRequestBody struct {

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

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

func (CreateRouteRequestBody) String 

func (o CreateRouteRequestBody) String() string

type CreateSessionReqGroup 

type CreateSessionReqGroup struct {

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

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

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

func (CreateSessionReqGroup) String 

func (o CreateSessionReqGroup) String() string

type CreateSessionReqResource 

type CreateSessionReqResource struct {

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

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

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

func (CreateSessionReqResource) String 

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

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

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

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

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

CreateSqlJobRequestBody 提交SQL作业

func (CreateSqlJobRequestBody) String 

func (o CreateSqlJobRequestBody) String() string

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 *[][]string `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 CreateSqlTemplatesRequest 

type CreateSqlTemplatesRequest struct {
	Body *CreateSqlTemplatesRequestBody `json:"body,omitempty"`
}

CreateSqlTemplatesRequest Request Object

func (CreateSqlTemplatesRequest) String 

func (o CreateSqlTemplatesRequest) String() string

type CreateSqlTemplatesRequestBody 

type CreateSqlTemplatesRequestBody struct {

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

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

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

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

func (CreateSqlTemplatesRequestBody) String 

func (o CreateSqlTemplatesRequestBody) String() string

type CreateSqlTemplatesResponse 

type CreateSqlTemplatesResponse 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:"-"`
}

CreateSqlTemplatesResponse Response Object

func (CreateSqlTemplatesResponse) String 

func (o CreateSqlTemplatesResponse) String() string

type CreateStreamGraphRequest 

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

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

CreateStreamGraphRequest Request Object

func (CreateStreamGraphRequest) String 

func (o CreateStreamGraphRequest) String() string

type CreateStreamGraphResponse 

type CreateStreamGraphResponse 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:"-"`
}

CreateStreamGraphResponse Response Object

func (CreateStreamGraphResponse) String 

func (o CreateStreamGraphResponse) String() string

type CreateTableReq 

type CreateTableReq struct {

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

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

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

	// OBS表和DLI表必选参数。新增表的列。
	Columns []CreateTableReqColumn `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 *[]TmsTagEntity `json:"tags,omitempty"`
}

CreateTableReq 创建表的请求body体。

func (CreateTableReq) String 

func (o CreateTableReq) String() string

type CreateTableReqColumn 

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

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

func (CreateTableReqColumn) String 

func (o CreateTableReqColumn) String() string

type CreateTableRequest 

type CreateTableRequest struct {

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

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

CreateTableRequest Request Object

func (CreateTableRequest) String 

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

	// 系统提示信息，执行成功时，返回“Deleted”。
	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"`

	// 系统提示信息，执行成功时，返回“Deleted”。
	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 *bool `json:"is_success,omitempty"`

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

DeleteFlinkJobResponse Response Object

func (DeleteFlinkJobResponse) String 

func (o DeleteFlinkJobResponse) String() string

type DeleteFlinkTemplateRequest 

type DeleteFlinkTemplateRequest struct {

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

DeleteFlinkTemplateRequest Request Object

func (DeleteFlinkTemplateRequest) String 

func (o DeleteFlinkTemplateRequest) String() string

type DeleteFlinkTemplateResponse 

type DeleteFlinkTemplateResponse struct {

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

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

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

DeleteFlinkTemplateResponse Response Object

func (DeleteFlinkTemplateResponse) String 

func (o DeleteFlinkTemplateResponse) String() string

type DeleteGlobalValueRequest 

type DeleteGlobalValueRequest struct {

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

DeleteGlobalValueRequest Request Object

func (DeleteGlobalValueRequest) String 

func (o DeleteGlobalValueRequest) String() string

type DeleteGlobalValueResponse 

type DeleteGlobalValueResponse struct {

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

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

DeleteGlobalValueResponse Response Object

func (DeleteGlobalValueResponse) String 

func (o DeleteGlobalValueResponse) 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 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 DeleteResourceRequest 

type DeleteResourceRequest struct {

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

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

DeleteResourceRequest Request Object

func (DeleteResourceRequest) String 

func (o DeleteResourceRequest) String() string

type DeleteResourceResponse 

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

DeleteResourceResponse Response Object

func (DeleteResourceResponse) String 

func (o DeleteResourceResponse) String() string

type DeleteSqlTemplatesRequest 

type DeleteSqlTemplatesRequest struct {
	Body *DeleteSqlTemplatesRequestBody `json:"body,omitempty"`
}

DeleteSqlTemplatesRequest Request Object

func (DeleteSqlTemplatesRequest) String 

func (o DeleteSqlTemplatesRequest) String() string

type DeleteSqlTemplatesRequestBody 

type DeleteSqlTemplatesRequestBody struct {

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

func (DeleteSqlTemplatesRequestBody) String 

func (o DeleteSqlTemplatesRequestBody) String() string

type DeleteSqlTemplatesResponse 

type DeleteSqlTemplatesResponse struct {

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

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

DeleteSqlTemplatesResponse Response Object

func (DeleteSqlTemplatesResponse) String 

func (o DeleteSqlTemplatesResponse) 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 DeleteTemplateRespTemplate 

type DeleteTemplateRespTemplate struct {

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

DeleteTemplateRespTemplate 删除模板信息。

func (DeleteTemplateRespTemplate) String 

func (o DeleteTemplateRespTemplate) String() string

type DisassociateConnectionQueueReq 

type DisassociateConnectionQueueReq struct {

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

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

func (DisassociateConnectionQueueReq) String 

func (o DisassociateConnectionQueueReq) String() string

type DisassociateConnectionQueueRequest 

type DisassociateConnectionQueueRequest struct {

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

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

DisassociateConnectionQueueRequest Request Object

func (DisassociateConnectionQueueRequest) String 

func (o DisassociateConnectionQueueRequest) String() string

type DisassociateConnectionQueueResponse 

type DisassociateConnectionQueueResponse struct {

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

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

DisassociateConnectionQueueResponse Response Object

func (DisassociateConnectionQueueResponse) String 

func (o DisassociateConnectionQueueResponse) String() string

type ElasticResourcePoolsResponse 

type ElasticResourcePoolsResponse struct {

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

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

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

	// 资源池名称
	ElasticResourcePoolName *string `json:"elastic_resource_pool_name,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"`
}

ElasticResourcePoolsResponse 弹性资源池列表

func (ElasticResourcePoolsResponse) String 

func (o ElasticResourcePoolsResponse) String() string

type EnhancedConnectionResourceInfo 

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

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

func (EnhancedConnectionResourceInfo) String 

func (o EnhancedConnectionResourceInfo) String() string

type EnhancedConnectionsHost 

type EnhancedConnectionsHost struct {

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

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

EnhancedConnectionsHost 用户自定义主机信息。

func (EnhancedConnectionsHost) String 

func (o EnhancedConnectionsHost) String() string

type ExportFlinkJobRequest 

type ExportFlinkJobRequest struct {
	Body *ExportFlinkJobRequestBody `json:"body,omitempty"`
}

ExportFlinkJobRequest Request Object

func (ExportFlinkJobRequest) String 

func (o ExportFlinkJobRequest) String() string

type ExportFlinkJobRequestBody 

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

ExportFlinkJobRequestBody 导出作业的请求参数。

func (ExportFlinkJobRequestBody) String 

func (o ExportFlinkJobRequestBody) String() string

type ExportFlinkJobResponse 

type ExportFlinkJobResponse struct {

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

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

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

ExportFlinkJobResponse Response Object

func (ExportFlinkJobResponse) String 

func (o ExportFlinkJobResponse) String() string

type ExportSqlJobResultRequest 

type ExportSqlJobResultRequest struct {

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

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

ExportSqlJobResultRequest Request Object

func (ExportSqlJobResultRequest) String 

func (o ExportSqlJobResultRequest) String() string

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 ExportSqlResultRequestBody 

type ExportSqlResultRequestBody 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 *ExportSqlResultRequestBodyExportMode `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"`
}

ExportSqlResultRequestBody 导出查询结果

func (ExportSqlResultRequestBody) String 

func (o ExportSqlResultRequestBody) String() string

type ExportSqlResultRequestBodyExportMode 

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

func (ExportSqlResultRequestBodyExportMode) MarshalJSON 

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

func (*ExportSqlResultRequestBodyExportMode) UnmarshalJSON 

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

func (ExportSqlResultRequestBodyExportMode) Value 

func (c ExportSqlResultRequestBodyExportMode) Value() string

type ExportSqlResultRequestBodyExportModeEnum 

type ExportSqlResultRequestBodyExportModeEnum struct {
	ERROR_IF_EXISTS ExportSqlResultRequestBodyExportMode
	OVERWRITE       ExportSqlResultRequestBodyExportMode
}

func GetExportSqlResultRequestBodyExportModeEnum 

func GetExportSqlResultRequestBodyExportModeEnum() ExportSqlResultRequestBodyExportModeEnum

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

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

func (FlinkJobConfig) String 

func (o FlinkJobConfig) String() string

type FlinkJobDetail 

type FlinkJobDetail struct {

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

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

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

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

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

	// 作业状态描述。
	StatusDesc *string `json:"status_desc,omitempty"`

	// 作业创建时间。
	CreateTime int64 `json:"create_time"`

	// 作业开始时间。
	StartTime *int64 `json:"start_time,omitempty"`

	// 作业所属用户标识。
	UserId *string `json:"user_id,omitempty"`

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

	// 作业所属项目标识。
	ProjectId *string `json:"project_id,omitempty"`

	// Stream SQL语句。
	SqlBody *string `json:"sql_body,omitempty"`

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

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

	// jar包主类。
	MainClass *string `json:"main_class,omitempty"`

	// jar包作业运行参数，多个参数之间空格分隔。
	EntrypointArgs *string `json:"entrypoint_args,omitempty"`

	// 作业执行计划。
	ExecutionGraph *string `json:"execution_graph,omitempty"`

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

	// 手动产生的Checkpoint的保存路径。
	SavepointPath *string `json:"savepoint_path,omitempty"`
}

FlinkJobDetail 作业详细信息。

func (FlinkJobDetail) String 

func (o FlinkJobDetail) String() string

type FlinkJobInfo 

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

	JobConfig *ShowStreamJobListJobConfig `json:"job_config,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"`
}

FlinkJobInfo 作业列表信息。

func (FlinkJobInfo) String 

func (o FlinkJobInfo) String() string

type FlinkJobList 

type FlinkJobList struct {

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

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

FlinkJobList 作业列表详情。

func (FlinkJobList) String 

func (o FlinkJobList) 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 FlinkTemplateDetail 

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

FlinkTemplateDetail

func (FlinkTemplateDetail) String 

func (o FlinkTemplateDetail) String() string

type FlinkTemplateList 

type FlinkTemplateList struct {

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

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

FlinkTemplateList

func (FlinkTemplateList) String 

func (o FlinkTemplateList) String() string

type GenStreamGraphReq 

type GenStreamGraphReq struct {

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

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

	// 流图类型
	GraphType *string `json:"graph_type,omitempty"`

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

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

func (GenStreamGraphReq) String 

func (o GenStreamGraphReq) String() string

type GrantDataPermissionReq 

type GrantDataPermissionReq struct {

	// 被赋权的用户名称，该用户将有权访问指定的数据库或数据表，被收回或者更新访问权限。
	UserName string `json:"user_name"`

	// 指定赋权或回收。值为：grant，revoke或update。 说明： 当用户同时拥有grant和revoke权限的时候才有权限使用update操作。
	Action string `json:"action"`

	// 赋权信息。
	Privileges []GrantDataPermissionRespPrivilege `json:"privileges"`
}

GrantDataPermissionReq 数据授权的请求body体。

func (GrantDataPermissionReq) String 

func (o GrantDataPermissionReq) String() string

type GrantDataPermissionRespPrivilege 

type GrantDataPermissionRespPrivilege struct {

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

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

GrantDataPermissionRespPrivilege 数据赋权的赋权信息。

func (GrantDataPermissionRespPrivilege) String 

func (o GrantDataPermissionRespPrivilege) String() string

type GrantQueuePermissionReq 

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

GrantQueuePermissionReq 队列赋权的请求参数。

func (GrantQueuePermissionReq) String 

func (o GrantQueuePermissionReq) String() string

type IefEvents 

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

IefEvents IEF系统事件的数据

func (IefEvents) String 

func (o IefEvents) String() string

type IefFlinkJobMessagesReq 

type IefFlinkJobMessagesReq struct {

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

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

IefFlinkJobMessagesReq IEF Flink job action回调的请求body体。

func (IefFlinkJobMessagesReq) String 

func (o IefFlinkJobMessagesReq) String() string

type IefFlinkJobStatusReportReq 

type IefFlinkJobStatusReportReq struct {

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

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

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

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

func (IefFlinkJobStatusReportReq) String 

func (o IefFlinkJobStatusReportReq) String() string

type IefSystemEventsReq 

type IefSystemEventsReq struct {
	Data *IefEvents `json:"data"`
}

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

func (IefSystemEventsReq) String 

func (o IefSystemEventsReq) String() string

type ImportFlinkJobRequest 

type ImportFlinkJobRequest struct {
	Body *ImportFlinkJobRequestBody `json:"body,omitempty"`
}

ImportFlinkJobRequest Request Object

func (ImportFlinkJobRequest) String 

func (o ImportFlinkJobRequest) String() string

type ImportFlinkJobRequestBody 

type ImportFlinkJobRequestBody struct {

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

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

ImportFlinkJobRequestBody 导入作业的请求参数。

func (ImportFlinkJobRequestBody) String 

func (o ImportFlinkJobRequestBody) String() string

type ImportFlinkJobResponse 

type ImportFlinkJobResponse struct {

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

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

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

ImportFlinkJobResponse Response Object

func (ImportFlinkJobResponse) String 

func (o ImportFlinkJobResponse) 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 JobMapInfo 

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

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

func (JobMapInfo) String 

func (o JobMapInfo) String() string

type JobTemplateInfo 

type JobTemplateInfo struct {

	// 模板类型
	Type *string `json:"type,omitempty"`

	// 模板id
	Id *string `json:"id,omitempty"`

	// 模板名字
	Name *string `json:"name,omitempty"`

	Body *BatchJobInfo `json:"body,omitempty"`

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

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

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

	// 模板拥有者
	Owner *string `json:"owner,omitempty"`
}

func (JobTemplateInfo) String 

func (o JobTemplateInfo) String() string

type Jobs 

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

Jobs 作业信息列表

func (Jobs) String 

func (o Jobs) String() string

type ListAllTablesRequest 

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

ListAllTablesRequest Request Object

func (ListAllTablesRequest) String 

func (o ListAllTablesRequest) String() string

type ListAllTablesResponse 

type ListAllTablesResponse 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:"-"`
}

ListAllTablesResponse Response Object

func (ListAllTablesResponse) String 

func (o ListAllTablesResponse) 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      *[]AuthInfos `json:"auth_infos,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ListAuthInfoResponse Response Object

func (ListAuthInfoResponse) String 

func (o ListAuthInfoResponse) String() string

type ListBatchesRequest 

type ListBatchesRequest struct {

	// DLI队列名称，不填写则获取当前Project下所有批处理作业(不推荐使用)。
	ClusterName *string `json:"cluster_name,omitempty"`

	// 用于查询开始时间在该时间点之前的作业。时间格式为unix时间戳，单位：毫秒。
	End *int64 `json:"end,omitempty"`

	// 起始批处理作业的索引号，默认从0开始。
	From *int32 `json:"from,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"`
}

ListBatchesRequest Request Object

func (ListBatchesRequest) String 

func (o ListBatchesRequest) String() string

type ListBatchesResponse 

type ListBatchesResponse struct {

	// 起始批处理作业的索引号。
	From *int32 `json:"from,omitempty"`

	// 返回批处理作业的总数。
	Total *int32 `json:"total,omitempty"`

	// 批处理作业信息。
	Sessions *[]ShowBatchJobDetailResp `json:"sessions,omitempty"`

	// 批处理作业的创建时间。
	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListBatchesResponse Response Object

func (ListBatchesResponse) String 

func (o ListBatchesResponse) 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     *[]ShowDatabaseUsersPrivilege `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 *[]ShowDatasourceConnectionResp `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 *[]QueueInfo `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 *int32 `json:"count,omitempty"`

	// 数组中返回的数据
	Items *[][]interface{} `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"`

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

	// 弹性资源池列表
	ElasticResourcePools *[]ElasticResourcePoolsResponse `json:"elastic_resource_pools,omitempty"`
	HttpStatusCode       int                             `json:"-"`
}

ListElasticResourcePoolsResponse Response Object

func (ListElasticResourcePoolsResponse) String 

func (o ListElasticResourcePoolsResponse) String() string

type ListEnhancedConnectionsDetail 

type ListEnhancedConnectionsDetail struct {

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

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

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

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

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

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

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

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

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

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

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

func (ListEnhancedConnectionsDetail) String 

func (o ListEnhancedConnectionsDetail) 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 *[]ListEnhancedConnectionsDetail `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 *bool `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 ListFlinkTemplatesRequest 

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

ListFlinkTemplatesRequest Request Object

func (ListFlinkTemplatesRequest) String 

func (o ListFlinkTemplatesRequest) String() string

type ListFlinkTemplatesResponse 

type ListFlinkTemplatesResponse struct {

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

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

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

ListFlinkTemplatesResponse Response Object

func (ListFlinkTemplatesResponse) String 

func (o ListFlinkTemplatesResponse) String() string

type ListGlobalValue 

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

ListGlobalValue 全局变量

func (ListGlobalValue) String 

func (o ListGlobalValue) String() string

type ListGlobalValuesRequest 

type ListGlobalValuesRequest struct {

	// 每页显示的返回信息的个数，默认值为“100”。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量，默认值为“0”。
	Offset *int32 `json:"offset,omitempty"`
}

ListGlobalValuesRequest Request Object

func (ListGlobalValuesRequest) String 

func (o ListGlobalValuesRequest) String() string

type ListGlobalValuesResponse 

type ListGlobalValuesResponse struct {

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

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

	// 全局变量
	GlobalVars *[]ListGlobalValue `json:"global_vars,omitempty"`

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

ListGlobalValuesResponse Response Object

func (ListGlobalValuesResponse) String 

func (o ListGlobalValuesResponse) String() string

type ListGroupPackagesResource 

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

ListGroupPackagesResource 已上传的用户资源名列表。

func (ListGroupPackagesResource) String 

func (o ListGroupPackagesResource) String() string

type ListJobTemplatesRequest 

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

ListJobTemplatesRequest Request Object

func (ListJobTemplatesRequest) String 

func (o ListJobTemplatesRequest) String() string

type ListJobTemplatesResponse 

type ListJobTemplatesResponse struct {

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

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

	// 返回的模板个数
	Count *int32 `json:"count,omitempty"`

	// 模板信息列表。
	Templates      *[]JobTemplateInfo `json:"templates,omitempty"`
	HttpStatusCode int                `json:"-"`
}

ListJobTemplatesResponse Response Object

func (ListJobTemplatesResponse) String 

func (o ListJobTemplatesResponse) String() string

type ListJobsJobs 

type ListJobsJobs 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 *int32 `json:"duration,omitempty"`

	// 此作业的当前状态，包含提交（LAUNCHING）、运行中（RUNNING）、完成（FINISHED）、失败（FAILED）、取消（CANCELLED）。
	Status ListJobsJobsStatus `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 int32 `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 *[]TmsTagEntity `json:"tags,omitempty"`

	// 系统提示信息。
	Message *string `json:"message,omitempty"`

	// 作业结束的时间。是单位为“毫秒”的时间戳。
	EndTime *int64 `json:"end_time,omitempty"`
}

ListJobsJobs 作业信息。

func (ListJobsJobs) String 

func (o ListJobsJobs) String() string

type ListJobsJobsStatus 

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

func (ListJobsJobsStatus) MarshalJSON 

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

func (*ListJobsJobsStatus) UnmarshalJSON 

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

func (ListJobsJobsStatus) Value 

func (c ListJobsJobsStatus) Value() string

type ListJobsJobsStatusEnum 

type ListJobsJobsStatusEnum struct {
	LAUNCHING ListJobsJobsStatus
	RUNNING   ListJobsJobsStatus
	FINISHED  ListJobsJobsStatus
	FAILED    ListJobsJobsStatus
	CANCELLED ListJobsJobsStatus
}

func GetListJobsJobsStatusEnum 

func GetListJobsJobsStatusEnum() ListJobsJobsStatusEnum

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          *[]QueuePlanEntity `json:"plans,omitempty"`
	HttpStatusCode int                `json:"-"`
}

ListQueuePlansResponse Response Object

func (ListQueuePlansResponse) String 

func (o ListQueuePlansResponse) 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     *[]PrivilegesInfo `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         *[]QueueDetails `json:"queues,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListQueuesResponse Response Object

func (ListQueuesResponse) String 

func (o ListQueuesResponse) String() string

type ListResourcePackagesRespMoudle 

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

ListResourcePackagesRespMoudle 系统内置资源模块列表。

func (ListResourcePackagesRespMoudle) String 

func (o ListResourcePackagesRespMoudle) String() string

type ListResourcesRequest 

type ListResourcesRequest struct {
	Kind *string `json:"kind,omitempty"`

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

ListResourcesRequest Request Object

func (ListResourcesRequest) String 

func (o ListResourcesRequest) String() string

type ListResourcesResponse 

type ListResourcesResponse struct {

	// 已上传的用户资源名列表。
	Resources *[]ListGroupPackagesResource `json:"resources,omitempty"`

	// 系统内置资源模块列表
	Modules *[]ListResourcePackagesRespMoudle `json:"modules,omitempty"`

	// 已上传的用户分组资源。
	Groups *[]interface{} `json:"groups,omitempty"`

	// 资源包返回总数
	Total          *int32 `json:"total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListResourcesResponse Response Object

func (ListResourcesResponse) String 

func (o ListResourcesResponse) 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 {
	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           *[]ListJobsJobs `json:"jobs,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListSqlJobsResponse Response Object

func (ListSqlJobsResponse) String 

func (o ListSqlJobsResponse) 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     *[]TableUserPermissionsRespPrivilege `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     *[]ShowTableUsersRespPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                            `json:"-"`
}

ListTableUsersResponse Response Object

func (ListTableUsersResponse) String 

func (o ListTableUsersResponse) String() string

type ObsBuckets 

type ObsBuckets struct {

	//
	ObsBuckets []string `json:"obs_buckets"`
}

ObsBuckets

func (ObsBuckets) String 

func (o ObsBuckets) String() string

type PartitionInfos 

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

PartitionInfos

func (PartitionInfos) String 

func (o PartitionInfos) String() string

type Partitions 

type Partitions struct {

	// 总个数
	TotalCount int64 `json:"total_count"`

	// 分区信息列表
	PartitionInfos []PartitionInfos `json:"partition_infos"`
}

Partitions

func (Partitions) String 

func (o Partitions) String() string

type PreviewJobResultRequest 

type PreviewJobResultRequest struct {

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

	// 指定获取作业结果的执行队列名称。若不指定则使用默认的系统队列
	QueueName *string `json:"queue-name,omitempty"`
}

PreviewJobResultRequest Request Object

func (PreviewJobResultRequest) String 

func (o PreviewJobResultRequest) String() string

type PreviewJobResultResponse 

type PreviewJobResultResponse 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 *PreviewJobResultResponseJobType `json:"job_type,omitempty"`

	// 作业结果总条数。
	RowCount *int32 `json:"row_count,omitempty"`

	// 作业执行过程中扫描的数据量。
	InputSize *int64 `json:"input_size,omitempty"`

	// 作业结果列名称和类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 作业结果集。
	Rows           *[][]string `json:"rows,omitempty"`
	HttpStatusCode int         `json:"-"`
}

PreviewJobResultResponse Response Object

func (PreviewJobResultResponse) String 

func (o PreviewJobResultResponse) String() string

type PreviewJobResultResponseJobType 

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

func (PreviewJobResultResponseJobType) MarshalJSON 

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

func (*PreviewJobResultResponseJobType) UnmarshalJSON 

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

func (PreviewJobResultResponseJobType) Value 

func (c PreviewJobResultResponseJobType) Value() string

type PreviewJobResultResponseJobTypeEnum 

type PreviewJobResultResponseJobTypeEnum struct {
	DDL    PreviewJobResultResponseJobType
	DCL    PreviewJobResultResponseJobType
	IMPORT PreviewJobResultResponseJobType
	EXPORT PreviewJobResultResponseJobType
	QUERY  PreviewJobResultResponseJobType
	INSERT PreviewJobResultResponseJobType
}

func GetPreviewJobResultResponseJobTypeEnum 

func GetPreviewJobResultResponseJobTypeEnum() PreviewJobResultResponseJobTypeEnum

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 PrivilegesInfo 

type PrivilegesInfo struct {

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

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

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

PrivilegesInfo 权限信息

func (PrivilegesInfo) String 

func (o PrivilegesInfo) String() string

type ProjectPrivilege 

type ProjectPrivilege struct {

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

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

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

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

func (ProjectPrivilege) String 

func (o ProjectPrivilege) String() string

type QueueDetails 

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

QueueDetails 查询所有队列的响应参数。

func (QueueDetails) String 

func (o QueueDetails) String() string

type QueueInfo 

type QueueInfo struct {

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

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

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

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

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

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

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

func (QueueInfo) String 

func (o QueueInfo) String() string

type QueuePlanEntity 

type QueuePlanEntity 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 []QueuePlanEntityRepeatDay `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"`
}

QueuePlanEntity 查询指定队列定时扩缩容信息的响应参数。

func (QueuePlanEntity) String 

func (o QueuePlanEntity) String() string

type QueuePlanEntityRepeatDay 

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

func (QueuePlanEntityRepeatDay) MarshalJSON 

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

func (*QueuePlanEntityRepeatDay) UnmarshalJSON 

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

func (QueuePlanEntityRepeatDay) Value 

func (c QueuePlanEntityRepeatDay) Value() string

type QueuePlanEntityRepeatDayEnum 

type QueuePlanEntityRepeatDayEnum struct {
	SUNDAY    QueuePlanEntityRepeatDay
	MONDAY    QueuePlanEntityRepeatDay
	TUESDAY   QueuePlanEntityRepeatDay
	WEDNESDAY QueuePlanEntityRepeatDay
	THURSDAY  QueuePlanEntityRepeatDay
	FRIDAY    QueuePlanEntityRepeatDay
	SATURDAY  QueuePlanEntityRepeatDay
}

func GetQueuePlanEntityRepeatDayEnum 

func GetQueuePlanEntityRepeatDayEnum() QueuePlanEntityRepeatDayEnum

type QueuePlanIds 

type QueuePlanIds struct {

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

QueuePlanIds

func (QueuePlanIds) String 

func (o QueuePlanIds) String() string

type QueueScalingPoliciesResponse 

type QueueScalingPoliciesResponse struct {

	// 策略优先级1-100，100优先级最高
	Priority *int32 `json:"priority,omitempty"`

	// 开始时间
	ImpactStartTime *string `json:"impact_start_time,omitempty"`

	// 结束时间
	ImpactStopTime *string `json:"impact_stop_time,omitempty"`

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

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

func (QueueScalingPoliciesResponse) String 

func (o QueueScalingPoliciesResponse) String() string

type QueueScalingPolicyInfo 

type QueueScalingPolicyInfo struct {

	// 优先级
	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"`
}

QueueScalingPolicyInfo 队列优先级策略信息

func (QueueScalingPolicyInfo) String 

func (o QueueScalingPolicyInfo) String() string

type RegisterAuthorizedQueueRequest 

type RegisterAuthorizedQueueRequest struct {
	Body *GrantQueuePermissionReq `json:"body,omitempty"`
}

RegisterAuthorizedQueueRequest Request Object

func (RegisterAuthorizedQueueRequest) String 

func (o RegisterAuthorizedQueueRequest) 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 *ObsBuckets `json:"body,omitempty"`
}

RegisterBucketRequest Request Object

func (RegisterBucketRequest) String 

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

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

RunIefJobActionCallBackRequest Request Object

func (RunIefJobActionCallBackRequest) String 

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

type RunQueueActionReq 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 (RunQueueActionReq) String 

func (o RunQueueActionReq) String() string

type RunQueueActionRequest 

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

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

RunQueueActionRequest Request Object

func (RunQueueActionRequest) String 

func (o RunQueueActionRequest) 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 SetQueuePlanReq 

type SetQueuePlanReq 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 []SetQueuePlanReqRepeatDay `json:"repeat_day"`

	// 有效期开始时间（13位时间戳）
	ValidDateBegin *int64 `json:"valid_date_begin,omitempty"`

	// 有效期结束时间（13位时间戳）
	ValidDateEnd *int64 `json:"valid_date_end,omitempty"`

	// 当前设置的扩缩容计划是否激活，默认为激活
	Activate *bool `json:"activate,omitempty"`
}

SetQueuePlanReq 创建扩缩容计划的body体。

func (SetQueuePlanReq) String 

func (o SetQueuePlanReq) String() string

type SetQueuePlanReqRepeatDay 

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

func (SetQueuePlanReqRepeatDay) MarshalJSON 

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

func (*SetQueuePlanReqRepeatDay) UnmarshalJSON 

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

func (SetQueuePlanReqRepeatDay) Value 

func (c SetQueuePlanReqRepeatDay) Value() string

type SetQueuePlanReqRepeatDayEnum 

type SetQueuePlanReqRepeatDayEnum struct {
	SUNDAY    SetQueuePlanReqRepeatDay
	MONDAY    SetQueuePlanReqRepeatDay
	TUESDAY   SetQueuePlanReqRepeatDay
	WEDNESDAY SetQueuePlanReqRepeatDay
	THURSDAY  SetQueuePlanReqRepeatDay
	FRIDAY    SetQueuePlanReqRepeatDay
	SATURDAY  SetQueuePlanReqRepeatDay
}

func GetSetQueuePlanReqRepeatDayEnum 

func GetSetQueuePlanReqRepeatDayEnum() SetQueuePlanReqRepeatDayEnum

type ShowBatchInfoRequest 

type ShowBatchInfoRequest struct {

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

ShowBatchInfoRequest Request Object

func (ShowBatchInfoRequest) String 

func (o ShowBatchInfoRequest) String() string

type ShowBatchInfoResponse 

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

	// 作业特性。表示用户作业使用的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:"-"`
}

ShowBatchInfoResponse Response Object

func (ShowBatchInfoResponse) String 

func (o ShowBatchInfoResponse) String() string

type ShowBatchJobDetailResp 

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

ShowBatchJobDetailResp 创建批处理作业的响应参数。

func (ShowBatchJobDetailResp) String 

func (o ShowBatchJobDetailResp) String() string

type ShowBatchLogRequest 

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

ShowBatchLogRequest Request Object

func (ShowBatchLogRequest) String 

func (o ShowBatchLogRequest) String() string

type ShowBatchLogResponse 

type ShowBatchLogResponse struct {

	// 批处理作业的id。
	Id *string `json:"id,omitempty"`

	// 日志起始索引。
	From *string `json:"from,omitempty"`

	// 日志的总记录数。
	Total *int64 `json:"total,omitempty"`

	// 显示当前批处理作业日志。
	Log            *[]string `json:"log,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowBatchLogResponse Response Object

func (ShowBatchLogResponse) String 

func (o ShowBatchLogResponse) String() string

type ShowBatchStateRequest 

type ShowBatchStateRequest struct {

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

ShowBatchStateRequest Request Object

func (ShowBatchStateRequest) String 

func (o ShowBatchStateRequest) String() string

type ShowBatchStateResponse 

type ShowBatchStateResponse struct {

	// 批处理作业的ID，采用UUID（通用唯一识别码）格式。
	Id *string `json:"id,omitempty"`

	// 批处理作业的状态。starting：正在启动；running：正在执行任务；dead：session已退出；success：session停止成功；recovering：正在恢复。
	State          *string `json:"state,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowBatchStateResponse Response Object

func (ShowBatchStateResponse) String 

func (o ShowBatchStateResponse) String() string

type ShowDatabaseUsersPrivilege 

type ShowDatabaseUsersPrivilege struct {

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

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

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

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

func (ShowDatabaseUsersPrivilege) String 

func (o ShowDatabaseUsersPrivilege) 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 ShowDatasourceConnectionResp 

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

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

func (ShowDatasourceConnectionResp) String 

func (o ShowDatasourceConnectionResp) 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 ShowDescribeTableRequest 

type ShowDescribeTableRequest struct {

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

	// 待描述表的名称。
	TableName string `json:"table_name"`
}

ShowDescribeTableRequest Request Object

func (ShowDescribeTableRequest) String 

func (o ShowDescribeTableRequest) String() string

type ShowDescribeTableResponse 

type ShowDescribeTableResponse struct {

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

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

	// 表的总列数。
	ColumnCount *int32 `json:"column_count,omitempty"`

	// 表的列信息，包含列名称、类型和描述信息。
	Columns *[]CreateTableReqColumn `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:"-"`
}

ShowDescribeTableResponse Response Object

func (ShowDescribeTableResponse) String 

func (o ShowDescribeTableResponse) 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 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 *[]EnhancedConnectionResourceInfo `json:"available_queue_info,omitempty"`

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

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

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

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

	// 用户自定义主机信息。
	Hosts          *[]EnhancedConnectionsHost `json:"hosts,omitempty"`
	HttpStatusCode int                        `json:"-"`
}

ShowEnhancedConnectionResponse Response Object

func (ShowEnhancedConnectionResponse) String 

func (o ShowEnhancedConnectionResponse) String() string

type ShowEnhancedPrivilegeRequest 

type ShowEnhancedPrivilegeRequest struct {

	// 增强型跨源连接ID。
	ConnectionId string `json:"connection_id"`
}

ShowEnhancedPrivilegeRequest Request Object

func (ShowEnhancedPrivilegeRequest) String 

func (o ShowEnhancedPrivilegeRequest) String() string

type ShowEnhancedPrivilegeResponse 

type ShowEnhancedPrivilegeResponse struct {

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

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

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

	// 跨源连接各个授权项目的信息。
	Privileges     *[]ProjectPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ShowEnhancedPrivilegeResponse Response Object

func (ShowEnhancedPrivilegeResponse) String 

func (o ShowEnhancedPrivilegeResponse) String() string

type ShowFlinkExecuteGraphRequest 

type ShowFlinkExecuteGraphRequest struct {

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

ShowFlinkExecuteGraphRequest Request Object

func (ShowFlinkExecuteGraphRequest) String 

func (o ShowFlinkExecuteGraphRequest) String() string

type ShowFlinkExecuteGraphResponse 

type ShowFlinkExecuteGraphResponse struct {

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

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

	ExecuteGraph   *StreamGraphInfo `json:"execute_graph,omitempty"`
	HttpStatusCode int              `json:"-"`
}

ShowFlinkExecuteGraphResponse Response Object

func (ShowFlinkExecuteGraphResponse) String 

func (o ShowFlinkExecuteGraphResponse) 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 *bool `json:"is_success,omitempty"`

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

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

ShowFlinkJobResponse Response Object

func (ShowFlinkJobResponse) String 

func (o ShowFlinkJobResponse) String() string

type ShowFlinkMetricRequest 

type ShowFlinkMetricRequest struct {
	Body *ShowJobMonitorInfoReq `json:"body,omitempty"`
}

ShowFlinkMetricRequest Request Object

func (ShowFlinkMetricRequest) String 

func (o ShowFlinkMetricRequest) String() string

type ShowFlinkMetricResponse 

type ShowFlinkMetricResponse struct {

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

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

	Metrics        *ShowJobMonitorInfoRespPayload `json:"metrics,omitempty"`
	HttpStatusCode int                            `json:"-"`
}

ShowFlinkMetricResponse Response Object

func (ShowFlinkMetricResponse) String 

func (o ShowFlinkMetricResponse) String() string

type ShowJobMonitorInfoReq 

type ShowJobMonitorInfoReq struct {

	// 作业ID列表。
	JobIds []int64 `json:"job_ids"`
}

ShowJobMonitorInfoReq 查询作业监控信息

func (ShowJobMonitorInfoReq) String 

func (o ShowJobMonitorInfoReq) String() string

type ShowJobMonitorInfoRespPayload 

type ShowJobMonitorInfoRespPayload struct {

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

ShowJobMonitorInfoRespPayload 作业审计日志信息。

func (ShowJobMonitorInfoRespPayload) String 

func (o ShowJobMonitorInfoRespPayload) String() string

type ShowJobMonitorInfoRespPayloadJobs 

type ShowJobMonitorInfoRespPayloadJobs struct {

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

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

ShowJobMonitorInfoRespPayloadJobs 所有作业监控信息。

func (ShowJobMonitorInfoRespPayloadJobs) String 

func (o ShowJobMonitorInfoRespPayloadJobs) String() string

type ShowJobMonitorInfoRespPayloadJobsMetrics 

type ShowJobMonitorInfoRespPayloadJobsMetrics struct {

	// 所有输入流。
	Sources *[]ShowJobMonitorInfoRespPayloadJobsMetricsSources `json:"sources,omitempty"`

	// 所有输出流。
	Sinks *[]ShowJobMonitorInfoRespPayloadJobsMetricsSources `json:"sinks,omitempty"`

	// 总输入速率
	TotalReadRate *float64 `json:"total_read_rate,omitempty"`

	// 总输出速率
	TotalWriteRate *float64 `json:"total_write_rate,omitempty"`
}

ShowJobMonitorInfoRespPayloadJobsMetrics 作业的所有输入输出监控信息。

func (ShowJobMonitorInfoRespPayloadJobsMetrics) String 

func (o ShowJobMonitorInfoRespPayloadJobsMetrics) String() string

type ShowJobMonitorInfoRespPayloadJobsMetricsSources 

type ShowJobMonitorInfoRespPayloadJobsMetricsSources struct {

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

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

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

ShowJobMonitorInfoRespPayloadJobsMetricsSources 所有输入流。

func (ShowJobMonitorInfoRespPayloadJobsMetricsSources) String 

func (o ShowJobMonitorInfoRespPayloadJobsMetricsSources) String() string

type ShowJobProgressRequest 

type ShowJobProgressRequest struct {

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

ShowJobProgressRequest Request Object

func (ShowJobProgressRequest) String 

func (o ShowJobProgressRequest) String() string

type ShowJobProgressResponse 

type ShowJobProgressResponse 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        *[]SubJobDatas `json:"sub_jobs,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ShowJobProgressResponse Response Object

func (ShowJobProgressResponse) String 

func (o ShowJobProgressResponse) String() string

type ShowJobTemplateRequest 

type ShowJobTemplateRequest struct {
	TemplateId string `json:"template_id"`
}

ShowJobTemplateRequest Request Object

func (ShowJobTemplateRequest) String 

func (o ShowJobTemplateRequest) String() string

type ShowJobTemplateResponse 

type ShowJobTemplateResponse struct {

	// 模板类型
	Type *string `json:"type,omitempty"`

	// 模板id
	Id *string `json:"id,omitempty"`

	// 模板名字
	Name *string `json:"name,omitempty"`

	Body *BatchJobInfo `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:"-"`
}

ShowJobTemplateResponse Response Object

func (ShowJobTemplateResponse) String 

func (o ShowJobTemplateResponse) String() string

type ShowNodeConnectivityRequest 

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

	TaskId string `json:"task_id"`
}

ShowNodeConnectivityRequest Request Object

func (ShowNodeConnectivityRequest) String 

func (o ShowNodeConnectivityRequest) String() string

type ShowNodeConnectivityResponse 

type ShowNodeConnectivityResponse struct {

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

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

	// 连通性测试结果
	Connectivity   *string `json:"connectivity,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowNodeConnectivityResponse Response Object

func (ShowNodeConnectivityResponse) String 

func (o ShowNodeConnectivityResponse) String() string

type ShowObjectUserRequest 

type ShowObjectUserRequest struct {

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

ShowObjectUserRequest Request Object

func (ShowObjectUserRequest) String 

func (o ShowObjectUserRequest) String() string

type ShowObjectUserResponse 

type ShowObjectUserResponse 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     *[]ShowDatabaseUsersPrivilege `json:"privileges,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

ShowObjectUserResponse Response Object

func (ShowObjectUserResponse) String 

func (o ShowObjectUserResponse) String() string

type ShowPartitionsRequest 

type ShowPartitionsRequest struct {

	// 数据库名
	DatabaseName string `json:"database_name"`

	// 表名
	TableName string `json:"table_name"`

	// 显示个数，默认值为100
	Limit *int32 `json:"limit,omitempty"`

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

ShowPartitionsRequest Request Object

func (ShowPartitionsRequest) String 

func (o ShowPartitionsRequest) String() string

type ShowPartitionsResponse 

type ShowPartitionsResponse struct {

	// 请求结果，true为成功，false为失败
	IsSuccess *bool `json:"is_success,omitempty"`

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

	Partitions     *Partitions `json:"partitions,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ShowPartitionsResponse Response Object

func (ShowPartitionsResponse) String 

func (o ShowPartitionsResponse) String() string

type ShowQueueDetailRequest 

type ShowQueueDetailRequest struct {

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

ShowQueueDetailRequest Request Object

func (ShowQueueDetailRequest) String 

func (o ShowQueueDetailRequest) String() string

type ShowQueueDetailResponse 

type ShowQueueDetailResponse 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:"-"`
}

ShowQueueDetailResponse Response Object

func (ShowQueueDetailResponse) String 

func (o ShowQueueDetailResponse) String() string

type ShowResourceInfoRequest 

type ShowResourceInfoRequest struct {

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

	Group *string `json:"group,omitempty"`
}

ShowResourceInfoRequest Request Object

func (ShowResourceInfoRequest) String 

func (o ShowResourceInfoRequest) String() string

type ShowResourceInfoResponse 

type ShowResourceInfoResponse 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:"-"`
}

ShowResourceInfoResponse Response Object

func (ShowResourceInfoResponse) String 

func (o ShowResourceInfoResponse) 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           *[]TmsTagEntity `json:"tags,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ShowSqlJobDetailResponse Response Object

func (ShowSqlJobDetailResponse) String 

func (o ShowSqlJobDetailResponse) 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语句。
	Statement *string `json:"statement,omitempty"`

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

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

	// 作业执行方式
	JobMode *string `json:"job_mode,omitempty"`

	// 作业标签
	Tags           *[]TmsTagEntity `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 ShowSqlSampleTemplatesRequest 

type ShowSqlSampleTemplatesRequest struct {
}

ShowSqlSampleTemplatesRequest Request Object

func (ShowSqlSampleTemplatesRequest) String 

func (o ShowSqlSampleTemplatesRequest) String() string

type ShowSqlSampleTemplatesResponse 

type ShowSqlSampleTemplatesResponse struct {

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

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

	// 样例模板信息。
	Sqls *[]SqlsSampleResp `json:"sqls,omitempty"`

	// 样例模板个数。
	SqlCount       *int32 `json:"sqlCount,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowSqlSampleTemplatesResponse Response Object

func (ShowSqlSampleTemplatesResponse) String 

func (o ShowSqlSampleTemplatesResponse) String() string

type ShowSqlTemplatesRequest 

type ShowSqlTemplatesRequest struct {

	// 用于过滤SQL模板的名字。
	Keyword *string `json:"keyword,omitempty"`
}

ShowSqlTemplatesRequest Request Object

func (ShowSqlTemplatesRequest) String 

func (o ShowSqlTemplatesRequest) String() string

type ShowSqlTemplatesResponse 

type ShowSqlTemplatesResponse struct {

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

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

	// SQL模板总数。
	SqlCount *int32 `json:"sql_count,omitempty"`

	Sqls           *[]SqlsResp `json:"sqls,omitempty"`
	HttpStatusCode int         `json:"-"`
}

ShowSqlTemplatesResponse Response Object

func (ShowSqlTemplatesResponse) String 

func (o ShowSqlTemplatesResponse) String() string

type ShowStreamJobListJobConfig 

type ShowStreamJobListJobConfig 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 *int32 `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"`
}

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

func (ShowStreamJobListJobConfig) String 

func (o ShowStreamJobListJobConfig) String() string

type ShowTableContentRequest 

type ShowTableContentRequest struct {

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

	// 待预览的表名称。
	TableName string `json:"table_name"`

	// 预览表的模式，取值为““SYNC””或者““ASYNC””默认值为：“SYNC”。
	Mode *string `json:"mode,omitempty"`
}

ShowTableContentRequest Request Object

func (ShowTableContentRequest) String 

func (o ShowTableContentRequest) String() string

type ShowTableContentResponse 

type ShowTableContentResponse 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:"-"`
}

ShowTableContentResponse Response Object

func (ShowTableContentResponse) String 

func (o ShowTableContentResponse) String() string

type ShowTableUsersRespPrivilege 

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

ShowTableUsersRespPrivilege 查看表的使用者响应的权限信息。

func (ShowTableUsersRespPrivilege) String 

func (o ShowTableUsersRespPrivilege) String() string

type SqlsResp 

type SqlsResp 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 (SqlsResp) String 

func (o SqlsResp) String() string

type SqlsSampleResp 

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

SqlsSampleResp 样例模板信息。

func (SqlsSampleResp) String 

func (o SqlsSampleResp) String() string

type State 

type State struct {
	Phase string `json:"phase"`

	Reason *string `json:"reason,omitempty"`
}

State

func (State) String 

func (o State) String() string

type StopFlinkJobsRequest 

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

StopFlinkJobsRequest Request Object

func (StopFlinkJobsRequest) String 

func (o StopFlinkJobsRequest) 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 StopFlinkJobsResponse 

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

StopFlinkJobsResponse Response Object

func (StopFlinkJobsResponse) String 

func (o StopFlinkJobsResponse) String() string

type StreamGraphInfo 

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

StreamGraphInfo 查询作业执行计划。

func (StreamGraphInfo) String 

func (o StreamGraphInfo) String() string

type SubJobDatas 

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

SubJobDatas 子作业JobData信息，对应spark的JobData。

func (SubJobDatas) String 

func (o SubJobDatas) String() string

type Table 

type Table struct {

	// 表创建时间。是单位为“毫秒”的时间戳。
	CreateTime int32 `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 int32 `json:"last_access_time"`

	// OBS表上的存储路径。
	Location *string `json:"location,omitempty"`

	// 表创建者。
	Owner string `json:"owner"`

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

	// DLI表的大小。非DLI表该参数值为0。
	TableSize int32 `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 TableUserPermissionsRespPrivilege 

type TableUserPermissionsRespPrivilege struct {

	// 该用户有权限的对象： “databases.数据库名.tables.表名”，用户在当前表上的权限。 “databases.数据库名.tables.表名.columns.列名”，用户在列上的权限。
	Object *string `json:"object,omitempty"`

	// 用户在指定对象上的权限。
	Privileges *[]string `json:"privileges,omitempty"`
}

TableUserPermissionsRespPrivilege 查看表的用户权限响应的权限信息。

func (TableUserPermissionsRespPrivilege) String 

func (o TableUserPermissionsRespPrivilege) String() string

type TmsTag 

type TmsTag struct {

	// 标签名称
	Key string `json:"key"`

	// 标签值
	Value string `json:"value"`
}

TmsTag 标签

func (TmsTag) String 

func (o TmsTag) String() string

type TmsTagEntity 

type TmsTagEntity struct {

	// 标签的键
	Key string `json:"key"`

	// 标签的值
	Value string `json:"value"`
}

TmsTagEntity

func (TmsTagEntity) String 

func (o TmsTagEntity) 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 UpdateElasticResourcePoolQueueInfoRequest 

type UpdateElasticResourcePoolQueueInfoRequest struct {

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

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

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

UpdateElasticResourcePoolQueueInfoRequest Request Object

func (UpdateElasticResourcePoolQueueInfoRequest) String 

func (o UpdateElasticResourcePoolQueueInfoRequest) String() string

type UpdateElasticResourcePoolQueueInfoResponse 

type UpdateElasticResourcePoolQueueInfoResponse struct {

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

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

UpdateElasticResourcePoolQueueInfoResponse Response Object

func (UpdateElasticResourcePoolQueueInfoResponse) String 

func (o UpdateElasticResourcePoolQueueInfoResponse) String() string

type UpdateElasticResourcePoolQueueScalingPolicyInfo 

type UpdateElasticResourcePoolQueueScalingPolicyInfo struct {

	// 该队列在该弹性资源池下的扩缩容策略信息。单条策略信息包含时间段、优先级和CU范围。每个队列至少要配置一条时间段为[00:00, 24:00]的默认扩缩容策略。
	QueueScalingPolicies []QueueScalingPolicyInfo `json:"queue_scaling_policies"`
}

UpdateElasticResourcePoolQueueScalingPolicyInfo 更新弹性资源池队列消息请求

func (UpdateElasticResourcePoolQueueScalingPolicyInfo) String 

func (o UpdateElasticResourcePoolQueueScalingPolicyInfo) 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 UpdateFlinkJarRequest 

type UpdateFlinkJarRequest struct {

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

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

UpdateFlinkJarRequest Request Object

func (UpdateFlinkJarRequest) String 

func (o UpdateFlinkJarRequest) String() string

type UpdateFlinkJarRequestBody 

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

UpdateFlinkJarRequestBody 更新Flink Jar作业的响应参数。

func (UpdateFlinkJarRequestBody) String 

func (o UpdateFlinkJarRequestBody) String() string

type UpdateFlinkJarResponse 

type UpdateFlinkJarResponse struct {

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

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

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

UpdateFlinkJarResponse Response Object

func (UpdateFlinkJarResponse) String 

func (o UpdateFlinkJarResponse) String() string

type UpdateFlinkSqlRequest 

type UpdateFlinkSqlRequest struct {

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

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

UpdateFlinkSqlRequest Request Object

func (UpdateFlinkSqlRequest) String 

func (o UpdateFlinkSqlRequest) String() string

type UpdateFlinkSqlRequestBody 

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

UpdateFlinkSqlRequestBody 更新SQL作业的请求参数。

func (UpdateFlinkSqlRequestBody) String 

func (o UpdateFlinkSqlRequestBody) String() string

type UpdateFlinkSqlResponse 

type UpdateFlinkSqlResponse struct {

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

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

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

UpdateFlinkSqlResponse Response Object

func (UpdateFlinkSqlResponse) String 

func (o UpdateFlinkSqlResponse) String() string

type UpdateFlinkTemplateRequest 

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

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

UpdateFlinkTemplateRequest Request Object

func (UpdateFlinkTemplateRequest) String 

func (o UpdateFlinkTemplateRequest) String() string

type UpdateFlinkTemplateRequestBody 

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

UpdateFlinkTemplateRequestBody

func (UpdateFlinkTemplateRequestBody) String 

func (o UpdateFlinkTemplateRequestBody) String() string

type UpdateFlinkTemplateResponse 

type UpdateFlinkTemplateResponse struct {

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

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

UpdateFlinkTemplateResponse Response Object

func (UpdateFlinkTemplateResponse) String 

func (o UpdateFlinkTemplateResponse) String() string

type UpdateGlobalValueReq 

type UpdateGlobalValueReq struct {

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

UpdateGlobalValueReq

func (UpdateGlobalValueReq) String 

func (o UpdateGlobalValueReq) String() string

type UpdateGlobalValueRequest 

type UpdateGlobalValueRequest struct {

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

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

UpdateGlobalValueRequest Request Object

func (UpdateGlobalValueRequest) String 

func (o UpdateGlobalValueRequest) String() string

type UpdateGlobalValueResponse 

type UpdateGlobalValueResponse struct {

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

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

UpdateGlobalValueResponse Response Object

func (UpdateGlobalValueResponse) String 

func (o UpdateGlobalValueResponse) String() string

type UpdateGroupOrResourceOwnerRequest 

type UpdateGroupOrResourceOwnerRequest struct {
	Body *UpdateResourceOwner `json:"body,omitempty"`
}

UpdateGroupOrResourceOwnerRequest Request Object

func (UpdateGroupOrResourceOwnerRequest) String 

func (o UpdateGroupOrResourceOwnerRequest) String() string

type UpdateGroupOrResourceOwnerResponse 

type UpdateGroupOrResourceOwnerResponse struct {

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

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

UpdateGroupOrResourceOwnerResponse Response Object

func (UpdateGroupOrResourceOwnerResponse) String 

func (o UpdateGroupOrResourceOwnerResponse) String() string

type UpdateHostMassageReq 

type UpdateHostMassageReq struct {

	// 用户自定义主机信息，最大支持2万条记录。内容填空表示清除所有已配置的主机信息。
	Hosts []EnhancedConnectionsHost `json:"hosts"`
}

UpdateHostMassageReq 修改主机信息的请求body体。

func (UpdateHostMassageReq) String 

func (o UpdateHostMassageReq) String() string

type UpdateHostMassageRequest 

type UpdateHostMassageRequest struct {

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

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

UpdateHostMassageRequest Request Object

func (UpdateHostMassageRequest) String 

func (o UpdateHostMassageRequest) String() string

type UpdateHostMassageResponse 

type UpdateHostMassageResponse struct {

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

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

UpdateHostMassageResponse Response Object

func (UpdateHostMassageResponse) String 

func (o UpdateHostMassageResponse) String() string

type UpdateJobRespJob 

type UpdateJobRespJob struct {

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

UpdateJobRespJob 作业更新信息。

func (UpdateJobRespJob) String 

func (o UpdateJobRespJob) String() string

type UpdateJobTemplatesRequest 

type UpdateJobTemplatesRequest struct {
	TemplateId string `json:"template_id"`

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

UpdateJobTemplatesRequest Request Object

func (UpdateJobTemplatesRequest) String 

func (o UpdateJobTemplatesRequest) String() string

type UpdateJobTemplatesRequestBody 

type UpdateJobTemplatesRequestBody struct {

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

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

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

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

func (UpdateJobTemplatesRequestBody) String 

func (o UpdateJobTemplatesRequestBody) String() string

type UpdateJobTemplatesResponse 

type UpdateJobTemplatesResponse struct {

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

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

UpdateJobTemplatesResponse Response Object

func (UpdateJobTemplatesResponse) String 

func (o UpdateJobTemplatesResponse) String() string

type UpdateOwnerRequestBody 

type UpdateOwnerRequestBody struct {

	// 新owner名称。
	NewOwner string `json:"new_owner"`
}

UpdateOwnerRequestBody 修改数据库用户的请求body体。

func (UpdateOwnerRequestBody) String 

func (o UpdateOwnerRequestBody) String() string

type UpdateQueueCidrReq 

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

UpdateQueueCidrReq 修改队列网段的请求body体。

func (UpdateQueueCidrReq) String 

func (o UpdateQueueCidrReq) String() string

type UpdateQueueCidrRequest 

type UpdateQueueCidrRequest struct {

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

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

UpdateQueueCidrRequest Request Object

func (UpdateQueueCidrRequest) String 

func (o UpdateQueueCidrRequest) 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 UpdateResourceOwner 

type UpdateResourceOwner struct {

	// 新用户名,只能包含数字、英文字母、下划线和中划线且不能以数字开头,长度在5-32字符之间
	NewOwner string `json:"new_owner"`

	// 组名,名称只能包含数字、英文字母、点、下划线和中划线,长度不能超过64字符
	GroupName string `json:"group_name"`

	// 包名,包名,长度（包含文件后缀）不能超过128个字符
	ResourceName *string `json:"resource_name,omitempty"`
}

UpdateResourceOwner group_name和resource_name可以单独使用，也可以组合使用 修改组的拥有者：使用group_name 修改资源包拥有者：使用resource_name 修改组下的资源包的拥有者：使用group_name加resource_name

func (UpdateResourceOwner) String 

func (o UpdateResourceOwner) String() string

type UpdateSqlTemplatesRequest 

type UpdateSqlTemplatesRequest struct {
	SqlId string `json:"sql_id"`

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

UpdateSqlTemplatesRequest Request Object

func (UpdateSqlTemplatesRequest) String 

func (o UpdateSqlTemplatesRequest) String() string

type UpdateSqlTemplatesRequestBody 

type UpdateSqlTemplatesRequestBody 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 (UpdateSqlTemplatesRequestBody) String 

func (o UpdateSqlTemplatesRequestBody) String() string

type UpdateSqlTemplatesResponse 

type UpdateSqlTemplatesResponse struct {

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

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

UpdateSqlTemplatesResponse Response Object

func (UpdateSqlTemplatesResponse) String 

func (o UpdateSqlTemplatesResponse) 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 UploadFilesRequest 

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

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

UploadFilesRequest Request Object

func (UploadFilesRequest) String 

func (o UploadFilesRequest) String() string

type UploadFilesResponse 

type UploadFilesResponse 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 *[]UploadPackageGroupDetailsResp `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadFilesResponse Response Object

func (UploadFilesResponse) String 

func (o UploadFilesResponse) String() string

type UploadGroupPackageReq 

type UploadGroupPackageReq struct {

	// 用户OBS对象路径列表，OBS对象路径为OBS对象URL。
	Paths []string `json:"paths"`

	// 所属资源分组名。
	Group string `json:"group"`
}

UploadGroupPackageReq 上传jar类型分组资源请求body体。

func (UploadGroupPackageReq) String 

func (o UploadGroupPackageReq) String() string

type UploadJarsRequest 

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

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

UploadJarsRequest Request Object

func (UploadJarsRequest) String 

func (o UploadJarsRequest) String() string

type UploadJarsResponse 

type UploadJarsResponse 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 *[]UploadPackageGroupDetailsResp `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadJarsResponse Response Object

func (UploadJarsResponse) String 

func (o UploadJarsResponse) String() string

type UploadPackageGroupDetailsResp 

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

UploadPackageGroupDetailsResp 上传分组资源的请求返回详细body体。

func (UploadPackageGroupDetailsResp) String 

func (o UploadPackageGroupDetailsResp) String() string

type UploadPackageGroupReq 

type UploadPackageGroupReq 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 *[]TmsTagEntity `json:"tags,omitempty"`
}

UploadPackageGroupReq 上传分组资源的请求body体。

func (UploadPackageGroupReq) String 

func (o UploadPackageGroupReq) String() string

type UploadPythonFilesRequest 

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

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

UploadPythonFilesRequest Request Object

func (UploadPythonFilesRequest) String 

func (o UploadPythonFilesRequest) String() string

type UploadPythonFilesResponse 

type UploadPythonFilesResponse 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 *[]UploadPackageGroupDetailsResp `json:"details,omitempty"`

	// 资源模块名
	ModuleName *string `json:"module_name,omitempty"`

	// 资源模块类型。jar:用户jar文件;pyFile:用户python文件;file:用户文件
	ModuleType     *string `json:"module_type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UploadPythonFilesResponse Response Object

func (UploadPythonFilesResponse) String 

func (o UploadPythonFilesResponse) String() string

type UploadResourcesRequest 

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

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

UploadResourcesRequest Request Object

func (UploadResourcesRequest) String 

func (o UploadResourcesRequest) String() string

type UploadResourcesResponse 

type UploadResourcesResponse 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        *[]UploadPackageGroupDetailsResp `json:"details,omitempty"`
	HttpStatusCode int                              `json:"-"`
}

UploadResourcesResponse Response Object

func (UploadResourcesResponse) String 

func (o UploadResourcesResponse) String() string

type VerityConnectivityReq 

type VerityConnectivityReq struct {

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

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

func (VerityConnectivityReq) String 

func (o VerityConnectivityReq) 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.