Documentation
¶
Index ¶
- Variables
- func GetEndpointMap() map[string]string
- func GetEndpointType() string
- func SetClientProperty(client *Client, propertyName string, propertyValue interface{})
- func SetEndpointDataToClient(client *Client)
- type AppGroup
- type AppGroups
- type BatchDeleteJobsRequest
- type BatchDeleteJobsResponse
- type BatchDeleteRouteStrategyRequest
- type BatchDeleteRouteStrategyResponse
- type BatchDisableJobsRequest
- type BatchDisableJobsResponse
- type BatchEnableJobsRequest
- type BatchEnableJobsResponse
- type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) BatchDeleteJobs(request *BatchDeleteJobsRequest) (response *BatchDeleteJobsResponse, err error)
- func (client *Client) BatchDeleteJobsWithCallback(request *BatchDeleteJobsRequest, ...) <-chan int
- func (client *Client) BatchDeleteJobsWithChan(request *BatchDeleteJobsRequest) (<-chan *BatchDeleteJobsResponse, <-chan error)
- func (client *Client) BatchDeleteRouteStrategy(request *BatchDeleteRouteStrategyRequest) (response *BatchDeleteRouteStrategyResponse, err error)
- func (client *Client) BatchDeleteRouteStrategyWithCallback(request *BatchDeleteRouteStrategyRequest, ...) <-chan int
- func (client *Client) BatchDeleteRouteStrategyWithChan(request *BatchDeleteRouteStrategyRequest) (<-chan *BatchDeleteRouteStrategyResponse, <-chan error)
- func (client *Client) BatchDisableJobs(request *BatchDisableJobsRequest) (response *BatchDisableJobsResponse, err error)
- func (client *Client) BatchDisableJobsWithCallback(request *BatchDisableJobsRequest, ...) <-chan int
- func (client *Client) BatchDisableJobsWithChan(request *BatchDisableJobsRequest) (<-chan *BatchDisableJobsResponse, <-chan error)
- func (client *Client) BatchEnableJobs(request *BatchEnableJobsRequest) (response *BatchEnableJobsResponse, err error)
- func (client *Client) BatchEnableJobsWithCallback(request *BatchEnableJobsRequest, ...) <-chan int
- func (client *Client) BatchEnableJobsWithChan(request *BatchEnableJobsRequest) (<-chan *BatchEnableJobsResponse, <-chan error)
- func (client *Client) CreateAppGroup(request *CreateAppGroupRequest) (response *CreateAppGroupResponse, err error)
- func (client *Client) CreateAppGroupWithCallback(request *CreateAppGroupRequest, ...) <-chan int
- func (client *Client) CreateAppGroupWithChan(request *CreateAppGroupRequest) (<-chan *CreateAppGroupResponse, <-chan error)
- func (client *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)
- func (client *Client) CreateJobWithCallback(request *CreateJobRequest, ...) <-chan int
- func (client *Client) CreateJobWithChan(request *CreateJobRequest) (<-chan *CreateJobResponse, <-chan error)
- func (client *Client) CreateNamespace(request *CreateNamespaceRequest) (response *CreateNamespaceResponse, err error)
- func (client *Client) CreateNamespaceWithCallback(request *CreateNamespaceRequest, ...) <-chan int
- func (client *Client) CreateNamespaceWithChan(request *CreateNamespaceRequest) (<-chan *CreateNamespaceResponse, <-chan error)
- func (client *Client) CreateRouteStrategy(request *CreateRouteStrategyRequest) (response *CreateRouteStrategyResponse, err error)
- func (client *Client) CreateRouteStrategyWithCallback(request *CreateRouteStrategyRequest, ...) <-chan int
- func (client *Client) CreateRouteStrategyWithChan(request *CreateRouteStrategyRequest) (<-chan *CreateRouteStrategyResponse, <-chan error)
- func (client *Client) CreateWorkflow(request *CreateWorkflowRequest) (response *CreateWorkflowResponse, err error)
- func (client *Client) CreateWorkflowWithCallback(request *CreateWorkflowRequest, ...) <-chan int
- func (client *Client) CreateWorkflowWithChan(request *CreateWorkflowRequest) (<-chan *CreateWorkflowResponse, <-chan error)
- func (client *Client) DeleteAppGroup(request *DeleteAppGroupRequest) (response *DeleteAppGroupResponse, err error)
- func (client *Client) DeleteAppGroupWithCallback(request *DeleteAppGroupRequest, ...) <-chan int
- func (client *Client) DeleteAppGroupWithChan(request *DeleteAppGroupRequest) (<-chan *DeleteAppGroupResponse, <-chan error)
- func (client *Client) DeleteJob(request *DeleteJobRequest) (response *DeleteJobResponse, err error)
- func (client *Client) DeleteJobWithCallback(request *DeleteJobRequest, ...) <-chan int
- func (client *Client) DeleteJobWithChan(request *DeleteJobRequest) (<-chan *DeleteJobResponse, <-chan error)
- func (client *Client) DeleteRouteStrategy(request *DeleteRouteStrategyRequest) (response *DeleteRouteStrategyResponse, err error)
- func (client *Client) DeleteRouteStrategyWithCallback(request *DeleteRouteStrategyRequest, ...) <-chan int
- func (client *Client) DeleteRouteStrategyWithChan(request *DeleteRouteStrategyRequest) (<-chan *DeleteRouteStrategyResponse, <-chan error)
- func (client *Client) DeleteWorkflow(request *DeleteWorkflowRequest) (response *DeleteWorkflowResponse, err error)
- func (client *Client) DeleteWorkflowWithCallback(request *DeleteWorkflowRequest, ...) <-chan int
- func (client *Client) DeleteWorkflowWithChan(request *DeleteWorkflowRequest) (<-chan *DeleteWorkflowResponse, <-chan error)
- func (client *Client) DescribeRegions(request *DescribeRegionsRequest) (response *DescribeRegionsResponse, err error)
- func (client *Client) DescribeRegionsWithCallback(request *DescribeRegionsRequest, ...) <-chan int
- func (client *Client) DescribeRegionsWithChan(request *DescribeRegionsRequest) (<-chan *DescribeRegionsResponse, <-chan error)
- func (client *Client) DesignateWorkers(request *DesignateWorkersRequest) (response *DesignateWorkersResponse, err error)
- func (client *Client) DesignateWorkersWithCallback(request *DesignateWorkersRequest, ...) <-chan int
- func (client *Client) DesignateWorkersWithChan(request *DesignateWorkersRequest) (<-chan *DesignateWorkersResponse, <-chan error)
- func (client *Client) DisableJob(request *DisableJobRequest) (response *DisableJobResponse, err error)
- func (client *Client) DisableJobWithCallback(request *DisableJobRequest, ...) <-chan int
- func (client *Client) DisableJobWithChan(request *DisableJobRequest) (<-chan *DisableJobResponse, <-chan error)
- func (client *Client) DisableWorkflow(request *DisableWorkflowRequest) (response *DisableWorkflowResponse, err error)
- func (client *Client) DisableWorkflowWithCallback(request *DisableWorkflowRequest, ...) <-chan int
- func (client *Client) DisableWorkflowWithChan(request *DisableWorkflowRequest) (<-chan *DisableWorkflowResponse, <-chan error)
- func (client *Client) EnableJob(request *EnableJobRequest) (response *EnableJobResponse, err error)
- func (client *Client) EnableJobWithCallback(request *EnableJobRequest, ...) <-chan int
- func (client *Client) EnableJobWithChan(request *EnableJobRequest) (<-chan *EnableJobResponse, <-chan error)
- func (client *Client) EnableWorkflow(request *EnableWorkflowRequest) (response *EnableWorkflowResponse, err error)
- func (client *Client) EnableWorkflowWithCallback(request *EnableWorkflowRequest, ...) <-chan int
- func (client *Client) EnableWorkflowWithChan(request *EnableWorkflowRequest) (<-chan *EnableWorkflowResponse, <-chan error)
- func (client *Client) ExecuteJob(request *ExecuteJobRequest) (response *ExecuteJobResponse, err error)
- func (client *Client) ExecuteJobWithCallback(request *ExecuteJobRequest, ...) <-chan int
- func (client *Client) ExecuteJobWithChan(request *ExecuteJobRequest) (<-chan *ExecuteJobResponse, <-chan error)
- func (client *Client) ExecuteWorkflow(request *ExecuteWorkflowRequest) (response *ExecuteWorkflowResponse, err error)
- func (client *Client) ExecuteWorkflowWithCallback(request *ExecuteWorkflowRequest, ...) <-chan int
- func (client *Client) ExecuteWorkflowWithChan(request *ExecuteWorkflowRequest) (<-chan *ExecuteWorkflowResponse, <-chan error)
- func (client *Client) GetAppGroup(request *GetAppGroupRequest) (response *GetAppGroupResponse, err error)
- func (client *Client) GetAppGroupWithCallback(request *GetAppGroupRequest, ...) <-chan int
- func (client *Client) GetAppGroupWithChan(request *GetAppGroupRequest) (<-chan *GetAppGroupResponse, <-chan error)
- func (client *Client) GetJobInfo(request *GetJobInfoRequest) (response *GetJobInfoResponse, err error)
- func (client *Client) GetJobInfoWithCallback(request *GetJobInfoRequest, ...) <-chan int
- func (client *Client) GetJobInfoWithChan(request *GetJobInfoRequest) (<-chan *GetJobInfoResponse, <-chan error)
- func (client *Client) GetJobInstance(request *GetJobInstanceRequest) (response *GetJobInstanceResponse, err error)
- func (client *Client) GetJobInstanceList(request *GetJobInstanceListRequest) (response *GetJobInstanceListResponse, err error)
- func (client *Client) GetJobInstanceListWithCallback(request *GetJobInstanceListRequest, ...) <-chan int
- func (client *Client) GetJobInstanceListWithChan(request *GetJobInstanceListRequest) (<-chan *GetJobInstanceListResponse, <-chan error)
- func (client *Client) GetJobInstanceWithCallback(request *GetJobInstanceRequest, ...) <-chan int
- func (client *Client) GetJobInstanceWithChan(request *GetJobInstanceRequest) (<-chan *GetJobInstanceResponse, <-chan error)
- func (client *Client) GetLog(request *GetLogRequest) (response *GetLogResponse, err error)
- func (client *Client) GetLogWithCallback(request *GetLogRequest, callback func(response *GetLogResponse, err error)) <-chan int
- func (client *Client) GetLogWithChan(request *GetLogRequest) (<-chan *GetLogResponse, <-chan error)
- func (client *Client) GetOverview(request *GetOverviewRequest) (response *GetOverviewResponse, err error)
- func (client *Client) GetOverviewWithCallback(request *GetOverviewRequest, ...) <-chan int
- func (client *Client) GetOverviewWithChan(request *GetOverviewRequest) (<-chan *GetOverviewResponse, <-chan error)
- func (client *Client) GetWorkFlow(request *GetWorkFlowRequest) (response *GetWorkFlowResponse, err error)
- func (client *Client) GetWorkFlowWithCallback(request *GetWorkFlowRequest, ...) <-chan int
- func (client *Client) GetWorkFlowWithChan(request *GetWorkFlowRequest) (<-chan *GetWorkFlowResponse, <-chan error)
- func (client *Client) GetWorkerList(request *GetWorkerListRequest) (response *GetWorkerListResponse, err error)
- func (client *Client) GetWorkerListWithCallback(request *GetWorkerListRequest, ...) <-chan int
- func (client *Client) GetWorkerListWithChan(request *GetWorkerListRequest) (<-chan *GetWorkerListResponse, <-chan error)
- func (client *Client) GetWorkflowInstance(request *GetWorkflowInstanceRequest) (response *GetWorkflowInstanceResponse, err error)
- func (client *Client) GetWorkflowInstanceWithCallback(request *GetWorkflowInstanceRequest, ...) <-chan int
- func (client *Client) GetWorkflowInstanceWithChan(request *GetWorkflowInstanceRequest) (<-chan *GetWorkflowInstanceResponse, <-chan error)
- func (client *Client) GrantPermission(request *GrantPermissionRequest) (response *GrantPermissionResponse, err error)
- func (client *Client) GrantPermissionWithCallback(request *GrantPermissionRequest, ...) <-chan int
- func (client *Client) GrantPermissionWithChan(request *GrantPermissionRequest) (<-chan *GrantPermissionResponse, <-chan error)
- func (client *Client) ListGroups(request *ListGroupsRequest) (response *ListGroupsResponse, err error)
- func (client *Client) ListGroupsWithCallback(request *ListGroupsRequest, ...) <-chan int
- func (client *Client) ListGroupsWithChan(request *ListGroupsRequest) (<-chan *ListGroupsResponse, <-chan error)
- func (client *Client) ListJobs(request *ListJobsRequest) (response *ListJobsResponse, err error)
- func (client *Client) ListJobsWithCallback(request *ListJobsRequest, callback func(response *ListJobsResponse, err error)) <-chan int
- func (client *Client) ListJobsWithChan(request *ListJobsRequest) (<-chan *ListJobsResponse, <-chan error)
- func (client *Client) ListNamespaces(request *ListNamespacesRequest) (response *ListNamespacesResponse, err error)
- func (client *Client) ListNamespacesWithCallback(request *ListNamespacesRequest, ...) <-chan int
- func (client *Client) ListNamespacesWithChan(request *ListNamespacesRequest) (<-chan *ListNamespacesResponse, <-chan error)
- func (client *Client) ListWorkflowInstance(request *ListWorkflowInstanceRequest) (response *ListWorkflowInstanceResponse, err error)
- func (client *Client) ListWorkflowInstanceWithCallback(request *ListWorkflowInstanceRequest, ...) <-chan int
- func (client *Client) ListWorkflowInstanceWithChan(request *ListWorkflowInstanceRequest) (<-chan *ListWorkflowInstanceResponse, <-chan error)
- func (client *Client) RerunJob(request *RerunJobRequest) (response *RerunJobResponse, err error)
- func (client *Client) RerunJobWithCallback(request *RerunJobRequest, callback func(response *RerunJobResponse, err error)) <-chan int
- func (client *Client) RerunJobWithChan(request *RerunJobRequest) (<-chan *RerunJobResponse, <-chan error)
- func (client *Client) RetryJobInstance(request *RetryJobInstanceRequest) (response *RetryJobInstanceResponse, err error)
- func (client *Client) RetryJobInstanceWithCallback(request *RetryJobInstanceRequest, ...) <-chan int
- func (client *Client) RetryJobInstanceWithChan(request *RetryJobInstanceRequest) (<-chan *RetryJobInstanceResponse, <-chan error)
- func (client *Client) RevokePermission(request *RevokePermissionRequest) (response *RevokePermissionResponse, err error)
- func (client *Client) RevokePermissionWithCallback(request *RevokePermissionRequest, ...) <-chan int
- func (client *Client) RevokePermissionWithChan(request *RevokePermissionRequest) (<-chan *RevokePermissionResponse, <-chan error)
- func (client *Client) SetJobInstanceSuccess(request *SetJobInstanceSuccessRequest) (response *SetJobInstanceSuccessResponse, err error)
- func (client *Client) SetJobInstanceSuccessWithCallback(request *SetJobInstanceSuccessRequest, ...) <-chan int
- func (client *Client) SetJobInstanceSuccessWithChan(request *SetJobInstanceSuccessRequest) (<-chan *SetJobInstanceSuccessResponse, <-chan error)
- func (client *Client) SetWfInstanceSuccess(request *SetWfInstanceSuccessRequest) (response *SetWfInstanceSuccessResponse, err error)
- func (client *Client) SetWfInstanceSuccessWithCallback(request *SetWfInstanceSuccessRequest, ...) <-chan int
- func (client *Client) SetWfInstanceSuccessWithChan(request *SetWfInstanceSuccessRequest) (<-chan *SetWfInstanceSuccessResponse, <-chan error)
- func (client *Client) StopInstance(request *StopInstanceRequest) (response *StopInstanceResponse, err error)
- func (client *Client) StopInstanceWithCallback(request *StopInstanceRequest, ...) <-chan int
- func (client *Client) StopInstanceWithChan(request *StopInstanceRequest) (<-chan *StopInstanceResponse, <-chan error)
- func (client *Client) UpdateAppGroup(request *UpdateAppGroupRequest) (response *UpdateAppGroupResponse, err error)
- func (client *Client) UpdateAppGroupWithCallback(request *UpdateAppGroupRequest, ...) <-chan int
- func (client *Client) UpdateAppGroupWithChan(request *UpdateAppGroupRequest) (<-chan *UpdateAppGroupResponse, <-chan error)
- func (client *Client) UpdateJob(request *UpdateJobRequest) (response *UpdateJobResponse, err error)
- func (client *Client) UpdateJobWithCallback(request *UpdateJobRequest, ...) <-chan int
- func (client *Client) UpdateJobWithChan(request *UpdateJobRequest) (<-chan *UpdateJobResponse, <-chan error)
- func (client *Client) UpdateWorkflow(request *UpdateWorkflowRequest) (response *UpdateWorkflowResponse, err error)
- func (client *Client) UpdateWorkflowDag(request *UpdateWorkflowDagRequest) (response *UpdateWorkflowDagResponse, err error)
- func (client *Client) UpdateWorkflowDagWithCallback(request *UpdateWorkflowDagRequest, ...) <-chan int
- func (client *Client) UpdateWorkflowDagWithChan(request *UpdateWorkflowDagRequest) (<-chan *UpdateWorkflowDagResponse, <-chan error)
- func (client *Client) UpdateWorkflowWithCallback(request *UpdateWorkflowRequest, ...) <-chan int
- func (client *Client) UpdateWorkflowWithChan(request *UpdateWorkflowRequest) (<-chan *UpdateWorkflowResponse, <-chan error)
- type ContactInfoInGetJobInfo
- type ContactInfoInListJobs
- type ContactInfoItem
- type CreateAppGroupRequest
- type CreateAppGroupResponse
- type CreateJobContactInfo
- type CreateJobRequest
- type CreateJobResponse
- type CreateNamespaceRequest
- type CreateNamespaceResponse
- type CreateRouteStrategyRequest
- type CreateRouteStrategyResponse
- type CreateWorkflowRequest
- type CreateWorkflowResponse
- type Data
- type DeleteAppGroupRequest
- type DeleteAppGroupResponse
- type DeleteJobRequest
- type DeleteJobResponse
- type DeleteRouteStrategyRequest
- type DeleteRouteStrategyResponse
- type DeleteWorkflowRequest
- type DeleteWorkflowResponse
- type DescribeRegionsRequest
- type DescribeRegionsResponse
- type DesignateWorkersRequest
- type DesignateWorkersResponse
- type DisableJobRequest
- type DisableJobResponse
- type DisableWorkflowRequest
- type DisableWorkflowResponse
- type Edge
- type EdgesInGetWorkFlow
- type EdgesInGetWorkflowInstance
- type EnableJobRequest
- type EnableJobResponse
- type EnableWorkflowRequest
- type EnableWorkflowResponse
- type ExecuteJobRequest
- type ExecuteJobResponse
- type ExecuteWorkflowRequest
- type ExecuteWorkflowResponse
- type GetAppGroupRequest
- type GetAppGroupResponse
- type GetJobInfoRequest
- type GetJobInfoResponse
- type GetJobInstanceListRequest
- type GetJobInstanceListResponse
- type GetJobInstanceRequest
- type GetJobInstanceResponse
- type GetLogRequest
- type GetLogResponse
- type GetOverviewRequest
- type GetOverviewResponse
- type GetWorkFlowRequest
- type GetWorkFlowResponse
- type GetWorkerListRequest
- type GetWorkerListResponse
- type GetWorkflowInstanceRequest
- type GetWorkflowInstanceResponse
- type GrantPermissionRequest
- type GrantPermissionResponse
- type Job
- type JobConfigInfo
- type JobInstanceDetail
- type JobInstanceDetails
- type JobInstanceDetailsItem
- type JobMonitorInfo
- type Jobs
- type ListGroupsRequest
- type ListGroupsResponse
- type ListJobsRequest
- type ListJobsResponse
- type ListNamespacesRequest
- type ListNamespacesResponse
- type ListWorkflowInstanceRequest
- type ListWorkflowInstanceResponse
- type Logs
- type MapTaskXAttrs
- type MonitorConfig
- type Namespace
- type Namespaces
- type Node
- type NodesInGetWorkFlow
- type NodesInGetWorkflowInstance
- type Region
- type Regions
- type RerunJobRequest
- type RerunJobResponse
- type RetryJobInstanceRequest
- type RetryJobInstanceResponse
- type RevokePermissionRequest
- type RevokePermissionResponse
- type SetJobInstanceSuccessRequest
- type SetJobInstanceSuccessResponse
- type SetWfInstanceSuccessRequest
- type SetWfInstanceSuccessResponse
- type StopInstanceRequest
- type StopInstanceResponse
- type TimeConfig
- type UpdateAppGroupRequest
- type UpdateAppGroupResponse
- type UpdateJobContactInfo
- type UpdateJobRequest
- type UpdateJobResponse
- type UpdateWorkflowDagRequest
- type UpdateWorkflowDagResponse
- type UpdateWorkflowRequest
- type UpdateWorkflowResponse
- type WfInstanceDag
- type WfInstanceInfo
- type WfInstanceInfos
- type WfInstanceInfosItem
- type WorkFlowInfo
- type WorkFlowNodeInfo
- type WorkerInfo
- type WorkerInfos
Constants ¶
This section is empty.
Variables ¶
var EndpointMap map[string]string
EndpointMap Endpoint Data
var EndpointType = "regional"
EndpointType regional or central
Functions ¶
func SetClientProperty ¶
SetClientProperty Set Property by Reflect
func SetEndpointDataToClient ¶
func SetEndpointDataToClient(client *Client)
SetEndpointDataToClient Set EndpointMap and ENdpointType
Types ¶
type AppGroup ¶ added in v1.61.948
type AppGroup struct { AppGroupId int64 `json:"AppGroupId" xml:"AppGroupId"` AppName string `json:"AppName" xml:"AppName"` AppKey string `json:"AppKey" xml:"AppKey"` Description string `json:"Description" xml:"Description"` GroupId string `json:"GroupId" xml:"GroupId"` Xattrs string `json:"Xattrs" xml:"Xattrs"` AppVersion int `json:"AppVersion" xml:"AppVersion"` }
AppGroup is a nested struct in schedulerx2 response
type AppGroups ¶ added in v1.61.948
type AppGroups struct {
AppGroup []AppGroup `json:"AppGroup" xml:"AppGroup"`
}
AppGroups is a nested struct in schedulerx2 response
type BatchDeleteJobsRequest ¶ added in v1.61.948
type BatchDeleteJobsRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobIdList *[]string `position:"Body" name:"JobIdList" type:"Repeated"` Namespace string `position:"Query" name:"Namespace"` }
BatchDeleteJobsRequest is the request struct for api BatchDeleteJobs
func CreateBatchDeleteJobsRequest ¶ added in v1.61.948
func CreateBatchDeleteJobsRequest() (request *BatchDeleteJobsRequest)
CreateBatchDeleteJobsRequest creates a request to invoke BatchDeleteJobs API
type BatchDeleteJobsResponse ¶ added in v1.61.948
type BatchDeleteJobsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
BatchDeleteJobsResponse is the response struct for api BatchDeleteJobs
func CreateBatchDeleteJobsResponse ¶ added in v1.61.948
func CreateBatchDeleteJobsResponse() (response *BatchDeleteJobsResponse)
CreateBatchDeleteJobsResponse creates a response to parse from BatchDeleteJobs response
type BatchDeleteRouteStrategyRequest ¶ added in v1.62.177
type BatchDeleteRouteStrategyRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` JobIdList *[]string `position:"Body" name:"JobIdList" type:"Repeated"` Namespace string `position:"Query" name:"Namespace"` StrategyIdList *[]string `position:"Body" name:"StrategyIdList" type:"Repeated"` }
BatchDeleteRouteStrategyRequest is the request struct for api BatchDeleteRouteStrategy
func CreateBatchDeleteRouteStrategyRequest ¶ added in v1.62.177
func CreateBatchDeleteRouteStrategyRequest() (request *BatchDeleteRouteStrategyRequest)
CreateBatchDeleteRouteStrategyRequest creates a request to invoke BatchDeleteRouteStrategy API
type BatchDeleteRouteStrategyResponse ¶ added in v1.62.177
type BatchDeleteRouteStrategyResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` }
BatchDeleteRouteStrategyResponse is the response struct for api BatchDeleteRouteStrategy
func CreateBatchDeleteRouteStrategyResponse ¶ added in v1.62.177
func CreateBatchDeleteRouteStrategyResponse() (response *BatchDeleteRouteStrategyResponse)
CreateBatchDeleteRouteStrategyResponse creates a response to parse from BatchDeleteRouteStrategy response
type BatchDisableJobsRequest ¶ added in v1.61.948
type BatchDisableJobsRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobIdList *[]string `position:"Body" name:"JobIdList" type:"Repeated"` Namespace string `position:"Query" name:"Namespace"` }
BatchDisableJobsRequest is the request struct for api BatchDisableJobs
func CreateBatchDisableJobsRequest ¶ added in v1.61.948
func CreateBatchDisableJobsRequest() (request *BatchDisableJobsRequest)
CreateBatchDisableJobsRequest creates a request to invoke BatchDisableJobs API
type BatchDisableJobsResponse ¶ added in v1.61.948
type BatchDisableJobsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
BatchDisableJobsResponse is the response struct for api BatchDisableJobs
func CreateBatchDisableJobsResponse ¶ added in v1.61.948
func CreateBatchDisableJobsResponse() (response *BatchDisableJobsResponse)
CreateBatchDisableJobsResponse creates a response to parse from BatchDisableJobs response
type BatchEnableJobsRequest ¶ added in v1.61.948
type BatchEnableJobsRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobIdList *[]string `position:"Body" name:"JobIdList" type:"Repeated"` Namespace string `position:"Query" name:"Namespace"` }
BatchEnableJobsRequest is the request struct for api BatchEnableJobs
func CreateBatchEnableJobsRequest ¶ added in v1.61.948
func CreateBatchEnableJobsRequest() (request *BatchEnableJobsRequest)
CreateBatchEnableJobsRequest creates a request to invoke BatchEnableJobs API
type BatchEnableJobsResponse ¶ added in v1.61.948
type BatchEnableJobsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
BatchEnableJobsResponse is the response struct for api BatchEnableJobs
func CreateBatchEnableJobsResponse ¶ added in v1.61.948
func CreateBatchEnableJobsResponse() (response *BatchEnableJobsResponse)
CreateBatchEnableJobsResponse creates a response to parse from BatchEnableJobs response
type Client ¶
Client is the sdk client struct, each func corresponds to an OpenAPI
func NewClientWithAccessKey ¶
func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithEcsRamRole ¶
NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithOptions ¶
func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client
func NewClientWithProvider ¶
func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArn ¶
func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArnAndPolicy ¶
func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRsaKeyPair ¶
func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithStsToken ¶
func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func (*Client) BatchDeleteJobs ¶ added in v1.61.948
func (client *Client) BatchDeleteJobs(request *BatchDeleteJobsRequest) (response *BatchDeleteJobsResponse, err error)
BatchDeleteJobs invokes the schedulerx2.BatchDeleteJobs API synchronously
func (*Client) BatchDeleteJobsWithCallback ¶ added in v1.61.948
func (client *Client) BatchDeleteJobsWithCallback(request *BatchDeleteJobsRequest, callback func(response *BatchDeleteJobsResponse, err error)) <-chan int
BatchDeleteJobsWithCallback invokes the schedulerx2.BatchDeleteJobs API asynchronously
func (*Client) BatchDeleteJobsWithChan ¶ added in v1.61.948
func (client *Client) BatchDeleteJobsWithChan(request *BatchDeleteJobsRequest) (<-chan *BatchDeleteJobsResponse, <-chan error)
BatchDeleteJobsWithChan invokes the schedulerx2.BatchDeleteJobs API asynchronously
func (*Client) BatchDeleteRouteStrategy ¶ added in v1.62.177
func (client *Client) BatchDeleteRouteStrategy(request *BatchDeleteRouteStrategyRequest) (response *BatchDeleteRouteStrategyResponse, err error)
BatchDeleteRouteStrategy invokes the schedulerx2.BatchDeleteRouteStrategy API synchronously
func (*Client) BatchDeleteRouteStrategyWithCallback ¶ added in v1.62.177
func (client *Client) BatchDeleteRouteStrategyWithCallback(request *BatchDeleteRouteStrategyRequest, callback func(response *BatchDeleteRouteStrategyResponse, err error)) <-chan int
BatchDeleteRouteStrategyWithCallback invokes the schedulerx2.BatchDeleteRouteStrategy API asynchronously
func (*Client) BatchDeleteRouteStrategyWithChan ¶ added in v1.62.177
func (client *Client) BatchDeleteRouteStrategyWithChan(request *BatchDeleteRouteStrategyRequest) (<-chan *BatchDeleteRouteStrategyResponse, <-chan error)
BatchDeleteRouteStrategyWithChan invokes the schedulerx2.BatchDeleteRouteStrategy API asynchronously
func (*Client) BatchDisableJobs ¶ added in v1.61.948
func (client *Client) BatchDisableJobs(request *BatchDisableJobsRequest) (response *BatchDisableJobsResponse, err error)
BatchDisableJobs invokes the schedulerx2.BatchDisableJobs API synchronously
func (*Client) BatchDisableJobsWithCallback ¶ added in v1.61.948
func (client *Client) BatchDisableJobsWithCallback(request *BatchDisableJobsRequest, callback func(response *BatchDisableJobsResponse, err error)) <-chan int
BatchDisableJobsWithCallback invokes the schedulerx2.BatchDisableJobs API asynchronously
func (*Client) BatchDisableJobsWithChan ¶ added in v1.61.948
func (client *Client) BatchDisableJobsWithChan(request *BatchDisableJobsRequest) (<-chan *BatchDisableJobsResponse, <-chan error)
BatchDisableJobsWithChan invokes the schedulerx2.BatchDisableJobs API asynchronously
func (*Client) BatchEnableJobs ¶ added in v1.61.948
func (client *Client) BatchEnableJobs(request *BatchEnableJobsRequest) (response *BatchEnableJobsResponse, err error)
BatchEnableJobs invokes the schedulerx2.BatchEnableJobs API synchronously
func (*Client) BatchEnableJobsWithCallback ¶ added in v1.61.948
func (client *Client) BatchEnableJobsWithCallback(request *BatchEnableJobsRequest, callback func(response *BatchEnableJobsResponse, err error)) <-chan int
BatchEnableJobsWithCallback invokes the schedulerx2.BatchEnableJobs API asynchronously
func (*Client) BatchEnableJobsWithChan ¶ added in v1.61.948
func (client *Client) BatchEnableJobsWithChan(request *BatchEnableJobsRequest) (<-chan *BatchEnableJobsResponse, <-chan error)
BatchEnableJobsWithChan invokes the schedulerx2.BatchEnableJobs API asynchronously
func (*Client) CreateAppGroup ¶
func (client *Client) CreateAppGroup(request *CreateAppGroupRequest) (response *CreateAppGroupResponse, err error)
CreateAppGroup invokes the schedulerx2.CreateAppGroup API synchronously
func (*Client) CreateAppGroupWithCallback ¶
func (client *Client) CreateAppGroupWithCallback(request *CreateAppGroupRequest, callback func(response *CreateAppGroupResponse, err error)) <-chan int
CreateAppGroupWithCallback invokes the schedulerx2.CreateAppGroup API asynchronously
func (*Client) CreateAppGroupWithChan ¶
func (client *Client) CreateAppGroupWithChan(request *CreateAppGroupRequest) (<-chan *CreateAppGroupResponse, <-chan error)
CreateAppGroupWithChan invokes the schedulerx2.CreateAppGroup API asynchronously
func (*Client) CreateJob ¶
func (client *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)
CreateJob invokes the schedulerx2.CreateJob API synchronously
func (*Client) CreateJobWithCallback ¶
func (client *Client) CreateJobWithCallback(request *CreateJobRequest, callback func(response *CreateJobResponse, err error)) <-chan int
CreateJobWithCallback invokes the schedulerx2.CreateJob API asynchronously
func (*Client) CreateJobWithChan ¶
func (client *Client) CreateJobWithChan(request *CreateJobRequest) (<-chan *CreateJobResponse, <-chan error)
CreateJobWithChan invokes the schedulerx2.CreateJob API asynchronously
func (*Client) CreateNamespace ¶ added in v1.61.1529
func (client *Client) CreateNamespace(request *CreateNamespaceRequest) (response *CreateNamespaceResponse, err error)
CreateNamespace invokes the schedulerx2.CreateNamespace API synchronously
func (*Client) CreateNamespaceWithCallback ¶ added in v1.61.1529
func (client *Client) CreateNamespaceWithCallback(request *CreateNamespaceRequest, callback func(response *CreateNamespaceResponse, err error)) <-chan int
CreateNamespaceWithCallback invokes the schedulerx2.CreateNamespace API asynchronously
func (*Client) CreateNamespaceWithChan ¶ added in v1.61.1529
func (client *Client) CreateNamespaceWithChan(request *CreateNamespaceRequest) (<-chan *CreateNamespaceResponse, <-chan error)
CreateNamespaceWithChan invokes the schedulerx2.CreateNamespace API asynchronously
func (*Client) CreateRouteStrategy ¶ added in v1.62.177
func (client *Client) CreateRouteStrategy(request *CreateRouteStrategyRequest) (response *CreateRouteStrategyResponse, err error)
CreateRouteStrategy invokes the schedulerx2.CreateRouteStrategy API synchronously
func (*Client) CreateRouteStrategyWithCallback ¶ added in v1.62.177
func (client *Client) CreateRouteStrategyWithCallback(request *CreateRouteStrategyRequest, callback func(response *CreateRouteStrategyResponse, err error)) <-chan int
CreateRouteStrategyWithCallback invokes the schedulerx2.CreateRouteStrategy API asynchronously
func (*Client) CreateRouteStrategyWithChan ¶ added in v1.62.177
func (client *Client) CreateRouteStrategyWithChan(request *CreateRouteStrategyRequest) (<-chan *CreateRouteStrategyResponse, <-chan error)
CreateRouteStrategyWithChan invokes the schedulerx2.CreateRouteStrategy API asynchronously
func (*Client) CreateWorkflow ¶ added in v1.62.160
func (client *Client) CreateWorkflow(request *CreateWorkflowRequest) (response *CreateWorkflowResponse, err error)
CreateWorkflow invokes the schedulerx2.CreateWorkflow API synchronously
func (*Client) CreateWorkflowWithCallback ¶ added in v1.62.160
func (client *Client) CreateWorkflowWithCallback(request *CreateWorkflowRequest, callback func(response *CreateWorkflowResponse, err error)) <-chan int
CreateWorkflowWithCallback invokes the schedulerx2.CreateWorkflow API asynchronously
func (*Client) CreateWorkflowWithChan ¶ added in v1.62.160
func (client *Client) CreateWorkflowWithChan(request *CreateWorkflowRequest) (<-chan *CreateWorkflowResponse, <-chan error)
CreateWorkflowWithChan invokes the schedulerx2.CreateWorkflow API asynchronously
func (*Client) DeleteAppGroup ¶ added in v1.62.177
func (client *Client) DeleteAppGroup(request *DeleteAppGroupRequest) (response *DeleteAppGroupResponse, err error)
DeleteAppGroup invokes the schedulerx2.DeleteAppGroup API synchronously
func (*Client) DeleteAppGroupWithCallback ¶ added in v1.62.177
func (client *Client) DeleteAppGroupWithCallback(request *DeleteAppGroupRequest, callback func(response *DeleteAppGroupResponse, err error)) <-chan int
DeleteAppGroupWithCallback invokes the schedulerx2.DeleteAppGroup API asynchronously
func (*Client) DeleteAppGroupWithChan ¶ added in v1.62.177
func (client *Client) DeleteAppGroupWithChan(request *DeleteAppGroupRequest) (<-chan *DeleteAppGroupResponse, <-chan error)
DeleteAppGroupWithChan invokes the schedulerx2.DeleteAppGroup API asynchronously
func (*Client) DeleteJob ¶
func (client *Client) DeleteJob(request *DeleteJobRequest) (response *DeleteJobResponse, err error)
DeleteJob invokes the schedulerx2.DeleteJob API synchronously
func (*Client) DeleteJobWithCallback ¶
func (client *Client) DeleteJobWithCallback(request *DeleteJobRequest, callback func(response *DeleteJobResponse, err error)) <-chan int
DeleteJobWithCallback invokes the schedulerx2.DeleteJob API asynchronously
func (*Client) DeleteJobWithChan ¶
func (client *Client) DeleteJobWithChan(request *DeleteJobRequest) (<-chan *DeleteJobResponse, <-chan error)
DeleteJobWithChan invokes the schedulerx2.DeleteJob API asynchronously
func (*Client) DeleteRouteStrategy ¶ added in v1.62.177
func (client *Client) DeleteRouteStrategy(request *DeleteRouteStrategyRequest) (response *DeleteRouteStrategyResponse, err error)
DeleteRouteStrategy invokes the schedulerx2.DeleteRouteStrategy API synchronously
func (*Client) DeleteRouteStrategyWithCallback ¶ added in v1.62.177
func (client *Client) DeleteRouteStrategyWithCallback(request *DeleteRouteStrategyRequest, callback func(response *DeleteRouteStrategyResponse, err error)) <-chan int
DeleteRouteStrategyWithCallback invokes the schedulerx2.DeleteRouteStrategy API asynchronously
func (*Client) DeleteRouteStrategyWithChan ¶ added in v1.62.177
func (client *Client) DeleteRouteStrategyWithChan(request *DeleteRouteStrategyRequest) (<-chan *DeleteRouteStrategyResponse, <-chan error)
DeleteRouteStrategyWithChan invokes the schedulerx2.DeleteRouteStrategy API asynchronously
func (*Client) DeleteWorkflow ¶
func (client *Client) DeleteWorkflow(request *DeleteWorkflowRequest) (response *DeleteWorkflowResponse, err error)
DeleteWorkflow invokes the schedulerx2.DeleteWorkflow API synchronously
func (*Client) DeleteWorkflowWithCallback ¶
func (client *Client) DeleteWorkflowWithCallback(request *DeleteWorkflowRequest, callback func(response *DeleteWorkflowResponse, err error)) <-chan int
DeleteWorkflowWithCallback invokes the schedulerx2.DeleteWorkflow API asynchronously
func (*Client) DeleteWorkflowWithChan ¶
func (client *Client) DeleteWorkflowWithChan(request *DeleteWorkflowRequest) (<-chan *DeleteWorkflowResponse, <-chan error)
DeleteWorkflowWithChan invokes the schedulerx2.DeleteWorkflow API asynchronously
func (*Client) DescribeRegions ¶
func (client *Client) DescribeRegions(request *DescribeRegionsRequest) (response *DescribeRegionsResponse, err error)
DescribeRegions invokes the schedulerx2.DescribeRegions API synchronously
func (*Client) DescribeRegionsWithCallback ¶
func (client *Client) DescribeRegionsWithCallback(request *DescribeRegionsRequest, callback func(response *DescribeRegionsResponse, err error)) <-chan int
DescribeRegionsWithCallback invokes the schedulerx2.DescribeRegions API asynchronously
func (*Client) DescribeRegionsWithChan ¶
func (client *Client) DescribeRegionsWithChan(request *DescribeRegionsRequest) (<-chan *DescribeRegionsResponse, <-chan error)
DescribeRegionsWithChan invokes the schedulerx2.DescribeRegions API asynchronously
func (*Client) DesignateWorkers ¶ added in v1.61.1394
func (client *Client) DesignateWorkers(request *DesignateWorkersRequest) (response *DesignateWorkersResponse, err error)
DesignateWorkers invokes the schedulerx2.DesignateWorkers API synchronously
func (*Client) DesignateWorkersWithCallback ¶ added in v1.61.1394
func (client *Client) DesignateWorkersWithCallback(request *DesignateWorkersRequest, callback func(response *DesignateWorkersResponse, err error)) <-chan int
DesignateWorkersWithCallback invokes the schedulerx2.DesignateWorkers API asynchronously
func (*Client) DesignateWorkersWithChan ¶ added in v1.61.1394
func (client *Client) DesignateWorkersWithChan(request *DesignateWorkersRequest) (<-chan *DesignateWorkersResponse, <-chan error)
DesignateWorkersWithChan invokes the schedulerx2.DesignateWorkers API asynchronously
func (*Client) DisableJob ¶
func (client *Client) DisableJob(request *DisableJobRequest) (response *DisableJobResponse, err error)
DisableJob invokes the schedulerx2.DisableJob API synchronously
func (*Client) DisableJobWithCallback ¶
func (client *Client) DisableJobWithCallback(request *DisableJobRequest, callback func(response *DisableJobResponse, err error)) <-chan int
DisableJobWithCallback invokes the schedulerx2.DisableJob API asynchronously
func (*Client) DisableJobWithChan ¶
func (client *Client) DisableJobWithChan(request *DisableJobRequest) (<-chan *DisableJobResponse, <-chan error)
DisableJobWithChan invokes the schedulerx2.DisableJob API asynchronously
func (*Client) DisableWorkflow ¶
func (client *Client) DisableWorkflow(request *DisableWorkflowRequest) (response *DisableWorkflowResponse, err error)
DisableWorkflow invokes the schedulerx2.DisableWorkflow API synchronously
func (*Client) DisableWorkflowWithCallback ¶
func (client *Client) DisableWorkflowWithCallback(request *DisableWorkflowRequest, callback func(response *DisableWorkflowResponse, err error)) <-chan int
DisableWorkflowWithCallback invokes the schedulerx2.DisableWorkflow API asynchronously
func (*Client) DisableWorkflowWithChan ¶
func (client *Client) DisableWorkflowWithChan(request *DisableWorkflowRequest) (<-chan *DisableWorkflowResponse, <-chan error)
DisableWorkflowWithChan invokes the schedulerx2.DisableWorkflow API asynchronously
func (*Client) EnableJob ¶
func (client *Client) EnableJob(request *EnableJobRequest) (response *EnableJobResponse, err error)
EnableJob invokes the schedulerx2.EnableJob API synchronously
func (*Client) EnableJobWithCallback ¶
func (client *Client) EnableJobWithCallback(request *EnableJobRequest, callback func(response *EnableJobResponse, err error)) <-chan int
EnableJobWithCallback invokes the schedulerx2.EnableJob API asynchronously
func (*Client) EnableJobWithChan ¶
func (client *Client) EnableJobWithChan(request *EnableJobRequest) (<-chan *EnableJobResponse, <-chan error)
EnableJobWithChan invokes the schedulerx2.EnableJob API asynchronously
func (*Client) EnableWorkflow ¶
func (client *Client) EnableWorkflow(request *EnableWorkflowRequest) (response *EnableWorkflowResponse, err error)
EnableWorkflow invokes the schedulerx2.EnableWorkflow API synchronously
func (*Client) EnableWorkflowWithCallback ¶
func (client *Client) EnableWorkflowWithCallback(request *EnableWorkflowRequest, callback func(response *EnableWorkflowResponse, err error)) <-chan int
EnableWorkflowWithCallback invokes the schedulerx2.EnableWorkflow API asynchronously
func (*Client) EnableWorkflowWithChan ¶
func (client *Client) EnableWorkflowWithChan(request *EnableWorkflowRequest) (<-chan *EnableWorkflowResponse, <-chan error)
EnableWorkflowWithChan invokes the schedulerx2.EnableWorkflow API asynchronously
func (*Client) ExecuteJob ¶
func (client *Client) ExecuteJob(request *ExecuteJobRequest) (response *ExecuteJobResponse, err error)
ExecuteJob invokes the schedulerx2.ExecuteJob API synchronously
func (*Client) ExecuteJobWithCallback ¶
func (client *Client) ExecuteJobWithCallback(request *ExecuteJobRequest, callback func(response *ExecuteJobResponse, err error)) <-chan int
ExecuteJobWithCallback invokes the schedulerx2.ExecuteJob API asynchronously
func (*Client) ExecuteJobWithChan ¶
func (client *Client) ExecuteJobWithChan(request *ExecuteJobRequest) (<-chan *ExecuteJobResponse, <-chan error)
ExecuteJobWithChan invokes the schedulerx2.ExecuteJob API asynchronously
func (*Client) ExecuteWorkflow ¶
func (client *Client) ExecuteWorkflow(request *ExecuteWorkflowRequest) (response *ExecuteWorkflowResponse, err error)
ExecuteWorkflow invokes the schedulerx2.ExecuteWorkflow API synchronously
func (*Client) ExecuteWorkflowWithCallback ¶
func (client *Client) ExecuteWorkflowWithCallback(request *ExecuteWorkflowRequest, callback func(response *ExecuteWorkflowResponse, err error)) <-chan int
ExecuteWorkflowWithCallback invokes the schedulerx2.ExecuteWorkflow API asynchronously
func (*Client) ExecuteWorkflowWithChan ¶
func (client *Client) ExecuteWorkflowWithChan(request *ExecuteWorkflowRequest) (<-chan *ExecuteWorkflowResponse, <-chan error)
ExecuteWorkflowWithChan invokes the schedulerx2.ExecuteWorkflow API asynchronously
func (*Client) GetAppGroup ¶ added in v1.62.177
func (client *Client) GetAppGroup(request *GetAppGroupRequest) (response *GetAppGroupResponse, err error)
GetAppGroup invokes the schedulerx2.GetAppGroup API synchronously
func (*Client) GetAppGroupWithCallback ¶ added in v1.62.177
func (client *Client) GetAppGroupWithCallback(request *GetAppGroupRequest, callback func(response *GetAppGroupResponse, err error)) <-chan int
GetAppGroupWithCallback invokes the schedulerx2.GetAppGroup API asynchronously
func (*Client) GetAppGroupWithChan ¶ added in v1.62.177
func (client *Client) GetAppGroupWithChan(request *GetAppGroupRequest) (<-chan *GetAppGroupResponse, <-chan error)
GetAppGroupWithChan invokes the schedulerx2.GetAppGroup API asynchronously
func (*Client) GetJobInfo ¶
func (client *Client) GetJobInfo(request *GetJobInfoRequest) (response *GetJobInfoResponse, err error)
GetJobInfo invokes the schedulerx2.GetJobInfo API synchronously
func (*Client) GetJobInfoWithCallback ¶
func (client *Client) GetJobInfoWithCallback(request *GetJobInfoRequest, callback func(response *GetJobInfoResponse, err error)) <-chan int
GetJobInfoWithCallback invokes the schedulerx2.GetJobInfo API asynchronously
func (*Client) GetJobInfoWithChan ¶
func (client *Client) GetJobInfoWithChan(request *GetJobInfoRequest) (<-chan *GetJobInfoResponse, <-chan error)
GetJobInfoWithChan invokes the schedulerx2.GetJobInfo API asynchronously
func (*Client) GetJobInstance ¶
func (client *Client) GetJobInstance(request *GetJobInstanceRequest) (response *GetJobInstanceResponse, err error)
GetJobInstance invokes the schedulerx2.GetJobInstance API synchronously
func (*Client) GetJobInstanceList ¶
func (client *Client) GetJobInstanceList(request *GetJobInstanceListRequest) (response *GetJobInstanceListResponse, err error)
GetJobInstanceList invokes the schedulerx2.GetJobInstanceList API synchronously
func (*Client) GetJobInstanceListWithCallback ¶
func (client *Client) GetJobInstanceListWithCallback(request *GetJobInstanceListRequest, callback func(response *GetJobInstanceListResponse, err error)) <-chan int
GetJobInstanceListWithCallback invokes the schedulerx2.GetJobInstanceList API asynchronously
func (*Client) GetJobInstanceListWithChan ¶
func (client *Client) GetJobInstanceListWithChan(request *GetJobInstanceListRequest) (<-chan *GetJobInstanceListResponse, <-chan error)
GetJobInstanceListWithChan invokes the schedulerx2.GetJobInstanceList API asynchronously
func (*Client) GetJobInstanceWithCallback ¶
func (client *Client) GetJobInstanceWithCallback(request *GetJobInstanceRequest, callback func(response *GetJobInstanceResponse, err error)) <-chan int
GetJobInstanceWithCallback invokes the schedulerx2.GetJobInstance API asynchronously
func (*Client) GetJobInstanceWithChan ¶
func (client *Client) GetJobInstanceWithChan(request *GetJobInstanceRequest) (<-chan *GetJobInstanceResponse, <-chan error)
GetJobInstanceWithChan invokes the schedulerx2.GetJobInstance API asynchronously
func (*Client) GetLog ¶ added in v1.62.160
func (client *Client) GetLog(request *GetLogRequest) (response *GetLogResponse, err error)
GetLog invokes the schedulerx2.GetLog API synchronously
func (*Client) GetLogWithCallback ¶ added in v1.62.160
func (client *Client) GetLogWithCallback(request *GetLogRequest, callback func(response *GetLogResponse, err error)) <-chan int
GetLogWithCallback invokes the schedulerx2.GetLog API asynchronously
func (*Client) GetLogWithChan ¶ added in v1.62.160
func (client *Client) GetLogWithChan(request *GetLogRequest) (<-chan *GetLogResponse, <-chan error)
GetLogWithChan invokes the schedulerx2.GetLog API asynchronously
func (*Client) GetOverview ¶ added in v1.62.359
func (client *Client) GetOverview(request *GetOverviewRequest) (response *GetOverviewResponse, err error)
GetOverview invokes the schedulerx2.GetOverview API synchronously
func (*Client) GetOverviewWithCallback ¶ added in v1.62.359
func (client *Client) GetOverviewWithCallback(request *GetOverviewRequest, callback func(response *GetOverviewResponse, err error)) <-chan int
GetOverviewWithCallback invokes the schedulerx2.GetOverview API asynchronously
func (*Client) GetOverviewWithChan ¶ added in v1.62.359
func (client *Client) GetOverviewWithChan(request *GetOverviewRequest) (<-chan *GetOverviewResponse, <-chan error)
GetOverviewWithChan invokes the schedulerx2.GetOverview API asynchronously
func (*Client) GetWorkFlow ¶ added in v1.61.1394
func (client *Client) GetWorkFlow(request *GetWorkFlowRequest) (response *GetWorkFlowResponse, err error)
GetWorkFlow invokes the schedulerx2.GetWorkFlow API synchronously
func (*Client) GetWorkFlowWithCallback ¶ added in v1.61.1394
func (client *Client) GetWorkFlowWithCallback(request *GetWorkFlowRequest, callback func(response *GetWorkFlowResponse, err error)) <-chan int
GetWorkFlowWithCallback invokes the schedulerx2.GetWorkFlow API asynchronously
func (*Client) GetWorkFlowWithChan ¶ added in v1.61.1394
func (client *Client) GetWorkFlowWithChan(request *GetWorkFlowRequest) (<-chan *GetWorkFlowResponse, <-chan error)
GetWorkFlowWithChan invokes the schedulerx2.GetWorkFlow API asynchronously
func (*Client) GetWorkerList ¶ added in v1.61.1420
func (client *Client) GetWorkerList(request *GetWorkerListRequest) (response *GetWorkerListResponse, err error)
GetWorkerList invokes the schedulerx2.GetWorkerList API synchronously
func (*Client) GetWorkerListWithCallback ¶ added in v1.61.1420
func (client *Client) GetWorkerListWithCallback(request *GetWorkerListRequest, callback func(response *GetWorkerListResponse, err error)) <-chan int
GetWorkerListWithCallback invokes the schedulerx2.GetWorkerList API asynchronously
func (*Client) GetWorkerListWithChan ¶ added in v1.61.1420
func (client *Client) GetWorkerListWithChan(request *GetWorkerListRequest) (<-chan *GetWorkerListResponse, <-chan error)
GetWorkerListWithChan invokes the schedulerx2.GetWorkerList API asynchronously
func (*Client) GetWorkflowInstance ¶ added in v1.62.160
func (client *Client) GetWorkflowInstance(request *GetWorkflowInstanceRequest) (response *GetWorkflowInstanceResponse, err error)
GetWorkflowInstance invokes the schedulerx2.GetWorkflowInstance API synchronously
func (*Client) GetWorkflowInstanceWithCallback ¶ added in v1.62.160
func (client *Client) GetWorkflowInstanceWithCallback(request *GetWorkflowInstanceRequest, callback func(response *GetWorkflowInstanceResponse, err error)) <-chan int
GetWorkflowInstanceWithCallback invokes the schedulerx2.GetWorkflowInstance API asynchronously
func (*Client) GetWorkflowInstanceWithChan ¶ added in v1.62.160
func (client *Client) GetWorkflowInstanceWithChan(request *GetWorkflowInstanceRequest) (<-chan *GetWorkflowInstanceResponse, <-chan error)
GetWorkflowInstanceWithChan invokes the schedulerx2.GetWorkflowInstance API asynchronously
func (*Client) GrantPermission ¶
func (client *Client) GrantPermission(request *GrantPermissionRequest) (response *GrantPermissionResponse, err error)
GrantPermission invokes the schedulerx2.GrantPermission API synchronously
func (*Client) GrantPermissionWithCallback ¶
func (client *Client) GrantPermissionWithCallback(request *GrantPermissionRequest, callback func(response *GrantPermissionResponse, err error)) <-chan int
GrantPermissionWithCallback invokes the schedulerx2.GrantPermission API asynchronously
func (*Client) GrantPermissionWithChan ¶
func (client *Client) GrantPermissionWithChan(request *GrantPermissionRequest) (<-chan *GrantPermissionResponse, <-chan error)
GrantPermissionWithChan invokes the schedulerx2.GrantPermission API asynchronously
func (*Client) ListGroups ¶ added in v1.61.948
func (client *Client) ListGroups(request *ListGroupsRequest) (response *ListGroupsResponse, err error)
ListGroups invokes the schedulerx2.ListGroups API synchronously
func (*Client) ListGroupsWithCallback ¶ added in v1.61.948
func (client *Client) ListGroupsWithCallback(request *ListGroupsRequest, callback func(response *ListGroupsResponse, err error)) <-chan int
ListGroupsWithCallback invokes the schedulerx2.ListGroups API asynchronously
func (*Client) ListGroupsWithChan ¶ added in v1.61.948
func (client *Client) ListGroupsWithChan(request *ListGroupsRequest) (<-chan *ListGroupsResponse, <-chan error)
ListGroupsWithChan invokes the schedulerx2.ListGroups API asynchronously
func (*Client) ListJobs ¶ added in v1.61.948
func (client *Client) ListJobs(request *ListJobsRequest) (response *ListJobsResponse, err error)
ListJobs invokes the schedulerx2.ListJobs API synchronously
func (*Client) ListJobsWithCallback ¶ added in v1.61.948
func (client *Client) ListJobsWithCallback(request *ListJobsRequest, callback func(response *ListJobsResponse, err error)) <-chan int
ListJobsWithCallback invokes the schedulerx2.ListJobs API asynchronously
func (*Client) ListJobsWithChan ¶ added in v1.61.948
func (client *Client) ListJobsWithChan(request *ListJobsRequest) (<-chan *ListJobsResponse, <-chan error)
ListJobsWithChan invokes the schedulerx2.ListJobs API asynchronously
func (*Client) ListNamespaces ¶ added in v1.61.948
func (client *Client) ListNamespaces(request *ListNamespacesRequest) (response *ListNamespacesResponse, err error)
ListNamespaces invokes the schedulerx2.ListNamespaces API synchronously
func (*Client) ListNamespacesWithCallback ¶ added in v1.61.948
func (client *Client) ListNamespacesWithCallback(request *ListNamespacesRequest, callback func(response *ListNamespacesResponse, err error)) <-chan int
ListNamespacesWithCallback invokes the schedulerx2.ListNamespaces API asynchronously
func (*Client) ListNamespacesWithChan ¶ added in v1.61.948
func (client *Client) ListNamespacesWithChan(request *ListNamespacesRequest) (<-chan *ListNamespacesResponse, <-chan error)
ListNamespacesWithChan invokes the schedulerx2.ListNamespaces API asynchronously
func (*Client) ListWorkflowInstance ¶ added in v1.62.160
func (client *Client) ListWorkflowInstance(request *ListWorkflowInstanceRequest) (response *ListWorkflowInstanceResponse, err error)
ListWorkflowInstance invokes the schedulerx2.ListWorkflowInstance API synchronously
func (*Client) ListWorkflowInstanceWithCallback ¶ added in v1.62.160
func (client *Client) ListWorkflowInstanceWithCallback(request *ListWorkflowInstanceRequest, callback func(response *ListWorkflowInstanceResponse, err error)) <-chan int
ListWorkflowInstanceWithCallback invokes the schedulerx2.ListWorkflowInstance API asynchronously
func (*Client) ListWorkflowInstanceWithChan ¶ added in v1.62.160
func (client *Client) ListWorkflowInstanceWithChan(request *ListWorkflowInstanceRequest) (<-chan *ListWorkflowInstanceResponse, <-chan error)
ListWorkflowInstanceWithChan invokes the schedulerx2.ListWorkflowInstance API asynchronously
func (*Client) RerunJob ¶ added in v1.62.160
func (client *Client) RerunJob(request *RerunJobRequest) (response *RerunJobResponse, err error)
RerunJob invokes the schedulerx2.RerunJob API synchronously
func (*Client) RerunJobWithCallback ¶ added in v1.62.160
func (client *Client) RerunJobWithCallback(request *RerunJobRequest, callback func(response *RerunJobResponse, err error)) <-chan int
RerunJobWithCallback invokes the schedulerx2.RerunJob API asynchronously
func (*Client) RerunJobWithChan ¶ added in v1.62.160
func (client *Client) RerunJobWithChan(request *RerunJobRequest) (<-chan *RerunJobResponse, <-chan error)
RerunJobWithChan invokes the schedulerx2.RerunJob API asynchronously
func (*Client) RetryJobInstance ¶ added in v1.62.160
func (client *Client) RetryJobInstance(request *RetryJobInstanceRequest) (response *RetryJobInstanceResponse, err error)
RetryJobInstance invokes the schedulerx2.RetryJobInstance API synchronously
func (*Client) RetryJobInstanceWithCallback ¶ added in v1.62.160
func (client *Client) RetryJobInstanceWithCallback(request *RetryJobInstanceRequest, callback func(response *RetryJobInstanceResponse, err error)) <-chan int
RetryJobInstanceWithCallback invokes the schedulerx2.RetryJobInstance API asynchronously
func (*Client) RetryJobInstanceWithChan ¶ added in v1.62.160
func (client *Client) RetryJobInstanceWithChan(request *RetryJobInstanceRequest) (<-chan *RetryJobInstanceResponse, <-chan error)
RetryJobInstanceWithChan invokes the schedulerx2.RetryJobInstance API asynchronously
func (*Client) RevokePermission ¶
func (client *Client) RevokePermission(request *RevokePermissionRequest) (response *RevokePermissionResponse, err error)
RevokePermission invokes the schedulerx2.RevokePermission API synchronously
func (*Client) RevokePermissionWithCallback ¶
func (client *Client) RevokePermissionWithCallback(request *RevokePermissionRequest, callback func(response *RevokePermissionResponse, err error)) <-chan int
RevokePermissionWithCallback invokes the schedulerx2.RevokePermission API asynchronously
func (*Client) RevokePermissionWithChan ¶
func (client *Client) RevokePermissionWithChan(request *RevokePermissionRequest) (<-chan *RevokePermissionResponse, <-chan error)
RevokePermissionWithChan invokes the schedulerx2.RevokePermission API asynchronously
func (*Client) SetJobInstanceSuccess ¶ added in v1.62.160
func (client *Client) SetJobInstanceSuccess(request *SetJobInstanceSuccessRequest) (response *SetJobInstanceSuccessResponse, err error)
SetJobInstanceSuccess invokes the schedulerx2.SetJobInstanceSuccess API synchronously
func (*Client) SetJobInstanceSuccessWithCallback ¶ added in v1.62.160
func (client *Client) SetJobInstanceSuccessWithCallback(request *SetJobInstanceSuccessRequest, callback func(response *SetJobInstanceSuccessResponse, err error)) <-chan int
SetJobInstanceSuccessWithCallback invokes the schedulerx2.SetJobInstanceSuccess API asynchronously
func (*Client) SetJobInstanceSuccessWithChan ¶ added in v1.62.160
func (client *Client) SetJobInstanceSuccessWithChan(request *SetJobInstanceSuccessRequest) (<-chan *SetJobInstanceSuccessResponse, <-chan error)
SetJobInstanceSuccessWithChan invokes the schedulerx2.SetJobInstanceSuccess API asynchronously
func (*Client) SetWfInstanceSuccess ¶ added in v1.62.160
func (client *Client) SetWfInstanceSuccess(request *SetWfInstanceSuccessRequest) (response *SetWfInstanceSuccessResponse, err error)
SetWfInstanceSuccess invokes the schedulerx2.SetWfInstanceSuccess API synchronously
func (*Client) SetWfInstanceSuccessWithCallback ¶ added in v1.62.160
func (client *Client) SetWfInstanceSuccessWithCallback(request *SetWfInstanceSuccessRequest, callback func(response *SetWfInstanceSuccessResponse, err error)) <-chan int
SetWfInstanceSuccessWithCallback invokes the schedulerx2.SetWfInstanceSuccess API asynchronously
func (*Client) SetWfInstanceSuccessWithChan ¶ added in v1.62.160
func (client *Client) SetWfInstanceSuccessWithChan(request *SetWfInstanceSuccessRequest) (<-chan *SetWfInstanceSuccessResponse, <-chan error)
SetWfInstanceSuccessWithChan invokes the schedulerx2.SetWfInstanceSuccess API asynchronously
func (*Client) StopInstance ¶
func (client *Client) StopInstance(request *StopInstanceRequest) (response *StopInstanceResponse, err error)
StopInstance invokes the schedulerx2.StopInstance API synchronously
func (*Client) StopInstanceWithCallback ¶
func (client *Client) StopInstanceWithCallback(request *StopInstanceRequest, callback func(response *StopInstanceResponse, err error)) <-chan int
StopInstanceWithCallback invokes the schedulerx2.StopInstance API asynchronously
func (*Client) StopInstanceWithChan ¶
func (client *Client) StopInstanceWithChan(request *StopInstanceRequest) (<-chan *StopInstanceResponse, <-chan error)
StopInstanceWithChan invokes the schedulerx2.StopInstance API asynchronously
func (*Client) UpdateAppGroup ¶ added in v1.62.177
func (client *Client) UpdateAppGroup(request *UpdateAppGroupRequest) (response *UpdateAppGroupResponse, err error)
UpdateAppGroup invokes the schedulerx2.UpdateAppGroup API synchronously
func (*Client) UpdateAppGroupWithCallback ¶ added in v1.62.177
func (client *Client) UpdateAppGroupWithCallback(request *UpdateAppGroupRequest, callback func(response *UpdateAppGroupResponse, err error)) <-chan int
UpdateAppGroupWithCallback invokes the schedulerx2.UpdateAppGroup API asynchronously
func (*Client) UpdateAppGroupWithChan ¶ added in v1.62.177
func (client *Client) UpdateAppGroupWithChan(request *UpdateAppGroupRequest) (<-chan *UpdateAppGroupResponse, <-chan error)
UpdateAppGroupWithChan invokes the schedulerx2.UpdateAppGroup API asynchronously
func (*Client) UpdateJob ¶
func (client *Client) UpdateJob(request *UpdateJobRequest) (response *UpdateJobResponse, err error)
UpdateJob invokes the schedulerx2.UpdateJob API synchronously
func (*Client) UpdateJobWithCallback ¶
func (client *Client) UpdateJobWithCallback(request *UpdateJobRequest, callback func(response *UpdateJobResponse, err error)) <-chan int
UpdateJobWithCallback invokes the schedulerx2.UpdateJob API asynchronously
func (*Client) UpdateJobWithChan ¶
func (client *Client) UpdateJobWithChan(request *UpdateJobRequest) (<-chan *UpdateJobResponse, <-chan error)
UpdateJobWithChan invokes the schedulerx2.UpdateJob API asynchronously
func (*Client) UpdateWorkflow ¶ added in v1.62.160
func (client *Client) UpdateWorkflow(request *UpdateWorkflowRequest) (response *UpdateWorkflowResponse, err error)
UpdateWorkflow invokes the schedulerx2.UpdateWorkflow API synchronously
func (*Client) UpdateWorkflowDag ¶ added in v1.62.160
func (client *Client) UpdateWorkflowDag(request *UpdateWorkflowDagRequest) (response *UpdateWorkflowDagResponse, err error)
UpdateWorkflowDag invokes the schedulerx2.UpdateWorkflowDag API synchronously
func (*Client) UpdateWorkflowDagWithCallback ¶ added in v1.62.160
func (client *Client) UpdateWorkflowDagWithCallback(request *UpdateWorkflowDagRequest, callback func(response *UpdateWorkflowDagResponse, err error)) <-chan int
UpdateWorkflowDagWithCallback invokes the schedulerx2.UpdateWorkflowDag API asynchronously
func (*Client) UpdateWorkflowDagWithChan ¶ added in v1.62.160
func (client *Client) UpdateWorkflowDagWithChan(request *UpdateWorkflowDagRequest) (<-chan *UpdateWorkflowDagResponse, <-chan error)
UpdateWorkflowDagWithChan invokes the schedulerx2.UpdateWorkflowDag API asynchronously
func (*Client) UpdateWorkflowWithCallback ¶ added in v1.62.160
func (client *Client) UpdateWorkflowWithCallback(request *UpdateWorkflowRequest, callback func(response *UpdateWorkflowResponse, err error)) <-chan int
UpdateWorkflowWithCallback invokes the schedulerx2.UpdateWorkflow API asynchronously
func (*Client) UpdateWorkflowWithChan ¶ added in v1.62.160
func (client *Client) UpdateWorkflowWithChan(request *UpdateWorkflowRequest) (<-chan *UpdateWorkflowResponse, <-chan error)
UpdateWorkflowWithChan invokes the schedulerx2.UpdateWorkflow API asynchronously
type ContactInfoInGetJobInfo ¶ added in v1.61.948
type ContactInfoInGetJobInfo struct {
ContactInfoItem []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"`
}
ContactInfoInGetJobInfo is a nested struct in schedulerx2 response
type ContactInfoInListJobs ¶ added in v1.61.948
type ContactInfoInListJobs struct {
ContactInfoItem []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"`
}
ContactInfoInListJobs is a nested struct in schedulerx2 response
type ContactInfoItem ¶
type ContactInfoItem struct { UserMail string `json:"UserMail" xml:"UserMail"` UserPhone string `json:"UserPhone" xml:"UserPhone"` UserName string `json:"UserName" xml:"UserName"` Ding string `json:"Ding" xml:"Ding"` }
ContactInfoItem is a nested struct in schedulerx2 response
type CreateAppGroupRequest ¶
type CreateAppGroupRequest struct { *requests.RpcRequest NamespaceName string `position:"Query" name:"NamespaceName"` NamespaceSource string `position:"Query" name:"NamespaceSource"` ScheduleBusyWorkers requests.Boolean `position:"Query" name:"ScheduleBusyWorkers"` Description string `position:"Query" name:"Description"` AppName string `position:"Query" name:"AppName"` AlarmJson string `position:"Query" name:"AlarmJson"` MonitorContactsJson string `position:"Query" name:"MonitorContactsJson"` MaxJobs requests.Integer `position:"Query" name:"MaxJobs"` MetricsThresholdJson string `position:"Query" name:"MetricsThresholdJson"` GroupId string `position:"Query" name:"GroupId"` AppType requests.Integer `position:"Query" name:"AppType"` AppVersion requests.Integer `position:"Query" name:"AppVersion"` MonitorConfigJson string `position:"Query" name:"MonitorConfigJson"` Namespace string `position:"Query" name:"Namespace"` Xattrs string `position:"Query" name:"Xattrs"` EnableLog requests.Boolean `position:"Query" name:"EnableLog"` AppKey string `position:"Query" name:"AppKey"` }
CreateAppGroupRequest is the request struct for api CreateAppGroup
func CreateCreateAppGroupRequest ¶
func CreateCreateAppGroupRequest() (request *CreateAppGroupRequest)
CreateCreateAppGroupRequest creates a request to invoke CreateAppGroup API
type CreateAppGroupResponse ¶
type CreateAppGroupResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
CreateAppGroupResponse is the response struct for api CreateAppGroup
func CreateCreateAppGroupResponse ¶
func CreateCreateAppGroupResponse() (response *CreateAppGroupResponse)
CreateCreateAppGroupResponse creates a response to parse from CreateAppGroup response
type CreateJobContactInfo ¶
type CreateJobContactInfo struct { Ding string `name:"Ding"` UserPhone string `name:"UserPhone"` UserMail string `name:"UserMail"` UserName string `name:"UserName"` }
CreateJobContactInfo is a repeated param struct in CreateJobRequest
type CreateJobRequest ¶
type CreateJobRequest struct { *requests.RpcRequest AttemptInterval requests.Integer `position:"Body" name:"AttemptInterval"` FailTimes requests.Integer `position:"Body" name:"FailTimes"` ConsumerSize requests.Integer `position:"Body" name:"ConsumerSize"` JarUrl string `position:"Body" name:"JarUrl"` GroupId string `position:"Body" name:"GroupId"` DataOffset requests.Integer `position:"Body" name:"DataOffset"` TaskMaxAttempt requests.Integer `position:"Body" name:"TaskMaxAttempt"` DispatcherSize requests.Integer `position:"Body" name:"DispatcherSize"` JobType string `position:"Body" name:"JobType"` TaskAttemptInterval requests.Integer `position:"Body" name:"TaskAttemptInterval"` ExecuteMode string `position:"Body" name:"ExecuteMode"` TimeExpression string `position:"Body" name:"TimeExpression"` TimeoutEnable requests.Boolean `position:"Body" name:"TimeoutEnable"` ContactInfo *[]CreateJobContactInfo `position:"Body" name:"ContactInfo" type:"Repeated"` Name string `position:"Body" name:"Name"` TimeType requests.Integer `position:"Body" name:"TimeType"` Parameters string `position:"Body" name:"Parameters"` Status requests.Integer `position:"Body" name:"Status"` NamespaceSource string `position:"Body" name:"NamespaceSource"` Timezone string `position:"Body" name:"Timezone"` Description string `position:"Body" name:"Description"` Content string `position:"Body" name:"Content"` Timeout requests.Integer `position:"Body" name:"Timeout"` TimeoutKillEnable requests.Boolean `position:"Body" name:"TimeoutKillEnable"` PageSize requests.Integer `position:"Body" name:"PageSize"` Calendar string `position:"Body" name:"Calendar"` FailEnable requests.Boolean `position:"Body" name:"FailEnable"` SendChannel string `position:"Body" name:"SendChannel"` MaxAttempt requests.Integer `position:"Body" name:"MaxAttempt"` MissWorkerEnable requests.Boolean `position:"Body" name:"MissWorkerEnable"` SuccessNoticeEnable requests.Boolean `position:"Body" name:"SuccessNoticeEnable"` QueueSize requests.Integer `position:"Body" name:"QueueSize"` ClassName string `position:"Body" name:"ClassName"` Namespace string `position:"Body" name:"Namespace"` XAttrs string `position:"Body" name:"XAttrs"` MaxConcurrency requests.Integer `position:"Body" name:"MaxConcurrency"` }
CreateJobRequest is the request struct for api CreateJob
func CreateCreateJobRequest ¶
func CreateCreateJobRequest() (request *CreateJobRequest)
CreateCreateJobRequest creates a request to invoke CreateJob API
type CreateJobResponse ¶
type CreateJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
CreateJobResponse is the response struct for api CreateJob
func CreateCreateJobResponse ¶
func CreateCreateJobResponse() (response *CreateJobResponse)
CreateCreateJobResponse creates a response to parse from CreateJob response
type CreateNamespaceRequest ¶ added in v1.61.1529
type CreateNamespaceRequest struct { *requests.RpcRequest Description string `position:"Query" name:"Description"` Source string `position:"Query" name:"Source"` Uid string `position:"Query" name:"Uid"` Name string `position:"Query" name:"Name"` }
CreateNamespaceRequest is the request struct for api CreateNamespace
func CreateCreateNamespaceRequest ¶ added in v1.61.1529
func CreateCreateNamespaceRequest() (request *CreateNamespaceRequest)
CreateCreateNamespaceRequest creates a request to invoke CreateNamespace API
type CreateNamespaceResponse ¶ added in v1.61.1529
type CreateNamespaceResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
CreateNamespaceResponse is the response struct for api CreateNamespace
func CreateCreateNamespaceResponse ¶ added in v1.61.1529
func CreateCreateNamespaceResponse() (response *CreateNamespaceResponse)
CreateCreateNamespaceResponse creates a response to parse from CreateNamespace response
type CreateRouteStrategyRequest ¶ added in v1.62.177
type CreateRouteStrategyRequest struct { *requests.RpcRequest Type requests.Integer `position:"Query" name:"Type"` JobId requests.Integer `position:"Query" name:"JobId"` GroupId string `position:"Query" name:"GroupId"` StrategyContent string `position:"Query" name:"StrategyContent"` Name string `position:"Query" name:"Name"` Namespace string `position:"Query" name:"Namespace"` Status requests.Integer `position:"Query" name:"Status"` }
CreateRouteStrategyRequest is the request struct for api CreateRouteStrategy
func CreateCreateRouteStrategyRequest ¶ added in v1.62.177
func CreateCreateRouteStrategyRequest() (request *CreateRouteStrategyRequest)
CreateCreateRouteStrategyRequest creates a request to invoke CreateRouteStrategy API
type CreateRouteStrategyResponse ¶ added in v1.62.177
type CreateRouteStrategyResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
CreateRouteStrategyResponse is the response struct for api CreateRouteStrategy
func CreateCreateRouteStrategyResponse ¶ added in v1.62.177
func CreateCreateRouteStrategyResponse() (response *CreateRouteStrategyResponse)
CreateCreateRouteStrategyResponse creates a response to parse from CreateRouteStrategy response
type CreateWorkflowRequest ¶ added in v1.62.160
type CreateWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Body" name:"NamespaceSource"` Timezone string `position:"Body" name:"Timezone"` Description string `position:"Body" name:"Description"` GroupId string `position:"Body" name:"GroupId"` TimeExpression string `position:"Body" name:"TimeExpression"` Namespace string `position:"Body" name:"Namespace"` Name string `position:"Body" name:"Name"` MaxConcurrency requests.Integer `position:"Body" name:"MaxConcurrency"` TimeType requests.Integer `position:"Body" name:"TimeType"` }
CreateWorkflowRequest is the request struct for api CreateWorkflow
func CreateCreateWorkflowRequest ¶ added in v1.62.160
func CreateCreateWorkflowRequest() (request *CreateWorkflowRequest)
CreateCreateWorkflowRequest creates a request to invoke CreateWorkflow API
type CreateWorkflowResponse ¶ added in v1.62.160
type CreateWorkflowResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code string `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` Data Data `json:"Data" xml:"Data"` }
CreateWorkflowResponse is the response struct for api CreateWorkflow
func CreateCreateWorkflowResponse ¶ added in v1.62.160
func CreateCreateWorkflowResponse() (response *CreateWorkflowResponse)
CreateCreateWorkflowResponse creates a response to parse from CreateWorkflow response
type Data ¶
type Data struct { Xattrs string `json:"Xattrs" xml:"Xattrs"` JobInstanceId int64 `json:"JobInstanceId" xml:"JobInstanceId"` MonitorConfigJson string `json:"MonitorConfigJson" xml:"MonitorConfigJson"` WfInstanceId int64 `json:"WfInstanceId" xml:"WfInstanceId"` ReadyInstanceNum int `json:"ReadyInstanceNum" xml:"ReadyInstanceNum"` MetricsThresholdJson string `json:"MetricsThresholdJson" xml:"MetricsThresholdJson"` GroupId string `json:"GroupId" xml:"GroupId"` AlarmJson string `json:"AlarmJson" xml:"AlarmJson"` Description string `json:"Description" xml:"Description"` NamespaceUid string `json:"NamespaceUid" xml:"NamespaceUid"` JobId int64 `json:"JobId" xml:"JobId"` MaxJobs int `json:"MaxJobs" xml:"MaxJobs"` AppKey string `json:"AppKey" xml:"AppKey"` MaxConcurrency int `json:"MaxConcurrency" xml:"MaxConcurrency"` CurJobs int `json:"CurJobs" xml:"CurJobs"` WorkflowId int64 `json:"WorkflowId" xml:"WorkflowId"` RunningInstanceNum int `json:"RunningInstanceNum" xml:"RunningInstanceNum"` AppGroupId int64 `json:"AppGroupId" xml:"AppGroupId"` AppVersion string `json:"AppVersion" xml:"AppVersion"` AppName string `json:"AppName" xml:"AppName"` Logs []string `json:"Logs" xml:"Logs"` JobInstanceDetail JobInstanceDetail `json:"JobInstanceDetail" xml:"JobInstanceDetail"` WfInstanceDag WfInstanceDag `json:"WfInstanceDag" xml:"WfInstanceDag"` WorkFlowInfo WorkFlowInfo `json:"WorkFlowInfo" xml:"WorkFlowInfo"` JobConfigInfo JobConfigInfo `json:"JobConfigInfo" xml:"JobConfigInfo"` WorkFlowNodeInfo WorkFlowNodeInfo `json:"WorkFlowNodeInfo" xml:"WorkFlowNodeInfo"` WfInstanceInfo WfInstanceInfo `json:"WfInstanceInfo" xml:"WfInstanceInfo"` WorkerInfos []WorkerInfo `json:"WorkerInfos" xml:"WorkerInfos"` AppGroups []AppGroup `json:"AppGroups" xml:"AppGroups"` Namespaces []Namespace `json:"Namespaces" xml:"Namespaces"` JobInstanceDetails []JobInstanceDetailsItem `json:"JobInstanceDetails" xml:"JobInstanceDetails"` Jobs []Job `json:"Jobs" xml:"Jobs"` WfInstanceInfos []WfInstanceInfosItem `json:"WfInstanceInfos" xml:"WfInstanceInfos"` }
Data is a nested struct in schedulerx2 response
type DeleteAppGroupRequest ¶ added in v1.62.177
type DeleteAppGroupRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` DeleteJobs requests.Boolean `position:"Query" name:"DeleteJobs"` Namespace string `position:"Query" name:"Namespace"` }
DeleteAppGroupRequest is the request struct for api DeleteAppGroup
func CreateDeleteAppGroupRequest ¶ added in v1.62.177
func CreateDeleteAppGroupRequest() (request *DeleteAppGroupRequest)
CreateDeleteAppGroupRequest creates a request to invoke DeleteAppGroup API
type DeleteAppGroupResponse ¶ added in v1.62.177
type DeleteAppGroupResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` }
DeleteAppGroupResponse is the response struct for api DeleteAppGroup
func CreateDeleteAppGroupResponse ¶ added in v1.62.177
func CreateDeleteAppGroupResponse() (response *DeleteAppGroupResponse)
CreateDeleteAppGroupResponse creates a response to parse from DeleteAppGroup response
type DeleteJobRequest ¶
type DeleteJobRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` }
DeleteJobRequest is the request struct for api DeleteJob
func CreateDeleteJobRequest ¶
func CreateDeleteJobRequest() (request *DeleteJobRequest)
CreateDeleteJobRequest creates a request to invoke DeleteJob API
type DeleteJobResponse ¶
type DeleteJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
DeleteJobResponse is the response struct for api DeleteJob
func CreateDeleteJobResponse ¶
func CreateDeleteJobResponse() (response *DeleteJobResponse)
CreateDeleteJobResponse creates a response to parse from DeleteJob response
type DeleteRouteStrategyRequest ¶ added in v1.62.177
type DeleteRouteStrategyRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` StrategyId requests.Integer `position:"Query" name:"StrategyId"` }
DeleteRouteStrategyRequest is the request struct for api DeleteRouteStrategy
func CreateDeleteRouteStrategyRequest ¶ added in v1.62.177
func CreateDeleteRouteStrategyRequest() (request *DeleteRouteStrategyRequest)
CreateDeleteRouteStrategyRequest creates a request to invoke DeleteRouteStrategy API
type DeleteRouteStrategyResponse ¶ added in v1.62.177
type DeleteRouteStrategyResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
DeleteRouteStrategyResponse is the response struct for api DeleteRouteStrategy
func CreateDeleteRouteStrategyResponse ¶ added in v1.62.177
func CreateDeleteRouteStrategyResponse() (response *DeleteRouteStrategyResponse)
CreateDeleteRouteStrategyResponse creates a response to parse from DeleteRouteStrategy response
type DeleteWorkflowRequest ¶
type DeleteWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
DeleteWorkflowRequest is the request struct for api DeleteWorkflow
func CreateDeleteWorkflowRequest ¶
func CreateDeleteWorkflowRequest() (request *DeleteWorkflowRequest)
CreateDeleteWorkflowRequest creates a request to invoke DeleteWorkflow API
type DeleteWorkflowResponse ¶
type DeleteWorkflowResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
DeleteWorkflowResponse is the response struct for api DeleteWorkflow
func CreateDeleteWorkflowResponse ¶
func CreateDeleteWorkflowResponse() (response *DeleteWorkflowResponse)
CreateDeleteWorkflowResponse creates a response to parse from DeleteWorkflow response
type DescribeRegionsRequest ¶
type DescribeRegionsRequest struct {
*requests.RpcRequest
}
DescribeRegionsRequest is the request struct for api DescribeRegions
func CreateDescribeRegionsRequest ¶
func CreateDescribeRegionsRequest() (request *DescribeRegionsRequest)
CreateDescribeRegionsRequest creates a request to invoke DescribeRegions API
type DescribeRegionsResponse ¶
type DescribeRegionsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Regions []Region `json:"Regions" xml:"Regions"` }
DescribeRegionsResponse is the response struct for api DescribeRegions
func CreateDescribeRegionsResponse ¶
func CreateDescribeRegionsResponse() (response *DescribeRegionsResponse)
CreateDescribeRegionsResponse creates a response to parse from DescribeRegions response
type DesignateWorkersRequest ¶ added in v1.61.1394
type DesignateWorkersRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` Transferable requests.Boolean `position:"Query" name:"Transferable"` DesignateType requests.Integer `position:"Query" name:"DesignateType"` JobId requests.Integer `position:"Query" name:"JobId"` Workers string `position:"Query" name:"Workers"` GroupId string `position:"Query" name:"GroupId"` Labels string `position:"Query" name:"Labels"` Namespace string `position:"Query" name:"Namespace"` }
DesignateWorkersRequest is the request struct for api DesignateWorkers
func CreateDesignateWorkersRequest ¶ added in v1.61.1394
func CreateDesignateWorkersRequest() (request *DesignateWorkersRequest)
CreateDesignateWorkersRequest creates a request to invoke DesignateWorkers API
type DesignateWorkersResponse ¶ added in v1.61.1394
type DesignateWorkersResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Message string `json:"Message" xml:"Message"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` }
DesignateWorkersResponse is the response struct for api DesignateWorkers
func CreateDesignateWorkersResponse ¶ added in v1.61.1394
func CreateDesignateWorkersResponse() (response *DesignateWorkersResponse)
CreateDesignateWorkersResponse creates a response to parse from DesignateWorkers response
type DisableJobRequest ¶
type DisableJobRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` }
DisableJobRequest is the request struct for api DisableJob
func CreateDisableJobRequest ¶
func CreateDisableJobRequest() (request *DisableJobRequest)
CreateDisableJobRequest creates a request to invoke DisableJob API
type DisableJobResponse ¶
type DisableJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
DisableJobResponse is the response struct for api DisableJob
func CreateDisableJobResponse ¶
func CreateDisableJobResponse() (response *DisableJobResponse)
CreateDisableJobResponse creates a response to parse from DisableJob response
type DisableWorkflowRequest ¶
type DisableWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
DisableWorkflowRequest is the request struct for api DisableWorkflow
func CreateDisableWorkflowRequest ¶
func CreateDisableWorkflowRequest() (request *DisableWorkflowRequest)
CreateDisableWorkflowRequest creates a request to invoke DisableWorkflow API
type DisableWorkflowResponse ¶
type DisableWorkflowResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
DisableWorkflowResponse is the response struct for api DisableWorkflow
func CreateDisableWorkflowResponse ¶
func CreateDisableWorkflowResponse() (response *DisableWorkflowResponse)
CreateDisableWorkflowResponse creates a response to parse from DisableWorkflow response
type Edge ¶ added in v1.61.1394
type Edge struct { Source int64 `json:"Source" xml:"Source"` Target int64 `json:"Target" xml:"Target"` }
Edge is a nested struct in schedulerx2 response
type EdgesInGetWorkFlow ¶ added in v1.62.160
type EdgesInGetWorkFlow struct {
Edge []Edge `json:"Edge" xml:"Edge"`
}
EdgesInGetWorkFlow is a nested struct in schedulerx2 response
type EdgesInGetWorkflowInstance ¶ added in v1.62.160
type EdgesInGetWorkflowInstance struct {
Edge []Edge `json:"Edge" xml:"Edge"`
}
EdgesInGetWorkflowInstance is a nested struct in schedulerx2 response
type EnableJobRequest ¶
type EnableJobRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` }
EnableJobRequest is the request struct for api EnableJob
func CreateEnableJobRequest ¶
func CreateEnableJobRequest() (request *EnableJobRequest)
CreateEnableJobRequest creates a request to invoke EnableJob API
type EnableJobResponse ¶
type EnableJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
EnableJobResponse is the response struct for api EnableJob
func CreateEnableJobResponse ¶
func CreateEnableJobResponse() (response *EnableJobResponse)
CreateEnableJobResponse creates a response to parse from EnableJob response
type EnableWorkflowRequest ¶
type EnableWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
EnableWorkflowRequest is the request struct for api EnableWorkflow
func CreateEnableWorkflowRequest ¶
func CreateEnableWorkflowRequest() (request *EnableWorkflowRequest)
CreateEnableWorkflowRequest creates a request to invoke EnableWorkflow API
type EnableWorkflowResponse ¶
type EnableWorkflowResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
EnableWorkflowResponse is the response struct for api EnableWorkflow
func CreateEnableWorkflowResponse ¶
func CreateEnableWorkflowResponse() (response *EnableWorkflowResponse)
CreateEnableWorkflowResponse creates a response to parse from EnableWorkflow response
type ExecuteJobRequest ¶
type ExecuteJobRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` CheckJobStatus requests.Boolean `position:"Query" name:"CheckJobStatus"` DesignateType requests.Integer `position:"Query" name:"DesignateType"` JobId requests.Integer `position:"Query" name:"JobId"` Worker string `position:"Query" name:"Worker"` InstanceParameters string `position:"Query" name:"InstanceParameters"` GroupId string `position:"Query" name:"GroupId"` Label string `position:"Query" name:"Label"` Namespace string `position:"Query" name:"Namespace"` }
ExecuteJobRequest is the request struct for api ExecuteJob
func CreateExecuteJobRequest ¶
func CreateExecuteJobRequest() (request *ExecuteJobRequest)
CreateExecuteJobRequest creates a request to invoke ExecuteJob API
type ExecuteJobResponse ¶
type ExecuteJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
ExecuteJobResponse is the response struct for api ExecuteJob
func CreateExecuteJobResponse ¶
func CreateExecuteJobResponse() (response *ExecuteJobResponse)
CreateExecuteJobResponse creates a response to parse from ExecuteJob response
type ExecuteWorkflowRequest ¶
type ExecuteWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` InstanceParameters string `position:"Query" name:"InstanceParameters"` }
ExecuteWorkflowRequest is the request struct for api ExecuteWorkflow
func CreateExecuteWorkflowRequest ¶
func CreateExecuteWorkflowRequest() (request *ExecuteWorkflowRequest)
CreateExecuteWorkflowRequest creates a request to invoke ExecuteWorkflow API
type ExecuteWorkflowResponse ¶
type ExecuteWorkflowResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
ExecuteWorkflowResponse is the response struct for api ExecuteWorkflow
func CreateExecuteWorkflowResponse ¶
func CreateExecuteWorkflowResponse() (response *ExecuteWorkflowResponse)
CreateExecuteWorkflowResponse creates a response to parse from ExecuteWorkflow response
type GetAppGroupRequest ¶ added in v1.62.177
type GetAppGroupRequest struct { *requests.RpcRequest GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` }
GetAppGroupRequest is the request struct for api GetAppGroup
func CreateGetAppGroupRequest ¶ added in v1.62.177
func CreateGetAppGroupRequest() (request *GetAppGroupRequest)
CreateGetAppGroupRequest creates a request to invoke GetAppGroup API
type GetAppGroupResponse ¶ added in v1.62.177
type GetAppGroupResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetAppGroupResponse is the response struct for api GetAppGroup
func CreateGetAppGroupResponse ¶ added in v1.62.177
func CreateGetAppGroupResponse() (response *GetAppGroupResponse)
CreateGetAppGroupResponse creates a response to parse from GetAppGroup response
type GetJobInfoRequest ¶
type GetJobInfoRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` JobName string `position:"Query" name:"JobName"` }
GetJobInfoRequest is the request struct for api GetJobInfo
func CreateGetJobInfoRequest ¶
func CreateGetJobInfoRequest() (request *GetJobInfoRequest)
CreateGetJobInfoRequest creates a request to invoke GetJobInfo API
type GetJobInfoResponse ¶
type GetJobInfoResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetJobInfoResponse is the response struct for api GetJobInfo
func CreateGetJobInfoResponse ¶
func CreateGetJobInfoResponse() (response *GetJobInfoResponse)
CreateGetJobInfoResponse creates a response to parse from GetJobInfo response
type GetJobInstanceListRequest ¶
type GetJobInstanceListRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` StartTimestamp requests.Integer `position:"Query" name:"StartTimestamp"` PageNum requests.Integer `position:"Query" name:"PageNum"` EndTimestamp requests.Integer `position:"Query" name:"EndTimestamp"` JobId requests.Integer `position:"Query" name:"JobId"` PageSize requests.Integer `position:"Query" name:"PageSize"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` Status requests.Integer `position:"Query" name:"Status"` }
GetJobInstanceListRequest is the request struct for api GetJobInstanceList
func CreateGetJobInstanceListRequest ¶
func CreateGetJobInstanceListRequest() (request *GetJobInstanceListRequest)
CreateGetJobInstanceListRequest creates a request to invoke GetJobInstanceList API
type GetJobInstanceListResponse ¶
type GetJobInstanceListResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetJobInstanceListResponse is the response struct for api GetJobInstanceList
func CreateGetJobInstanceListResponse ¶
func CreateGetJobInstanceListResponse() (response *GetJobInstanceListResponse)
CreateGetJobInstanceListResponse creates a response to parse from GetJobInstanceList response
type GetJobInstanceRequest ¶
type GetJobInstanceRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` JobInstanceId requests.Integer `position:"Query" name:"JobInstanceId"` }
GetJobInstanceRequest is the request struct for api GetJobInstance
func CreateGetJobInstanceRequest ¶
func CreateGetJobInstanceRequest() (request *GetJobInstanceRequest)
CreateGetJobInstanceRequest creates a request to invoke GetJobInstance API
type GetJobInstanceResponse ¶
type GetJobInstanceResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetJobInstanceResponse is the response struct for api GetJobInstance
func CreateGetJobInstanceResponse ¶
func CreateGetJobInstanceResponse() (response *GetJobInstanceResponse)
CreateGetJobInstanceResponse creates a response to parse from GetJobInstance response
type GetLogRequest ¶ added in v1.62.160
type GetLogRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` Line requests.Integer `position:"Query" name:"Line"` StartTimestamp requests.Integer `position:"Query" name:"StartTimestamp"` EndTimestamp requests.Integer `position:"Query" name:"EndTimestamp"` JobId string `position:"Query" name:"JobId"` Keyword string `position:"Query" name:"Keyword"` Offset requests.Integer `position:"Query" name:"Offset"` GroupId string `position:"Query" name:"GroupId"` Reverse requests.Boolean `position:"Query" name:"Reverse"` Namespace string `position:"Query" name:"Namespace"` JobInstanceId string `position:"Query" name:"JobInstanceId"` }
GetLogRequest is the request struct for api GetLog
func CreateGetLogRequest ¶ added in v1.62.160
func CreateGetLogRequest() (request *GetLogRequest)
CreateGetLogRequest creates a request to invoke GetLog API
type GetLogResponse ¶ added in v1.62.160
type GetLogResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` Data Data `json:"Data" xml:"Data"` }
GetLogResponse is the response struct for api GetLog
func CreateGetLogResponse ¶ added in v1.62.160
func CreateGetLogResponse() (response *GetLogResponse)
CreateGetLogResponse creates a response to parse from GetLog response
type GetOverviewRequest ¶ added in v1.62.359
type GetOverviewRequest struct { *requests.RpcRequest MetricType requests.Integer `position:"Query" name:"MetricType"` NamespaceSource string `position:"Query" name:"NamespaceSource"` StartTime requests.Integer `position:"Query" name:"StartTime"` GroupId string `position:"Query" name:"GroupId"` EndTime requests.Integer `position:"Query" name:"EndTime"` Operate string `position:"Query" name:"Operate"` Namespace string `position:"Query" name:"Namespace"` }
GetOverviewRequest is the request struct for api GetOverview
func CreateGetOverviewRequest ¶ added in v1.62.359
func CreateGetOverviewRequest() (request *GetOverviewRequest)
CreateGetOverviewRequest creates a request to invoke GetOverview API
type GetOverviewResponse ¶ added in v1.62.359
type GetOverviewResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` Data string `json:"Data" xml:"Data"` }
GetOverviewResponse is the response struct for api GetOverview
func CreateGetOverviewResponse ¶ added in v1.62.359
func CreateGetOverviewResponse() (response *GetOverviewResponse)
CreateGetOverviewResponse creates a response to parse from GetOverview response
type GetWorkFlowRequest ¶ added in v1.61.1394
type GetWorkFlowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
GetWorkFlowRequest is the request struct for api GetWorkFlow
func CreateGetWorkFlowRequest ¶ added in v1.61.1394
func CreateGetWorkFlowRequest() (request *GetWorkFlowRequest)
CreateGetWorkFlowRequest creates a request to invoke GetWorkFlow API
type GetWorkFlowResponse ¶ added in v1.61.1394
type GetWorkFlowResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetWorkFlowResponse is the response struct for api GetWorkFlow
func CreateGetWorkFlowResponse ¶ added in v1.61.1394
func CreateGetWorkFlowResponse() (response *GetWorkFlowResponse)
CreateGetWorkFlowResponse creates a response to parse from GetWorkFlow response
type GetWorkerListRequest ¶ added in v1.61.1420
type GetWorkerListRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` }
GetWorkerListRequest is the request struct for api GetWorkerList
func CreateGetWorkerListRequest ¶ added in v1.61.1420
func CreateGetWorkerListRequest() (request *GetWorkerListRequest)
CreateGetWorkerListRequest creates a request to invoke GetWorkerList API
type GetWorkerListResponse ¶ added in v1.61.1420
type GetWorkerListResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
GetWorkerListResponse is the response struct for api GetWorkerList
func CreateGetWorkerListResponse ¶ added in v1.61.1420
func CreateGetWorkerListResponse() (response *GetWorkerListResponse)
CreateGetWorkerListResponse creates a response to parse from GetWorkerList response
type GetWorkflowInstanceRequest ¶ added in v1.62.160
type GetWorkflowInstanceRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` WfInstanceId requests.Integer `position:"Query" name:"WfInstanceId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
GetWorkflowInstanceRequest is the request struct for api GetWorkflowInstance
func CreateGetWorkflowInstanceRequest ¶ added in v1.62.160
func CreateGetWorkflowInstanceRequest() (request *GetWorkflowInstanceRequest)
CreateGetWorkflowInstanceRequest creates a request to invoke GetWorkflowInstance API
type GetWorkflowInstanceResponse ¶ added in v1.62.160
type GetWorkflowInstanceResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` Data Data `json:"Data" xml:"Data"` }
GetWorkflowInstanceResponse is the response struct for api GetWorkflowInstance
func CreateGetWorkflowInstanceResponse ¶ added in v1.62.160
func CreateGetWorkflowInstanceResponse() (response *GetWorkflowInstanceResponse)
CreateGetWorkflowInstanceResponse creates a response to parse from GetWorkflowInstance response
type GrantPermissionRequest ¶
type GrantPermissionRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` UserId string `position:"Query" name:"UserId"` GrantOption requests.Boolean `position:"Query" name:"GrantOption"` Namespace string `position:"Query" name:"Namespace"` UserName string `position:"Query" name:"UserName"` }
GrantPermissionRequest is the request struct for api GrantPermission
func CreateGrantPermissionRequest ¶
func CreateGrantPermissionRequest() (request *GrantPermissionRequest)
CreateGrantPermissionRequest creates a request to invoke GrantPermission API
type GrantPermissionResponse ¶
type GrantPermissionResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
GrantPermissionResponse is the response struct for api GrantPermission
func CreateGrantPermissionResponse ¶
func CreateGrantPermissionResponse() (response *GrantPermissionResponse)
CreateGrantPermissionResponse creates a response to parse from GrantPermission response
type Job ¶ added in v1.61.948
type Job struct { Status int `json:"Status" xml:"Status"` JarUrl string `json:"JarUrl" xml:"JarUrl"` MaxAttempt int `json:"MaxAttempt" xml:"MaxAttempt"` Parameters string `json:"Parameters" xml:"Parameters"` Description string `json:"Description" xml:"Description"` JobId int64 `json:"JobId" xml:"JobId"` ExecuteMode string `json:"ExecuteMode" xml:"ExecuteMode"` MaxConcurrency string `json:"MaxConcurrency" xml:"MaxConcurrency"` Name string `json:"Name" xml:"Name"` ClassName string `json:"ClassName" xml:"ClassName"` Content string `json:"Content" xml:"Content"` JobType string `json:"JobType" xml:"JobType"` AttemptInterval int `json:"AttemptInterval" xml:"AttemptInterval"` XAttrs string `json:"XAttrs" xml:"XAttrs"` MapTaskXAttrs MapTaskXAttrs `json:"MapTaskXAttrs" xml:"MapTaskXAttrs"` TimeConfig TimeConfig `json:"TimeConfig" xml:"TimeConfig"` JobMonitorInfo JobMonitorInfo `json:"JobMonitorInfo" xml:"JobMonitorInfo"` }
Job is a nested struct in schedulerx2 response
type JobConfigInfo ¶
type JobConfigInfo struct { JobId int64 `json:"JobId" xml:"JobId"` Status int `json:"Status" xml:"Status"` Parameters string `json:"Parameters" xml:"Parameters"` Description string `json:"Description" xml:"Description"` ExecuteMode string `json:"ExecuteMode" xml:"ExecuteMode"` MaxConcurrency string `json:"MaxConcurrency" xml:"MaxConcurrency"` Name string `json:"Name" xml:"Name"` MaxAttempt int `json:"MaxAttempt" xml:"MaxAttempt"` Content string `json:"Content" xml:"Content"` JarUrl string `json:"JarUrl" xml:"JarUrl"` ClassName string `json:"ClassName" xml:"ClassName"` JobType string `json:"JobType" xml:"JobType"` AttemptInterval int `json:"AttemptInterval" xml:"AttemptInterval"` XAttrs string `json:"XAttrs" xml:"XAttrs"` MapTaskXAttrs MapTaskXAttrs `json:"MapTaskXAttrs" xml:"MapTaskXAttrs"` TimeConfig TimeConfig `json:"TimeConfig" xml:"TimeConfig"` JobMonitorInfo JobMonitorInfo `json:"JobMonitorInfo" xml:"JobMonitorInfo"` }
JobConfigInfo is a nested struct in schedulerx2 response
type JobInstanceDetail ¶
type JobInstanceDetail struct { Status int `json:"Status" xml:"Status"` Progress string `json:"Progress" xml:"Progress"` Result string `json:"Result" xml:"Result"` InstanceId int64 `json:"InstanceId" xml:"InstanceId"` TimeType int `json:"TimeType" xml:"TimeType"` TriggerType int `json:"TriggerType" xml:"TriggerType"` EndTime string `json:"EndTime" xml:"EndTime"` StartTime string `json:"StartTime" xml:"StartTime"` Executor string `json:"Executor" xml:"Executor"` JobId int64 `json:"JobId" xml:"JobId"` ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"` DataTime string `json:"DataTime" xml:"DataTime"` WorkAddr string `json:"WorkAddr" xml:"WorkAddr"` Parameters string `json:"Parameters" xml:"Parameters"` JobName string `json:"JobName" xml:"JobName"` TraceId string `json:"TraceId" xml:"TraceId"` }
JobInstanceDetail is a nested struct in schedulerx2 response
type JobInstanceDetails ¶
type JobInstanceDetails struct {
JobInstanceDetailsItem []JobInstanceDetailsItem `json:"JobInstanceDetails" xml:"JobInstanceDetails"`
}
JobInstanceDetails is a nested struct in schedulerx2 response
type JobInstanceDetailsItem ¶
type JobInstanceDetailsItem struct { Status int `json:"Status" xml:"Status"` Progress string `json:"Progress" xml:"Progress"` Result string `json:"Result" xml:"Result"` InstanceId int64 `json:"InstanceId" xml:"InstanceId"` TimeType int `json:"TimeType" xml:"TimeType"` TriggerType int `json:"TriggerType" xml:"TriggerType"` EndTime string `json:"EndTime" xml:"EndTime"` StartTime string `json:"StartTime" xml:"StartTime"` Executor string `json:"Executor" xml:"Executor"` JobId int64 `json:"JobId" xml:"JobId"` ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"` DataTime string `json:"DataTime" xml:"DataTime"` WorkAddr string `json:"WorkAddr" xml:"WorkAddr"` }
JobInstanceDetailsItem is a nested struct in schedulerx2 response
type JobMonitorInfo ¶
type JobMonitorInfo struct { MonitorConfig MonitorConfig `json:"MonitorConfig" xml:"MonitorConfig"` ContactInfo []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"` }
JobMonitorInfo is a nested struct in schedulerx2 response
type Jobs ¶ added in v1.61.948
type Jobs struct {
Job []Job `json:"Job" xml:"Job"`
}
Jobs is a nested struct in schedulerx2 response
type ListGroupsRequest ¶ added in v1.61.948
type ListGroupsRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` AppGroupName string `position:"Query" name:"AppGroupName"` Namespace string `position:"Query" name:"Namespace"` }
ListGroupsRequest is the request struct for api ListGroups
func CreateListGroupsRequest ¶ added in v1.61.948
func CreateListGroupsRequest() (request *ListGroupsRequest)
CreateListGroupsRequest creates a request to invoke ListGroups API
type ListGroupsResponse ¶ added in v1.61.948
type ListGroupsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
ListGroupsResponse is the response struct for api ListGroups
func CreateListGroupsResponse ¶ added in v1.61.948
func CreateListGroupsResponse() (response *ListGroupsResponse)
CreateListGroupsResponse creates a response to parse from ListGroups response
type ListJobsRequest ¶ added in v1.61.948
type ListJobsRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` JobName string `position:"Query" name:"JobName"` Status string `position:"Query" name:"Status"` }
ListJobsRequest is the request struct for api ListJobs
func CreateListJobsRequest ¶ added in v1.61.948
func CreateListJobsRequest() (request *ListJobsRequest)
CreateListJobsRequest creates a request to invoke ListJobs API
type ListJobsResponse ¶ added in v1.61.948
type ListJobsResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
ListJobsResponse is the response struct for api ListJobs
func CreateListJobsResponse ¶ added in v1.61.948
func CreateListJobsResponse() (response *ListJobsResponse)
CreateListJobsResponse creates a response to parse from ListJobs response
type ListNamespacesRequest ¶ added in v1.61.948
type ListNamespacesRequest struct { *requests.RpcRequest NamespaceName string `position:"Query" name:"NamespaceName"` Namespace string `position:"Query" name:"Namespace"` }
ListNamespacesRequest is the request struct for api ListNamespaces
func CreateListNamespacesRequest ¶ added in v1.61.948
func CreateListNamespacesRequest() (request *ListNamespacesRequest)
CreateListNamespacesRequest creates a request to invoke ListNamespaces API
type ListNamespacesResponse ¶ added in v1.61.948
type ListNamespacesResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` Data Data `json:"Data" xml:"Data"` }
ListNamespacesResponse is the response struct for api ListNamespaces
func CreateListNamespacesResponse ¶ added in v1.61.948
func CreateListNamespacesResponse() (response *ListNamespacesResponse)
CreateListNamespacesResponse creates a response to parse from ListNamespaces response
type ListWorkflowInstanceRequest ¶ added in v1.62.160
type ListWorkflowInstanceRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId string `position:"Query" name:"WorkflowId"` }
ListWorkflowInstanceRequest is the request struct for api ListWorkflowInstance
func CreateListWorkflowInstanceRequest ¶ added in v1.62.160
func CreateListWorkflowInstanceRequest() (request *ListWorkflowInstanceRequest)
CreateListWorkflowInstanceRequest creates a request to invoke ListWorkflowInstance API
type ListWorkflowInstanceResponse ¶ added in v1.62.160
type ListWorkflowInstanceResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` Data Data `json:"Data" xml:"Data"` }
ListWorkflowInstanceResponse is the response struct for api ListWorkflowInstance
func CreateListWorkflowInstanceResponse ¶ added in v1.62.160
func CreateListWorkflowInstanceResponse() (response *ListWorkflowInstanceResponse)
CreateListWorkflowInstanceResponse creates a response to parse from ListWorkflowInstance response
type Logs ¶ added in v1.62.160
type Logs struct {
Logs []string `json:"Logs" xml:"Logs"`
}
Logs is a nested struct in schedulerx2 response
type MapTaskXAttrs ¶
type MapTaskXAttrs struct { DispatcherSize int `json:"DispatcherSize" xml:"DispatcherSize"` QueueSize int `json:"QueueSize" xml:"QueueSize"` TaskMaxAttempt int `json:"TaskMaxAttempt" xml:"TaskMaxAttempt"` TaskAttemptInterval int `json:"TaskAttemptInterval" xml:"TaskAttemptInterval"` ConsumerSize int `json:"ConsumerSize" xml:"ConsumerSize"` PageSize int `json:"PageSize" xml:"PageSize"` }
MapTaskXAttrs is a nested struct in schedulerx2 response
type MonitorConfig ¶
type MonitorConfig struct { Timeout int64 `json:"Timeout" xml:"Timeout"` FailEnable bool `json:"FailEnable" xml:"FailEnable"` MissWorkerEnable bool `json:"MissWorkerEnable" xml:"MissWorkerEnable"` TimeoutEnable bool `json:"TimeoutEnable" xml:"TimeoutEnable"` SendChannel string `json:"SendChannel" xml:"SendChannel"` TimeoutKillEnable bool `json:"TimeoutKillEnable" xml:"TimeoutKillEnable"` }
MonitorConfig is a nested struct in schedulerx2 response
type Namespace ¶ added in v1.61.948
type Namespace struct { Name string `json:"Name" xml:"Name"` Description string `json:"Description" xml:"Description"` UId string `json:"UId" xml:"UId"` }
Namespace is a nested struct in schedulerx2 response
type Namespaces ¶ added in v1.61.948
type Namespaces struct {
Namespace []Namespace `json:"Namespace" xml:"Namespace"`
}
Namespaces is a nested struct in schedulerx2 response
type Node ¶ added in v1.61.1394
type Node struct { JobId int64 `json:"JobId" xml:"JobId"` Status int `json:"Status" xml:"Status"` JobInstanceId int64 `json:"JobInstanceId" xml:"JobInstanceId"` Label string `json:"Label" xml:"Label"` Result string `json:"Result" xml:"Result"` Id int64 `json:"Id" xml:"Id"` ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"` Attempt int `json:"Attempt" xml:"Attempt"` StartTime string `json:"StartTime" xml:"StartTime"` EndTime string `json:"EndTime" xml:"EndTime"` WorkAddr string `json:"WorkAddr" xml:"WorkAddr"` JobName string `json:"JobName" xml:"JobName"` DataTime string `json:"DataTime" xml:"DataTime"` }
Node is a nested struct in schedulerx2 response
type NodesInGetWorkFlow ¶ added in v1.62.160
type NodesInGetWorkFlow struct {
Node []Node `json:"Node" xml:"Node"`
}
NodesInGetWorkFlow is a nested struct in schedulerx2 response
type NodesInGetWorkflowInstance ¶ added in v1.62.160
type NodesInGetWorkflowInstance struct {
Node []Node `json:"Node" xml:"Node"`
}
NodesInGetWorkflowInstance is a nested struct in schedulerx2 response
type Region ¶
type Region struct { RegionEndpoint string `json:"RegionEndpoint" xml:"RegionEndpoint"` LocalName string `json:"LocalName" xml:"LocalName"` RegionId string `json:"RegionId" xml:"RegionId"` }
Region is a nested struct in schedulerx2 response
type Regions ¶
type Regions struct {
Region []Region `json:"Region" xml:"Region"`
}
Regions is a nested struct in schedulerx2 response
type RerunJobRequest ¶ added in v1.62.160
type RerunJobRequest struct { *requests.RpcRequest NamespaceSource string `position:"Body" name:"NamespaceSource"` DataTime string `position:"Body" name:"DataTime"` StartDate requests.Integer `position:"Body" name:"StartDate"` JobId requests.Integer `position:"Body" name:"JobId"` GroupId string `position:"Body" name:"GroupId"` EndDate requests.Integer `position:"Body" name:"EndDate"` Namespace string `position:"Body" name:"Namespace"` }
RerunJobRequest is the request struct for api RerunJob
func CreateRerunJobRequest ¶ added in v1.62.160
func CreateRerunJobRequest() (request *RerunJobRequest)
CreateRerunJobRequest creates a request to invoke RerunJob API
type RerunJobResponse ¶ added in v1.62.160
type RerunJobResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
RerunJobResponse is the response struct for api RerunJob
func CreateRerunJobResponse ¶ added in v1.62.160
func CreateRerunJobResponse() (response *RerunJobResponse)
CreateRerunJobResponse creates a response to parse from RerunJob response
type RetryJobInstanceRequest ¶ added in v1.62.160
type RetryJobInstanceRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` JobInstanceId requests.Integer `position:"Query" name:"JobInstanceId"` }
RetryJobInstanceRequest is the request struct for api RetryJobInstance
func CreateRetryJobInstanceRequest ¶ added in v1.62.160
func CreateRetryJobInstanceRequest() (request *RetryJobInstanceRequest)
CreateRetryJobInstanceRequest creates a request to invoke RetryJobInstance API
type RetryJobInstanceResponse ¶ added in v1.62.160
type RetryJobInstanceResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
RetryJobInstanceResponse is the response struct for api RetryJobInstance
func CreateRetryJobInstanceResponse ¶ added in v1.62.160
func CreateRetryJobInstanceResponse() (response *RetryJobInstanceResponse)
CreateRetryJobInstanceResponse creates a response to parse from RetryJobInstance response
type RevokePermissionRequest ¶
type RevokePermissionRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` UserId string `position:"Query" name:"UserId"` Namespace string `position:"Query" name:"Namespace"` }
RevokePermissionRequest is the request struct for api RevokePermission
func CreateRevokePermissionRequest ¶
func CreateRevokePermissionRequest() (request *RevokePermissionRequest)
CreateRevokePermissionRequest creates a request to invoke RevokePermission API
type RevokePermissionResponse ¶
type RevokePermissionResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
RevokePermissionResponse is the response struct for api RevokePermission
func CreateRevokePermissionResponse ¶
func CreateRevokePermissionResponse() (response *RevokePermissionResponse)
CreateRevokePermissionResponse creates a response to parse from RevokePermission response
type SetJobInstanceSuccessRequest ¶ added in v1.62.160
type SetJobInstanceSuccessRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` JobInstanceId requests.Integer `position:"Query" name:"JobInstanceId"` }
SetJobInstanceSuccessRequest is the request struct for api SetJobInstanceSuccess
func CreateSetJobInstanceSuccessRequest ¶ added in v1.62.160
func CreateSetJobInstanceSuccessRequest() (request *SetJobInstanceSuccessRequest)
CreateSetJobInstanceSuccessRequest creates a request to invoke SetJobInstanceSuccess API
type SetJobInstanceSuccessResponse ¶ added in v1.62.160
type SetJobInstanceSuccessResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
SetJobInstanceSuccessResponse is the response struct for api SetJobInstanceSuccess
func CreateSetJobInstanceSuccessResponse ¶ added in v1.62.160
func CreateSetJobInstanceSuccessResponse() (response *SetJobInstanceSuccessResponse)
CreateSetJobInstanceSuccessResponse creates a response to parse from SetJobInstanceSuccess response
type SetWfInstanceSuccessRequest ¶ added in v1.62.160
type SetWfInstanceSuccessRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` WfInstanceId requests.Integer `position:"Query" name:"WfInstanceId"` Namespace string `position:"Query" name:"Namespace"` WorkflowId requests.Integer `position:"Query" name:"WorkflowId"` }
SetWfInstanceSuccessRequest is the request struct for api SetWfInstanceSuccess
func CreateSetWfInstanceSuccessRequest ¶ added in v1.62.160
func CreateSetWfInstanceSuccessRequest() (request *SetWfInstanceSuccessRequest)
CreateSetWfInstanceSuccessRequest creates a request to invoke SetWfInstanceSuccess API
type SetWfInstanceSuccessResponse ¶ added in v1.62.160
type SetWfInstanceSuccessResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
SetWfInstanceSuccessResponse is the response struct for api SetWfInstanceSuccess
func CreateSetWfInstanceSuccessResponse ¶ added in v1.62.160
func CreateSetWfInstanceSuccessResponse() (response *SetWfInstanceSuccessResponse)
CreateSetWfInstanceSuccessResponse creates a response to parse from SetWfInstanceSuccess response
type StopInstanceRequest ¶
type StopInstanceRequest struct { *requests.RpcRequest NamespaceSource string `position:"Query" name:"NamespaceSource"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` InstanceId requests.Integer `position:"Query" name:"InstanceId"` Namespace string `position:"Query" name:"Namespace"` }
StopInstanceRequest is the request struct for api StopInstance
func CreateStopInstanceRequest ¶
func CreateStopInstanceRequest() (request *StopInstanceRequest)
CreateStopInstanceRequest creates a request to invoke StopInstance API
type StopInstanceResponse ¶
type StopInstanceResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
StopInstanceResponse is the response struct for api StopInstance
func CreateStopInstanceResponse ¶
func CreateStopInstanceResponse() (response *StopInstanceResponse)
CreateStopInstanceResponse creates a response to parse from StopInstance response
type TimeConfig ¶
type TimeConfig struct { TimeType int `json:"TimeType" xml:"TimeType"` DataOffset int `json:"DataOffset" xml:"DataOffset"` Calendar string `json:"Calendar" xml:"Calendar"` TimeExpression string `json:"TimeExpression" xml:"TimeExpression"` }
TimeConfig is a nested struct in schedulerx2 response
type UpdateAppGroupRequest ¶ added in v1.62.177
type UpdateAppGroupRequest struct { *requests.RpcRequest Description string `position:"Query" name:"Description"` AlarmJson string `position:"Query" name:"AlarmJson"` AppGroupId requests.Integer `position:"Query" name:"AppGroupId"` MaxJobs requests.Integer `position:"Query" name:"MaxJobs"` MetricsThresholdJson string `position:"Query" name:"MetricsThresholdJson"` GroupId string `position:"Query" name:"GroupId"` AppVersion requests.Integer `position:"Query" name:"AppVersion"` Namespace string `position:"Query" name:"Namespace"` Xattrs string `position:"Query" name:"Xattrs"` MaxConcurrency requests.Integer `position:"Query" name:"MaxConcurrency"` }
UpdateAppGroupRequest is the request struct for api UpdateAppGroup
func CreateUpdateAppGroupRequest ¶ added in v1.62.177
func CreateUpdateAppGroupRequest() (request *UpdateAppGroupRequest)
CreateUpdateAppGroupRequest creates a request to invoke UpdateAppGroup API
type UpdateAppGroupResponse ¶ added in v1.62.177
type UpdateAppGroupResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` Success bool `json:"Success" xml:"Success"` }
UpdateAppGroupResponse is the response struct for api UpdateAppGroup
func CreateUpdateAppGroupResponse ¶ added in v1.62.177
func CreateUpdateAppGroupResponse() (response *UpdateAppGroupResponse)
CreateUpdateAppGroupResponse creates a response to parse from UpdateAppGroup response
type UpdateJobContactInfo ¶
type UpdateJobContactInfo struct { Ding string `name:"Ding"` UserPhone string `name:"UserPhone"` UserMail string `name:"UserMail"` UserName string `name:"UserName"` }
UpdateJobContactInfo is a repeated param struct in UpdateJobRequest
type UpdateJobRequest ¶
type UpdateJobRequest struct { *requests.RpcRequest AttemptInterval requests.Integer `position:"Body" name:"AttemptInterval"` FailTimes requests.Integer `position:"Body" name:"FailTimes"` JobId requests.Integer `position:"Body" name:"JobId"` ConsumerSize requests.Integer `position:"Body" name:"ConsumerSize"` JarUrl string `position:"Body" name:"JarUrl"` GroupId string `position:"Body" name:"GroupId"` TaskMaxAttempt requests.Integer `position:"Body" name:"TaskMaxAttempt"` DataOffset requests.Integer `position:"Body" name:"DataOffset"` DispatcherSize requests.Integer `position:"Body" name:"DispatcherSize"` TaskAttemptInterval requests.Integer `position:"Body" name:"TaskAttemptInterval"` ExecuteMode string `position:"Body" name:"ExecuteMode"` TimeExpression string `position:"Body" name:"TimeExpression"` TimeoutEnable requests.Boolean `position:"Body" name:"TimeoutEnable"` ContactInfo *[]UpdateJobContactInfo `position:"Body" name:"ContactInfo" type:"Repeated"` Name string `position:"Body" name:"Name"` TimeType requests.Integer `position:"Body" name:"TimeType"` Parameters string `position:"Body" name:"Parameters"` Template string `position:"Body" name:"Template"` NamespaceSource string `position:"Body" name:"NamespaceSource"` Timezone string `position:"Body" name:"Timezone"` Description string `position:"Body" name:"Description"` Content string `position:"Body" name:"Content"` Timeout requests.Integer `position:"Body" name:"Timeout"` TimeoutKillEnable requests.Boolean `position:"Body" name:"TimeoutKillEnable"` PageSize requests.Integer `position:"Body" name:"PageSize"` TaskDispatchMode string `position:"Body" name:"TaskDispatchMode"` Calendar string `position:"Body" name:"Calendar"` FailEnable requests.Boolean `position:"Body" name:"FailEnable"` SendChannel string `position:"Body" name:"SendChannel"` MaxAttempt requests.Integer `position:"Body" name:"MaxAttempt"` MissWorkerEnable requests.Boolean `position:"Body" name:"MissWorkerEnable"` SuccessNoticeEnable requests.Boolean `position:"Body" name:"SuccessNoticeEnable"` QueueSize requests.Integer `position:"Body" name:"QueueSize"` ClassName string `position:"Body" name:"ClassName"` Namespace string `position:"Body" name:"Namespace"` XAttrs string `position:"Body" name:"XAttrs"` MaxConcurrency requests.Integer `position:"Body" name:"MaxConcurrency"` }
UpdateJobRequest is the request struct for api UpdateJob
func CreateUpdateJobRequest ¶
func CreateUpdateJobRequest() (request *UpdateJobRequest)
CreateUpdateJobRequest creates a request to invoke UpdateJob API
type UpdateJobResponse ¶
type UpdateJobResponse struct { *responses.BaseResponse Code int `json:"Code" xml:"Code"` Message string `json:"Message" xml:"Message"` RequestId string `json:"RequestId" xml:"RequestId"` Success bool `json:"Success" xml:"Success"` }
UpdateJobResponse is the response struct for api UpdateJob
func CreateUpdateJobResponse ¶
func CreateUpdateJobResponse() (response *UpdateJobResponse)
CreateUpdateJobResponse creates a response to parse from UpdateJob response
type UpdateWorkflowDagRequest ¶ added in v1.62.160
type UpdateWorkflowDagRequest struct { *requests.RpcRequest DagJson string `position:"Body" name:"DagJson"` NamespaceSource string `position:"Body" name:"NamespaceSource"` GroupId string `position:"Body" name:"GroupId"` Namespace string `position:"Body" name:"Namespace"` WorkflowId string `position:"Body" name:"WorkflowId"` }
UpdateWorkflowDagRequest is the request struct for api UpdateWorkflowDag
func CreateUpdateWorkflowDagRequest ¶ added in v1.62.160
func CreateUpdateWorkflowDagRequest() (request *UpdateWorkflowDagRequest)
CreateUpdateWorkflowDagRequest creates a request to invoke UpdateWorkflowDag API
type UpdateWorkflowDagResponse ¶ added in v1.62.160
type UpdateWorkflowDagResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
UpdateWorkflowDagResponse is the response struct for api UpdateWorkflowDag
func CreateUpdateWorkflowDagResponse ¶ added in v1.62.160
func CreateUpdateWorkflowDagResponse() (response *UpdateWorkflowDagResponse)
CreateUpdateWorkflowDagResponse creates a response to parse from UpdateWorkflowDag response
type UpdateWorkflowRequest ¶ added in v1.62.160
type UpdateWorkflowRequest struct { *requests.RpcRequest NamespaceSource string `position:"Body" name:"NamespaceSource"` Description string `position:"Body" name:"Description"` WorkflowId string `position:"Body" name:"WorkflowId"` GroupId string `position:"Body" name:"GroupId"` TimeExpression string `position:"Body" name:"TimeExpression"` Namespace string `position:"Body" name:"Namespace"` Name string `position:"Body" name:"Name"` TimeType requests.Integer `position:"Body" name:"TimeType"` }
UpdateWorkflowRequest is the request struct for api UpdateWorkflow
func CreateUpdateWorkflowRequest ¶ added in v1.62.160
func CreateUpdateWorkflowRequest() (request *UpdateWorkflowRequest)
CreateUpdateWorkflowRequest creates a request to invoke UpdateWorkflow API
type UpdateWorkflowResponse ¶ added in v1.62.160
type UpdateWorkflowResponse struct { *responses.BaseResponse RequestId string `json:"RequestId" xml:"RequestId"` Code int `json:"Code" xml:"Code"` Success bool `json:"Success" xml:"Success"` Message string `json:"Message" xml:"Message"` }
UpdateWorkflowResponse is the response struct for api UpdateWorkflow
func CreateUpdateWorkflowResponse ¶ added in v1.62.160
func CreateUpdateWorkflowResponse() (response *UpdateWorkflowResponse)
CreateUpdateWorkflowResponse creates a response to parse from UpdateWorkflow response
type WfInstanceDag ¶ added in v1.62.160
type WfInstanceDag struct { Nodes []Node `json:"Nodes" xml:"Nodes"` Edges []Edge `json:"Edges" xml:"Edges"` }
WfInstanceDag is a nested struct in schedulerx2 response
type WfInstanceInfo ¶ added in v1.62.160
type WfInstanceInfo struct { Status int `json:"Status" xml:"Status"` StartTime string `json:"StartTime" xml:"StartTime"` EndTime string `json:"EndTime" xml:"EndTime"` ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"` DataTime string `json:"DataTime" xml:"DataTime"` }
WfInstanceInfo is a nested struct in schedulerx2 response
type WfInstanceInfos ¶ added in v1.62.160
type WfInstanceInfos struct {
WfInstanceInfosItem []WfInstanceInfosItem `json:"WfInstanceInfos" xml:"WfInstanceInfos"`
}
WfInstanceInfos is a nested struct in schedulerx2 response
type WfInstanceInfosItem ¶ added in v1.62.160
type WfInstanceInfosItem struct { WfInstanceId int64 `json:"WfInstanceId" xml:"WfInstanceId"` WorkflowId int64 `json:"WorkflowId" xml:"WorkflowId"` Status int `json:"Status" xml:"Status"` StartTime string `json:"StartTime" xml:"StartTime"` EndTime string `json:"EndTime" xml:"EndTime"` ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"` DataTime string `json:"DataTime" xml:"DataTime"` }
WfInstanceInfosItem is a nested struct in schedulerx2 response
type WorkFlowInfo ¶ added in v1.61.1394
type WorkFlowInfo struct { WorkflowId int64 `json:"WorkflowId" xml:"WorkflowId"` Name string `json:"Name" xml:"Name"` Description string `json:"Description" xml:"Description"` Status string `json:"Status" xml:"Status"` TimeType string `json:"TimeType" xml:"TimeType"` TimeExpression string `json:"TimeExpression" xml:"TimeExpression"` }
WorkFlowInfo is a nested struct in schedulerx2 response
type WorkFlowNodeInfo ¶ added in v1.61.1394
type WorkFlowNodeInfo struct { Nodes []Node `json:"Nodes" xml:"Nodes"` Edges []Edge `json:"Edges" xml:"Edges"` }
WorkFlowNodeInfo is a nested struct in schedulerx2 response
type WorkerInfo ¶ added in v1.61.1420
type WorkerInfo struct { Ip string `json:"Ip" xml:"Ip"` Port int `json:"Port" xml:"Port"` WorkerAddress string `json:"WorkerAddress" xml:"WorkerAddress"` Label string `json:"Label" xml:"Label"` Version string `json:"Version" xml:"Version"` Starter string `json:"Starter" xml:"Starter"` }
WorkerInfo is a nested struct in schedulerx2 response
type WorkerInfos ¶ added in v1.61.1420
type WorkerInfos struct {
WorkerInfo []WorkerInfo `json:"WorkerInfo" xml:"WorkerInfo"`
}
WorkerInfos is a nested struct in schedulerx2 response
Source Files
¶
- batch_delete_jobs.go
- batch_delete_route_strategy.go
- batch_disable_jobs.go
- batch_enable_jobs.go
- client.go
- create_app_group.go
- create_job.go
- create_namespace.go
- create_route_strategy.go
- create_workflow.go
- delete_app_group.go
- delete_job.go
- delete_route_strategy.go
- delete_workflow.go
- describe_regions.go
- designate_workers.go
- disable_job.go
- disable_workflow.go
- enable_job.go
- enable_workflow.go
- endpoint.go
- execute_job.go
- execute_workflow.go
- get_app_group.go
- get_job_info.go
- get_job_instance.go
- get_job_instance_list.go
- get_log.go
- get_overview.go
- get_work_flow.go
- get_worker_list.go
- get_workflow_instance.go
- grant_permission.go
- list_groups.go
- list_jobs.go
- list_namespaces.go
- list_workflow_instance.go
- rerun_job.go
- retry_job_instance.go
- revoke_permission.go
- set_job_instance_success.go
- set_wf_instance_success.go
- stop_instance.go
- struct_app_group.go
- struct_app_groups.go
- struct_contact_info_in_get_job_info.go
- struct_contact_info_in_list_jobs.go
- struct_contact_info_item.go
- struct_data.go
- struct_edge.go
- struct_edges_in_get_work_flow.go
- struct_edges_in_get_workflow_instance.go
- struct_job.go
- struct_job_config_info.go
- struct_job_instance_detail.go
- struct_job_instance_details.go
- struct_job_instance_details_item.go
- struct_job_monitor_info.go
- struct_jobs.go
- struct_logs.go
- struct_map_task_x_attrs.go
- struct_monitor_config.go
- struct_namespace.go
- struct_namespaces.go
- struct_node.go
- struct_nodes_in_get_work_flow.go
- struct_nodes_in_get_workflow_instance.go
- struct_region.go
- struct_regions.go
- struct_time_config.go
- struct_wf_instance_dag.go
- struct_wf_instance_info.go
- struct_wf_instance_infos.go
- struct_wf_instance_infos_item.go
- struct_work_flow_info.go
- struct_work_flow_node_info.go
- struct_worker_info.go
- struct_worker_infos.go
- update_app_group.go
- update_job.go
- update_workflow.go
- update_workflow_dag.go