v20190422

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const APIVersion = "2019-04-22"

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential *common.Credential, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) CreateJob 

func (c *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)

新建作业接口，一个 AppId 最多允许创建1000个作业

func (*Client) CreateJobConfig 

func (c *Client) CreateJobConfig(request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)

创建作业配置，一个作业最多有100个配置版本

func (*Client) CreateResource 

func (c *Client) CreateResource(request *CreateResourceRequest) (response *CreateResourceResponse, err error)

创建资源接口

func (*Client) CreateResourceConfig 

func (c *Client) CreateResourceConfig(request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)

创建资源配置接口

func (*Client) DeleteResourceConfigs 

func (c *Client) DeleteResourceConfigs(request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)

删除资源版本

func (*Client) DeleteResources 

func (c *Client) DeleteResources(request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)

删除资源接口

func (*Client) DeleteTableConfig 

func (c *Client) DeleteTableConfig(request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)

删除作业表配置

func (*Client) DescribeJobConfigs 

func (c *Client) DescribeJobConfigs(request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)

查询作业配置列表，一次最多查询100个

func (*Client) DescribeJobs 

func (c *Client) DescribeJobs(request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)

查询作业

func (*Client) DescribeResourceConfigs 

func (c *Client) DescribeResourceConfigs(request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)

描述资源配置接口

func (*Client) DescribeResourceRelatedJobs 

func (c *Client) DescribeResourceRelatedJobs(request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)

获取资源关联作业信息

func (*Client) DescribeResources 

func (c *Client) DescribeResources(request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)

描述资源接口

func (*Client) DescribeSystemResources 

func (c *Client) DescribeSystemResources(request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)

描述系统资源接口

func (*Client) RunJobs 

func (c *Client) RunJobs(request *RunJobsRequest) (response *RunJobsResponse, err error)

批量启动或者恢复作业，批量操作数量上限20

func (*Client) StopJobs 

func (c *Client) StopJobs(request *StopJobsRequest) (response *StopJobsResponse, err error)

批量停止作业，批量操作数量上限为20

type CreateJobConfigRequest 

type CreateJobConfigRequest struct {
	*tchttp.BaseRequest

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 主类
	EntrypointClass *string `json:"EntrypointClass,omitempty" name:"EntrypointClass"`

	// 主类入参
	ProgramArgs *string `json:"ProgramArgs,omitempty" name:"ProgramArgs"`

	// 备注
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源引用数组
	ResourceRefs []*ResourceRef `json:"ResourceRefs,omitempty" name:"ResourceRefs" list`

	// 作业默认并行度
	DefaultParallelism *uint64 `json:"DefaultParallelism,omitempty" name:"DefaultParallelism"`

	// 系统参数
	Properties []*Property `json:"Properties,omitempty" name:"Properties" list`

	// 1: 作业配置达到上限之后，自动删除可删除的最早版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`

	// 作业使用的 COS 存储桶名
	COSBucket *string `json:"COSBucket,omitempty" name:"COSBucket"`

	// 是否采集作业日志
	LogCollect *bool `json:"LogCollect,omitempty" name:"LogCollect"`
}

func NewCreateJobConfigRequest 

func NewCreateJobConfigRequest() (request *CreateJobConfigRequest)

func (*CreateJobConfigRequest) FromJsonString 

func (r *CreateJobConfigRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateJobConfigRequest) ToJsonString 

func (r *CreateJobConfigRequest) ToJsonString() string

type CreateJobConfigResponse 

type CreateJobConfigResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 作业配置版本号
		Version *uint64 `json:"Version,omitempty" name:"Version"`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateJobConfigResponse 

func NewCreateJobConfigResponse() (response *CreateJobConfigResponse)

func (*CreateJobConfigResponse) FromJsonString 

func (r *CreateJobConfigResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateJobConfigResponse) ToJsonString 

func (r *CreateJobConfigResponse) ToJsonString() string

type CreateJobRequest 

type CreateJobRequest struct {
	*tchttp.BaseRequest

	// 作业名称，允许输入长度小于等于50个字符的中文、英文、数字、-（横线）、_（下划线）、.（点），且符号必须半角字符。注意作业名不能和现有作业同名
	Name *string `json:"Name,omitempty" name:"Name"`

	// 作业的类型，1 表示 SQL 作业，2 表示 JAR 作业
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`

	// 集群的类型，1 表示共享集群，2 表示独享集群
	ClusterType *int64 `json:"ClusterType,omitempty" name:"ClusterType"`

	// 当 ClusterType=2 时，必选，用来指定该作业提交的独享集群 ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 设置每 CU 的内存规格，单位为 GB，支持 2、4、8、16（需申请开通白名单后使用）。默认为 4，即 1 CU 对应 4 GB 的运行内存
	CuMem *uint64 `json:"CuMem,omitempty" name:"CuMem"`

	// 作业的备注信息，可以随意设置
	Remark *string `json:"Remark,omitempty" name:"Remark"`
}

func NewCreateJobRequest 

func NewCreateJobRequest() (request *CreateJobRequest)

func (*CreateJobRequest) FromJsonString 

func (r *CreateJobRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateJobRequest) ToJsonString 

func (r *CreateJobRequest) ToJsonString() string

type CreateJobResponse 

type CreateJobResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 作业Id
		JobId *string `json:"JobId,omitempty" name:"JobId"`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateJobResponse 

func NewCreateJobResponse() (response *CreateJobResponse)

func (*CreateJobResponse) FromJsonString 

func (r *CreateJobResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateJobResponse) ToJsonString 

func (r *CreateJobResponse) ToJsonString() string

type CreateResourceConfigRequest 

type CreateResourceConfigRequest struct {
	*tchttp.BaseRequest

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

	// 位置信息
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源描述信息
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 1： 资源版本达到上限，自动删除最早可删除的版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`
}

func NewCreateResourceConfigRequest 

func NewCreateResourceConfigRequest() (request *CreateResourceConfigRequest)

func (*CreateResourceConfigRequest) FromJsonString 

func (r *CreateResourceConfigRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateResourceConfigRequest) ToJsonString 

func (r *CreateResourceConfigRequest) ToJsonString() string

type CreateResourceConfigResponse 

type CreateResourceConfigResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 资源版本ID
		Version *int64 `json:"Version,omitempty" name:"Version"`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateResourceConfigResponse 

func NewCreateResourceConfigResponse() (response *CreateResourceConfigResponse)

func (*CreateResourceConfigResponse) FromJsonString 

func (r *CreateResourceConfigResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateResourceConfigResponse) ToJsonString 

func (r *CreateResourceConfigResponse) ToJsonString() string

type CreateResourceRequest 

type CreateResourceRequest struct {
	*tchttp.BaseRequest

	// 资源位置
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

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

	// 资源类型，占时只支持jar，填1
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源版本描述
	ResourceConfigRemark *string `json:"ResourceConfigRemark,omitempty" name:"ResourceConfigRemark"`
}

func NewCreateResourceRequest 

func NewCreateResourceRequest() (request *CreateResourceRequest)

func (*CreateResourceRequest) FromJsonString 

func (r *CreateResourceRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateResourceRequest) ToJsonString 

func (r *CreateResourceRequest) ToJsonString() string

type CreateResourceResponse 

type CreateResourceResponse struct {
	*tchttp.BaseResponse
	Response *struct {

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

		// 资源版本
		Version *int64 `json:"Version,omitempty" name:"Version"`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewCreateResourceResponse 

func NewCreateResourceResponse() (response *CreateResourceResponse)

func (*CreateResourceResponse) FromJsonString 

func (r *CreateResourceResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateResourceResponse) ToJsonString 

func (r *CreateResourceResponse) ToJsonString() string

type DeleteResourceConfigsRequest 

type DeleteResourceConfigsRequest struct {
	*tchttp.BaseRequest

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

	// 资源版本数组
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions" list`
}

func NewDeleteResourceConfigsRequest 

func NewDeleteResourceConfigsRequest() (request *DeleteResourceConfigsRequest)

func (*DeleteResourceConfigsRequest) FromJsonString 

func (r *DeleteResourceConfigsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteResourceConfigsRequest) ToJsonString 

func (r *DeleteResourceConfigsRequest) ToJsonString() string

type DeleteResourceConfigsResponse 

type DeleteResourceConfigsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteResourceConfigsResponse 

func NewDeleteResourceConfigsResponse() (response *DeleteResourceConfigsResponse)

func (*DeleteResourceConfigsResponse) FromJsonString 

func (r *DeleteResourceConfigsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteResourceConfigsResponse) ToJsonString 

func (r *DeleteResourceConfigsResponse) ToJsonString() string

type DeleteResourcesRequest 

type DeleteResourcesRequest struct {
	*tchttp.BaseRequest

	// 待删除资源ID列表
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds" list`
}

func NewDeleteResourcesRequest 

func NewDeleteResourcesRequest() (request *DeleteResourcesRequest)

func (*DeleteResourcesRequest) FromJsonString 

func (r *DeleteResourcesRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteResourcesRequest) ToJsonString 

func (r *DeleteResourcesRequest) ToJsonString() string

type DeleteResourcesResponse 

type DeleteResourcesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteResourcesResponse 

func NewDeleteResourcesResponse() (response *DeleteResourcesResponse)

func (*DeleteResourcesResponse) FromJsonString 

func (r *DeleteResourcesResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteResourcesResponse) ToJsonString 

func (r *DeleteResourcesResponse) ToJsonString() string

type DeleteTableConfigRequest 

type DeleteTableConfigRequest struct {
	*tchttp.BaseRequest

	// 作业ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 调试作业ID
	DebugId *int64 `json:"DebugId,omitempty" name:"DebugId"`

	// 表名
	TableName *string `json:"TableName,omitempty" name:"TableName"`
}

func NewDeleteTableConfigRequest 

func NewDeleteTableConfigRequest() (request *DeleteTableConfigRequest)

func (*DeleteTableConfigRequest) FromJsonString 

func (r *DeleteTableConfigRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTableConfigRequest) ToJsonString 

func (r *DeleteTableConfigRequest) ToJsonString() string

type DeleteTableConfigResponse 

type DeleteTableConfigResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDeleteTableConfigResponse 

func NewDeleteTableConfigResponse() (response *DeleteTableConfigResponse)

func (*DeleteTableConfigResponse) FromJsonString 

func (r *DeleteTableConfigResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTableConfigResponse) ToJsonString 

func (r *DeleteTableConfigResponse) ToJsonString() string

type DescribeJobConfigsRequest 

type DescribeJobConfigsRequest struct {
	*tchttp.BaseRequest

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 作业配置版本
	JobConfigVersions []*uint64 `json:"JobConfigVersions,omitempty" name:"JobConfigVersions" list`

	// 偏移量，默认0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认20，最大100
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 过滤条件
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`

	// true 表示只展示草稿
	OnlyDraft *bool `json:"OnlyDraft,omitempty" name:"OnlyDraft"`
}

func NewDescribeJobConfigsRequest 

func NewDescribeJobConfigsRequest() (request *DescribeJobConfigsRequest)

func (*DescribeJobConfigsRequest) FromJsonString 

func (r *DescribeJobConfigsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeJobConfigsRequest) ToJsonString 

func (r *DescribeJobConfigsRequest) ToJsonString() string

type DescribeJobConfigsResponse 

type DescribeJobConfigsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 总的配置版本数量
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 作业配置列表
		JobConfigSet []*JobConfig `json:"JobConfigSet,omitempty" name:"JobConfigSet" list`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeJobConfigsResponse 

func NewDescribeJobConfigsResponse() (response *DescribeJobConfigsResponse)

func (*DescribeJobConfigsResponse) FromJsonString 

func (r *DescribeJobConfigsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeJobConfigsResponse) ToJsonString 

func (r *DescribeJobConfigsResponse) ToJsonString() string

type DescribeJobsRequest 

type DescribeJobsRequest struct {
	*tchttp.BaseRequest

	// 按照一个或者多个作业ID查询。作业ID形如：cql-11112222，每次请求的作业上限为100。参数不支持同时指定JobIds和Filters。
	JobIds []*string `json:"JobIds,omitempty" name:"JobIds" list`

	// 过滤条件，详见作业过滤条件表。每次请求的Filters的上限为10，Filter.Values的上限为5。参数不支持同时指定JobIds和Filters。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`
}

func NewDescribeJobsRequest 

func NewDescribeJobsRequest() (request *DescribeJobsRequest)

func (*DescribeJobsRequest) FromJsonString 

func (r *DescribeJobsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeJobsRequest) ToJsonString 

func (r *DescribeJobsRequest) ToJsonString() string

type DescribeJobsResponse 

type DescribeJobsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 作业总数
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 作业列表
		JobSet []*JobV1 `json:"JobSet,omitempty" name:"JobSet" list`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeJobsResponse 

func NewDescribeJobsResponse() (response *DescribeJobsResponse)

func (*DescribeJobsResponse) FromJsonString 

func (r *DescribeJobsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeJobsResponse) ToJsonString 

func (r *DescribeJobsResponse) ToJsonString() string

type DescribeResourceConfigsRequest 

type DescribeResourceConfigsRequest struct {
	*tchttp.BaseRequest

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

	// 偏移量
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 返回值大小
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 资源配置Versions集合
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions" list`

	// 作业配置版本
	JobConfigVersion *int64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// 作业ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`
}

func NewDescribeResourceConfigsRequest 

func NewDescribeResourceConfigsRequest() (request *DescribeResourceConfigsRequest)

func (*DescribeResourceConfigsRequest) FromJsonString 

func (r *DescribeResourceConfigsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourceConfigsRequest) ToJsonString 

func (r *DescribeResourceConfigsRequest) ToJsonString() string

type DescribeResourceConfigsResponse 

type DescribeResourceConfigsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 资源配置描述数组
		ResourceConfigSet []*ResourceConfigItem `json:"ResourceConfigSet,omitempty" name:"ResourceConfigSet" list`

		// 资源配置数量
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeResourceConfigsResponse 

func NewDescribeResourceConfigsResponse() (response *DescribeResourceConfigsResponse)

func (*DescribeResourceConfigsResponse) FromJsonString 

func (r *DescribeResourceConfigsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourceConfigsResponse) ToJsonString 

func (r *DescribeResourceConfigsResponse) ToJsonString() string

type DescribeResourceRelatedJobsRequest 

type DescribeResourceRelatedJobsRequest struct {
	*tchttp.BaseRequest

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

	// 默认0;   1： 按照作业版本创建时间降序
	DESCByJobConfigCreateTime *int64 `json:"DESCByJobConfigCreateTime,omitempty" name:"DESCByJobConfigCreateTime"`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`
}

func NewDescribeResourceRelatedJobsRequest 

func NewDescribeResourceRelatedJobsRequest() (request *DescribeResourceRelatedJobsRequest)

func (*DescribeResourceRelatedJobsRequest) FromJsonString 

func (r *DescribeResourceRelatedJobsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourceRelatedJobsRequest) ToJsonString 

func (r *DescribeResourceRelatedJobsRequest) ToJsonString() string

type DescribeResourceRelatedJobsResponse 

type DescribeResourceRelatedJobsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 总数
		TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

		// 关联作业信息
		RefJobInfos []*ResourceRefJobInfo `json:"RefJobInfos,omitempty" name:"RefJobInfos" list`

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeResourceRelatedJobsResponse 

func NewDescribeResourceRelatedJobsResponse() (response *DescribeResourceRelatedJobsResponse)

func (*DescribeResourceRelatedJobsResponse) FromJsonString 

func (r *DescribeResourceRelatedJobsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourceRelatedJobsResponse) ToJsonString 

func (r *DescribeResourceRelatedJobsResponse) ToJsonString() string

type DescribeResourcesRequest 

type DescribeResourcesRequest struct {
	*tchttp.BaseRequest

	// 需要查询的资源ID数组
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds" list`

	// 偏移量
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 查询资源配置列表， 如果不填写，返回该ResourceId下所有作业配置列表
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`
}

func NewDescribeResourcesRequest 

func NewDescribeResourcesRequest() (request *DescribeResourcesRequest)

func (*DescribeResourcesRequest) FromJsonString 

func (r *DescribeResourcesRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourcesRequest) ToJsonString 

func (r *DescribeResourcesRequest) ToJsonString() string

type DescribeResourcesResponse 

type DescribeResourcesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 资源详细信息集合
		ResourceSet []*ResourceItem `json:"ResourceSet,omitempty" name:"ResourceSet" list`

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

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeResourcesResponse 

func NewDescribeResourcesResponse() (response *DescribeResourcesResponse)

func (*DescribeResourcesResponse) FromJsonString 

func (r *DescribeResourcesResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeResourcesResponse) ToJsonString 

func (r *DescribeResourcesResponse) ToJsonString() string

type DescribeSystemResourcesRequest 

type DescribeSystemResourcesRequest struct {
	*tchttp.BaseRequest

	// 需要查询的资源ID数组
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds" list`

	// 偏移量
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 查询资源配置列表， 如果不填写，返回该ResourceId下所有作业配置列表
	Filters []*Filter `json:"Filters,omitempty" name:"Filters" list`

	// 集群ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`
}

func NewDescribeSystemResourcesRequest 

func NewDescribeSystemResourcesRequest() (request *DescribeSystemResourcesRequest)

func (*DescribeSystemResourcesRequest) FromJsonString 

func (r *DescribeSystemResourcesRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSystemResourcesRequest) ToJsonString 

func (r *DescribeSystemResourcesRequest) ToJsonString() string

type DescribeSystemResourcesResponse 

type DescribeSystemResourcesResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 资源详细信息集合
		ResourceSet []*SystemResourceItem `json:"ResourceSet,omitempty" name:"ResourceSet" list`

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

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewDescribeSystemResourcesResponse 

func NewDescribeSystemResourcesResponse() (response *DescribeSystemResourcesResponse)

func (*DescribeSystemResourcesResponse) FromJsonString 

func (r *DescribeSystemResourcesResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeSystemResourcesResponse) ToJsonString 

func (r *DescribeSystemResourcesResponse) ToJsonString() string

type Filter 

type Filter struct {

	// 要过滤的字段
	Name *string `json:"Name,omitempty" name:"Name"`

	// 字段的过滤值
	Values []*string `json:"Values,omitempty" name:"Values" list`
}

type JobConfig 

type JobConfig struct {

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 主类
	// 注意：此字段可能返回 null，表示取不到有效值。
	EntrypointClass *string `json:"EntrypointClass,omitempty" name:"EntrypointClass"`

	// 主类入参
	// 注意：此字段可能返回 null，表示取不到有效值。
	ProgramArgs *string `json:"ProgramArgs,omitempty" name:"ProgramArgs"`

	// 备注
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 作业配置创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 作业配置的版本号
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 作业默认并行度
	// 注意：此字段可能返回 null，表示取不到有效值。
	DefaultParallelism *uint64 `json:"DefaultParallelism,omitempty" name:"DefaultParallelism"`

	// 系统参数
	// 注意：此字段可能返回 null，表示取不到有效值。
	Properties []*Property `json:"Properties,omitempty" name:"Properties" list`

	// 引用资源
	// 注意：此字段可能返回 null，表示取不到有效值。
	ResourceRefDetails []*ResourceRefDetail `json:"ResourceRefDetails,omitempty" name:"ResourceRefDetails" list`

	// 创建者uin
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 作业配置上次启动时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 作业绑定的存储桶
	// 注意：此字段可能返回 null，表示取不到有效值。
	COSBucket *string `json:"COSBucket,omitempty" name:"COSBucket"`

	// 是否启用日志收集，0-未启用，1-已启用，2-历史集群未设置日志集，3-历史集群已开启
	// 注意：此字段可能返回 null，表示取不到有效值。
	LogCollect *int64 `json:"LogCollect,omitempty" name:"LogCollect"`

	// 作业的最大并行度
	// 注意：此字段可能返回 null，表示取不到有效值。
	MaxParallelism *uint64 `json:"MaxParallelism,omitempty" name:"MaxParallelism"`
}

type JobV1 

type JobV1 struct {

	// 作业ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 地域
	// 注意：此字段可能返回 null，表示取不到有效值。
	Region *string `json:"Region,omitempty" name:"Region"`

	// 可用区
	// 注意：此字段可能返回 null，表示取不到有效值。
	Zone *string `json:"Zone,omitempty" name:"Zone"`

	// 用户AppId
	// 注意：此字段可能返回 null，表示取不到有效值。
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 用户UIN
	// 注意：此字段可能返回 null，表示取不到有效值。
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建者UIN
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 作业名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// 作业类型
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`

	// 作业状态，1：未初始化，2：未发布，3：操作中，4：运行中，5：停止，6：暂停，-1：故障
	// 注意：此字段可能返回 null，表示取不到有效值。
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 作业创建时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 作业启动时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	StartTime *string `json:"StartTime,omitempty" name:"StartTime"`

	// 作业停止时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	StopTime *string `json:"StopTime,omitempty" name:"StopTime"`

	// 作业更新时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 作业累计运行时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	TotalRunMillis *int64 `json:"TotalRunMillis,omitempty" name:"TotalRunMillis"`

	// 备注信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 操作错误提示信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	LastOpResult *string `json:"LastOpResult,omitempty" name:"LastOpResult"`

	// 集群名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// 最新配置版本号
	// 注意：此字段可能返回 null，表示取不到有效值。
	LatestJobConfigVersion *int64 `json:"LatestJobConfigVersion,omitempty" name:"LatestJobConfigVersion"`

	// 已发布的配置版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	PublishedJobConfigVersion *int64 `json:"PublishedJobConfigVersion,omitempty" name:"PublishedJobConfigVersion"`

	// 运行的CU数量
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningCuNum *int64 `json:"RunningCuNum,omitempty" name:"RunningCuNum"`

	// 作业内存规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	CuMem *int64 `json:"CuMem,omitempty" name:"CuMem"`

	// 作业状态描述
	// 注意：此字段可能返回 null，表示取不到有效值。
	StatusDesc *string `json:"StatusDesc,omitempty" name:"StatusDesc"`

	// 运行状态时表示单次运行时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	CurrentRunMillis *int64 `json:"CurrentRunMillis,omitempty" name:"CurrentRunMillis"`

	// 作业所在的集群ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 作业管理WEB UI 入口
	// 注意：此字段可能返回 null，表示取不到有效值。
	WebUIUrl *string `json:"WebUIUrl,omitempty" name:"WebUIUrl"`

	// 作业所在集群类型
	// 注意：此字段可能返回 null，表示取不到有效值。
	SchedulerType *int64 `json:"SchedulerType,omitempty" name:"SchedulerType"`

	// 作业所在集群状态
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterStatus *int64 `json:"ClusterStatus,omitempty" name:"ClusterStatus"`
}

type Property 

type Property struct {

	// 系统配置的Key
	Key *string `json:"Key,omitempty" name:"Key"`

	// 系统配置的Value
	Value *string `json:"Value,omitempty" name:"Value"`
}

type ResourceConfigItem 

type ResourceConfigItem struct {

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

	// 资源类型
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源所属地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 资源所属AppId
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号Uin
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 子账号Uin
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 资源位置描述
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 资源版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 资源描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源状态：0: 资源同步中，1:资源已就绪
	// 注意：此字段可能返回 null，表示取不到有效值。
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 关联作业个数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobCount *int64 `json:"RefJobCount,omitempty" name:"RefJobCount"`
}

type ResourceItem 

type ResourceItem struct {

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

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

	// 资源类型
	ResourceType *uint64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源位置
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 应用ID
	AppId *uint64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号Uin
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 子账号Uin
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 资源创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 资源最后更新时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 资源的资源版本ID
	LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitempty" name:"LatestResourceConfigVersion"`

	// 资源备注
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 版本个数
	// 注意：此字段可能返回 null，表示取不到有效值。
	VersionCount *int64 `json:"VersionCount,omitempty" name:"VersionCount"`

	// 关联作业数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobCount *int64 `json:"RefJobCount,omitempty" name:"RefJobCount"`
}

type ResourceLoc 

type ResourceLoc struct {

	// 资源位置的存储类型，目前只支持COS
	StorageType *int64 `json:"StorageType,omitempty" name:"StorageType"`

	// 描述资源位置的json
	Param *ResourceLocParam `json:"Param,omitempty" name:"Param"`
}

type ResourceLocParam 

type ResourceLocParam struct {

	// 资源bucket
	Bucket *string `json:"Bucket,omitempty" name:"Bucket"`

	// 资源路径
	Path *string `json:"Path,omitempty" name:"Path"`

	// 资源所在地域，如果不填，则使用Resource的Region
	// 注意：此字段可能返回 null，表示取不到有效值。
	Region *string `json:"Region,omitempty" name:"Region"`
}

type ResourceRef 

type ResourceRef struct {

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

	// 资源版本ID，-1表示使用最新版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 引用资源类型，例如主资源设置为1，代表main class所在的jar包
	Type *int64 `json:"Type,omitempty" name:"Type"`
}

type ResourceRefDetail 

type ResourceRefDetail struct {

	// 资源id
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源版本，-1表示使用最新版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

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

	// 1: 主资源
	Type *int64 `json:"Type,omitempty" name:"Type"`

	// 1: 系统内置资源
	SystemProvide *int64 `json:"SystemProvide,omitempty" name:"SystemProvide"`
}

type ResourceRefJobInfo 

type ResourceRefJobInfo struct {

	// Job id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Job配置版本
	JobConfigVersion *int64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// 资源版本
	ResourceVersion *int64 `json:"ResourceVersion,omitempty" name:"ResourceVersion"`
}

type RunJobDescription 

type RunJobDescription struct {

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 运行类型，1：启动，2：恢复
	RunType *int64 `json:"RunType,omitempty" name:"RunType"`

	// SQL类型作业启动参数：指定数据源消费起始时间点
	StartMode *string `json:"StartMode,omitempty" name:"StartMode"`

	// 已发布上线的作业配置版本
	JobConfigVersion *uint64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`
}

type RunJobsRequest 

type RunJobsRequest struct {
	*tchttp.BaseRequest

	// 批量启动作业的描述信息
	RunJobDescriptions []*RunJobDescription `json:"RunJobDescriptions,omitempty" name:"RunJobDescriptions" list`
}

func NewRunJobsRequest 

func NewRunJobsRequest() (request *RunJobsRequest)

func (*RunJobsRequest) FromJsonString 

func (r *RunJobsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RunJobsRequest) ToJsonString 

func (r *RunJobsRequest) ToJsonString() string

type RunJobsResponse 

type RunJobsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewRunJobsResponse 

func NewRunJobsResponse() (response *RunJobsResponse)

func (*RunJobsResponse) FromJsonString 

func (r *RunJobsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*RunJobsResponse) ToJsonString 

func (r *RunJobsResponse) ToJsonString() string

type StopJobDescription 

type StopJobDescription struct {

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 停止类型，1 停止 2 暂停
	StopType *int64 `json:"StopType,omitempty" name:"StopType"`
}

type StopJobsRequest 

type StopJobsRequest struct {
	*tchttp.BaseRequest

	// 批量停止作业的描述信息
	StopJobDescriptions []*StopJobDescription `json:"StopJobDescriptions,omitempty" name:"StopJobDescriptions" list`
}

func NewStopJobsRequest 

func NewStopJobsRequest() (request *StopJobsRequest)

func (*StopJobsRequest) FromJsonString 

func (r *StopJobsRequest) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*StopJobsRequest) ToJsonString 

func (r *StopJobsRequest) ToJsonString() string

type StopJobsResponse 

type StopJobsResponse struct {
	*tchttp.BaseResponse
	Response *struct {

		// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
		RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
	} `json:"Response"`
}

func NewStopJobsResponse 

func NewStopJobsResponse() (response *StopJobsResponse)

func (*StopJobsResponse) FromJsonString 

func (r *StopJobsResponse) FromJsonString(s string) error

It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*StopJobsResponse) ToJsonString 

func (r *StopJobsResponse) ToJsonString() string

type SystemResourceItem 

type SystemResourceItem struct {

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

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

	// 资源类型
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源备注
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源所属地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 资源的最新版本
	LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitempty" name:"LatestResourceConfigVersion"`
}

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.