Documentation
¶
Index ¶
- Constants
- type Client
- func (c *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)
- func (c *Client) CreateJobConfig(request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)
- func (c *Client) CreateResource(request *CreateResourceRequest) (response *CreateResourceResponse, err error)
- func (c *Client) CreateResourceConfig(request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)
- func (c *Client) DeleteResourceConfigs(request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)
- func (c *Client) DeleteResources(request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)
- func (c *Client) DeleteTableConfig(request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)
- func (c *Client) DescribeJobConfigs(request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)
- func (c *Client) DescribeJobs(request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)
- func (c *Client) DescribeResourceConfigs(request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)
- func (c *Client) DescribeResourceRelatedJobs(request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)
- func (c *Client) DescribeResources(request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)
- func (c *Client) DescribeSystemResources(request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)
- func (c *Client) RunJobs(request *RunJobsRequest) (response *RunJobsResponse, err error)
- func (c *Client) StopJobs(request *StopJobsRequest) (response *StopJobsResponse, err error)
- type CreateJobConfigRequest
- type CreateJobConfigResponse
- type CreateJobRequest
- type CreateJobResponse
- type CreateResourceConfigRequest
- type CreateResourceConfigResponse
- type CreateResourceRequest
- type CreateResourceResponse
- type DeleteResourceConfigsRequest
- type DeleteResourceConfigsResponse
- type DeleteResourcesRequest
- type DeleteResourcesResponse
- type DeleteTableConfigRequest
- type DeleteTableConfigResponse
- type DescribeJobConfigsRequest
- type DescribeJobConfigsResponse
- type DescribeJobsRequest
- type DescribeJobsResponse
- type DescribeResourceConfigsRequest
- type DescribeResourceConfigsResponse
- type DescribeResourceRelatedJobsRequest
- type DescribeResourceRelatedJobsResponse
- type DescribeResourcesRequest
- type DescribeResourcesResponse
- type DescribeSystemResourcesRequest
- type DescribeSystemResourcesResponse
- type Filter
- type JobConfig
- type JobV1
- type Property
- type ResourceConfigItem
- type ResourceItem
- type ResourceLoc
- type ResourceLocParam
- type ResourceRef
- type ResourceRefDetail
- type ResourceRefJobInfo
- type RunJobDescription
- type RunJobsRequest
- type RunJobsResponse
- type StopJobDescription
- type StopJobsRequest
- type StopJobsResponse
- type SystemResourceItem
Constants ¶
const APIVersion = "2019-04-22"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func NewClient ¶
func NewClient(credential *common.Credential, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
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 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 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 ResourceRef ¶
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 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 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"`
}