schedulerx2

package

v1.62.688 Latest Latest Go to latest Published: Mar 6, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aliyun/alibaba-cloud-sdk-go

Links

Open Source Insights

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
- func CreateBatchDeleteJobsRequest() (request *BatchDeleteJobsRequest)
type BatchDeleteJobsResponse
- func CreateBatchDeleteJobsResponse() (response *BatchDeleteJobsResponse)
type BatchDeleteRouteStrategyRequest
- func CreateBatchDeleteRouteStrategyRequest() (request *BatchDeleteRouteStrategyRequest)
type BatchDeleteRouteStrategyResponse
- func CreateBatchDeleteRouteStrategyResponse() (response *BatchDeleteRouteStrategyResponse)
type BatchDisableJobsRequest
- func CreateBatchDisableJobsRequest() (request *BatchDisableJobsRequest)
type BatchDisableJobsResponse
- func CreateBatchDisableJobsResponse() (response *BatchDisableJobsResponse)
type BatchEnableJobsRequest
- func CreateBatchEnableJobsRequest() (request *BatchEnableJobsRequest)
type BatchEnableJobsResponse
- func CreateBatchEnableJobsResponse() (response *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
- func CreateCreateAppGroupRequest() (request *CreateAppGroupRequest)
type CreateAppGroupResponse
- func CreateCreateAppGroupResponse() (response *CreateAppGroupResponse)
type CreateJobContactInfo
type CreateJobRequest
- func CreateCreateJobRequest() (request *CreateJobRequest)
type CreateJobResponse
- func CreateCreateJobResponse() (response *CreateJobResponse)
type CreateNamespaceRequest
- func CreateCreateNamespaceRequest() (request *CreateNamespaceRequest)
type CreateNamespaceResponse
- func CreateCreateNamespaceResponse() (response *CreateNamespaceResponse)
type CreateRouteStrategyRequest
- func CreateCreateRouteStrategyRequest() (request *CreateRouteStrategyRequest)
type CreateRouteStrategyResponse
- func CreateCreateRouteStrategyResponse() (response *CreateRouteStrategyResponse)
type CreateWorkflowRequest
- func CreateCreateWorkflowRequest() (request *CreateWorkflowRequest)
type CreateWorkflowResponse
- func CreateCreateWorkflowResponse() (response *CreateWorkflowResponse)
type Data
type DeleteAppGroupRequest
- func CreateDeleteAppGroupRequest() (request *DeleteAppGroupRequest)
type DeleteAppGroupResponse
- func CreateDeleteAppGroupResponse() (response *DeleteAppGroupResponse)
type DeleteJobRequest
- func CreateDeleteJobRequest() (request *DeleteJobRequest)
type DeleteJobResponse
- func CreateDeleteJobResponse() (response *DeleteJobResponse)
type DeleteRouteStrategyRequest
- func CreateDeleteRouteStrategyRequest() (request *DeleteRouteStrategyRequest)
type DeleteRouteStrategyResponse
- func CreateDeleteRouteStrategyResponse() (response *DeleteRouteStrategyResponse)
type DeleteWorkflowRequest
- func CreateDeleteWorkflowRequest() (request *DeleteWorkflowRequest)
type DeleteWorkflowResponse
- func CreateDeleteWorkflowResponse() (response *DeleteWorkflowResponse)
type DescribeRegionsRequest
- func CreateDescribeRegionsRequest() (request *DescribeRegionsRequest)
type DescribeRegionsResponse
- func CreateDescribeRegionsResponse() (response *DescribeRegionsResponse)
type DesignateWorkersRequest
- func CreateDesignateWorkersRequest() (request *DesignateWorkersRequest)
type DesignateWorkersResponse
- func CreateDesignateWorkersResponse() (response *DesignateWorkersResponse)
type DisableJobRequest
- func CreateDisableJobRequest() (request *DisableJobRequest)
type DisableJobResponse
- func CreateDisableJobResponse() (response *DisableJobResponse)
type DisableWorkflowRequest
- func CreateDisableWorkflowRequest() (request *DisableWorkflowRequest)
type DisableWorkflowResponse
- func CreateDisableWorkflowResponse() (response *DisableWorkflowResponse)
type Edge
type EdgesInGetWorkFlow
type EdgesInGetWorkflowInstance
type EnableJobRequest
- func CreateEnableJobRequest() (request *EnableJobRequest)
type EnableJobResponse
- func CreateEnableJobResponse() (response *EnableJobResponse)
type EnableWorkflowRequest
- func CreateEnableWorkflowRequest() (request *EnableWorkflowRequest)
type EnableWorkflowResponse
- func CreateEnableWorkflowResponse() (response *EnableWorkflowResponse)
type ExecuteJobRequest
- func CreateExecuteJobRequest() (request *ExecuteJobRequest)
type ExecuteJobResponse
- func CreateExecuteJobResponse() (response *ExecuteJobResponse)
type ExecuteWorkflowRequest
- func CreateExecuteWorkflowRequest() (request *ExecuteWorkflowRequest)
type ExecuteWorkflowResponse
- func CreateExecuteWorkflowResponse() (response *ExecuteWorkflowResponse)
type GetAppGroupRequest
- func CreateGetAppGroupRequest() (request *GetAppGroupRequest)
type GetAppGroupResponse
- func CreateGetAppGroupResponse() (response *GetAppGroupResponse)
type GetJobInfoRequest
- func CreateGetJobInfoRequest() (request *GetJobInfoRequest)
type GetJobInfoResponse
- func CreateGetJobInfoResponse() (response *GetJobInfoResponse)
type GetJobInstanceListRequest
- func CreateGetJobInstanceListRequest() (request *GetJobInstanceListRequest)
type GetJobInstanceListResponse
- func CreateGetJobInstanceListResponse() (response *GetJobInstanceListResponse)
type GetJobInstanceRequest
- func CreateGetJobInstanceRequest() (request *GetJobInstanceRequest)
type GetJobInstanceResponse
- func CreateGetJobInstanceResponse() (response *GetJobInstanceResponse)
type GetLogRequest
- func CreateGetLogRequest() (request *GetLogRequest)
type GetLogResponse
- func CreateGetLogResponse() (response *GetLogResponse)
type GetOverviewRequest
- func CreateGetOverviewRequest() (request *GetOverviewRequest)
type GetOverviewResponse
- func CreateGetOverviewResponse() (response *GetOverviewResponse)
type GetWorkFlowRequest
- func CreateGetWorkFlowRequest() (request *GetWorkFlowRequest)
type GetWorkFlowResponse
- func CreateGetWorkFlowResponse() (response *GetWorkFlowResponse)
type GetWorkerListRequest
- func CreateGetWorkerListRequest() (request *GetWorkerListRequest)
type GetWorkerListResponse
- func CreateGetWorkerListResponse() (response *GetWorkerListResponse)
type GetWorkflowInstanceRequest
- func CreateGetWorkflowInstanceRequest() (request *GetWorkflowInstanceRequest)
type GetWorkflowInstanceResponse
- func CreateGetWorkflowInstanceResponse() (response *GetWorkflowInstanceResponse)
type GrantPermissionRequest
- func CreateGrantPermissionRequest() (request *GrantPermissionRequest)
type GrantPermissionResponse
- func CreateGrantPermissionResponse() (response *GrantPermissionResponse)
type Job
type JobConfigInfo
type JobInstanceDetail
type JobInstanceDetails
type JobInstanceDetailsItem
type JobMonitorInfo
type Jobs
type ListGroupsRequest
- func CreateListGroupsRequest() (request *ListGroupsRequest)
type ListGroupsResponse
- func CreateListGroupsResponse() (response *ListGroupsResponse)
type ListJobsRequest
- func CreateListJobsRequest() (request *ListJobsRequest)
type ListJobsResponse
- func CreateListJobsResponse() (response *ListJobsResponse)
type ListNamespacesRequest
- func CreateListNamespacesRequest() (request *ListNamespacesRequest)
type ListNamespacesResponse
- func CreateListNamespacesResponse() (response *ListNamespacesResponse)
type ListWorkflowInstanceRequest
- func CreateListWorkflowInstanceRequest() (request *ListWorkflowInstanceRequest)
type ListWorkflowInstanceResponse
- func CreateListWorkflowInstanceResponse() (response *ListWorkflowInstanceResponse)
type Logs
type MapTaskXAttrs
type MonitorConfig
type Namespace
type Namespaces
type Node
type NodesInGetWorkFlow
type NodesInGetWorkflowInstance
type Region
type Regions
type RerunJobRequest
- func CreateRerunJobRequest() (request *RerunJobRequest)
type RerunJobResponse
- func CreateRerunJobResponse() (response *RerunJobResponse)
type RetryJobInstanceRequest
- func CreateRetryJobInstanceRequest() (request *RetryJobInstanceRequest)
type RetryJobInstanceResponse
- func CreateRetryJobInstanceResponse() (response *RetryJobInstanceResponse)
type RevokePermissionRequest
- func CreateRevokePermissionRequest() (request *RevokePermissionRequest)
type RevokePermissionResponse
- func CreateRevokePermissionResponse() (response *RevokePermissionResponse)
type SetJobInstanceSuccessRequest
- func CreateSetJobInstanceSuccessRequest() (request *SetJobInstanceSuccessRequest)
type SetJobInstanceSuccessResponse
- func CreateSetJobInstanceSuccessResponse() (response *SetJobInstanceSuccessResponse)
type SetWfInstanceSuccessRequest
- func CreateSetWfInstanceSuccessRequest() (request *SetWfInstanceSuccessRequest)
type SetWfInstanceSuccessResponse
- func CreateSetWfInstanceSuccessResponse() (response *SetWfInstanceSuccessResponse)
type StopInstanceRequest
- func CreateStopInstanceRequest() (request *StopInstanceRequest)
type StopInstanceResponse
- func CreateStopInstanceResponse() (response *StopInstanceResponse)
type TimeConfig
type UpdateAppGroupRequest
- func CreateUpdateAppGroupRequest() (request *UpdateAppGroupRequest)
type UpdateAppGroupResponse
- func CreateUpdateAppGroupResponse() (response *UpdateAppGroupResponse)
type UpdateJobContactInfo
type UpdateJobRequest
- func CreateUpdateJobRequest() (request *UpdateJobRequest)
type UpdateJobResponse
- func CreateUpdateJobResponse() (response *UpdateJobResponse)
type UpdateWorkflowDagRequest
- func CreateUpdateWorkflowDagRequest() (request *UpdateWorkflowDagRequest)
type UpdateWorkflowDagResponse
- func CreateUpdateWorkflowDagResponse() (response *UpdateWorkflowDagResponse)
type UpdateWorkflowRequest
- func CreateUpdateWorkflowRequest() (request *UpdateWorkflowRequest)
type UpdateWorkflowResponse
- func CreateUpdateWorkflowResponse() (response *UpdateWorkflowResponse)
type WfInstanceDag
type WfInstanceInfo
type WfInstanceInfos
type WfInstanceInfosItem
type WorkFlowInfo
type WorkFlowNodeInfo
type WorkerInfo
type WorkerInfos

Constants ¶

This section is empty.

Variables ¶

View Source

var EndpointMap map[string]string

EndpointMap Endpoint Data

View Source

var EndpointType = "regional"

EndpointType regional or central

Functions ¶

func GetEndpointMap ¶

func GetEndpointMap() map[string]string

GetEndpointMap Get Endpoint Data Map

func GetEndpointType ¶

func GetEndpointType() string

GetEndpointType Get Endpoint Type Value

func SetClientProperty ¶

func SetClientProperty(client *Client, propertyName string, propertyValue interface{})

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

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 ¶

type Client struct {
	sdk.Client
}

Client is the sdk client struct, each func corresponds to an OpenAPI

func NewClient ¶

func NewClient() (client *Client, err error)

NewClient creates a sdk client with environment variables

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 ¶

func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)

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"`
	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
	GroupId         string           `position:"Query" name:"GroupId"`
	StrategyContent string           `position:"Query" name:"StrategyContent"`
	Type            requests.Integer `position:"Query" name:"Type"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	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"`
	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"`
	GroupId         string           `position:"Query" name:"GroupId"`
	StartTimestamp  requests.Integer `position:"Query" name:"StartTimestamp"`
	EndTimestamp    requests.Integer `position:"Query" name:"EndTimestamp"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	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"`
	GroupId         string           `position:"Query" name:"GroupId"`
	EndTime         requests.Integer `position:"Query" name:"EndTime"`
	StartTime       requests.Integer `position:"Query" name:"StartTime"`
	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"`
	GroupId         string           `position:"Body" name:"GroupId"`
	StartDate       requests.Integer `position:"Body" name:"StartDate"`
	JobId           requests.Integer `position:"Body" name:"JobId"`
	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"`
	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 ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL