v20190422

package
v0.0.0-...-de5d023 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// CAM签名/鉴权错误。
	AUTHFAILURE = "AuthFailure"

	// 未授权操作。
	AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"

	// 重复的作业名。
	FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName"

	// 语法检查失败。
	FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure"

	// 用户未实名验证。
	FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated"

	// 内部错误。
	INTERNALERROR = "InternalError"

	// COS 服务访问错误。
	INTERNALERROR_COSCLIENT = "InternalError.COSClient"

	// CAM 网关错误。
	INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError"

	// 数据库异常。
	INTERNALERROR_DB = "InternalError.DB"

	// 失败的目标资源。
	INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources"

	// 无法更新作业错误。
	INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob"

	// 内部错误。
	INTERNALERROR_LOGICERROR = "InternalError.LogicError"

	// 资源只有一个版本，无法删除。
	INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete"

	// 资源不存在。
	INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist"

	// 未找到sqlcode错误。
	INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound"

	// 内部错误。
	INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient"

	// 系统错误。
	INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"

	// AppId资源不匹配。
	INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch"

	// 非法的 MaxParallelism 参数。
	INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"

	// appid错误。
	INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId"

	// 无效集群id。
	INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId"

	// 名字不符合规范。
	INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName"

	// 无效Region。
	INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion"

	// ResourceIds非法。
	INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds"

	// MaxParallelism 过大。
	INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge"

	// MaxParallelism 不允许小于算子默认并行度。
	INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall"

	// Uin资源不匹配。
	INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch"

	// Flink参数非法。
	INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf"

	// 参数取值错误。
	INVALIDPARAMETERVALUE = "InvalidParameterValue"

	// 集群Id指定错误，为空或者不存在。
	INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId"

	// CU内存规格不匹配。
	INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem"

	// 无效启动模式。
	INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode"

	// 作业id的参数无效。
	INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError"

	// Illegal JobName。
	INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName"

	// 作业名称已存在。
	INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted"

	// 集群模式与作业类型不匹配。
	INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType"

	// SQL作业不能指定EntrypointClass，JAR作业则必须指定。
	INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass"

	// 未找到资源ID。
	INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound"

	// 批量运行作业个数超过上限。
	INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount"

	// RunType错误。
	INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType"

	// 不支持的复合类型。
	INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite"

	// 超过配额限制。
	LIMITEXCEEDED = "LimitExceeded"

	// Job个数超过限额。
	LIMITEXCEEDED_JOB = "LimitExceeded.Job"

	// 作业配置超出限制。
	LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig"

	// 资源被占用。
	RESOURCEINUSE = "ResourceInUse"

	// 集群有其他操作。
	RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess"

	// 资源名称已存在。
	RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists"

	// CU资源不足。
	RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU"

	// 资源不存在。
	RESOURCENOTFOUND = "ResourceNotFound"

	// COS Bucket 未找到或无权限访问。
	RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket"

	// 集群不存在。
	RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"

	// 作业不存在。
	RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"

	// 作业配置版本不存在。
	RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig"

	// 找不到作业。
	RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"

	// 程序包不存在。
	RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource"

	// 程序包版本不存在。
	RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig"

	// 资源不存在。
	RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist"

	// 资源不可用。
	RESOURCEUNAVAILABLE = "ResourceUnavailable"

	// 被某个作业配置使用。
	RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig"

	// 检查资源位置是否存在错误。
	RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists"

	// 群集组状态错误。
	RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus"

	// 失败的目标资源。
	RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources"

	// 获取发布的作业作业配置错误。
	RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig"

	// 作业资源配置未就绪。
	RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady"

	// 找不到JobId的正在运行的作业实例。
	RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId"

	// 不允许停止或暂停错误。
	RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause"

	// 共享群集只允许CuMem=4。
	RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem"

	// cos上的程序包不存在。
	RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists"

	// 操作不支持。
	UNSUPPORTEDOPERATION = "UnsupportedOperation"

	// Checkpoint 时间间隔，错误。
	UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError"

	// 不支持的启动模式。
	UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"
)
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.CredentialIface, 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)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName"
FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName"
INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId"
INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem"
INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName"
INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted"
INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType"
INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_JOB = "LimitExceeded.Job"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus"
RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem"

func (*Client) CreateJobConfig 

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

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound"
INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient"
INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"
INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion"
INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge"
INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall"
INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError"

func (*Client) CreateJobConfigWithContext 

func (c *Client) CreateJobConfigWithContext(ctx context.Context, request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound"
INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient"
INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"
INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion"
INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge"
INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall"
INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError"

func (*Client) CreateJobWithContext 

func (c *Client) CreateJobWithContext(ctx context.Context, request *CreateJobRequest) (response *CreateJobResponse, err error)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName"
FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName"
INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId"
INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem"
INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName"
INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted"
INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType"
INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite"
LIMITEXCEEDED = "LimitExceeded"
LIMITEXCEEDED_JOB = "LimitExceeded.Job"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus"
RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem"

func (*Client) CreateResource 

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

CreateResource 创建资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists"
RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists"

func (*Client) CreateResourceConfig 

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

CreateResourceConfig 创建资源配置接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist"
LIMITEXCEEDED = "LimitExceeded"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist"

func (*Client) CreateResourceConfigWithContext 

func (c *Client) CreateResourceConfigWithContext(ctx context.Context, request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)

CreateResourceConfig 创建资源配置接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist"
LIMITEXCEEDED = "LimitExceeded"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist"

func (*Client) CreateResourceWithContext 

func (c *Client) CreateResourceWithContext(ctx context.Context, request *CreateResourceRequest) (response *CreateResourceResponse, err error)

CreateResource 创建资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId"
LIMITEXCEEDED = "LimitExceeded"
RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists"
RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists"

func (*Client) DeleteResourceConfigs 

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

DeleteResourceConfigs 删除资源版本

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete"
INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds"
INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig"

func (*Client) DeleteResourceConfigsWithContext 

func (c *Client) DeleteResourceConfigsWithContext(ctx context.Context, request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)

DeleteResourceConfigs 删除资源版本

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete"
INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds"
INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig"

func (*Client) DeleteResources 

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

DeleteResources 删除资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteResourcesWithContext 

func (c *Client) DeleteResourcesWithContext(ctx context.Context, request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)

DeleteResources 删除资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DeleteTableConfig 

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

DeleteTableConfig 删除作业表配置

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"

func (*Client) DeleteTableConfigWithContext 

func (c *Client) DeleteTableConfigWithContext(ctx context.Context, request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)

DeleteTableConfig 删除作业表配置

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"

func (*Client) DescribeJobConfigs 

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

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"
INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge"
INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"

func (*Client) DescribeJobConfigsWithContext 

func (c *Client) DescribeJobConfigsWithContext(ctx context.Context, request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"
INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge"
INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"

func (*Client) DescribeJobs 

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

DescribeJobs 查询作业

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError"
INTERNALERROR_DB = "InternalError.DB"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig"

func (*Client) DescribeJobsWithContext 

func (c *Client) DescribeJobsWithContext(ctx context.Context, request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)

DescribeJobs 查询作业

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError"
INTERNALERROR_DB = "InternalError.DB"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig"

func (*Client) DescribeResourceConfigs 

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

DescribeResourceConfigs 描述资源配置接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch"
INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig"

func (*Client) DescribeResourceConfigsWithContext 

func (c *Client) DescribeResourceConfigsWithContext(ctx context.Context, request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)

DescribeResourceConfigs 描述资源配置接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch"
INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig"

func (*Client) DescribeResourceRelatedJobs 

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

DescribeResourceRelatedJobs 获取资源关联作业信息

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeResourceRelatedJobsWithContext 

func (c *Client) DescribeResourceRelatedJobsWithContext(ctx context.Context, request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)

DescribeResourceRelatedJobs 获取资源关联作业信息

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeResources 

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

DescribeResources 描述资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig"

func (*Client) DescribeResourcesWithContext 

func (c *Client) DescribeResourcesWithContext(ctx context.Context, request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)

DescribeResources 描述资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig"

func (*Client) DescribeSystemResources 

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

DescribeSystemResources 描述系统资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources"

func (*Client) DescribeSystemResourcesWithContext 

func (c *Client) DescribeSystemResourcesWithContext(ctx context.Context, request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)

DescribeSystemResources 描述系统资源接口

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR = "InternalError"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources"
INVALIDPARAMETERVALUE = "InvalidParameterValue"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources"

func (*Client) RunJobs 

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

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient"
INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId"
INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion"
INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode"
INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError"
INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount"
INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType"
RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess"
RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig"
RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady"
RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId"
UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"

func (*Client) RunJobsWithContext 

func (c *Client) RunJobsWithContext(ctx context.Context, request *RunJobsRequest) (response *RunJobsResponse, err error)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_COSCLIENT = "InternalError.COSClient"
INTERNALERROR_DB = "InternalError.DB"
INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob"
INTERNALERROR_LOGICERROR = "InternalError.LogicError"
INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient"
INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId"
INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion"
INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode"
INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError"
INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount"
INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType"
RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess"
RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket"
RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig"
RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource"
RESOURCEUNAVAILABLE = "ResourceUnavailable"
RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady"
RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId"
UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"

func (*Client) StopJobs 

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

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

func (*Client) StopJobsWithContext 

func (c *Client) StopJobsWithContext(ctx context.Context, request *StopJobsRequest) (response *StopJobsResponse, err error)

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

可能返回的错误码: 

AUTHFAILURE = "AuthFailure"
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"
INTERNALERROR_SYSTEMERROR = "InternalError.SystemError"
RESOURCEINUSE = "ResourceInUse"
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job"
RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId"
RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause"
UNSUPPORTEDOPERATION = "UnsupportedOperation"

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

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

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

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

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

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

	// JobManager规格
	JobManagerSpec *float64 `json:"JobManagerSpec,omitempty" name:"JobManagerSpec"`

	// TaskManager规格
	TaskManagerSpec *float64 `json:"TaskManagerSpec,omitempty" name:"TaskManagerSpec"`

	// CLS日志集ID
	ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"`

	// CLS日志主题ID
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`
}

func NewCreateJobConfigRequest 

func NewCreateJobConfigRequest() (request *CreateJobConfigRequest)

func (*CreateJobConfigRequest) FromJsonString 

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

FromJsonString 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

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

	// 作业名所属文件夹ID，根目录为"root"
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 作业运行的Flink版本
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`
}

func NewCreateJobRequest 

func NewCreateJobRequest() (request *CreateJobRequest)

func (*CreateJobRequest) FromJsonString 

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

FromJsonString 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

FromJsonString 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

FromJsonString 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

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

	// 资源类型。目前只支持 JAR，取值为 1
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

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

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

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

	// 目录ID
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`
}

func NewCreateResourceRequest 

func NewCreateResourceRequest() (request *CreateResourceRequest)

func (*CreateResourceRequest) FromJsonString 

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

FromJsonString 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

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

func NewDeleteResourceConfigsRequest 

func NewDeleteResourceConfigsRequest() (request *DeleteResourceConfigsRequest)

func (*DeleteResourceConfigsRequest) FromJsonString 

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

FromJsonString 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

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

func NewDeleteResourcesRequest 

func NewDeleteResourcesRequest() (request *DeleteResourcesRequest)

func (*DeleteResourcesRequest) FromJsonString 

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

FromJsonString 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

FromJsonString 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

FromJsonString 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

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

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

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

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

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

func NewDescribeJobConfigsRequest 

func NewDescribeJobConfigsRequest() (request *DescribeJobConfigsRequest)

func (*DescribeJobConfigsRequest) FromJsonString 

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

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

		// 唯一请求 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

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

	// 过滤条件，支持的 Filter.Name 为：作业名 Name、作业状态 Status、所属集群 ClusterId。每次请求的 Filters 个数的上限为 3，Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 偏移量，默认为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

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

		// 唯一请求 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

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

	// 偏移量，仅当设置 Limit 时该参数有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 返回值大小，不填则返回全量数据
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

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

	// 作业配置版本
	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

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

		// 资源配置数量
		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

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

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

func NewDescribeResourceRelatedJobsRequest 

func NewDescribeResourceRelatedJobsRequest() (request *DescribeResourceRelatedJobsRequest)

func (*DescribeResourceRelatedJobsRequest) FromJsonString 

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

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

		// 唯一请求 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

FromJsonString 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数组，数量不超过100个。如果填写了该参数则忽略Filters参数。
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds"`

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制。如果不填，默认返回 20 条
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// <li><strong>ResourceName</strong></li>
	// <p style="padding-left: 30px;">按照资源名字过滤，支持模糊过滤。传入的过滤名字不超过5个</p><p style="padding-left: 30px;">类型: String</p><p style="padding-left: 30px;">必选: 否</p>
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`
}

func NewDescribeResourcesRequest 

func NewDescribeResourcesRequest() (request *DescribeResourcesRequest)

func (*DescribeResourcesRequest) FromJsonString 

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

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

		// 总数量
		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

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

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制，默认返回 20 条
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

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

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

	// 查询对应Flink版本的内置connector
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`
}

func NewDescribeSystemResourcesRequest 

func NewDescribeSystemResourcesRequest() (request *DescribeSystemResourcesRequest)

func (*DescribeSystemResourcesRequest) FromJsonString 

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

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

		// 总数量
		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

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

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

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

	// 创建者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"`

	// JobManager规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobManagerSpec *float64 `json:"JobManagerSpec,omitempty" name:"JobManagerSpec"`

	// TaskManager规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	TaskManagerSpec *float64 `json:"TaskManagerSpec,omitempty" name:"TaskManagerSpec"`

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

	// CLS日志主题ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`
}

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

	// 作业类型，1：sql作业，2：Jar作业
	// 注意：此字段可能返回 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"`

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

	// 作业运行的 Flink 版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`
}

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 {

	// 资源位置的存储类型，目前只支持1: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"`

	// Savepoint路径
	SavepointPath *string `json:"SavepointPath,omitempty" name:"SavepointPath"`

	// Savepoint的Id
	SavepointId *string `json:"SavepointId,omitempty" name:"SavepointId"`
}

type RunJobsRequest 

type RunJobsRequest struct {
	*tchttp.BaseRequest

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

func NewRunJobsRequest 

func NewRunJobsRequest() (request *RunJobsRequest)

func (*RunJobsRequest) FromJsonString 

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

FromJsonString 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

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

func NewStopJobsRequest 

func NewStopJobsRequest() (request *StopJobsRequest)

func (*StopJobsRequest) FromJsonString 

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

FromJsonString 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

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

	// 资源类型。1 表示 JAR 包，目前只支持该值。
	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.