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 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) 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) 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) 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) 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) 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) 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) 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) 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) 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)
- type ContactInfoInGetJobInfo
- type ContactInfoInListJobs
- type ContactInfoItem
- type CreateAppGroupRequest
- type CreateAppGroupResponse
- type CreateJobContactInfo
- type CreateJobRequest
- type CreateJobResponse
- type CreateNamespaceRequest
- type CreateNamespaceResponse
- type Data
- type DeleteJobRequest
- type DeleteJobResponse
- type DeleteWorkflowRequest
- type DeleteWorkflowResponse
- type DescribeRegionsRequest
- type DescribeRegionsResponse
- type DesignateWorkersRequest
- type DesignateWorkersResponse
- type DisableJobRequest
- type DisableJobResponse
- type DisableWorkflowRequest
- type DisableWorkflowResponse
- type Edge
- type Edges
- type EnableJobRequest
- type EnableJobResponse
- type EnableWorkflowRequest
- type EnableWorkflowResponse
- type ExecuteJobRequest
- type ExecuteJobResponse
- type ExecuteWorkflowRequest
- type ExecuteWorkflowResponse
- type GetJobInfoRequest
- type GetJobInfoResponse
- type GetJobInstanceListRequest
- type GetJobInstanceListResponse
- type GetJobInstanceRequest
- type GetJobInstanceResponse
- type GetWorkFlowRequest
- type GetWorkFlowResponse
- type GetWorkerListRequest
- type GetWorkerListResponse
- 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 MapTaskXAttrs
- type MonitorConfig
- type Namespace
- type Namespaces
- type Node
- type Nodes
- type Region
- type Regions
- type RevokePermissionRequest
- type RevokePermissionResponse
- type StopInstanceRequest
- type StopInstanceResponse
- type TimeConfig
- type UpdateJobContactInfo
- type UpdateJobRequest
- type UpdateJobResponse
- 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 { AppName string `json:"AppName" xml:"AppName"` AppKey string `json:"AppKey" xml:"AppKey"` Description string `json:"Description" xml:"Description"` GroupId string `json:"GroupId" xml:"GroupId"` }
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 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) 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) 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) 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) 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) 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) 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) 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) 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) 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
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"` MonitorConfigJson string `position:"Query" name:"MonitorConfigJson"` Namespace string `position:"Query" name:"Namespace"` 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"` ConsumerSize requests.Integer `position:"Body" name:"ConsumerSize"` JarUrl string `position:"Body" name:"JarUrl"` DataOffset requests.Integer `position:"Body" name:"DataOffset"` GroupId string `position:"Body" name:"GroupId"` 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"` 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"` 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 Data ¶
type Data struct { JobId int64 `json:"JobId" xml:"JobId"` JobInstanceId int64 `json:"JobInstanceId" xml:"JobInstanceId"` AppKey string `json:"AppKey" xml:"AppKey"` WfInstanceId int64 `json:"WfInstanceId" xml:"WfInstanceId"` AppGroupId int64 `json:"AppGroupId" xml:"AppGroupId"` NamespaceUid string `json:"NamespaceUid" xml:"NamespaceUid"` JobInstanceDetail JobInstanceDetail `json:"JobInstanceDetail" xml:"JobInstanceDetail"` WorkFlowInfo WorkFlowInfo `json:"WorkFlowInfo" xml:"WorkFlowInfo"` WorkFlowNodeInfo WorkFlowNodeInfo `json:"WorkFlowNodeInfo" xml:"WorkFlowNodeInfo"` JobConfigInfo JobConfigInfo `json:"JobConfigInfo" xml:"JobConfigInfo"` WorkerInfos []WorkerInfo `json:"WorkerInfos" xml:"WorkerInfos"` Namespaces []Namespace `json:"Namespaces" xml:"Namespaces"` JobInstanceDetails []JobInstanceDetailsItem `json:"JobInstanceDetails" xml:"JobInstanceDetails"` AppGroups []AppGroup `json:"AppGroups" xml:"AppGroups"` Jobs []Job `json:"Jobs" xml:"Jobs"` }
Data is a nested struct in schedulerx2 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 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 Edges ¶ added in v1.61.1394
type Edges struct {
Edge []Edge `json:"Edge" xml:"Edge"`
}
Edges 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 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"` GroupId string `position:"Query" name:"GroupId"` JobId requests.Integer `position:"Query" name:"JobId"` Namespace string `position:"Query" name:"Namespace"` }
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 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 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"` AttemptInterval int `json:"AttemptInterval" xml:"AttemptInterval"` 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"` AttemptInterval int `json:"AttemptInterval" xml:"AttemptInterval"` 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"` }
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"` 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
}
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 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 { Id int64 `json:"Id" xml:"Id"` Label string `json:"Label" xml:"Label"` Status int `json:"Status" xml:"Status"` }
Node is a nested struct in schedulerx2 response
type Nodes ¶ added in v1.61.1394
type Nodes struct {
Node []Node `json:"Node" xml:"Node"`
}
Nodes 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 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 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 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 NamespaceSource string `position:"Body" name:"NamespaceSource"` Description string `position:"Body" name:"Description"` AttemptInterval requests.Integer `position:"Body" name:"AttemptInterval"` Content string `position:"Body" name:"Content"` Timeout requests.Integer `position:"Body" name:"Timeout"` TimeoutKillEnable requests.Boolean `position:"Body" name:"TimeoutKillEnable"` JobId requests.Integer `position:"Body" name:"JobId"` PageSize requests.Integer `position:"Body" name:"PageSize"` ConsumerSize requests.Integer `position:"Body" name:"ConsumerSize"` JarUrl string `position:"Body" name:"JarUrl"` Calendar string `position:"Body" name:"Calendar"` FailEnable requests.Boolean `position:"Body" name:"FailEnable"` SendChannel string `position:"Body" name:"SendChannel"` DataOffset requests.Integer `position:"Body" name:"DataOffset"` GroupId string `position:"Body" name:"GroupId"` TaskMaxAttempt requests.Integer `position:"Body" name:"TaskMaxAttempt"` MaxAttempt requests.Integer `position:"Body" name:"MaxAttempt"` MissWorkerEnable requests.Boolean `position:"Body" name:"MissWorkerEnable"` DispatcherSize requests.Integer `position:"Body" name:"DispatcherSize"` TaskAttemptInterval requests.Integer `position:"Body" name:"TaskAttemptInterval"` ExecuteMode string `position:"Body" name:"ExecuteMode"` QueueSize requests.Integer `position:"Body" name:"QueueSize"` TimeExpression string `position:"Body" name:"TimeExpression"` ClassName string `position:"Body" name:"ClassName"` TimeoutEnable requests.Boolean `position:"Body" name:"TimeoutEnable"` ContactInfo *[]UpdateJobContactInfo `position:"Body" name:"ContactInfo" type:"Repeated"` Name string `position:"Body" name:"Name"` Namespace string `position:"Body" name:"Namespace"` MaxConcurrency requests.Integer `position:"Body" name:"MaxConcurrency"` TimeType requests.Integer `position:"Body" name:"TimeType"` Parameters string `position:"Body" name:"Parameters"` }
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 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_disable_jobs.go
- batch_enable_jobs.go
- client.go
- create_app_group.go
- create_job.go
- create_namespace.go
- delete_job.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_job_info.go
- get_job_instance.go
- get_job_instance_list.go
- get_work_flow.go
- get_worker_list.go
- grant_permission.go
- list_groups.go
- list_jobs.go
- list_namespaces.go
- revoke_permission.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.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_map_task_x_attrs.go
- struct_monitor_config.go
- struct_namespace.go
- struct_namespaces.go
- struct_node.go
- struct_nodes.go
- struct_region.go
- struct_regions.go
- struct_time_config.go
- struct_work_flow_info.go
- struct_work_flow_node_info.go
- struct_worker_info.go
- struct_worker_infos.go
- update_job.go