Documentation ¶
Index ¶
- type BasicInfo
- type CancelScriptRequest
- type CancelScriptResponse
- type Condition
- type ConnectionInfo
- type ConnectionInfoType
- type ConnectionInfoTypeEnum
- type ConnectionParam
- type ConnectionParamConnectionType
- type ConnectionParamConnectionTypeEnum
- type CreateConnectionRequest
- type CreateConnectionResponse
- type CreateJobRequest
- type CreateJobResponse
- type CreateResourceRequest
- type CreateResourceResponse
- type CreateScriptRequest
- type CreateScriptResponse
- type Cron
- type DeleteConnctionRequest
- type DeleteConnctionResponse
- type DeleteJobRequest
- type DeleteJobResponse
- type DeleteResourceRequest
- type DeleteResourceResponse
- type DeleteScriptRequest
- type DeleteScriptResponse
- type DependJob
- type DependJobDependFailPolicy
- type DependJobDependFailPolicyEnum
- type Event
- type ExecuteScriptReq
- type ExecuteScriptRequest
- type ExecuteScriptResponse
- type ExportConnectionsRequest
- type ExportConnectionsResponse
- type ExportJobListRequest
- type ExportJobListResponse
- type ExportJobRequest
- type ExportJobResponse
- type ExportJobsReq
- type FilePath
- type ImportConnectionReq
- type ImportConnectionReqSameNamePolicy
- type ImportConnectionReqSameNamePolicyEnum
- type ImportConnectionsRequest
- type ImportConnectionsResponse
- type ImportFileReq
- type ImportFileReqSameNamePolicy
- type ImportFileReqSameNamePolicyEnum
- type ImportJobRequest
- type ImportJobResponse
- type Job
- type JobInfo
- type JobInfoJobType
- type JobInfoJobTypeEnum
- type JobInstance
- type JobParam
- type JobParamParamType
- type JobParamParamTypeEnum
- type ListConnectionsRequest
- type ListConnectionsResponse
- type ListJobInstancesRequest
- type ListJobInstancesResponse
- type ListJobsRequest
- type ListJobsResponse
- type ListResourcesRequest
- type ListResourcesResponse
- type ListScriptResultsRequest
- type ListScriptResultsResponse
- type ListScriptsRequest
- type ListScriptsResponse
- type ListSystemTasksRequest
- type ListSystemTasksResponse
- type ListSystemTasksResponseStatus
- type ListSystemTasksResponseStatusEnum
- type Location
- type Node
- type NodeFailPolicy
- type NodeFailPolicyEnum
- type NodeInstance
- type NodeNodeType
- type NodeNodeTypeEnum
- type RealTimeNodeStatus
- type RealTimeNodeStatusNodeType
- type RealTimeNodeStatusNodeTypeEnum
- type RealTimeNodeStatusStatus
- type RealTimeNodeStatusStatusEnum
- type ResourceInfo
- type ResourceInfoType
- type ResourceInfoTypeEnum
- type RestoreJobInstanceRequest
- type RestoreJobInstanceResponse
- type Result
- type RunOnceRequest
- type RunOnceResponse
- type Schedule
- type ScheduleScheType
- type ScheduleScheTypeEnum
- type Script
- type ScriptInfo
- type ScriptInfoType
- type ScriptInfoTypeEnum
- type ShowConnectionRequest
- type ShowConnectionResponse
- type ShowConnectionResponseType
- type ShowConnectionResponseTypeEnum
- type ShowFileInfoRequest
- type ShowFileInfoResponse
- type ShowJobInstanceRequest
- type ShowJobInstanceResponse
- type ShowJobRequest
- type ShowJobResponse
- type ShowJobResponseJobType
- type ShowJobResponseJobTypeEnum
- type ShowJobStatusRequest
- type ShowJobStatusResponse
- type ShowJobStatusResponseStatus
- type ShowJobStatusResponseStatusEnum
- type ShowResourceRequest
- type ShowResourceResponse
- type ShowResourceResponseType
- type ShowResourceResponseTypeEnum
- type ShowScriptRequest
- type ShowScriptResponse
- type ShowScriptResponseType
- type ShowScriptResponseTypeEnum
- type StartJobReq
- type StartJobRequest
- type StartJobResponse
- type StopJobInstanceRequest
- type StopJobInstanceResponse
- type StopJobRequest
- type StopJobResponse
- type SubTaskStatus
- type SubTaskStatusStatus
- type SubTaskStatusStatusEnum
- type UpdateConnectionRequest
- type UpdateConnectionResponse
- type UpdateJobRequest
- type UpdateJobResponse
- type UpdateResourceRequest
- type UpdateResourceResponse
- type UpdateScriptRequest
- type UpdateScriptResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicInfo ¶
type BasicInfo struct { // 作业责任人 Owner *string `json:"owner,omitempty"` // 作业优先级 Priority *string `json:"priority,omitempty"` // 作业执行用户 ExecuteUser *string `json:"executeUser,omitempty"` // 实例超时时间 InstanceTimeout *string `json:"instanceTimeout,omitempty"` // 用户自定义属性字段 CustomFields *interface{} `json:"customFields,omitempty"` }
type CancelScriptRequest ¶
type CancelScriptRequest struct { ScriptName string `json:"script_name"` InstanceId string `json:"instance_id"` }
Request Object
func (CancelScriptRequest) String ¶
func (o CancelScriptRequest) String() string
type CancelScriptResponse ¶
type CancelScriptResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (CancelScriptResponse) String ¶
func (o CancelScriptResponse) String() string
type Condition ¶
type ConnectionInfo ¶
type ConnectionInfo struct { Name string `json:"name"` Type ConnectionInfoType `json:"type"` Config *interface{} `json:"config,omitempty"` Description *string `json:"description,omitempty"` }
func (ConnectionInfo) String ¶
func (o ConnectionInfo) String() string
type ConnectionInfoType ¶ added in v0.0.78
type ConnectionInfoType struct {
// contains filtered or unexported fields
}
func (ConnectionInfoType) MarshalJSON ¶ added in v0.0.78
func (c ConnectionInfoType) MarshalJSON() ([]byte, error)
func (*ConnectionInfoType) UnmarshalJSON ¶ added in v0.0.78
func (c *ConnectionInfoType) UnmarshalJSON(b []byte) error
type ConnectionInfoTypeEnum ¶ added in v0.0.78
type ConnectionInfoTypeEnum struct { DWS ConnectionInfoType DLI ConnectionInfoType SPARK_SQL ConnectionInfoType HIVE ConnectionInfoType RDS ConnectionInfoType CLOUD_TABLE ConnectionInfoType }
func GetConnectionInfoTypeEnum ¶ added in v0.0.78
func GetConnectionInfoTypeEnum() ConnectionInfoTypeEnum
type ConnectionParam ¶
type ConnectionParam struct { Name *string `json:"name,omitempty"` ConnectionType *ConnectionParamConnectionType `json:"connectionType,omitempty"` Params *interface{} `json:"params,omitempty"` }
func (ConnectionParam) String ¶
func (o ConnectionParam) String() string
type ConnectionParamConnectionType ¶
type ConnectionParamConnectionType struct {
// contains filtered or unexported fields
}
func (ConnectionParamConnectionType) MarshalJSON ¶
func (c ConnectionParamConnectionType) MarshalJSON() ([]byte, error)
func (*ConnectionParamConnectionType) UnmarshalJSON ¶
func (c *ConnectionParamConnectionType) UnmarshalJSON(b []byte) error
type ConnectionParamConnectionTypeEnum ¶
type ConnectionParamConnectionTypeEnum struct { DWS ConnectionParamConnectionType DLI ConnectionParamConnectionType SPARK_SQL ConnectionParamConnectionType HIVE ConnectionParamConnectionType RDS ConnectionParamConnectionType CLOUD_TABLE ConnectionParamConnectionType }
func GetConnectionParamConnectionTypeEnum ¶
func GetConnectionParamConnectionTypeEnum() ConnectionParamConnectionTypeEnum
type CreateConnectionRequest ¶
type CreateConnectionRequest struct {
Body *ConnectionInfo `json:"body,omitempty"`
}
Request Object
func (CreateConnectionRequest) String ¶
func (o CreateConnectionRequest) String() string
type CreateConnectionResponse ¶
type CreateConnectionResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (CreateConnectionResponse) String ¶
func (o CreateConnectionResponse) String() string
type CreateJobRequest ¶
type CreateJobRequest struct {
Body *JobInfo `json:"body,omitempty"`
}
Request Object
func (CreateJobRequest) String ¶
func (o CreateJobRequest) String() string
type CreateJobResponse ¶
type CreateJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (CreateJobResponse) String ¶
func (o CreateJobResponse) String() string
type CreateResourceRequest ¶
type CreateResourceRequest struct {
Body *ResourceInfo `json:"body,omitempty"`
}
Request Object
func (CreateResourceRequest) String ¶
func (o CreateResourceRequest) String() string
type CreateResourceResponse ¶
type CreateResourceResponse struct { Body *string `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateResourceResponse) String ¶
func (o CreateResourceResponse) String() string
type CreateScriptRequest ¶
type CreateScriptRequest struct {
Body *ScriptInfo `json:"body,omitempty"`
}
Request Object
func (CreateScriptRequest) String ¶
func (o CreateScriptRequest) String() string
type CreateScriptResponse ¶
type CreateScriptResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (CreateScriptResponse) String ¶
func (o CreateScriptResponse) String() string
type Cron ¶
type Cron struct { StartTime *string `json:"startTime,omitempty"` EndTime *string `json:"endTime,omitempty"` // Cron表达式 Expression *string `json:"expression,omitempty"` // 是否依赖本作业上一个运行周期任务的执行结果 DependPrePeriod *bool `json:"dependPrePeriod,omitempty"` // 依赖其它作业列表 DependJobs *[]DependJob `json:"dependJobs,omitempty"` }
type DeleteConnctionRequest ¶
type DeleteConnctionRequest struct { // 连接名称. ConnectionName string `json:"connection_name"` }
Request Object
func (DeleteConnctionRequest) String ¶
func (o DeleteConnctionRequest) String() string
type DeleteConnctionResponse ¶
type DeleteConnctionResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteConnctionResponse) String ¶
func (o DeleteConnctionResponse) String() string
type DeleteJobRequest ¶
type DeleteJobRequest struct { // 作业名称. JobName string `json:"job_name"` }
Request Object
func (DeleteJobRequest) String ¶
func (o DeleteJobRequest) String() string
type DeleteJobResponse ¶
type DeleteJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteJobResponse) String ¶
func (o DeleteJobResponse) String() string
type DeleteResourceRequest ¶
type DeleteResourceRequest struct { // 资源id. ResourceId string `json:"resource_id"` }
Request Object
func (DeleteResourceRequest) String ¶
func (o DeleteResourceRequest) String() string
type DeleteResourceResponse ¶
type DeleteResourceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteResourceResponse) String ¶
func (o DeleteResourceResponse) String() string
type DeleteScriptRequest ¶
type DeleteScriptRequest struct {
ScriptName string `json:"script_name"`
}
Request Object
func (DeleteScriptRequest) String ¶
func (o DeleteScriptRequest) String() string
type DeleteScriptResponse ¶
type DeleteScriptResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteScriptResponse) String ¶
func (o DeleteScriptResponse) String() string
type DependJob ¶
type DependJob struct { Jobs *string `json:"jobs,omitempty"` DependPeriod *string `json:"dependPeriod,omitempty"` DependFailPolicy *DependJobDependFailPolicy `json:"dependFailPolicy,omitempty"` }
type DependJobDependFailPolicy ¶
type DependJobDependFailPolicy struct {
// contains filtered or unexported fields
}
func (DependJobDependFailPolicy) MarshalJSON ¶
func (c DependJobDependFailPolicy) MarshalJSON() ([]byte, error)
func (*DependJobDependFailPolicy) UnmarshalJSON ¶
func (c *DependJobDependFailPolicy) UnmarshalJSON(b []byte) error
type DependJobDependFailPolicyEnum ¶
type DependJobDependFailPolicyEnum struct { FAIL DependJobDependFailPolicy IGNORE DependJobDependFailPolicy SUSPEND DependJobDependFailPolicy }
func GetDependJobDependFailPolicyEnum ¶
func GetDependJobDependFailPolicyEnum() DependJobDependFailPolicyEnum
type Event ¶
type Event struct { // 事件类型 EventType *string `json:"eventType,omitempty"` // DIS通道名称 Channel *string `json:"channel,omitempty"` // 执行失败处理策略 FailPolicy *string `json:"failPolicy,omitempty"` // 调度并发数 Concurrent *int32 `json:"concurrent,omitempty"` // 读取策略 ReadPolicy *string `json:"readPolicy,omitempty"` }
type ExecuteScriptReq ¶
type ExecuteScriptReq struct {
// 脚本的执行参数
Params *interface{} `json:"params,omitempty"`
}
func (ExecuteScriptReq) String ¶
func (o ExecuteScriptReq) String() string
type ExecuteScriptRequest ¶
type ExecuteScriptRequest struct { ScriptName string `json:"script_name"` Body *ExecuteScriptReq `json:"body,omitempty"` }
Request Object
func (ExecuteScriptRequest) String ¶
func (o ExecuteScriptRequest) String() string
type ExecuteScriptResponse ¶
type ExecuteScriptResponse struct { InstanceId *string `json:"instanceId,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ExecuteScriptResponse) String ¶
func (o ExecuteScriptResponse) String() string
type ExportConnectionsRequest ¶
type ExportConnectionsRequest struct { }
Request Object
func (ExportConnectionsRequest) String ¶
func (o ExportConnectionsRequest) String() string
type ExportConnectionsResponse ¶
type ExportConnectionsResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (ExportConnectionsResponse) String ¶
func (o ExportConnectionsResponse) String() string
type ExportJobListRequest ¶
type ExportJobListRequest struct {
Body *ExportJobsReq `json:"body,omitempty"`
}
Request Object
func (ExportJobListRequest) String ¶
func (o ExportJobListRequest) String() string
type ExportJobListResponse ¶
type ExportJobListResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (ExportJobListResponse) String ¶
func (o ExportJobListResponse) String() string
type ExportJobRequest ¶
type ExportJobRequest struct { // 作业名称. JobName string `json:"job_name"` }
Request Object
func (ExportJobRequest) String ¶
func (o ExportJobRequest) String() string
type ExportJobResponse ¶
type ExportJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (ExportJobResponse) String ¶
func (o ExportJobResponse) String() string
type ExportJobsReq ¶
type ExportJobsReq struct { JobList *[]string `json:"jobList,omitempty"` // 是否导出作业依赖的脚本和资源 ExportDepend *bool `json:"exportDepend,omitempty"` }
func (ExportJobsReq) String ¶
func (o ExportJobsReq) String() string
type ImportConnectionReq ¶
type ImportConnectionReq struct { Path *string `json:"path,omitempty"` // 连接参数 Params *[]ConnectionParam `json:"params,omitempty"` SameNamePolicy *ImportConnectionReqSameNamePolicy `json:"sameNamePolicy,omitempty"` }
func (ImportConnectionReq) String ¶
func (o ImportConnectionReq) String() string
type ImportConnectionReqSameNamePolicy ¶
type ImportConnectionReqSameNamePolicy struct {
// contains filtered or unexported fields
}
func (ImportConnectionReqSameNamePolicy) MarshalJSON ¶
func (c ImportConnectionReqSameNamePolicy) MarshalJSON() ([]byte, error)
func (*ImportConnectionReqSameNamePolicy) UnmarshalJSON ¶
func (c *ImportConnectionReqSameNamePolicy) UnmarshalJSON(b []byte) error
type ImportConnectionReqSameNamePolicyEnum ¶
type ImportConnectionReqSameNamePolicyEnum struct { SKIP ImportConnectionReqSameNamePolicy OVERWRITE ImportConnectionReqSameNamePolicy }
func GetImportConnectionReqSameNamePolicyEnum ¶
func GetImportConnectionReqSameNamePolicyEnum() ImportConnectionReqSameNamePolicyEnum
type ImportConnectionsRequest ¶
type ImportConnectionsRequest struct {
Body *ImportConnectionReq `json:"body,omitempty"`
}
Request Object
func (ImportConnectionsRequest) String ¶
func (o ImportConnectionsRequest) String() string
type ImportConnectionsResponse ¶
type ImportConnectionsResponse struct { // 任务id TaskId *string `json:"taskId,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ImportConnectionsResponse) String ¶
func (o ImportConnectionsResponse) String() string
type ImportFileReq ¶
type ImportFileReq struct { Path *string `json:"path,omitempty"` // 公共作业参数 Params *interface{} `json:"params,omitempty"` SameNamePolicy *ImportFileReqSameNamePolicy `json:"sameNamePolicy,omitempty"` // 指定作业参数 JobsParam *interface{} `json:"jobsParam,omitempty"` ExecuteUser *string `json:"executeUser,omitempty"` }
func (ImportFileReq) String ¶
func (o ImportFileReq) String() string
type ImportFileReqSameNamePolicy ¶
type ImportFileReqSameNamePolicy struct {
// contains filtered or unexported fields
}
func (ImportFileReqSameNamePolicy) MarshalJSON ¶
func (c ImportFileReqSameNamePolicy) MarshalJSON() ([]byte, error)
func (*ImportFileReqSameNamePolicy) UnmarshalJSON ¶
func (c *ImportFileReqSameNamePolicy) UnmarshalJSON(b []byte) error
type ImportFileReqSameNamePolicyEnum ¶
type ImportFileReqSameNamePolicyEnum struct { SKIP ImportFileReqSameNamePolicy OVERWRITE ImportFileReqSameNamePolicy }
func GetImportFileReqSameNamePolicyEnum ¶
func GetImportFileReqSameNamePolicyEnum() ImportFileReqSameNamePolicyEnum
type ImportJobRequest ¶
type ImportJobRequest struct {
Body *ImportFileReq `json:"body,omitempty"`
}
Request Object
func (ImportJobRequest) String ¶
func (o ImportJobRequest) String() string
type ImportJobResponse ¶
type ImportJobResponse struct { // 任务id TaskId *string `json:"taskId,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ImportJobResponse) String ¶
func (o ImportJobResponse) String() string
type Job ¶
type JobInfo ¶
type JobInfo struct { Name *string `json:"name,omitempty"` Nodes *[]Node `json:"nodes,omitempty"` Schedule *Schedule `json:"schedule,omitempty"` Params *[]JobParam `json:"params,omitempty"` Directory *string `json:"directory,omitempty"` JobType *JobInfoJobType `json:"jobType,omitempty"` BasicConfig *BasicInfo `json:"basicConfig,omitempty"` }
type JobInfoJobType ¶
type JobInfoJobType struct {
// contains filtered or unexported fields
}
func (JobInfoJobType) MarshalJSON ¶
func (c JobInfoJobType) MarshalJSON() ([]byte, error)
func (*JobInfoJobType) UnmarshalJSON ¶
func (c *JobInfoJobType) UnmarshalJSON(b []byte) error
type JobInfoJobTypeEnum ¶
type JobInfoJobTypeEnum struct { BATCH JobInfoJobType REAL_TIME JobInfoJobType }
func GetJobInfoJobTypeEnum ¶
func GetJobInfoJobTypeEnum() JobInfoJobTypeEnum
type JobInstance ¶
type JobInstance struct { JobName *string `json:"jobName,omitempty"` Status *string `json:"status,omitempty"` PlanTime *int32 `json:"planTime,omitempty"` StartTime *int32 `json:"startTime,omitempty"` EndTime *int32 `json:"endTime,omitempty"` ExecuteTime *int32 `json:"executeTime,omitempty"` InstancesId *string `json:"instancesId,omitempty"` }
func (JobInstance) String ¶
func (o JobInstance) String() string
type JobParam ¶
type JobParam struct { Name *string `json:"name,omitempty"` Value *string `json:"value,omitempty"` ParamType *JobParamParamType `json:"paramType,omitempty"` }
type JobParamParamType ¶
type JobParamParamType struct {
// contains filtered or unexported fields
}
func (JobParamParamType) MarshalJSON ¶
func (c JobParamParamType) MarshalJSON() ([]byte, error)
func (*JobParamParamType) UnmarshalJSON ¶
func (c *JobParamParamType) UnmarshalJSON(b []byte) error
type JobParamParamTypeEnum ¶
type JobParamParamTypeEnum struct { VARIABLE JobParamParamType CONSTANTS JobParamParamType }
func GetJobParamParamTypeEnum ¶
func GetJobParamParamTypeEnum() JobParamParamTypeEnum
type ListConnectionsRequest ¶
type ListConnectionsRequest struct { }
Request Object
func (ListConnectionsRequest) String ¶
func (o ListConnectionsRequest) String() string
type ListConnectionsResponse ¶
type ListConnectionsResponse struct { Total *int32 `json:"total,omitempty"` Connections *[]ConnectionInfo `json:"connections,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListConnectionsResponse) String ¶
func (o ListConnectionsResponse) String() string
type ListJobInstancesRequest ¶
type ListJobInstancesRequest struct { }
Request Object
func (ListJobInstancesRequest) String ¶
func (o ListJobInstancesRequest) String() string
type ListJobInstancesResponse ¶
type ListJobInstancesResponse struct { Total *int32 `json:"total,omitempty"` Instances *[]JobInstance `json:"instances,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListJobInstancesResponse) String ¶
func (o ListJobInstancesResponse) String() string
type ListJobsRequest ¶
type ListJobsRequest struct { }
Request Object
func (ListJobsRequest) String ¶
func (o ListJobsRequest) String() string
type ListJobsResponse ¶
type ListJobsResponse struct { Total *int32 `json:"total,omitempty"` Jobs *[]JobInfo `json:"jobs,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListJobsResponse) String ¶
func (o ListJobsResponse) String() string
type ListResourcesRequest ¶
type ListResourcesRequest struct { }
Request Object
func (ListResourcesRequest) String ¶
func (o ListResourcesRequest) String() string
type ListResourcesResponse ¶
type ListResourcesResponse struct { Total *int32 `json:"total,omitempty"` Resources *[]ResourceInfo `json:"resources,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListResourcesResponse) String ¶
func (o ListResourcesResponse) String() string
type ListScriptResultsRequest ¶
type ListScriptResultsRequest struct { ScriptName string `json:"script_name"` InstanceId string `json:"instance_id"` }
Request Object
func (ListScriptResultsRequest) String ¶
func (o ListScriptResultsRequest) String() string
type ListScriptResultsResponse ¶
type ListScriptResultsResponse struct { Status *string `json:"status,omitempty"` Result *[]Result `json:"result,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListScriptResultsResponse) String ¶
func (o ListScriptResultsResponse) String() string
type ListScriptsRequest ¶
type ListScriptsRequest struct { }
Request Object
func (ListScriptsRequest) String ¶
func (o ListScriptsRequest) String() string
type ListScriptsResponse ¶
type ListScriptsResponse struct { Total *int32 `json:"total,omitempty"` Scripts *[]ScriptInfo `json:"scripts,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListScriptsResponse) String ¶
func (o ListScriptsResponse) String() string
type ListSystemTasksRequest ¶
type ListSystemTasksRequest struct { // 系统任务id. TaskId string `json:"task_id"` }
Request Object
func (ListSystemTasksRequest) String ¶
func (o ListSystemTasksRequest) String() string
type ListSystemTasksResponse ¶
type ListSystemTasksResponse struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` StartTime *string `json:"startTime,omitempty"` EndTime *string `json:"endTime,omitempty"` LastUpdate *string `json:"lastUpdate,omitempty"` Status *ListSystemTasksResponseStatus `json:"status,omitempty"` Message *string `json:"message,omitempty"` SubTasks *[]SubTaskStatus `json:"subTasks,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ListSystemTasksResponse) String ¶
func (o ListSystemTasksResponse) String() string
type ListSystemTasksResponseStatus ¶
type ListSystemTasksResponseStatus struct {
// contains filtered or unexported fields
}
func (ListSystemTasksResponseStatus) MarshalJSON ¶
func (c ListSystemTasksResponseStatus) MarshalJSON() ([]byte, error)
func (*ListSystemTasksResponseStatus) UnmarshalJSON ¶
func (c *ListSystemTasksResponseStatus) UnmarshalJSON(b []byte) error
type ListSystemTasksResponseStatusEnum ¶
type ListSystemTasksResponseStatusEnum struct { RUNNING ListSystemTasksResponseStatus SUCCESSFUL ListSystemTasksResponseStatus FAILED ListSystemTasksResponseStatus }
func GetListSystemTasksResponseStatusEnum ¶
func GetListSystemTasksResponseStatusEnum() ListSystemTasksResponseStatusEnum
type Node ¶
type Node struct { Name *string `json:"name,omitempty"` // 节点的类型 NodeType *NodeNodeType `json:"nodeType,omitempty"` Location *Location `json:"location,omitempty"` // 本节点依赖的前一个节点名称 PreNodeNames *string `json:"preNodeNames,omitempty"` // 节点执行条件 Condition *[]Condition `json:"condition,omitempty"` // 节点的属性 NodeProperties *string `json:"nodeProperties,omitempty"` // 轮询节点执行结果时间间隔 PollingInterval *int32 `json:"pollingInterval,omitempty"` // 节点最大执行时间 MaxExecutionTime *int32 `json:"maxExecutionTime,omitempty"` // 节点失败重试次数 RetryTimes *int32 `json:"retryTimes,omitempty"` // 失败重试时间间隔 RetryInterval *int32 `json:"retryInterval,omitempty"` // 作业失败策略 FailPolicy *NodeFailPolicy `json:"failPolicy,omitempty"` EventTrigger *Event `json:"eventTrigger,omitempty"` CronTrigger *Cron `json:"cronTrigger,omitempty"` }
type NodeFailPolicy ¶
type NodeFailPolicy struct {
// contains filtered or unexported fields
}
func (NodeFailPolicy) MarshalJSON ¶
func (c NodeFailPolicy) MarshalJSON() ([]byte, error)
func (*NodeFailPolicy) UnmarshalJSON ¶
func (c *NodeFailPolicy) UnmarshalJSON(b []byte) error
type NodeFailPolicyEnum ¶
type NodeFailPolicyEnum struct { FAIL NodeFailPolicy IGNORE NodeFailPolicy SUSPEND NodeFailPolicy }
func GetNodeFailPolicyEnum ¶
func GetNodeFailPolicyEnum() NodeFailPolicyEnum
type NodeInstance ¶
type NodeInstance struct { NodeName *string `json:"nodeName,omitempty"` Status *string `json:"status,omitempty"` PlanTime *int32 `json:"planTime,omitempty"` StartTime *int32 `json:"startTime,omitempty"` EndTime *int32 `json:"endTime,omitempty"` ExecuteTime *int32 `json:"executeTime,omitempty"` NodeType *string `json:"nodeType,omitempty"` RetryTimes *int32 `json:"retryTimes,omitempty"` InstanceId *int32 `json:"instanceId,omitempty"` InputRowCount *int32 `json:"inputRowCount,omitempty"` OutputRowCount *int32 `json:"outputRowCount,omitempty"` LogPath *string `json:"logPath,omitempty"` }
func (NodeInstance) String ¶
func (o NodeInstance) String() string
type NodeNodeType ¶
type NodeNodeType struct {
// contains filtered or unexported fields
}
func (NodeNodeType) MarshalJSON ¶
func (c NodeNodeType) MarshalJSON() ([]byte, error)
func (*NodeNodeType) UnmarshalJSON ¶
func (c *NodeNodeType) UnmarshalJSON(b []byte) error
type NodeNodeTypeEnum ¶
type NodeNodeTypeEnum struct { HIVE_SQL NodeNodeType SPARK_SQL NodeNodeType DWSSQL NodeNodeType DLISQL NodeNodeType SHELL NodeNodeType CDM_JOB NodeNodeType DIS_TRANSFER_TASK NodeNodeType CS_JOB NodeNodeType CLOUD_TABLE_MANAGE NodeNodeType OBS_MANAGER NodeNodeType RESTAPI NodeNodeType MACHINE_LEARNING NodeNodeType SMN NodeNodeType MRS_SPARK NodeNodeType MAP_REDUCE NodeNodeType DLI_SPARK NodeNodeType }
func GetNodeNodeTypeEnum ¶
func GetNodeNodeTypeEnum() NodeNodeTypeEnum
type RealTimeNodeStatus ¶
type RealTimeNodeStatus struct { Name *string `json:"name,omitempty"` Status *RealTimeNodeStatusStatus `json:"status,omitempty"` LogPath *string `json:"logPath,omitempty"` NodeType *RealTimeNodeStatusNodeType `json:"nodeType,omitempty"` }
func (RealTimeNodeStatus) String ¶
func (o RealTimeNodeStatus) String() string
type RealTimeNodeStatusNodeType ¶
type RealTimeNodeStatusNodeType struct {
// contains filtered or unexported fields
}
func (RealTimeNodeStatusNodeType) MarshalJSON ¶
func (c RealTimeNodeStatusNodeType) MarshalJSON() ([]byte, error)
func (*RealTimeNodeStatusNodeType) UnmarshalJSON ¶
func (c *RealTimeNodeStatusNodeType) UnmarshalJSON(b []byte) error
type RealTimeNodeStatusNodeTypeEnum ¶
type RealTimeNodeStatusNodeTypeEnum struct { HIVE_SQL RealTimeNodeStatusNodeType SPARK_SQL RealTimeNodeStatusNodeType DWSSQL RealTimeNodeStatusNodeType DLISQL RealTimeNodeStatusNodeType SHELL RealTimeNodeStatusNodeType CDM_JOB RealTimeNodeStatusNodeType DIS_TRANSFER_TASK RealTimeNodeStatusNodeType CS_JOB RealTimeNodeStatusNodeType CLOUD_TABLE_MANAGE RealTimeNodeStatusNodeType OBS_MANAGER RealTimeNodeStatusNodeType RESTAPI RealTimeNodeStatusNodeType MACHINE_LEARNING RealTimeNodeStatusNodeType SMN RealTimeNodeStatusNodeType MRS_SPARK RealTimeNodeStatusNodeType MAP_REDUCE RealTimeNodeStatusNodeType DLI_SPARK RealTimeNodeStatusNodeType }
func GetRealTimeNodeStatusNodeTypeEnum ¶
func GetRealTimeNodeStatusNodeTypeEnum() RealTimeNodeStatusNodeTypeEnum
type RealTimeNodeStatusStatus ¶
type RealTimeNodeStatusStatus struct {
// contains filtered or unexported fields
}
func (RealTimeNodeStatusStatus) MarshalJSON ¶
func (c RealTimeNodeStatusStatus) MarshalJSON() ([]byte, error)
func (*RealTimeNodeStatusStatus) UnmarshalJSON ¶
func (c *RealTimeNodeStatusStatus) UnmarshalJSON(b []byte) error
type RealTimeNodeStatusStatusEnum ¶
type RealTimeNodeStatusStatusEnum struct { STARTTING RealTimeNodeStatusStatus NORMAL RealTimeNodeStatusStatus EXCEPTION RealTimeNodeStatusStatus STOPPING RealTimeNodeStatusStatus STOPPED RealTimeNodeStatusStatus }
func GetRealTimeNodeStatusStatusEnum ¶
func GetRealTimeNodeStatusStatusEnum() RealTimeNodeStatusStatusEnum
type ResourceInfo ¶
type ResourceInfo struct { Name *string `json:"name,omitempty"` Type *ResourceInfoType `json:"type,omitempty"` // 资源文件所在OBS路径 Location *string `json:"location,omitempty"` DependFiles *[]string `json:"dependFiles,omitempty"` Desc *string `json:"desc,omitempty"` // 资源所在目录 Directory *string `json:"directory,omitempty"` }
func (ResourceInfo) String ¶
func (o ResourceInfo) String() string
type ResourceInfoType ¶
type ResourceInfoType struct {
// contains filtered or unexported fields
}
func (ResourceInfoType) MarshalJSON ¶
func (c ResourceInfoType) MarshalJSON() ([]byte, error)
func (*ResourceInfoType) UnmarshalJSON ¶
func (c *ResourceInfoType) UnmarshalJSON(b []byte) error
type ResourceInfoTypeEnum ¶
type ResourceInfoTypeEnum struct { ARCHIVE ResourceInfoType FILE ResourceInfoType JAR ResourceInfoType }
func GetResourceInfoTypeEnum ¶
func GetResourceInfoTypeEnum() ResourceInfoTypeEnum
type RestoreJobInstanceRequest ¶
type RestoreJobInstanceRequest struct { // 作业名称. JobName string `json:"job_name"` // 作业实例id. InstanceId string `json:"instance_id"` }
Request Object
func (RestoreJobInstanceRequest) String ¶
func (o RestoreJobInstanceRequest) String() string
type RestoreJobInstanceResponse ¶
type RestoreJobInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (RestoreJobInstanceResponse) String ¶
func (o RestoreJobInstanceResponse) String() string
type Result ¶
type RunOnceRequest ¶
type RunOnceRequest struct { // 作业名称. JobName string `json:"job_name"` Body *StartJobReq `json:"body,omitempty"` }
Request Object
func (RunOnceRequest) String ¶
func (o RunOnceRequest) String() string
type RunOnceResponse ¶
type RunOnceResponse struct { // 作业实例id InstanceId *string `json:"instanceId,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (RunOnceResponse) String ¶
func (o RunOnceResponse) String() string
type Schedule ¶
type Schedule struct { ScheType *ScheduleScheType `json:"scheType,omitempty"` Cron *Cron `json:"cron,omitempty"` Event *Event `json:"event,omitempty"` }
type ScheduleScheType ¶
type ScheduleScheType struct {
// contains filtered or unexported fields
}
func (ScheduleScheType) MarshalJSON ¶
func (c ScheduleScheType) MarshalJSON() ([]byte, error)
func (*ScheduleScheType) UnmarshalJSON ¶
func (c *ScheduleScheType) UnmarshalJSON(b []byte) error
type ScheduleScheTypeEnum ¶
type ScheduleScheTypeEnum struct { EXECUTE_ONCE ScheduleScheType CRON ScheduleScheType EVENT ScheduleScheType }
func GetScheduleScheTypeEnum ¶
func GetScheduleScheTypeEnum() ScheduleScheTypeEnum
type ScriptInfo ¶
type ScriptInfo struct { Name *string `json:"name,omitempty"` // 脚本类型 Type *ScriptInfoType `json:"type,omitempty"` // 脚本关联的目录 Directory *string `json:"directory,omitempty"` // 脚本内容 Content *string `json:"content,omitempty"` // 脚本关联的连接名称 ConnectionName *string `json:"connectionName,omitempty"` // 脚本执行所在的数据库 Database *string `json:"database,omitempty"` // 脚本关联的DLI队列名称 QueueName *string `json:"queueName,omitempty"` // 脚本的配置项参数 Configuration *string `json:"configuration,omitempty"` }
func (ScriptInfo) String ¶
func (o ScriptInfo) String() string
type ScriptInfoType ¶
type ScriptInfoType struct {
// contains filtered or unexported fields
}
func (ScriptInfoType) MarshalJSON ¶
func (c ScriptInfoType) MarshalJSON() ([]byte, error)
func (*ScriptInfoType) UnmarshalJSON ¶
func (c *ScriptInfoType) UnmarshalJSON(b []byte) error
type ScriptInfoTypeEnum ¶
type ScriptInfoTypeEnum struct { FLINK_SQL ScriptInfoType DLISQL ScriptInfoType SPARK_SQL ScriptInfoType HIVE_SQL ScriptInfoType DWSSQL ScriptInfoType SHELL ScriptInfoType }
func GetScriptInfoTypeEnum ¶
func GetScriptInfoTypeEnum() ScriptInfoTypeEnum
type ShowConnectionRequest ¶
type ShowConnectionRequest struct { // 连接名称. ConnectionName string `json:"connection_name"` }
Request Object
func (ShowConnectionRequest) String ¶
func (o ShowConnectionRequest) String() string
type ShowConnectionResponse ¶
type ShowConnectionResponse struct { Name *string `json:"name,omitempty"` Type *ShowConnectionResponseType `json:"type,omitempty"` Config *interface{} `json:"config,omitempty"` Description *string `json:"description,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowConnectionResponse) String ¶
func (o ShowConnectionResponse) String() string
type ShowConnectionResponseType ¶ added in v0.0.78
type ShowConnectionResponseType struct {
// contains filtered or unexported fields
}
func (ShowConnectionResponseType) MarshalJSON ¶ added in v0.0.78
func (c ShowConnectionResponseType) MarshalJSON() ([]byte, error)
func (*ShowConnectionResponseType) UnmarshalJSON ¶ added in v0.0.78
func (c *ShowConnectionResponseType) UnmarshalJSON(b []byte) error
type ShowConnectionResponseTypeEnum ¶ added in v0.0.78
type ShowConnectionResponseTypeEnum struct { DWS ShowConnectionResponseType DLI ShowConnectionResponseType SPARK_SQL ShowConnectionResponseType HIVE ShowConnectionResponseType RDS ShowConnectionResponseType CLOUD_TABLE ShowConnectionResponseType }
func GetShowConnectionResponseTypeEnum ¶ added in v0.0.78
func GetShowConnectionResponseTypeEnum() ShowConnectionResponseTypeEnum
type ShowFileInfoRequest ¶
type ShowFileInfoRequest struct {
Body *FilePath `json:"body,omitempty"`
}
Request Object
func (ShowFileInfoRequest) String ¶
func (o ShowFileInfoRequest) String() string
type ShowFileInfoResponse ¶
type ShowFileInfoResponse struct { Jobs *[]Job `json:"jobs,omitempty"` Scripts *[]Script `json:"scripts,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowFileInfoResponse) String ¶
func (o ShowFileInfoResponse) String() string
type ShowJobInstanceRequest ¶
type ShowJobInstanceRequest struct { // 作业名称. JobName string `json:"job_name"` // 作业实例id. InstanceId string `json:"instance_id"` }
Request Object
func (ShowJobInstanceRequest) String ¶
func (o ShowJobInstanceRequest) String() string
type ShowJobInstanceResponse ¶
type ShowJobInstanceResponse struct { Status *string `json:"status,omitempty"` PlanTime *int32 `json:"planTime,omitempty"` StartTime *int32 `json:"startTime,omitempty"` EndTime *int32 `json:"endTime,omitempty"` ExecuteTime *int32 `json:"executeTime,omitempty"` InstancesId *string `json:"instancesId,omitempty"` Total *int32 `json:"total,omitempty"` Nodes *[]NodeInstance `json:"nodes,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowJobInstanceResponse) String ¶
func (o ShowJobInstanceResponse) String() string
type ShowJobRequest ¶
type ShowJobRequest struct { // 作业名称. JobName string `json:"job_name"` }
Request Object
func (ShowJobRequest) String ¶
func (o ShowJobRequest) String() string
type ShowJobResponse ¶
type ShowJobResponse struct { Name *string `json:"name,omitempty"` Nodes *[]Node `json:"nodes,omitempty"` Schedule *Schedule `json:"schedule,omitempty"` Params *[]JobParam `json:"params,omitempty"` Directory *string `json:"directory,omitempty"` JobType *ShowJobResponseJobType `json:"jobType,omitempty"` BasicConfig *BasicInfo `json:"basicConfig,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowJobResponse) String ¶
func (o ShowJobResponse) String() string
type ShowJobResponseJobType ¶
type ShowJobResponseJobType struct {
// contains filtered or unexported fields
}
func (ShowJobResponseJobType) MarshalJSON ¶
func (c ShowJobResponseJobType) MarshalJSON() ([]byte, error)
func (*ShowJobResponseJobType) UnmarshalJSON ¶
func (c *ShowJobResponseJobType) UnmarshalJSON(b []byte) error
type ShowJobResponseJobTypeEnum ¶
type ShowJobResponseJobTypeEnum struct { BATCH ShowJobResponseJobType REAL_TIME ShowJobResponseJobType }
func GetShowJobResponseJobTypeEnum ¶
func GetShowJobResponseJobTypeEnum() ShowJobResponseJobTypeEnum
type ShowJobStatusRequest ¶
type ShowJobStatusRequest struct { // 作业名称. JobName string `json:"job_name"` }
Request Object
func (ShowJobStatusRequest) String ¶
func (o ShowJobStatusRequest) String() string
type ShowJobStatusResponse ¶
type ShowJobStatusResponse struct { Name *string `json:"name,omitempty"` Status *ShowJobStatusResponseStatus `json:"status,omitempty"` Starttime *string `json:"starttime,omitempty"` EndTime *string `json:"endTime,omitempty"` // 状态最后更新时间 LastUpdateTime *string `json:"lastUpdateTime,omitempty"` Nodes *[]RealTimeNodeStatus `json:"nodes,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowJobStatusResponse) String ¶
func (o ShowJobStatusResponse) String() string
type ShowJobStatusResponseStatus ¶
type ShowJobStatusResponseStatus struct {
// contains filtered or unexported fields
}
func (ShowJobStatusResponseStatus) MarshalJSON ¶
func (c ShowJobStatusResponseStatus) MarshalJSON() ([]byte, error)
func (*ShowJobStatusResponseStatus) UnmarshalJSON ¶
func (c *ShowJobStatusResponseStatus) UnmarshalJSON(b []byte) error
type ShowJobStatusResponseStatusEnum ¶
type ShowJobStatusResponseStatusEnum struct { STARTTING ShowJobStatusResponseStatus NORMAL ShowJobStatusResponseStatus EXCEPTION ShowJobStatusResponseStatus STOPPING ShowJobStatusResponseStatus STOPPED ShowJobStatusResponseStatus }
func GetShowJobStatusResponseStatusEnum ¶
func GetShowJobStatusResponseStatusEnum() ShowJobStatusResponseStatusEnum
type ShowResourceRequest ¶
type ShowResourceRequest struct { // 资源id. ResourceId string `json:"resource_id"` }
Request Object
func (ShowResourceRequest) String ¶
func (o ShowResourceRequest) String() string
type ShowResourceResponse ¶
type ShowResourceResponse struct { Name *string `json:"name,omitempty"` Type *ShowResourceResponseType `json:"type,omitempty"` // 资源文件所在OBS路径 Location *string `json:"location,omitempty"` DependFiles *[]string `json:"dependFiles,omitempty"` Desc *string `json:"desc,omitempty"` // 资源所在目录 Directory *string `json:"directory,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowResourceResponse) String ¶
func (o ShowResourceResponse) String() string
type ShowResourceResponseType ¶
type ShowResourceResponseType struct {
// contains filtered or unexported fields
}
func (ShowResourceResponseType) MarshalJSON ¶
func (c ShowResourceResponseType) MarshalJSON() ([]byte, error)
func (*ShowResourceResponseType) UnmarshalJSON ¶
func (c *ShowResourceResponseType) UnmarshalJSON(b []byte) error
type ShowResourceResponseTypeEnum ¶
type ShowResourceResponseTypeEnum struct { ARCHIVE ShowResourceResponseType FILE ShowResourceResponseType JAR ShowResourceResponseType }
func GetShowResourceResponseTypeEnum ¶
func GetShowResourceResponseTypeEnum() ShowResourceResponseTypeEnum
type ShowScriptRequest ¶
type ShowScriptRequest struct {
ScriptName string `json:"script_name"`
}
Request Object
func (ShowScriptRequest) String ¶
func (o ShowScriptRequest) String() string
type ShowScriptResponse ¶
type ShowScriptResponse struct { Name *string `json:"name,omitempty"` // 脚本类型 Type *ShowScriptResponseType `json:"type,omitempty"` // 脚本关联的目录 Directory *string `json:"directory,omitempty"` // 脚本内容 Content *string `json:"content,omitempty"` // 脚本关联的连接名称 ConnectionName *string `json:"connectionName,omitempty"` // 脚本执行所在的数据库 Database *string `json:"database,omitempty"` // 脚本关联的DLI队列名称 QueueName *string `json:"queueName,omitempty"` // 脚本的配置项参数 Configuration *string `json:"configuration,omitempty"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowScriptResponse) String ¶
func (o ShowScriptResponse) String() string
type ShowScriptResponseType ¶
type ShowScriptResponseType struct {
// contains filtered or unexported fields
}
func (ShowScriptResponseType) MarshalJSON ¶
func (c ShowScriptResponseType) MarshalJSON() ([]byte, error)
func (*ShowScriptResponseType) UnmarshalJSON ¶
func (c *ShowScriptResponseType) UnmarshalJSON(b []byte) error
type ShowScriptResponseTypeEnum ¶
type ShowScriptResponseTypeEnum struct { FLINK_SQL ShowScriptResponseType DLISQL ShowScriptResponseType SPARK_SQL ShowScriptResponseType HIVE_SQL ShowScriptResponseType DWSSQL ShowScriptResponseType SHELL ShowScriptResponseType }
func GetShowScriptResponseTypeEnum ¶
func GetShowScriptResponseTypeEnum() ShowScriptResponseTypeEnum
type StartJobReq ¶
type StartJobReq struct {
JobParams *[]JobParam `json:"jobParams,omitempty"`
}
func (StartJobReq) String ¶
func (o StartJobReq) String() string
type StartJobRequest ¶
type StartJobRequest struct { // 作业名称. JobName string `json:"job_name"` Body *StartJobReq `json:"body,omitempty"` }
Request Object
func (StartJobRequest) String ¶
func (o StartJobRequest) String() string
type StartJobResponse ¶
type StartJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (StartJobResponse) String ¶
func (o StartJobResponse) String() string
type StopJobInstanceRequest ¶
type StopJobInstanceRequest struct { // 作业名称. JobName string `json:"job_name"` // 作业实例id. InstanceId string `json:"instance_id"` }
Request Object
func (StopJobInstanceRequest) String ¶
func (o StopJobInstanceRequest) String() string
type StopJobInstanceResponse ¶
type StopJobInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (StopJobInstanceResponse) String ¶
func (o StopJobInstanceResponse) String() string
type StopJobRequest ¶
type StopJobRequest struct { // 作业名称. JobName string `json:"job_name"` }
Request Object
func (StopJobRequest) String ¶
func (o StopJobRequest) String() string
type StopJobResponse ¶
type StopJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (StopJobResponse) String ¶
func (o StopJobResponse) String() string
type SubTaskStatus ¶
type SubTaskStatus struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` StartTime *string `json:"startTime,omitempty"` EndTime *string `json:"endTime,omitempty"` LastUpdate *string `json:"lastUpdate,omitempty"` Status *SubTaskStatusStatus `json:"status,omitempty"` }
func (SubTaskStatus) String ¶
func (o SubTaskStatus) String() string
type SubTaskStatusStatus ¶
type SubTaskStatusStatus struct {
// contains filtered or unexported fields
}
func (SubTaskStatusStatus) MarshalJSON ¶
func (c SubTaskStatusStatus) MarshalJSON() ([]byte, error)
func (*SubTaskStatusStatus) UnmarshalJSON ¶
func (c *SubTaskStatusStatus) UnmarshalJSON(b []byte) error
type SubTaskStatusStatusEnum ¶
type SubTaskStatusStatusEnum struct { RUNNING SubTaskStatusStatus SUCCESSFUL SubTaskStatusStatus FAILED SubTaskStatusStatus }
func GetSubTaskStatusStatusEnum ¶
func GetSubTaskStatusStatusEnum() SubTaskStatusStatusEnum
type UpdateConnectionRequest ¶
type UpdateConnectionRequest struct { // 连接名称. ConnectionName string `json:"connection_name"` Body *ConnectionInfo `json:"body,omitempty"` }
Request Object
func (UpdateConnectionRequest) String ¶
func (o UpdateConnectionRequest) String() string
type UpdateConnectionResponse ¶
type UpdateConnectionResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateConnectionResponse) String ¶
func (o UpdateConnectionResponse) String() string
type UpdateJobRequest ¶
type UpdateJobRequest struct { // 作业名称. JobName string `json:"job_name"` Body *JobInfo `json:"body,omitempty"` }
Request Object
func (UpdateJobRequest) String ¶
func (o UpdateJobRequest) String() string
type UpdateJobResponse ¶
type UpdateJobResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateJobResponse) String ¶
func (o UpdateJobResponse) String() string
type UpdateResourceRequest ¶
type UpdateResourceRequest struct { // 资源id. ResourceId string `json:"resource_id"` Body *ResourceInfo `json:"body,omitempty"` }
Request Object
func (UpdateResourceRequest) String ¶
func (o UpdateResourceRequest) String() string
type UpdateResourceResponse ¶
type UpdateResourceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateResourceResponse) String ¶
func (o UpdateResourceResponse) String() string
type UpdateScriptRequest ¶
type UpdateScriptRequest struct { ScriptName string `json:"script_name"` Body *ScriptInfo `json:"body,omitempty"` }
Request Object
func (UpdateScriptRequest) String ¶
func (o UpdateScriptRequest) String() string
type UpdateScriptResponse ¶
type UpdateScriptResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateScriptResponse) String ¶
func (o UpdateScriptResponse) String() string
Source Files ¶
- model_basic_info.go
- model_cancel_script_request.go
- model_cancel_script_response.go
- model_condition.go
- model_connection_info.go
- model_connection_param.go
- model_create_connection_request.go
- model_create_connection_response.go
- model_create_job_request.go
- model_create_job_response.go
- model_create_resource_request.go
- model_create_resource_response.go
- model_create_script_request.go
- model_create_script_response.go
- model_cron.go
- model_delete_connction_request.go
- model_delete_connction_response.go
- model_delete_job_request.go
- model_delete_job_response.go
- model_delete_resource_request.go
- model_delete_resource_response.go
- model_delete_script_request.go
- model_delete_script_response.go
- model_depend_job.go
- model_event.go
- model_execute_script_req.go
- model_execute_script_request.go
- model_execute_script_response.go
- model_export_connections_request.go
- model_export_connections_response.go
- model_export_job_list_request.go
- model_export_job_list_response.go
- model_export_job_request.go
- model_export_job_response.go
- model_export_jobs_req.go
- model_file_path.go
- model_import_connection_req.go
- model_import_connections_request.go
- model_import_connections_response.go
- model_import_file_req.go
- model_import_job_request.go
- model_import_job_response.go
- model_job.go
- model_job_info.go
- model_job_instance.go
- model_job_param.go
- model_list_connections_request.go
- model_list_connections_response.go
- model_list_job_instances_request.go
- model_list_job_instances_response.go
- model_list_jobs_request.go
- model_list_jobs_response.go
- model_list_resources_request.go
- model_list_resources_response.go
- model_list_script_results_request.go
- model_list_script_results_response.go
- model_list_scripts_request.go
- model_list_scripts_response.go
- model_list_system_tasks_request.go
- model_list_system_tasks_response.go
- model_location.go
- model_node.go
- model_node_instance.go
- model_real_time_node_status.go
- model_resource_info.go
- model_restore_job_instance_request.go
- model_restore_job_instance_response.go
- model_result.go
- model_run_once_request.go
- model_run_once_response.go
- model_schedule.go
- model_script.go
- model_script_info.go
- model_show_connection_request.go
- model_show_connection_response.go
- model_show_file_info_request.go
- model_show_file_info_response.go
- model_show_job_instance_request.go
- model_show_job_instance_response.go
- model_show_job_request.go
- model_show_job_response.go
- model_show_job_status_request.go
- model_show_job_status_response.go
- model_show_resource_request.go
- model_show_resource_response.go
- model_show_script_request.go
- model_show_script_response.go
- model_start_job_req.go
- model_start_job_request.go
- model_start_job_response.go
- model_stop_job_instance_request.go
- model_stop_job_instance_response.go
- model_stop_job_request.go
- model_stop_job_response.go
- model_sub_task_status.go
- model_update_connection_request.go
- model_update_connection_response.go
- model_update_job_request.go
- model_update_job_response.go
- model_update_resource_request.go
- model_update_resource_response.go
- model_update_script_request.go
- model_update_script_response.go