schedulerx2

package
v1.62.122 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

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 {
	AppName     string `json:"AppName" xml:"AppName"`
	AppKey      string `json:"AppKey" xml:"AppKey"`
	Description string `json:"Description" xml:"Description"`
	GroupId     string `json:"GroupId" xml:"GroupId"`
}

AppGroup is a nested struct in schedulerx2 response

type AppGroups added in v1.61.948 

type AppGroups struct {
	AppGroup []AppGroup `json:"AppGroup" xml:"AppGroup"`
}

AppGroups is a nested struct in schedulerx2 response

type BatchDeleteJobsRequest added in v1.61.948 

type BatchDeleteJobsRequest struct {
	*requests.RpcRequest
	NamespaceSource string    `position:"Query" name:"NamespaceSource"`
	GroupId         string    `position:"Query" name:"GroupId"`
	JobIdList       *[]string `position:"Body" name:"JobIdList"  type:"Repeated"`
	Namespace       string    `position:"Query" name:"Namespace"`
}

BatchDeleteJobsRequest is the request struct for api BatchDeleteJobs

func CreateBatchDeleteJobsRequest added in v1.61.948 

func CreateBatchDeleteJobsRequest() (request *BatchDeleteJobsRequest)

CreateBatchDeleteJobsRequest creates a request to invoke BatchDeleteJobs API

type BatchDeleteJobsResponse added in v1.61.948 

type BatchDeleteJobsResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

BatchDeleteJobsResponse is the response struct for api BatchDeleteJobs

func CreateBatchDeleteJobsResponse added in v1.61.948 

func CreateBatchDeleteJobsResponse() (response *BatchDeleteJobsResponse)

CreateBatchDeleteJobsResponse creates a response to parse from BatchDeleteJobs response

type BatchDisableJobsRequest added in v1.61.948 

type BatchDisableJobsRequest struct {
	*requests.RpcRequest
	NamespaceSource string    `position:"Query" name:"NamespaceSource"`
	GroupId         string    `position:"Query" name:"GroupId"`
	JobIdList       *[]string `position:"Body" name:"JobIdList"  type:"Repeated"`
	Namespace       string    `position:"Query" name:"Namespace"`
}

BatchDisableJobsRequest is the request struct for api BatchDisableJobs

func CreateBatchDisableJobsRequest added in v1.61.948 

func CreateBatchDisableJobsRequest() (request *BatchDisableJobsRequest)

CreateBatchDisableJobsRequest creates a request to invoke BatchDisableJobs API

type BatchDisableJobsResponse added in v1.61.948 

type BatchDisableJobsResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

BatchDisableJobsResponse is the response struct for api BatchDisableJobs

func CreateBatchDisableJobsResponse added in v1.61.948 

func CreateBatchDisableJobsResponse() (response *BatchDisableJobsResponse)

CreateBatchDisableJobsResponse creates a response to parse from BatchDisableJobs response

type BatchEnableJobsRequest added in v1.61.948 

type BatchEnableJobsRequest struct {
	*requests.RpcRequest
	NamespaceSource string    `position:"Query" name:"NamespaceSource"`
	GroupId         string    `position:"Query" name:"GroupId"`
	JobIdList       *[]string `position:"Body" name:"JobIdList"  type:"Repeated"`
	Namespace       string    `position:"Query" name:"Namespace"`
}

BatchEnableJobsRequest is the request struct for api BatchEnableJobs

func CreateBatchEnableJobsRequest added in v1.61.948 

func CreateBatchEnableJobsRequest() (request *BatchEnableJobsRequest)

CreateBatchEnableJobsRequest creates a request to invoke BatchEnableJobs API

type BatchEnableJobsResponse added in v1.61.948 

type BatchEnableJobsResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

BatchEnableJobsResponse is the response struct for api BatchEnableJobs

func CreateBatchEnableJobsResponse added in v1.61.948 

func CreateBatchEnableJobsResponse() (response *BatchEnableJobsResponse)

CreateBatchEnableJobsResponse creates a response to parse from BatchEnableJobs response

type Client 

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) BatchDisableJobs added in v1.61.948 

func (client *Client) BatchDisableJobs(request *BatchDisableJobsRequest) (response *BatchDisableJobsResponse, err error)

BatchDisableJobs invokes the schedulerx2.BatchDisableJobs API synchronously

func (*Client) BatchDisableJobsWithCallback added in v1.61.948 

func (client *Client) BatchDisableJobsWithCallback(request *BatchDisableJobsRequest, callback func(response *BatchDisableJobsResponse, err error)) <-chan int

BatchDisableJobsWithCallback invokes the schedulerx2.BatchDisableJobs API asynchronously

func (*Client) BatchDisableJobsWithChan added in v1.61.948 

func (client *Client) BatchDisableJobsWithChan(request *BatchDisableJobsRequest) (<-chan *BatchDisableJobsResponse, <-chan error)

BatchDisableJobsWithChan invokes the schedulerx2.BatchDisableJobs API asynchronously

func (*Client) BatchEnableJobs added in v1.61.948 

func (client *Client) BatchEnableJobs(request *BatchEnableJobsRequest) (response *BatchEnableJobsResponse, err error)

BatchEnableJobs invokes the schedulerx2.BatchEnableJobs API synchronously

func (*Client) BatchEnableJobsWithCallback added in v1.61.948 

func (client *Client) BatchEnableJobsWithCallback(request *BatchEnableJobsRequest, callback func(response *BatchEnableJobsResponse, err error)) <-chan int

BatchEnableJobsWithCallback invokes the schedulerx2.BatchEnableJobs API asynchronously

func (*Client) BatchEnableJobsWithChan added in v1.61.948 

func (client *Client) BatchEnableJobsWithChan(request *BatchEnableJobsRequest) (<-chan *BatchEnableJobsResponse, <-chan error)

BatchEnableJobsWithChan invokes the schedulerx2.BatchEnableJobs API asynchronously

func (*Client) CreateAppGroup 

func (client *Client) CreateAppGroup(request *CreateAppGroupRequest) (response *CreateAppGroupResponse, err error)

CreateAppGroup invokes the schedulerx2.CreateAppGroup API synchronously

func (*Client) CreateAppGroupWithCallback 

func (client *Client) CreateAppGroupWithCallback(request *CreateAppGroupRequest, callback func(response *CreateAppGroupResponse, err error)) <-chan int

CreateAppGroupWithCallback invokes the schedulerx2.CreateAppGroup API asynchronously

func (*Client) CreateAppGroupWithChan 

func (client *Client) CreateAppGroupWithChan(request *CreateAppGroupRequest) (<-chan *CreateAppGroupResponse, <-chan error)

CreateAppGroupWithChan invokes the schedulerx2.CreateAppGroup API asynchronously

func (*Client) CreateJob 

func (client *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)

CreateJob invokes the schedulerx2.CreateJob API synchronously

func (*Client) CreateJobWithCallback 

func (client *Client) CreateJobWithCallback(request *CreateJobRequest, callback func(response *CreateJobResponse, err error)) <-chan int

CreateJobWithCallback invokes the schedulerx2.CreateJob API asynchronously

func (*Client) CreateJobWithChan 

func (client *Client) CreateJobWithChan(request *CreateJobRequest) (<-chan *CreateJobResponse, <-chan error)

CreateJobWithChan invokes the schedulerx2.CreateJob API asynchronously

func (*Client) CreateNamespace added in v1.61.1529 

func (client *Client) CreateNamespace(request *CreateNamespaceRequest) (response *CreateNamespaceResponse, err error)

CreateNamespace invokes the schedulerx2.CreateNamespace API synchronously

func (*Client) CreateNamespaceWithCallback added in v1.61.1529 

func (client *Client) CreateNamespaceWithCallback(request *CreateNamespaceRequest, callback func(response *CreateNamespaceResponse, err error)) <-chan int

CreateNamespaceWithCallback invokes the schedulerx2.CreateNamespace API asynchronously

func (*Client) CreateNamespaceWithChan added in v1.61.1529 

func (client *Client) CreateNamespaceWithChan(request *CreateNamespaceRequest) (<-chan *CreateNamespaceResponse, <-chan error)

CreateNamespaceWithChan invokes the schedulerx2.CreateNamespace API asynchronously

func (*Client) DeleteJob 

func (client *Client) DeleteJob(request *DeleteJobRequest) (response *DeleteJobResponse, err error)

DeleteJob invokes the schedulerx2.DeleteJob API synchronously

func (*Client) DeleteJobWithCallback 

func (client *Client) DeleteJobWithCallback(request *DeleteJobRequest, callback func(response *DeleteJobResponse, err error)) <-chan int

DeleteJobWithCallback invokes the schedulerx2.DeleteJob API asynchronously

func (*Client) DeleteJobWithChan 

func (client *Client) DeleteJobWithChan(request *DeleteJobRequest) (<-chan *DeleteJobResponse, <-chan error)

DeleteJobWithChan invokes the schedulerx2.DeleteJob API asynchronously

func (*Client) DeleteWorkflow 

func (client *Client) DeleteWorkflow(request *DeleteWorkflowRequest) (response *DeleteWorkflowResponse, err error)

DeleteWorkflow invokes the schedulerx2.DeleteWorkflow API synchronously

func (*Client) DeleteWorkflowWithCallback 

func (client *Client) DeleteWorkflowWithCallback(request *DeleteWorkflowRequest, callback func(response *DeleteWorkflowResponse, err error)) <-chan int

DeleteWorkflowWithCallback invokes the schedulerx2.DeleteWorkflow API asynchronously

func (*Client) DeleteWorkflowWithChan 

func (client *Client) DeleteWorkflowWithChan(request *DeleteWorkflowRequest) (<-chan *DeleteWorkflowResponse, <-chan error)

DeleteWorkflowWithChan invokes the schedulerx2.DeleteWorkflow API asynchronously

func (*Client) DescribeRegions 

func (client *Client) DescribeRegions(request *DescribeRegionsRequest) (response *DescribeRegionsResponse, err error)

DescribeRegions invokes the schedulerx2.DescribeRegions API synchronously

func (*Client) DescribeRegionsWithCallback 

func (client *Client) DescribeRegionsWithCallback(request *DescribeRegionsRequest, callback func(response *DescribeRegionsResponse, err error)) <-chan int

DescribeRegionsWithCallback invokes the schedulerx2.DescribeRegions API asynchronously

func (*Client) DescribeRegionsWithChan 

func (client *Client) DescribeRegionsWithChan(request *DescribeRegionsRequest) (<-chan *DescribeRegionsResponse, <-chan error)

DescribeRegionsWithChan invokes the schedulerx2.DescribeRegions API asynchronously

func (*Client) DesignateWorkers added in v1.61.1394 

func (client *Client) DesignateWorkers(request *DesignateWorkersRequest) (response *DesignateWorkersResponse, err error)

DesignateWorkers invokes the schedulerx2.DesignateWorkers API synchronously

func (*Client) DesignateWorkersWithCallback added in v1.61.1394 

func (client *Client) DesignateWorkersWithCallback(request *DesignateWorkersRequest, callback func(response *DesignateWorkersResponse, err error)) <-chan int

DesignateWorkersWithCallback invokes the schedulerx2.DesignateWorkers API asynchronously

func (*Client) DesignateWorkersWithChan added in v1.61.1394 

func (client *Client) DesignateWorkersWithChan(request *DesignateWorkersRequest) (<-chan *DesignateWorkersResponse, <-chan error)

DesignateWorkersWithChan invokes the schedulerx2.DesignateWorkers API asynchronously

func (*Client) DisableJob 

func (client *Client) DisableJob(request *DisableJobRequest) (response *DisableJobResponse, err error)

DisableJob invokes the schedulerx2.DisableJob API synchronously

func (*Client) DisableJobWithCallback 

func (client *Client) DisableJobWithCallback(request *DisableJobRequest, callback func(response *DisableJobResponse, err error)) <-chan int

DisableJobWithCallback invokes the schedulerx2.DisableJob API asynchronously

func (*Client) DisableJobWithChan 

func (client *Client) DisableJobWithChan(request *DisableJobRequest) (<-chan *DisableJobResponse, <-chan error)

DisableJobWithChan invokes the schedulerx2.DisableJob API asynchronously

func (*Client) DisableWorkflow 

func (client *Client) DisableWorkflow(request *DisableWorkflowRequest) (response *DisableWorkflowResponse, err error)

DisableWorkflow invokes the schedulerx2.DisableWorkflow API synchronously

func (*Client) DisableWorkflowWithCallback 

func (client *Client) DisableWorkflowWithCallback(request *DisableWorkflowRequest, callback func(response *DisableWorkflowResponse, err error)) <-chan int

DisableWorkflowWithCallback invokes the schedulerx2.DisableWorkflow API asynchronously

func (*Client) DisableWorkflowWithChan 

func (client *Client) DisableWorkflowWithChan(request *DisableWorkflowRequest) (<-chan *DisableWorkflowResponse, <-chan error)

DisableWorkflowWithChan invokes the schedulerx2.DisableWorkflow API asynchronously

func (*Client) EnableJob 

func (client *Client) EnableJob(request *EnableJobRequest) (response *EnableJobResponse, err error)

EnableJob invokes the schedulerx2.EnableJob API synchronously

func (*Client) EnableJobWithCallback 

func (client *Client) EnableJobWithCallback(request *EnableJobRequest, callback func(response *EnableJobResponse, err error)) <-chan int

EnableJobWithCallback invokes the schedulerx2.EnableJob API asynchronously

func (*Client) EnableJobWithChan 

func (client *Client) EnableJobWithChan(request *EnableJobRequest) (<-chan *EnableJobResponse, <-chan error)

EnableJobWithChan invokes the schedulerx2.EnableJob API asynchronously

func (*Client) EnableWorkflow 

func (client *Client) EnableWorkflow(request *EnableWorkflowRequest) (response *EnableWorkflowResponse, err error)

EnableWorkflow invokes the schedulerx2.EnableWorkflow API synchronously

func (*Client) EnableWorkflowWithCallback 

func (client *Client) EnableWorkflowWithCallback(request *EnableWorkflowRequest, callback func(response *EnableWorkflowResponse, err error)) <-chan int

EnableWorkflowWithCallback invokes the schedulerx2.EnableWorkflow API asynchronously

func (*Client) EnableWorkflowWithChan 

func (client *Client) EnableWorkflowWithChan(request *EnableWorkflowRequest) (<-chan *EnableWorkflowResponse, <-chan error)

EnableWorkflowWithChan invokes the schedulerx2.EnableWorkflow API asynchronously

func (*Client) ExecuteJob 

func (client *Client) ExecuteJob(request *ExecuteJobRequest) (response *ExecuteJobResponse, err error)

ExecuteJob invokes the schedulerx2.ExecuteJob API synchronously

func (*Client) ExecuteJobWithCallback 

func (client *Client) ExecuteJobWithCallback(request *ExecuteJobRequest, callback func(response *ExecuteJobResponse, err error)) <-chan int

ExecuteJobWithCallback invokes the schedulerx2.ExecuteJob API asynchronously

func (*Client) ExecuteJobWithChan 

func (client *Client) ExecuteJobWithChan(request *ExecuteJobRequest) (<-chan *ExecuteJobResponse, <-chan error)

ExecuteJobWithChan invokes the schedulerx2.ExecuteJob API asynchronously

func (*Client) ExecuteWorkflow 

func (client *Client) ExecuteWorkflow(request *ExecuteWorkflowRequest) (response *ExecuteWorkflowResponse, err error)

ExecuteWorkflow invokes the schedulerx2.ExecuteWorkflow API synchronously

func (*Client) ExecuteWorkflowWithCallback 

func (client *Client) ExecuteWorkflowWithCallback(request *ExecuteWorkflowRequest, callback func(response *ExecuteWorkflowResponse, err error)) <-chan int

ExecuteWorkflowWithCallback invokes the schedulerx2.ExecuteWorkflow API asynchronously

func (*Client) ExecuteWorkflowWithChan 

func (client *Client) ExecuteWorkflowWithChan(request *ExecuteWorkflowRequest) (<-chan *ExecuteWorkflowResponse, <-chan error)

ExecuteWorkflowWithChan invokes the schedulerx2.ExecuteWorkflow API asynchronously

func (*Client) GetJobInfo 

func (client *Client) GetJobInfo(request *GetJobInfoRequest) (response *GetJobInfoResponse, err error)

GetJobInfo invokes the schedulerx2.GetJobInfo API synchronously

func (*Client) GetJobInfoWithCallback 

func (client *Client) GetJobInfoWithCallback(request *GetJobInfoRequest, callback func(response *GetJobInfoResponse, err error)) <-chan int

GetJobInfoWithCallback invokes the schedulerx2.GetJobInfo API asynchronously

func (*Client) GetJobInfoWithChan 

func (client *Client) GetJobInfoWithChan(request *GetJobInfoRequest) (<-chan *GetJobInfoResponse, <-chan error)

GetJobInfoWithChan invokes the schedulerx2.GetJobInfo API asynchronously

func (*Client) GetJobInstance 

func (client *Client) GetJobInstance(request *GetJobInstanceRequest) (response *GetJobInstanceResponse, err error)

GetJobInstance invokes the schedulerx2.GetJobInstance API synchronously

func (*Client) GetJobInstanceList 

func (client *Client) GetJobInstanceList(request *GetJobInstanceListRequest) (response *GetJobInstanceListResponse, err error)

GetJobInstanceList invokes the schedulerx2.GetJobInstanceList API synchronously

func (*Client) GetJobInstanceListWithCallback 

func (client *Client) GetJobInstanceListWithCallback(request *GetJobInstanceListRequest, callback func(response *GetJobInstanceListResponse, err error)) <-chan int

GetJobInstanceListWithCallback invokes the schedulerx2.GetJobInstanceList API asynchronously

func (*Client) GetJobInstanceListWithChan 

func (client *Client) GetJobInstanceListWithChan(request *GetJobInstanceListRequest) (<-chan *GetJobInstanceListResponse, <-chan error)

GetJobInstanceListWithChan invokes the schedulerx2.GetJobInstanceList API asynchronously

func (*Client) GetJobInstanceWithCallback 

func (client *Client) GetJobInstanceWithCallback(request *GetJobInstanceRequest, callback func(response *GetJobInstanceResponse, err error)) <-chan int

GetJobInstanceWithCallback invokes the schedulerx2.GetJobInstance API asynchronously

func (*Client) GetJobInstanceWithChan 

func (client *Client) GetJobInstanceWithChan(request *GetJobInstanceRequest) (<-chan *GetJobInstanceResponse, <-chan error)

GetJobInstanceWithChan invokes the schedulerx2.GetJobInstance API asynchronously

func (*Client) GetWorkFlow added in v1.61.1394 

func (client *Client) GetWorkFlow(request *GetWorkFlowRequest) (response *GetWorkFlowResponse, err error)

GetWorkFlow invokes the schedulerx2.GetWorkFlow API synchronously

func (*Client) GetWorkFlowWithCallback added in v1.61.1394 

func (client *Client) GetWorkFlowWithCallback(request *GetWorkFlowRequest, callback func(response *GetWorkFlowResponse, err error)) <-chan int

GetWorkFlowWithCallback invokes the schedulerx2.GetWorkFlow API asynchronously

func (*Client) GetWorkFlowWithChan added in v1.61.1394 

func (client *Client) GetWorkFlowWithChan(request *GetWorkFlowRequest) (<-chan *GetWorkFlowResponse, <-chan error)

GetWorkFlowWithChan invokes the schedulerx2.GetWorkFlow API asynchronously

func (*Client) GetWorkerList added in v1.61.1420 

func (client *Client) GetWorkerList(request *GetWorkerListRequest) (response *GetWorkerListResponse, err error)

GetWorkerList invokes the schedulerx2.GetWorkerList API synchronously

func (*Client) GetWorkerListWithCallback added in v1.61.1420 

func (client *Client) GetWorkerListWithCallback(request *GetWorkerListRequest, callback func(response *GetWorkerListResponse, err error)) <-chan int

GetWorkerListWithCallback invokes the schedulerx2.GetWorkerList API asynchronously

func (*Client) GetWorkerListWithChan added in v1.61.1420 

func (client *Client) GetWorkerListWithChan(request *GetWorkerListRequest) (<-chan *GetWorkerListResponse, <-chan error)

GetWorkerListWithChan invokes the schedulerx2.GetWorkerList API asynchronously

func (*Client) GrantPermission 

func (client *Client) GrantPermission(request *GrantPermissionRequest) (response *GrantPermissionResponse, err error)

GrantPermission invokes the schedulerx2.GrantPermission API synchronously

func (*Client) GrantPermissionWithCallback 

func (client *Client) GrantPermissionWithCallback(request *GrantPermissionRequest, callback func(response *GrantPermissionResponse, err error)) <-chan int

GrantPermissionWithCallback invokes the schedulerx2.GrantPermission API asynchronously

func (*Client) GrantPermissionWithChan 

func (client *Client) GrantPermissionWithChan(request *GrantPermissionRequest) (<-chan *GrantPermissionResponse, <-chan error)

GrantPermissionWithChan invokes the schedulerx2.GrantPermission API asynchronously

func (*Client) ListGroups added in v1.61.948 

func (client *Client) ListGroups(request *ListGroupsRequest) (response *ListGroupsResponse, err error)

ListGroups invokes the schedulerx2.ListGroups API synchronously

func (*Client) ListGroupsWithCallback added in v1.61.948 

func (client *Client) ListGroupsWithCallback(request *ListGroupsRequest, callback func(response *ListGroupsResponse, err error)) <-chan int

ListGroupsWithCallback invokes the schedulerx2.ListGroups API asynchronously

func (*Client) ListGroupsWithChan added in v1.61.948 

func (client *Client) ListGroupsWithChan(request *ListGroupsRequest) (<-chan *ListGroupsResponse, <-chan error)

ListGroupsWithChan invokes the schedulerx2.ListGroups API asynchronously

func (*Client) ListJobs added in v1.61.948 

func (client *Client) ListJobs(request *ListJobsRequest) (response *ListJobsResponse, err error)

ListJobs invokes the schedulerx2.ListJobs API synchronously

func (*Client) ListJobsWithCallback added in v1.61.948 

func (client *Client) ListJobsWithCallback(request *ListJobsRequest, callback func(response *ListJobsResponse, err error)) <-chan int

ListJobsWithCallback invokes the schedulerx2.ListJobs API asynchronously

func (*Client) ListJobsWithChan added in v1.61.948 

func (client *Client) ListJobsWithChan(request *ListJobsRequest) (<-chan *ListJobsResponse, <-chan error)

ListJobsWithChan invokes the schedulerx2.ListJobs API asynchronously

func (*Client) ListNamespaces added in v1.61.948 

func (client *Client) ListNamespaces(request *ListNamespacesRequest) (response *ListNamespacesResponse, err error)

ListNamespaces invokes the schedulerx2.ListNamespaces API synchronously

func (*Client) ListNamespacesWithCallback added in v1.61.948 

func (client *Client) ListNamespacesWithCallback(request *ListNamespacesRequest, callback func(response *ListNamespacesResponse, err error)) <-chan int

ListNamespacesWithCallback invokes the schedulerx2.ListNamespaces API asynchronously

func (*Client) ListNamespacesWithChan added in v1.61.948 

func (client *Client) ListNamespacesWithChan(request *ListNamespacesRequest) (<-chan *ListNamespacesResponse, <-chan error)

ListNamespacesWithChan invokes the schedulerx2.ListNamespaces API asynchronously

func (*Client) RevokePermission 

func (client *Client) RevokePermission(request *RevokePermissionRequest) (response *RevokePermissionResponse, err error)

RevokePermission invokes the schedulerx2.RevokePermission API synchronously

func (*Client) RevokePermissionWithCallback 

func (client *Client) RevokePermissionWithCallback(request *RevokePermissionRequest, callback func(response *RevokePermissionResponse, err error)) <-chan int

RevokePermissionWithCallback invokes the schedulerx2.RevokePermission API asynchronously

func (*Client) RevokePermissionWithChan 

func (client *Client) RevokePermissionWithChan(request *RevokePermissionRequest) (<-chan *RevokePermissionResponse, <-chan error)

RevokePermissionWithChan invokes the schedulerx2.RevokePermission API asynchronously

func (*Client) StopInstance 

func (client *Client) StopInstance(request *StopInstanceRequest) (response *StopInstanceResponse, err error)

StopInstance invokes the schedulerx2.StopInstance API synchronously

func (*Client) StopInstanceWithCallback 

func (client *Client) StopInstanceWithCallback(request *StopInstanceRequest, callback func(response *StopInstanceResponse, err error)) <-chan int

StopInstanceWithCallback invokes the schedulerx2.StopInstance API asynchronously

func (*Client) StopInstanceWithChan 

func (client *Client) StopInstanceWithChan(request *StopInstanceRequest) (<-chan *StopInstanceResponse, <-chan error)

StopInstanceWithChan invokes the schedulerx2.StopInstance API asynchronously

func (*Client) UpdateJob 

func (client *Client) UpdateJob(request *UpdateJobRequest) (response *UpdateJobResponse, err error)

UpdateJob invokes the schedulerx2.UpdateJob API synchronously

func (*Client) UpdateJobWithCallback 

func (client *Client) UpdateJobWithCallback(request *UpdateJobRequest, callback func(response *UpdateJobResponse, err error)) <-chan int

UpdateJobWithCallback invokes the schedulerx2.UpdateJob API asynchronously

func (*Client) UpdateJobWithChan 

func (client *Client) UpdateJobWithChan(request *UpdateJobRequest) (<-chan *UpdateJobResponse, <-chan error)

UpdateJobWithChan invokes the schedulerx2.UpdateJob API asynchronously

type ContactInfoInGetJobInfo added in v1.61.948 

type ContactInfoInGetJobInfo struct {
	ContactInfoItem []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"`
}

ContactInfoInGetJobInfo is a nested struct in schedulerx2 response

type ContactInfoInListJobs added in v1.61.948 

type ContactInfoInListJobs struct {
	ContactInfoItem []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"`
}

ContactInfoInListJobs is a nested struct in schedulerx2 response

type ContactInfoItem 

type ContactInfoItem struct {
	UserMail  string `json:"UserMail" xml:"UserMail"`
	UserPhone string `json:"UserPhone" xml:"UserPhone"`
	UserName  string `json:"UserName" xml:"UserName"`
	Ding      string `json:"Ding" xml:"Ding"`
}

ContactInfoItem is a nested struct in schedulerx2 response

type CreateAppGroupRequest 

type CreateAppGroupRequest struct {
	*requests.RpcRequest
	NamespaceName        string           `position:"Query" name:"NamespaceName"`
	NamespaceSource      string           `position:"Query" name:"NamespaceSource"`
	ScheduleBusyWorkers  requests.Boolean `position:"Query" name:"ScheduleBusyWorkers"`
	Description          string           `position:"Query" name:"Description"`
	AppName              string           `position:"Query" name:"AppName"`
	AlarmJson            string           `position:"Query" name:"AlarmJson"`
	MonitorContactsJson  string           `position:"Query" name:"MonitorContactsJson"`
	MaxJobs              requests.Integer `position:"Query" name:"MaxJobs"`
	MetricsThresholdJson string           `position:"Query" name:"MetricsThresholdJson"`
	GroupId              string           `position:"Query" name:"GroupId"`
	AppType              requests.Integer `position:"Query" name:"AppType"`
	MonitorConfigJson    string           `position:"Query" name:"MonitorConfigJson"`
	Namespace            string           `position:"Query" name:"Namespace"`
	AppKey               string           `position:"Query" name:"AppKey"`
}

CreateAppGroupRequest is the request struct for api CreateAppGroup

func CreateCreateAppGroupRequest 

func CreateCreateAppGroupRequest() (request *CreateAppGroupRequest)

CreateCreateAppGroupRequest creates a request to invoke CreateAppGroup API

type CreateAppGroupResponse 

type CreateAppGroupResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

CreateAppGroupResponse is the response struct for api CreateAppGroup

func CreateCreateAppGroupResponse 

func CreateCreateAppGroupResponse() (response *CreateAppGroupResponse)

CreateCreateAppGroupResponse creates a response to parse from CreateAppGroup response

type CreateJobContactInfo 

type CreateJobContactInfo struct {
	Ding      string `name:"Ding"`
	UserPhone string `name:"UserPhone"`
	UserMail  string `name:"UserMail"`
	UserName  string `name:"UserName"`
}

CreateJobContactInfo is a repeated param struct in CreateJobRequest

type CreateJobRequest 

type CreateJobRequest struct {
	*requests.RpcRequest
	AttemptInterval     requests.Integer        `position:"Body" name:"AttemptInterval"`
	ConsumerSize        requests.Integer        `position:"Body" name:"ConsumerSize"`
	JarUrl              string                  `position:"Body" name:"JarUrl"`
	DataOffset          requests.Integer        `position:"Body" name:"DataOffset"`
	GroupId             string                  `position:"Body" name:"GroupId"`
	TaskMaxAttempt      requests.Integer        `position:"Body" name:"TaskMaxAttempt"`
	DispatcherSize      requests.Integer        `position:"Body" name:"DispatcherSize"`
	JobType             string                  `position:"Body" name:"JobType"`
	TaskAttemptInterval requests.Integer        `position:"Body" name:"TaskAttemptInterval"`
	ExecuteMode         string                  `position:"Body" name:"ExecuteMode"`
	TimeExpression      string                  `position:"Body" name:"TimeExpression"`
	TimeoutEnable       requests.Boolean        `position:"Body" name:"TimeoutEnable"`
	ContactInfo         *[]CreateJobContactInfo `position:"Body" name:"ContactInfo"  type:"Repeated"`
	Name                string                  `position:"Body" name:"Name"`
	TimeType            requests.Integer        `position:"Body" name:"TimeType"`
	Parameters          string                  `position:"Body" name:"Parameters"`
	Status              requests.Integer        `position:"Body" name:"Status"`
	NamespaceSource     string                  `position:"Body" name:"NamespaceSource"`
	Description         string                  `position:"Body" name:"Description"`
	Content             string                  `position:"Body" name:"Content"`
	Timeout             requests.Integer        `position:"Body" name:"Timeout"`
	TimeoutKillEnable   requests.Boolean        `position:"Body" name:"TimeoutKillEnable"`
	PageSize            requests.Integer        `position:"Body" name:"PageSize"`
	Calendar            string                  `position:"Body" name:"Calendar"`
	FailEnable          requests.Boolean        `position:"Body" name:"FailEnable"`
	SendChannel         string                  `position:"Body" name:"SendChannel"`
	MaxAttempt          requests.Integer        `position:"Body" name:"MaxAttempt"`
	MissWorkerEnable    requests.Boolean        `position:"Body" name:"MissWorkerEnable"`
	QueueSize           requests.Integer        `position:"Body" name:"QueueSize"`
	ClassName           string                  `position:"Body" name:"ClassName"`
	Namespace           string                  `position:"Body" name:"Namespace"`
	XAttrs              string                  `position:"Body" name:"XAttrs"`
	MaxConcurrency      requests.Integer        `position:"Body" name:"MaxConcurrency"`
}

CreateJobRequest is the request struct for api CreateJob

func CreateCreateJobRequest 

func CreateCreateJobRequest() (request *CreateJobRequest)

CreateCreateJobRequest creates a request to invoke CreateJob API

type CreateJobResponse 

type CreateJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

CreateJobResponse is the response struct for api CreateJob

func CreateCreateJobResponse 

func CreateCreateJobResponse() (response *CreateJobResponse)

CreateCreateJobResponse creates a response to parse from CreateJob response

type CreateNamespaceRequest added in v1.61.1529 

type CreateNamespaceRequest struct {
	*requests.RpcRequest
	Description string `position:"Query" name:"Description"`
	Source      string `position:"Query" name:"Source"`
	Uid         string `position:"Query" name:"Uid"`
	Name        string `position:"Query" name:"Name"`
}

CreateNamespaceRequest is the request struct for api CreateNamespace

func CreateCreateNamespaceRequest added in v1.61.1529 

func CreateCreateNamespaceRequest() (request *CreateNamespaceRequest)

CreateCreateNamespaceRequest creates a request to invoke CreateNamespace API

type CreateNamespaceResponse added in v1.61.1529 

type CreateNamespaceResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

CreateNamespaceResponse is the response struct for api CreateNamespace

func CreateCreateNamespaceResponse added in v1.61.1529 

func CreateCreateNamespaceResponse() (response *CreateNamespaceResponse)

CreateCreateNamespaceResponse creates a response to parse from CreateNamespace response

type Data 

type Data struct {
	JobId              int64                    `json:"JobId" xml:"JobId"`
	JobInstanceId      int64                    `json:"JobInstanceId" xml:"JobInstanceId"`
	AppKey             string                   `json:"AppKey" xml:"AppKey"`
	WfInstanceId       int64                    `json:"WfInstanceId" xml:"WfInstanceId"`
	AppGroupId         int64                    `json:"AppGroupId" xml:"AppGroupId"`
	NamespaceUid       string                   `json:"NamespaceUid" xml:"NamespaceUid"`
	JobInstanceDetail  JobInstanceDetail        `json:"JobInstanceDetail" xml:"JobInstanceDetail"`
	WorkFlowInfo       WorkFlowInfo             `json:"WorkFlowInfo" xml:"WorkFlowInfo"`
	JobConfigInfo      JobConfigInfo            `json:"JobConfigInfo" xml:"JobConfigInfo"`
	WorkFlowNodeInfo   WorkFlowNodeInfo         `json:"WorkFlowNodeInfo" xml:"WorkFlowNodeInfo"`
	WorkerInfos        []WorkerInfo             `json:"WorkerInfos" xml:"WorkerInfos"`
	Namespaces         []Namespace              `json:"Namespaces" xml:"Namespaces"`
	JobInstanceDetails []JobInstanceDetailsItem `json:"JobInstanceDetails" xml:"JobInstanceDetails"`
	AppGroups          []AppGroup               `json:"AppGroups" xml:"AppGroups"`
	Jobs               []Job                    `json:"Jobs" xml:"Jobs"`
}

Data is a nested struct in schedulerx2 response

type DeleteJobRequest 

type DeleteJobRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

DeleteJobRequest is the request struct for api DeleteJob

func CreateDeleteJobRequest 

func CreateDeleteJobRequest() (request *DeleteJobRequest)

CreateDeleteJobRequest creates a request to invoke DeleteJob API

type DeleteJobResponse 

type DeleteJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteJobResponse is the response struct for api DeleteJob

func CreateDeleteJobResponse 

func CreateDeleteJobResponse() (response *DeleteJobResponse)

CreateDeleteJobResponse creates a response to parse from DeleteJob response

type DeleteWorkflowRequest 

type DeleteWorkflowRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	WorkflowId      requests.Integer `position:"Query" name:"WorkflowId"`
}

DeleteWorkflowRequest is the request struct for api DeleteWorkflow

func CreateDeleteWorkflowRequest 

func CreateDeleteWorkflowRequest() (request *DeleteWorkflowRequest)

CreateDeleteWorkflowRequest creates a request to invoke DeleteWorkflow API

type DeleteWorkflowResponse 

type DeleteWorkflowResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DeleteWorkflowResponse is the response struct for api DeleteWorkflow

func CreateDeleteWorkflowResponse 

func CreateDeleteWorkflowResponse() (response *DeleteWorkflowResponse)

CreateDeleteWorkflowResponse creates a response to parse from DeleteWorkflow response

type DescribeRegionsRequest 

type DescribeRegionsRequest struct {
	*requests.RpcRequest
}

DescribeRegionsRequest is the request struct for api DescribeRegions

func CreateDescribeRegionsRequest 

func CreateDescribeRegionsRequest() (request *DescribeRegionsRequest)

CreateDescribeRegionsRequest creates a request to invoke DescribeRegions API

type DescribeRegionsResponse 

type DescribeRegionsResponse struct {
	*responses.BaseResponse
	Code      int      `json:"Code" xml:"Code"`
	Message   string   `json:"Message" xml:"Message"`
	RequestId string   `json:"RequestId" xml:"RequestId"`
	Success   bool     `json:"Success" xml:"Success"`
	Regions   []Region `json:"Regions" xml:"Regions"`
}

DescribeRegionsResponse is the response struct for api DescribeRegions

func CreateDescribeRegionsResponse 

func CreateDescribeRegionsResponse() (response *DescribeRegionsResponse)

CreateDescribeRegionsResponse creates a response to parse from DescribeRegions response

type DesignateWorkersRequest added in v1.61.1394 

type DesignateWorkersRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	Transferable    requests.Boolean `position:"Query" name:"Transferable"`
	DesignateType   requests.Integer `position:"Query" name:"DesignateType"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Workers         string           `position:"Query" name:"Workers"`
	GroupId         string           `position:"Query" name:"GroupId"`
	Labels          string           `position:"Query" name:"Labels"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

DesignateWorkersRequest is the request struct for api DesignateWorkers

func CreateDesignateWorkersRequest added in v1.61.1394 

func CreateDesignateWorkersRequest() (request *DesignateWorkersRequest)

CreateDesignateWorkersRequest creates a request to invoke DesignateWorkers API

type DesignateWorkersResponse added in v1.61.1394 

type DesignateWorkersResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Message   string `json:"Message" xml:"Message"`
	Code      int    `json:"Code" xml:"Code"`
	Success   bool   `json:"Success" xml:"Success"`
}

DesignateWorkersResponse is the response struct for api DesignateWorkers

func CreateDesignateWorkersResponse added in v1.61.1394 

func CreateDesignateWorkersResponse() (response *DesignateWorkersResponse)

CreateDesignateWorkersResponse creates a response to parse from DesignateWorkers response

type DisableJobRequest 

type DisableJobRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

DisableJobRequest is the request struct for api DisableJob

func CreateDisableJobRequest 

func CreateDisableJobRequest() (request *DisableJobRequest)

CreateDisableJobRequest creates a request to invoke DisableJob API

type DisableJobResponse 

type DisableJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DisableJobResponse is the response struct for api DisableJob

func CreateDisableJobResponse 

func CreateDisableJobResponse() (response *DisableJobResponse)

CreateDisableJobResponse creates a response to parse from DisableJob response

type DisableWorkflowRequest 

type DisableWorkflowRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	WorkflowId      requests.Integer `position:"Query" name:"WorkflowId"`
}

DisableWorkflowRequest is the request struct for api DisableWorkflow

func CreateDisableWorkflowRequest 

func CreateDisableWorkflowRequest() (request *DisableWorkflowRequest)

CreateDisableWorkflowRequest creates a request to invoke DisableWorkflow API

type DisableWorkflowResponse 

type DisableWorkflowResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

DisableWorkflowResponse is the response struct for api DisableWorkflow

func CreateDisableWorkflowResponse 

func CreateDisableWorkflowResponse() (response *DisableWorkflowResponse)

CreateDisableWorkflowResponse creates a response to parse from DisableWorkflow response

type Edge added in v1.61.1394 

type Edge struct {
	Source int64 `json:"Source" xml:"Source"`
	Target int64 `json:"Target" xml:"Target"`
}

Edge is a nested struct in schedulerx2 response

type Edges added in v1.61.1394 

type Edges struct {
	Edge []Edge `json:"Edge" xml:"Edge"`
}

Edges is a nested struct in schedulerx2 response

type EnableJobRequest 

type EnableJobRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

EnableJobRequest is the request struct for api EnableJob

func CreateEnableJobRequest 

func CreateEnableJobRequest() (request *EnableJobRequest)

CreateEnableJobRequest creates a request to invoke EnableJob API

type EnableJobResponse 

type EnableJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

EnableJobResponse is the response struct for api EnableJob

func CreateEnableJobResponse 

func CreateEnableJobResponse() (response *EnableJobResponse)

CreateEnableJobResponse creates a response to parse from EnableJob response

type EnableWorkflowRequest 

type EnableWorkflowRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	WorkflowId      requests.Integer `position:"Query" name:"WorkflowId"`
}

EnableWorkflowRequest is the request struct for api EnableWorkflow

func CreateEnableWorkflowRequest 

func CreateEnableWorkflowRequest() (request *EnableWorkflowRequest)

CreateEnableWorkflowRequest creates a request to invoke EnableWorkflow API

type EnableWorkflowResponse 

type EnableWorkflowResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

EnableWorkflowResponse is the response struct for api EnableWorkflow

func CreateEnableWorkflowResponse 

func CreateEnableWorkflowResponse() (response *EnableWorkflowResponse)

CreateEnableWorkflowResponse creates a response to parse from EnableWorkflow response

type ExecuteJobRequest 

type ExecuteJobRequest struct {
	*requests.RpcRequest
	NamespaceSource    string           `position:"Query" name:"NamespaceSource"`
	CheckJobStatus     requests.Boolean `position:"Query" name:"CheckJobStatus"`
	DesignateType      requests.Integer `position:"Query" name:"DesignateType"`
	JobId              requests.Integer `position:"Query" name:"JobId"`
	Worker             string           `position:"Query" name:"Worker"`
	InstanceParameters string           `position:"Query" name:"InstanceParameters"`
	GroupId            string           `position:"Query" name:"GroupId"`
	Label              string           `position:"Query" name:"Label"`
	Namespace          string           `position:"Query" name:"Namespace"`
}

ExecuteJobRequest is the request struct for api ExecuteJob

func CreateExecuteJobRequest 

func CreateExecuteJobRequest() (request *ExecuteJobRequest)

CreateExecuteJobRequest creates a request to invoke ExecuteJob API

type ExecuteJobResponse 

type ExecuteJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

ExecuteJobResponse is the response struct for api ExecuteJob

func CreateExecuteJobResponse 

func CreateExecuteJobResponse() (response *ExecuteJobResponse)

CreateExecuteJobResponse creates a response to parse from ExecuteJob response

type ExecuteWorkflowRequest 

type ExecuteWorkflowRequest struct {
	*requests.RpcRequest
	NamespaceSource    string           `position:"Query" name:"NamespaceSource"`
	GroupId            string           `position:"Query" name:"GroupId"`
	Namespace          string           `position:"Query" name:"Namespace"`
	WorkflowId         requests.Integer `position:"Query" name:"WorkflowId"`
	InstanceParameters string           `position:"Query" name:"InstanceParameters"`
}

ExecuteWorkflowRequest is the request struct for api ExecuteWorkflow

func CreateExecuteWorkflowRequest 

func CreateExecuteWorkflowRequest() (request *ExecuteWorkflowRequest)

CreateExecuteWorkflowRequest creates a request to invoke ExecuteWorkflow API

type ExecuteWorkflowResponse 

type ExecuteWorkflowResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

ExecuteWorkflowResponse is the response struct for api ExecuteWorkflow

func CreateExecuteWorkflowResponse 

func CreateExecuteWorkflowResponse() (response *ExecuteWorkflowResponse)

CreateExecuteWorkflowResponse creates a response to parse from ExecuteWorkflow response

type GetJobInfoRequest 

type GetJobInfoRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	JobName         string           `position:"Query" name:"JobName"`
}

GetJobInfoRequest is the request struct for api GetJobInfo

func CreateGetJobInfoRequest 

func CreateGetJobInfoRequest() (request *GetJobInfoRequest)

CreateGetJobInfoRequest creates a request to invoke GetJobInfo API

type GetJobInfoResponse 

type GetJobInfoResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

GetJobInfoResponse is the response struct for api GetJobInfo

func CreateGetJobInfoResponse 

func CreateGetJobInfoResponse() (response *GetJobInfoResponse)

CreateGetJobInfoResponse creates a response to parse from GetJobInfo response

type GetJobInstanceListRequest 

type GetJobInstanceListRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

GetJobInstanceListRequest is the request struct for api GetJobInstanceList

func CreateGetJobInstanceListRequest 

func CreateGetJobInstanceListRequest() (request *GetJobInstanceListRequest)

CreateGetJobInstanceListRequest creates a request to invoke GetJobInstanceList API

type GetJobInstanceListResponse 

type GetJobInstanceListResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

GetJobInstanceListResponse is the response struct for api GetJobInstanceList

func CreateGetJobInstanceListResponse 

func CreateGetJobInstanceListResponse() (response *GetJobInstanceListResponse)

CreateGetJobInstanceListResponse creates a response to parse from GetJobInstanceList response

type GetJobInstanceRequest 

type GetJobInstanceRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	JobInstanceId   requests.Integer `position:"Query" name:"JobInstanceId"`
}

GetJobInstanceRequest is the request struct for api GetJobInstance

func CreateGetJobInstanceRequest 

func CreateGetJobInstanceRequest() (request *GetJobInstanceRequest)

CreateGetJobInstanceRequest creates a request to invoke GetJobInstance API

type GetJobInstanceResponse 

type GetJobInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

GetJobInstanceResponse is the response struct for api GetJobInstance

func CreateGetJobInstanceResponse 

func CreateGetJobInstanceResponse() (response *GetJobInstanceResponse)

CreateGetJobInstanceResponse creates a response to parse from GetJobInstance response

type GetWorkFlowRequest added in v1.61.1394 

type GetWorkFlowRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	Namespace       string           `position:"Query" name:"Namespace"`
	WorkflowId      requests.Integer `position:"Query" name:"WorkflowId"`
}

GetWorkFlowRequest is the request struct for api GetWorkFlow

func CreateGetWorkFlowRequest added in v1.61.1394 

func CreateGetWorkFlowRequest() (request *GetWorkFlowRequest)

CreateGetWorkFlowRequest creates a request to invoke GetWorkFlow API

type GetWorkFlowResponse added in v1.61.1394 

type GetWorkFlowResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

GetWorkFlowResponse is the response struct for api GetWorkFlow

func CreateGetWorkFlowResponse added in v1.61.1394 

func CreateGetWorkFlowResponse() (response *GetWorkFlowResponse)

CreateGetWorkFlowResponse creates a response to parse from GetWorkFlow response

type GetWorkerListRequest added in v1.61.1420 

type GetWorkerListRequest struct {
	*requests.RpcRequest
	NamespaceSource string `position:"Query" name:"NamespaceSource"`
	GroupId         string `position:"Query" name:"GroupId"`
	Namespace       string `position:"Query" name:"Namespace"`
}

GetWorkerListRequest is the request struct for api GetWorkerList

func CreateGetWorkerListRequest added in v1.61.1420 

func CreateGetWorkerListRequest() (request *GetWorkerListRequest)

CreateGetWorkerListRequest creates a request to invoke GetWorkerList API

type GetWorkerListResponse added in v1.61.1420 

type GetWorkerListResponse struct {
	*responses.BaseResponse
	RequestId string `json:"RequestId" xml:"RequestId"`
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

GetWorkerListResponse is the response struct for api GetWorkerList

func CreateGetWorkerListResponse added in v1.61.1420 

func CreateGetWorkerListResponse() (response *GetWorkerListResponse)

CreateGetWorkerListResponse creates a response to parse from GetWorkerList response

type GrantPermissionRequest 

type GrantPermissionRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	UserId          string           `position:"Query" name:"UserId"`
	GrantOption     requests.Boolean `position:"Query" name:"GrantOption"`
	Namespace       string           `position:"Query" name:"Namespace"`
	UserName        string           `position:"Query" name:"UserName"`
}

GrantPermissionRequest is the request struct for api GrantPermission

func CreateGrantPermissionRequest 

func CreateGrantPermissionRequest() (request *GrantPermissionRequest)

CreateGrantPermissionRequest creates a request to invoke GrantPermission API

type GrantPermissionResponse 

type GrantPermissionResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

GrantPermissionResponse is the response struct for api GrantPermission

func CreateGrantPermissionResponse 

func CreateGrantPermissionResponse() (response *GrantPermissionResponse)

CreateGrantPermissionResponse creates a response to parse from GrantPermission response

type Job added in v1.61.948 

type Job struct {
	Status          int            `json:"Status" xml:"Status"`
	JarUrl          string         `json:"JarUrl" xml:"JarUrl"`
	MaxAttempt      int            `json:"MaxAttempt" xml:"MaxAttempt"`
	Parameters      string         `json:"Parameters" xml:"Parameters"`
	Description     string         `json:"Description" xml:"Description"`
	JobId           int64          `json:"JobId" xml:"JobId"`
	ExecuteMode     string         `json:"ExecuteMode" xml:"ExecuteMode"`
	MaxConcurrency  string         `json:"MaxConcurrency" xml:"MaxConcurrency"`
	Name            string         `json:"Name" xml:"Name"`
	ClassName       string         `json:"ClassName" xml:"ClassName"`
	Content         string         `json:"Content" xml:"Content"`
	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"`
}

JobInstanceDetail is a nested struct in schedulerx2 response

type JobInstanceDetails 

type JobInstanceDetails struct {
	JobInstanceDetailsItem []JobInstanceDetailsItem `json:"JobInstanceDetails" xml:"JobInstanceDetails"`
}

JobInstanceDetails is a nested struct in schedulerx2 response

type JobInstanceDetailsItem 

type JobInstanceDetailsItem struct {
	Status       int    `json:"Status" xml:"Status"`
	Progress     string `json:"Progress" xml:"Progress"`
	Result       string `json:"Result" xml:"Result"`
	InstanceId   int64  `json:"InstanceId" xml:"InstanceId"`
	TimeType     int    `json:"TimeType" xml:"TimeType"`
	TriggerType  int    `json:"TriggerType" xml:"TriggerType"`
	EndTime      string `json:"EndTime" xml:"EndTime"`
	StartTime    string `json:"StartTime" xml:"StartTime"`
	Executor     string `json:"Executor" xml:"Executor"`
	JobId        int64  `json:"JobId" xml:"JobId"`
	ScheduleTime string `json:"ScheduleTime" xml:"ScheduleTime"`
	DataTime     string `json:"DataTime" xml:"DataTime"`
	WorkAddr     string `json:"WorkAddr" xml:"WorkAddr"`
}

JobInstanceDetailsItem is a nested struct in schedulerx2 response

type JobMonitorInfo 

type JobMonitorInfo struct {
	MonitorConfig MonitorConfig     `json:"MonitorConfig" xml:"MonitorConfig"`
	ContactInfo   []ContactInfoItem `json:"ContactInfo" xml:"ContactInfo"`
}

JobMonitorInfo is a nested struct in schedulerx2 response

type Jobs added in v1.61.948 

type Jobs struct {
	Job []Job `json:"Job" xml:"Job"`
}

Jobs is a nested struct in schedulerx2 response

type ListGroupsRequest added in v1.61.948 

type ListGroupsRequest struct {
	*requests.RpcRequest
	NamespaceSource string `position:"Query" name:"NamespaceSource"`
	Namespace       string `position:"Query" name:"Namespace"`
}

ListGroupsRequest is the request struct for api ListGroups

func CreateListGroupsRequest added in v1.61.948 

func CreateListGroupsRequest() (request *ListGroupsRequest)

CreateListGroupsRequest creates a request to invoke ListGroups API

type ListGroupsResponse added in v1.61.948 

type ListGroupsResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

ListGroupsResponse is the response struct for api ListGroups

func CreateListGroupsResponse added in v1.61.948 

func CreateListGroupsResponse() (response *ListGroupsResponse)

CreateListGroupsResponse creates a response to parse from ListGroups response

type ListJobsRequest added in v1.61.948 

type ListJobsRequest struct {
	*requests.RpcRequest
	NamespaceSource string `position:"Query" name:"NamespaceSource"`
	GroupId         string `position:"Query" name:"GroupId"`
	Namespace       string `position:"Query" name:"Namespace"`
	JobName         string `position:"Query" name:"JobName"`
	Status          string `position:"Query" name:"Status"`
}

ListJobsRequest is the request struct for api ListJobs

func CreateListJobsRequest added in v1.61.948 

func CreateListJobsRequest() (request *ListJobsRequest)

CreateListJobsRequest creates a request to invoke ListJobs API

type ListJobsResponse added in v1.61.948 

type ListJobsResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

ListJobsResponse is the response struct for api ListJobs

func CreateListJobsResponse added in v1.61.948 

func CreateListJobsResponse() (response *ListJobsResponse)

CreateListJobsResponse creates a response to parse from ListJobs response

type ListNamespacesRequest added in v1.61.948 

type ListNamespacesRequest struct {
	*requests.RpcRequest
}

ListNamespacesRequest is the request struct for api ListNamespaces

func CreateListNamespacesRequest added in v1.61.948 

func CreateListNamespacesRequest() (request *ListNamespacesRequest)

CreateListNamespacesRequest creates a request to invoke ListNamespaces API

type ListNamespacesResponse added in v1.61.948 

type ListNamespacesResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
	Data      Data   `json:"Data" xml:"Data"`
}

ListNamespacesResponse is the response struct for api ListNamespaces

func CreateListNamespacesResponse added in v1.61.948 

func CreateListNamespacesResponse() (response *ListNamespacesResponse)

CreateListNamespacesResponse creates a response to parse from ListNamespaces response

type MapTaskXAttrs 

type MapTaskXAttrs struct {
	DispatcherSize      int `json:"DispatcherSize" xml:"DispatcherSize"`
	QueueSize           int `json:"QueueSize" xml:"QueueSize"`
	TaskMaxAttempt      int `json:"TaskMaxAttempt" xml:"TaskMaxAttempt"`
	TaskAttemptInterval int `json:"TaskAttemptInterval" xml:"TaskAttemptInterval"`
	ConsumerSize        int `json:"ConsumerSize" xml:"ConsumerSize"`
	PageSize            int `json:"PageSize" xml:"PageSize"`
}

MapTaskXAttrs is a nested struct in schedulerx2 response

type MonitorConfig 

type MonitorConfig struct {
	Timeout           int64  `json:"Timeout" xml:"Timeout"`
	FailEnable        bool   `json:"FailEnable" xml:"FailEnable"`
	MissWorkerEnable  bool   `json:"MissWorkerEnable" xml:"MissWorkerEnable"`
	TimeoutEnable     bool   `json:"TimeoutEnable" xml:"TimeoutEnable"`
	SendChannel       string `json:"SendChannel" xml:"SendChannel"`
	TimeoutKillEnable bool   `json:"TimeoutKillEnable" xml:"TimeoutKillEnable"`
}

MonitorConfig is a nested struct in schedulerx2 response

type Namespace added in v1.61.948 

type Namespace struct {
	Name        string `json:"Name" xml:"Name"`
	Description string `json:"Description" xml:"Description"`
	UId         string `json:"UId" xml:"UId"`
}

Namespace is a nested struct in schedulerx2 response

type Namespaces added in v1.61.948 

type Namespaces struct {
	Namespace []Namespace `json:"Namespace" xml:"Namespace"`
}

Namespaces is a nested struct in schedulerx2 response

type Node added in v1.61.1394 

type Node struct {
	Id     int64  `json:"Id" xml:"Id"`
	Label  string `json:"Label" xml:"Label"`
	Status int    `json:"Status" xml:"Status"`
}

Node is a nested struct in schedulerx2 response

type Nodes added in v1.61.1394 

type Nodes struct {
	Node []Node `json:"Node" xml:"Node"`
}

Nodes is a nested struct in schedulerx2 response

type Region 

type Region struct {
	RegionEndpoint string `json:"RegionEndpoint" xml:"RegionEndpoint"`
	LocalName      string `json:"LocalName" xml:"LocalName"`
	RegionId       string `json:"RegionId" xml:"RegionId"`
}

Region is a nested struct in schedulerx2 response

type Regions 

type Regions struct {
	Region []Region `json:"Region" xml:"Region"`
}

Regions is a nested struct in schedulerx2 response

type RevokePermissionRequest 

type RevokePermissionRequest struct {
	*requests.RpcRequest
	NamespaceSource string `position:"Query" name:"NamespaceSource"`
	GroupId         string `position:"Query" name:"GroupId"`
	UserId          string `position:"Query" name:"UserId"`
	Namespace       string `position:"Query" name:"Namespace"`
}

RevokePermissionRequest is the request struct for api RevokePermission

func CreateRevokePermissionRequest 

func CreateRevokePermissionRequest() (request *RevokePermissionRequest)

CreateRevokePermissionRequest creates a request to invoke RevokePermission API

type RevokePermissionResponse 

type RevokePermissionResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

RevokePermissionResponse is the response struct for api RevokePermission

func CreateRevokePermissionResponse 

func CreateRevokePermissionResponse() (response *RevokePermissionResponse)

CreateRevokePermissionResponse creates a response to parse from RevokePermission response

type StopInstanceRequest 

type StopInstanceRequest struct {
	*requests.RpcRequest
	NamespaceSource string           `position:"Query" name:"NamespaceSource"`
	GroupId         string           `position:"Query" name:"GroupId"`
	JobId           requests.Integer `position:"Query" name:"JobId"`
	InstanceId      requests.Integer `position:"Query" name:"InstanceId"`
	Namespace       string           `position:"Query" name:"Namespace"`
}

StopInstanceRequest is the request struct for api StopInstance

func CreateStopInstanceRequest 

func CreateStopInstanceRequest() (request *StopInstanceRequest)

CreateStopInstanceRequest creates a request to invoke StopInstance API

type StopInstanceResponse 

type StopInstanceResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

StopInstanceResponse is the response struct for api StopInstance

func CreateStopInstanceResponse 

func CreateStopInstanceResponse() (response *StopInstanceResponse)

CreateStopInstanceResponse creates a response to parse from StopInstance response

type TimeConfig 

type TimeConfig struct {
	TimeType       int    `json:"TimeType" xml:"TimeType"`
	DataOffset     int    `json:"DataOffset" xml:"DataOffset"`
	Calendar       string `json:"Calendar" xml:"Calendar"`
	TimeExpression string `json:"TimeExpression" xml:"TimeExpression"`
}

TimeConfig is a nested struct in schedulerx2 response

type UpdateJobContactInfo 

type UpdateJobContactInfo struct {
	Ding      string `name:"Ding"`
	UserPhone string `name:"UserPhone"`
	UserMail  string `name:"UserMail"`
	UserName  string `name:"UserName"`
}

UpdateJobContactInfo is a repeated param struct in UpdateJobRequest

type UpdateJobRequest 

type UpdateJobRequest struct {
	*requests.RpcRequest
	NamespaceSource     string                  `position:"Body" name:"NamespaceSource"`
	Description         string                  `position:"Body" name:"Description"`
	AttemptInterval     requests.Integer        `position:"Body" name:"AttemptInterval"`
	Content             string                  `position:"Body" name:"Content"`
	Timeout             requests.Integer        `position:"Body" name:"Timeout"`
	TimeoutKillEnable   requests.Boolean        `position:"Body" name:"TimeoutKillEnable"`
	JobId               requests.Integer        `position:"Body" name:"JobId"`
	PageSize            requests.Integer        `position:"Body" name:"PageSize"`
	ConsumerSize        requests.Integer        `position:"Body" name:"ConsumerSize"`
	JarUrl              string                  `position:"Body" name:"JarUrl"`
	Calendar            string                  `position:"Body" name:"Calendar"`
	FailEnable          requests.Boolean        `position:"Body" name:"FailEnable"`
	SendChannel         string                  `position:"Body" name:"SendChannel"`
	DataOffset          requests.Integer        `position:"Body" name:"DataOffset"`
	GroupId             string                  `position:"Body" name:"GroupId"`
	TaskMaxAttempt      requests.Integer        `position:"Body" name:"TaskMaxAttempt"`
	MaxAttempt          requests.Integer        `position:"Body" name:"MaxAttempt"`
	MissWorkerEnable    requests.Boolean        `position:"Body" name:"MissWorkerEnable"`
	DispatcherSize      requests.Integer        `position:"Body" name:"DispatcherSize"`
	TaskAttemptInterval requests.Integer        `position:"Body" name:"TaskAttemptInterval"`
	ExecuteMode         string                  `position:"Body" name:"ExecuteMode"`
	QueueSize           requests.Integer        `position:"Body" name:"QueueSize"`
	TimeExpression      string                  `position:"Body" name:"TimeExpression"`
	ClassName           string                  `position:"Body" name:"ClassName"`
	TimeoutEnable       requests.Boolean        `position:"Body" name:"TimeoutEnable"`
	ContactInfo         *[]UpdateJobContactInfo `position:"Body" name:"ContactInfo"  type:"Repeated"`
	Name                string                  `position:"Body" name:"Name"`
	Namespace           string                  `position:"Body" name:"Namespace"`
	MaxConcurrency      requests.Integer        `position:"Body" name:"MaxConcurrency"`
	TimeType            requests.Integer        `position:"Body" name:"TimeType"`
	Parameters          string                  `position:"Body" name:"Parameters"`
}

UpdateJobRequest is the request struct for api UpdateJob

func CreateUpdateJobRequest 

func CreateUpdateJobRequest() (request *UpdateJobRequest)

CreateUpdateJobRequest creates a request to invoke UpdateJob API

type UpdateJobResponse 

type UpdateJobResponse struct {
	*responses.BaseResponse
	Code      int    `json:"Code" xml:"Code"`
	Message   string `json:"Message" xml:"Message"`
	RequestId string `json:"RequestId" xml:"RequestId"`
	Success   bool   `json:"Success" xml:"Success"`
}

UpdateJobResponse is the response struct for api UpdateJob

func CreateUpdateJobResponse 

func CreateUpdateJobResponse() (response *UpdateJobResponse)

CreateUpdateJobResponse creates a response to parse from UpdateJob response

type WorkFlowInfo added in v1.61.1394 

type WorkFlowInfo struct {
	WorkflowId     int64  `json:"WorkflowId" xml:"WorkflowId"`
	Name           string `json:"Name" xml:"Name"`
	Description    string `json:"Description" xml:"Description"`
	Status         string `json:"Status" xml:"Status"`
	TimeType       string `json:"TimeType" xml:"TimeType"`
	TimeExpression string `json:"TimeExpression" xml:"TimeExpression"`
}

WorkFlowInfo is a nested struct in schedulerx2 response

type WorkFlowNodeInfo added in v1.61.1394 

type WorkFlowNodeInfo struct {
	Nodes []Node `json:"Nodes" xml:"Nodes"`
	Edges []Edge `json:"Edges" xml:"Edges"`
}

WorkFlowNodeInfo is a nested struct in schedulerx2 response

type WorkerInfo added in v1.61.1420 

type WorkerInfo struct {
	Ip            string `json:"Ip" xml:"Ip"`
	Port          int    `json:"Port" xml:"Port"`
	WorkerAddress string `json:"WorkerAddress" xml:"WorkerAddress"`
	Label         string `json:"Label" xml:"Label"`
	Version       string `json:"Version" xml:"Version"`
	Starter       string `json:"Starter" xml:"Starter"`
}

WorkerInfo is a nested struct in schedulerx2 response

type WorkerInfos added in v1.61.1420 

type WorkerInfos struct {
	WorkerInfo []WorkerInfo `json:"WorkerInfo" xml:"WorkerInfo"`
}

WorkerInfos is a nested struct in schedulerx2 response

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.